byterazor/qpsmtpd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Connection id similar to the transaction id by Matt.

Browse Source 
git-svn-id: https://svn.perl.org/qpsmtpd/trunk@780 958fd67b-6ff1-0310-b445-bb7760255be9
This commit is contained in:
Peter J. Holzer 2007-08-30 20:19:30 +00:00
parent b57ee765de
commit 5ccdcca7b2
2 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
lib/Qpsmtpd/Connection.pm
View File

@ -1,6 +1,9 @@
package Qpsmtpd::Connection; package Qpsmtpd::Connection;
use strict; use strict;
use Sys::Hostname;
use Time::HiRes qw(gettimeofday);
# All of these parameters depend only on the physical connection, # All of these parameters depend only on the physical connection,
# i.e. not on anything sent from the remote machine. Hence, they # i.e. not on anything sent from the remote machine. Hence, they
# are an appropriate set to use for either start() or clone(). Do # are an appropriate set to use for either start() or clone(). Do
@ -15,6 +18,27 @@ my @parameters = qw(
relay_client relay_client
); );
my $SALT_HOST = crypt(hostname, chr(65+rand(57)).chr(65+rand(57)));
$SALT_HOST =~ tr/A-Za-z0-9//cd;
sub new_id {
my $self = shift;
# Generate unique id
# use gettimeofday for microsec precision
# add in rand() in case gettimeofday clock is slow (e.g. bsd?)
# add in $$ in case srand is set per process
my ($start, $mstart) = gettimeofday();
my $id = sprintf("%d.%06d.%s.%d.%d",
$start,
$mstart,
$SALT_HOST,
rand(10000),
$$,
);
$self->{_id} = $id;
}
sub new { sub new {
my $proto = shift; my $proto = shift;
my $class = ref($proto) || $proto; my $class = ref($proto) || $proto;
@ -35,12 +59,19 @@ sub start {
return $self; return $self;
} }
sub id {
my $self = shift;
$self->new_id unless $self->{_id};
$self->{_id};
}
sub clone { sub clone {
my $self = shift; my $self = shift;
my $new = $self->new(); my $new = $self->new();
foreach my $f ( @parameters ) { foreach my $f ( @parameters ) {
$new->$f($self->$f()) if $self->$f(); $new->$f($self->$f()) if $self->$f();
} }
# should we generate a new id here?
return $new; return $new;
} }

1
qpsmtpd-forkserver
View File

@ -239,6 +239,7 @@ while (1) {
# get local/remote hostname, port and ip address # get local/remote hostname, port and ip address
my ($port, $iaddr, $lport, $laddr, $nto_iaddr, $nto_laddr) = Qpsmtpd::TcpServer::lrpip($server, $client, $hisaddr); my ($port, $iaddr, $lport, $laddr, $nto_iaddr, $nto_laddr) = Qpsmtpd::TcpServer::lrpip($server, $client, $hisaddr);
$qpsmtpd->connection->new_id;
my ($rc, @msg) = $qpsmtpd->run_hooks("pre-connection", my ($rc, @msg) = $qpsmtpd->run_hooks("pre-connection",
remote_ip => $nto_iaddr, remote_ip => $nto_iaddr,
remote_port => $port, remote_port => $port,