Eric Faurot writes: > The api user should not have to care about normalizing the io input > buffer (i.e. resetting the read/write pos in the buffer). > Do it internally when reloading the io event. > > Eric.
Ok sunil@ > > Index: bounce.c > =================================================================== > RCS file: /cvs/src/usr.sbin/smtpd/bounce.c,v > retrieving revision 1.75 > diff -u -p -r1.75 bounce.c > --- bounce.c 21 Nov 2016 13:00:43 -0000 1.75 > +++ bounce.c 21 Nov 2016 19:33:46 -0000 > @@ -728,10 +728,8 @@ bounce_io(struct io *io, int evt, void * > return; > } > > - if (line == NULL) { > - iobuf_normalize(&s->iobuf); > + if (line == NULL) > break; > - } > > log_trace(TRACE_BOUNCE, "bounce: %p: <<< %s", s, line); > > Index: filter.c > =================================================================== > RCS file: /cvs/src/usr.sbin/smtpd/filter.c,v > retrieving revision 1.22 > diff -u -p -r1.22 filter.c > --- filter.c 21 Nov 2016 13:00:43 -0000 1.22 > +++ filter.c 21 Nov 2016 19:33:46 -0000 > @@ -706,7 +706,6 @@ filter_tx_io(struct io *io, int evt, voi > } > s->idatalen += n; > io_drop(&s->iev, n); > - iobuf_normalize(&s->ibuf); > return; > > case IO_DISCONNECTED: > Index: ioev.c > =================================================================== > RCS file: /cvs/src/usr.sbin/smtpd/ioev.c,v > retrieving revision 1.30 > diff -u -p -r1.30 ioev.c > --- ioev.c 20 Nov 2016 08:43:36 -0000 1.30 > +++ ioev.c 21 Nov 2016 19:33:46 -0000 > @@ -465,6 +465,9 @@ io_reload(struct io *io) > if (io->flags & IO_HELD) > return; > > + if (io->iobuf) > + iobuf_normalize(io->iobuf); > + > #ifdef IO_SSL > if (io->ssl) { > io_reload_ssl(io); > Index: mta_session.c > =================================================================== > RCS file: /cvs/src/usr.sbin/smtpd/mta_session.c,v > retrieving revision 1.88 > diff -u -p -r1.88 mta_session.c > --- mta_session.c 21 Nov 2016 13:00:43 -0000 1.88 > +++ mta_session.c 21 Nov 2016 19:33:47 -0000 > @@ -1182,10 +1182,8 @@ mta_io(struct io *io, int evt, void *arg > if (io_datalen(&s->io) >= LINE_MAX) { > mta_error(s, "Input too long"); > mta_free(s); > - return; > } > - iobuf_normalize(&s->iobuf); > - break; > + return; > } > > log_trace(TRACE_MTA, "mta: %p: <<< %s", s, line); > @@ -1263,8 +1261,6 @@ mta_io(struct io *io, int evt, void *arg > mta_connect(s); > return; > } > - > - iobuf_normalize(&s->iobuf); > > if (io_datalen(&s->io)) { > log_debug("debug: mta: remaining data in input buffer"); > Index: smtp_session.c > =================================================================== > RCS file: /cvs/src/usr.sbin/smtpd/smtp_session.c,v > retrieving revision 1.294 > diff -u -p -r1.294 smtp_session.c > --- smtp_session.c 21 Nov 2016 13:00:43 -0000 1.294 > +++ smtp_session.c 21 Nov 2016 19:33:48 -0000 > @@ -1310,10 +1310,8 @@ smtp_io(struct io *io, int evt, void *ar > } > > /* No complete line received */ > - if (line == NULL) { > - iobuf_normalize(&s->iobuf); > + if (line == NULL) > return; > - } > > /* Message body */ > if (s->state == STATE_BODY && strcmp(line, ".")) { > @@ -1338,7 +1336,6 @@ smtp_io(struct io *io, int evt, void *ar > > rfc2822_parser_flush(&s->tx->rfc2822_parser); > > - iobuf_normalize(&s->iobuf); > io_set_write(io); > > s->tx->dataeom = 1; > @@ -1353,7 +1350,6 @@ smtp_io(struct io *io, int evt, void *ar > (void)strlcpy(s->cmd, line, sizeof s->cmd); > io_set_write(io); > smtp_command(s, line); > - iobuf_normalize(&s->iobuf); > break; > > case IO_LOWAT: