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

body_write patches from Brian Grossman

Browse Source 
git-svn-id: https://svn.perl.org/qpsmtpd/branches/high_perf@395 958fd67b-6ff1-0310-b445-bb7760255be9
This commit is contained in:
Matt Sergeant 2005-03-10 18:19:27 +00:00
parent 58f03e5787
commit 41e13e7454
3 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
lib/Qpsmtpd/PollServer.pm
View File

@ -302,6 +302,7 @@ sub end_of_data {
$header = Mail::Header->new(Modify => 0, MailFrom => "COERCE"); $header = Mail::Header->new(Modify => 0, MailFrom => "COERCE");
$self->transaction->header($header); $self->transaction->header($header);
} }
# only true if client authenticated # only true if client authenticated
if ( defined $self->{_auth} and $self->{_auth} == OK ) { if ( defined $self->{_auth} and $self->{_auth} == OK ) {
$header->add("X-Qpsmtpd-Auth","True"); $header->add("X-Qpsmtpd-Auth","True");

2
lib/Qpsmtpd/SMTP.pm
View File

@ -454,7 +454,7 @@ sub data {
# save us buffering the mail content. # save us buffering the mail content.
# Save the start of just the body itself # Save the start of just the body itself
$self->transaction->body_start($size); $self->transaction->set_body_start();
} }

2
lib/Qpsmtpd/Transaction.pm
View File

@ -107,10 +107,12 @@ sub body_write {
while ($$ref =~ m/\G(.*?\n)/gc) { while ($$ref =~ m/\G(.*?\n)/gc) {
push @{ $self->{_body_array} }, $1; push @{ $self->{_body_array} }, $1;
$self->{_body_size} += length($1); $self->{_body_size} += length($1);
++$self->{_body_current_pos};
} }
if ($$ref =~ m/\G(.+)\z/gc) { if ($$ref =~ m/\G(.+)\z/gc) {
push @{ $self->{_body_array} }, $1; push @{ $self->{_body_array} }, $1;
$self->{_body_size} += length($1); $self->{_body_size} += length($1);
++$self->{_body_current_pos};
} }
if ($self->{_body_size} >= $self->{_size_threshold}) { if ($self->{_body_size} >= $self->{_size_threshold}) {
#warn("spooling to disk\n"); #warn("spooling to disk\n");