CommIoCbParams rd(this); // will be expanded with ReadNow results
rd.conn = io.conn;
- switch (Comm::ReadNow(rd, in.buf))
- {
+ switch (Comm::ReadNow(rd, in.buf)) {
case Comm::INPROGRESS:
if (in.buf.isEmpty())
debugs(33, 2, io.conn << ": no data to process, " << xstrerr(rd.xerrno));
/* Continue to process previously read data */
break;
- // case Comm::ERROR:
+ // case Comm::ERROR:
default: // no other flags should ever occur
debugs(33, 2, io.conn << ": got flag " << rd.flag << "; " << xstrerr(rd.xerrno));
notifyAllContexts(rd.xerrno);
*/
#include "squid.h"
#include "comm.h"
-#include "comm_internal.h"
-#include "CommCalls.h"
#include "comm/IoCallback.h"
#include "comm/Loops.h"
#include "comm/Read.h"
+#include "comm_internal.h"
+#include "CommCalls.h"
#include "Debug.h"
#include "fd.h"
#include "fde.h"
return;
};
-
/* Nope, register for some more IO */
Comm::SetSelect(fd, COMM_SELECT_READ, Comm::HandleRead, data, 0);
}