bashclub/piler
1
0
Fork 0
mirror of https://bitbucket.org/jsuto/piler.git synced 2024-12-25 06:40:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

src: bdat fix

Browse Source 
Signed-off-by: Janos SUTO <sj@acts.hu>
This commit is contained in:
Janos SUTO 2017-08-30 17:35:19 +02:00
parent b2b3ada394
commit 64056bdc73
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/bdat.c
View File

@ -55,7 +55,7 @@ void get_bdat_size_to_read(struct smtp_session *session, char *buf){
if(!p || session->bdat_bytes_to_read <= 0){ if(!p || session->bdat_bytes_to_read <= 0){
session->bdat_bytes_to_read = 0; session->bdat_bytes_to_read = 0;
syslog(LOG_INFO, "%s: malformed BDAT command", session->ttmpfile); syslog(LOG_INFO, "%s: ERROR: malformed BDAT command", session->ttmpfile);
} }
} }
@ -66,8 +66,6 @@ void process_bdat(struct smtp_session *session, char *readbuf, int readlen){
if(readlen <= 0) return; if(readlen <= 0) return;
//printf("readbuf in process_bdat (%d): *%s*\n", readlen, readbuf);
if(session->bdat_rounds == 1){ if(session->bdat_rounds == 1){
session->fd = open(session->ttmpfile, O_CREAT|O_RDWR, S_IRUSR|S_IWUSR|S_IRGRP); session->fd = open(session->ttmpfile, O_CREAT|O_RDWR, S_IRUSR|S_IWUSR|S_IRGRP);
if(session->fd == -1){ if(session->fd == -1){
@ -78,11 +76,13 @@ void process_bdat(struct smtp_session *session, char *readbuf, int readlen){
session->bdat_bytes_to_read -= readlen; session->bdat_bytes_to_read -= readlen;
if(session->fd != -1){ if(session->fd != -1){
if(write(session->fd, readbuf, readlen) == -1) syslog(LOG_PRIORITY, "ERROR: write(), %s, %d, %s", __func__, __LINE__, __FILE__); if(write(session->fd, readbuf, readlen) != -1){
session->tot_len += readlen; session->tot_len += readlen;
if(session->cfg->verbosity >= _LOG_DEBUG) syslog(LOG_INFO, "%s: wrote %d bytes, %d bytes to go", session->ttmpfile, readlen, session->bdat_bytes_to_read); if(session->cfg->verbosity >= _LOG_DEBUG) syslog(LOG_INFO, "%s: wrote %d bytes, %d bytes to go", session->ttmpfile, readlen, session->bdat_bytes_to_read);
} }
else syslog(LOG_PRIORITY, "ERROR: write(), %s, %d, %s", __func__, __LINE__, __FILE__);
}
if(session->bdat_bytes_to_read < 0){ if(session->bdat_bytes_to_read < 0){