From: Amos Jeffries Date: Thu, 5 Jun 2014 16:05:41 +0000 (-0700) Subject: Some flags missed in rev.13445 X-Git-Tag: SQUID_3_5_0_1~197 X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=23ff0beeaa7192f00b45f59596edea68bded9ab4;p=thirdparty%2Fsquid.git Some flags missed in rev.13445 --- diff --git a/src/adaptation/icap/Xaction.cc b/src/adaptation/icap/Xaction.cc index 55b7436c79..d69a7e669f 100644 --- a/src/adaptation/icap/Xaction.cc +++ b/src/adaptation/icap/Xaction.cc @@ -120,7 +120,7 @@ Adaptation::Icap::Xaction::openConnection() CbcPointer self(this); Dialer dialer(self, &Adaptation::Icap::Xaction::noteCommConnected); dialer.params.conn = connection; - dialer.params.flag = COMM_OK; + dialer.params.flag = Comm::OK; // fake other parameters by copying from the existing connection connector = asyncCall(93,3, "Adaptation::Icap::Xaction::noteCommConnected", dialer); ScheduleCallHere(connector); @@ -152,7 +152,7 @@ Adaptation::Icap::Xaction::dnsLookupDone(const ipcache_addrs *ia) CbcPointer self(this); Dialer dialer(self, &Adaptation::Icap::Xaction::noteCommConnected); dialer.params.conn = connection; - dialer.params.flag = COMM_ERROR; + dialer.params.flag = Comm::ERROR; // fake other parameters by copying from the existing connection connector = asyncCall(93,3, "Adaptation::Icap::Xaction::noteCommConnected", dialer); ScheduleCallHere(connector); @@ -185,7 +185,7 @@ Adaptation::Icap::Xaction::reusedConnection(void *data) { debugs(93, 5, HERE << "reused connection"); Adaptation::Icap::Xaction *x = (Adaptation::Icap::Xaction*)data; - x->noteCommConnected(COMM_OK); + x->noteCommConnected(Comm::OK); } #endif @@ -227,7 +227,7 @@ void Adaptation::Icap::Xaction::noteCommConnected(const CommConnectCbParams &io) { cs = NULL; - if (io.flag == COMM_TIMEOUT) { + if (io.flag == Comm::TIMEOUT) { handleCommTimedout(); return; } @@ -235,7 +235,7 @@ void Adaptation::Icap::Xaction::noteCommConnected(const CommConnectCbParams &io) Must(connector != NULL); connector = NULL; - if (io.flag != COMM_OK) + if (io.flag != Comm::OK) dieOnConnectionFailure(); // throws typedef CommCbMemFunT TimeoutDialer; @@ -286,7 +286,7 @@ void Adaptation::Icap::Xaction::noteCommWrote(const CommIoCbParams &io) ignoreLastWrite = false; debugs(93, 7, HERE << "ignoring last write; status: " << io.flag); } else { - Must(io.flag == COMM_OK); + Must(io.flag == Comm::OK); al.icap.bytesSent += io.size; updateTimeout(); handleCommWrote(io.size); @@ -392,7 +392,7 @@ void Adaptation::Icap::Xaction::noteCommRead(const CommIoCbParams &io) Must(reader != NULL); reader = NULL; - Must(io.flag == COMM_OK); + Must(io.flag == Comm::OK); if (!io.size) { commEof = true; diff --git a/src/comm/ModPoll.cc b/src/comm/ModPoll.cc index 82e8495288..bf9c548266 100644 --- a/src/comm/ModPoll.cc +++ b/src/comm/ModPoll.cc @@ -423,9 +423,9 @@ Comm::DoSelect(int msec) */ if (nfds == 0 && npending == 0) { if (shutting_down) - return COMM_SHUTDOWN; + return Comm::SHUTDOWN; else - return COMM_IDLE; + return Comm::IDLE; } for (;;) { diff --git a/src/comm/ModSelect.cc b/src/comm/ModSelect.cc index d02df7ed03..87b113f75f 100644 --- a/src/comm/ModSelect.cc +++ b/src/comm/ModSelect.cc @@ -440,7 +440,7 @@ Comm::DoSelect(int msec) #endif if (nreadfds + nwritefds == 0) { assert(shutting_down); - return COMM_SHUTDOWN; + return Comm::SHUTDOWN; } if (msec > MAX_POLL_TIME) diff --git a/src/comm/ModSelectWin32.cc b/src/comm/ModSelectWin32.cc index 5b788923a3..0906791223 100644 --- a/src/comm/ModSelectWin32.cc +++ b/src/comm/ModSelectWin32.cc @@ -434,7 +434,7 @@ Comm::DoSelect(int msec) #endif if (nreadfds + nwritefds == 0) { assert(shutting_down); - return COMM_SHUTDOWN; + return Comm::SHUTDOWN; } if (msec > MAX_POLL_TIME)