/*
- * $Id: ACLMaxUserIP.cc,v 1.12 2007/04/28 22:26:37 hno Exp $
+ * $Id: ACLMaxUserIP.cc,v 1.13 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 28 Access Control
* AUTHOR: Duane Wessels
maximum = xatoi(t);
- debugs(28, 5, "aclParseUserMaxIP: Max IP address's " << (int) maximum);
+ debugs(28, 5, "aclParseUserMaxIP: Max IP address's " << maximum);
return;
}
/*
- * $Id: ACLTimeData.cc,v 1.14 2007/04/28 22:26:37 hno Exp $
+ * $Id: ACLTimeData.cc,v 1.15 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 28 Access Control
* AUTHOR: Duane Wessels
ACLTimeData *data = this;
while (data) {
- debugs(28, 3, "aclMatchTime: checking " << (int) t << " in " <<
- (int) data->start << "-" << (int) data->stop << ", weekbits=" <<
+ debugs(28, 3, "aclMatchTime: checking " << t << " in " <<
+ data->start << "-" << data->stop << ", weekbits=" <<
std::hex << data->weekbits);
if (t >= data->start && t <= data->stop && (data->weekbits & (1 << tm.tm_wday)))
/*
- * $Id: AuthUser.cc,v 1.4 2007/04/28 22:26:37 hno Exp $
+ * $Id: AuthUser.cc,v 1.5 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 29 Authenticator
* AUTHOR: Robert Collins
proxy_match_cache.head = proxy_match_cache.tail = NULL;
ip_list.head = ip_list.tail = NULL;
requests.head = requests.tail = NULL;
- debugs(29, 5, "AuthUser::AuthUser: Initialised auth_user '" << this << "' with refcount '" << (long int) references << "'.");
+ debugs(29, 5, "AuthUser::AuthUser: Initialised auth_user '" << this << "' with refcount '" << references << "'.");
}
/* Combine two user structs. ONLY to be called from within a scheme
{
auth_user_request_t *auth_user_request;
dlink_node *link, *tmplink;
- debugs(29, 5, "AuthUser::~AuthUser: Freeing auth_user '" << this << "' with refcount '" << (long int) references << "'.");
+ debugs(29, 5, "AuthUser::~AuthUser: Freeing auth_user '" << this << "' with refcount '" << references << "'.");
assert(references == 0);
/* were they linked in by username ? */
auth_user_t *auth_user;
char const *username = NULL;
debugs(29, 3, "AuthUser::cacheCleanup: Cleaning the user cache now");
- debugs(29, 3, "AuthUser::cacheCleanup: Current time: " << (long int) current_time.tv_sec);
+ debugs(29, 3, "AuthUser::cacheCleanup: Current time: " << current_time.tv_sec);
hash_first(proxy_auth_username_cache);
while ((usernamehash = ((AuthUserHashPointer *) hash_next(proxy_auth_username_cache)))) {
debugs(29, 9, "authenticateAuthUserLock auth_user '" << this << "'.");
assert(this != NULL);
references++;
- debugs(29, 9, "authenticateAuthUserLock auth_user '" << this << "' now at '" << (long int) references << "'.");
+ debugs(29, 9, "authenticateAuthUserLock auth_user '" << this << "' now at '" << references << "'.");
}
void
debugs(29, 1, "Attempt to lower Auth User " << this << " refcount below 0!");
}
- debugs(29, 9, "authenticateAuthUserUnlock auth_user '" << this << "' now at '" << (long int) references << "'.");
+ debugs(29, 9, "authenticateAuthUserUnlock auth_user '" << this << "' now at '" << references << "'.");
if (references == 0)
delete this;
/*
- * $Id: AuthUserRequest.cc,v 1.13 2007/04/28 22:26:37 hno Exp $
+ * $Id: AuthUserRequest.cc,v 1.14 2007/04/30 16:56:09 wessels Exp $
*
* DO NOT MODIFY NEXT 2 LINES:
* arch-tag: 6803fde1-d5a2-4c29-9034-1c0c9f650eb4
AuthUserRequest::lock()
{
- debugs(29, 9, "AuthUserRequest::lock: auth_user request '" << this << "' (" << (long int) references << " references).");
+ debugs(29, 9, "AuthUserRequest::lock: auth_user request '" << this << "' (" << references << " references).");
assert(this);
++references;
}
void
AuthUserRequest::unlock()
{
- debugs(29, 9, "AuthUserRequest::unlock: auth_user request '" << this << "' (" << (long int) references << " references) .");
+ debugs(29, 9, "AuthUserRequest::unlock: auth_user request '" << this << "' (" << references << " references) .");
assert(this != NULL);
if (references > 0) {
/*
- * $Id: BlockingFile.cc,v 1.3 2007/04/28 22:26:44 hno Exp $
+ * $Id: BlockingFile.cc,v 1.4 2007/04/30 16:56:11 wessels Exp $
*
* DEBUG: section 47 Store Directory Routines
* AUTHOR: Robert Collins
BlockingFile::writeDone(int rvfd, int errflag, size_t len)
{
assert (rvfd == fd);
- debugs(79, 3, "storeUfsWriteDone: FD " << fd << ", len " << (long int) len);
+ debugs(79, 3, "storeUfsWriteDone: FD " << fd << ", len " << len);
WriteRequest::Pointer result = writeRequest;
writeRequest = NULL;
/*
- * $Id: DiskThreadsDiskFile.cc,v 1.9 2007/04/28 22:26:47 hno Exp $
+ * $Id: DiskThreadsDiskFile.cc,v 1.10 2007/04/30 16:56:13 wessels Exp $
*
* DEBUG: section 79 Disk IO Routines
* AUTHOR: Robert Collins
#endif
- debugs(79, 3, "DiskThreadsDiskFile::writeDone: FD " << fd << ", len " << (long int) len << ", err=" << errflag);
+ debugs(79, 3, "DiskThreadsDiskFile::writeDone: FD " << fd << ", len " << len << ", err=" << errflag);
assert(++loop_detect < 10);
/*
- * $Id: HttpHdrContRange.cc,v 1.18 2007/04/28 22:26:37 hno Exp $
+ * $Id: HttpHdrContRange.cc,v 1.19 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 68 HTTP Content-Range Header
* AUTHOR: Alex Rousskov
/* we managed to parse, check if the result makes sence */
if (known_spec((size_t)spec->length) && spec->length == 0) {
- debugs(68, 2, "invalid range (" << (long int) spec->offset << " += " <<
+ debugs(68, 2, "invalid range (" << spec->offset << " += " <<
(long int) spec->length << ") in resp-range-spec near: '" << field << "'");
return 0;
}
/*
- * $Id: HttpHdrRange.cc,v 1.41 2007/04/28 22:26:37 hno Exp $
+ * $Id: HttpHdrRange.cc,v 1.42 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 64 HTTP Range Header
* AUTHOR: Alex Rousskov
ssize_t
HttpHdrRangeIter::debt() const
{
- debugs(64, 3, "HttpHdrRangeIter::debt: debt is " << (int)debt_size);
+ debugs(64, 3, "HttpHdrRangeIter::debt: debt is " << debt_size);
return debt_size;
}
void HttpHdrRangeIter::debt(ssize_t newDebt)
{
- debugs(64, 3, "HttpHdrRangeIter::debt: was " << (int)debt_size << " now " << (int)newDebt);
+ debugs(64, 3, "HttpHdrRangeIter::debt: was " << debt_size << " now " << newDebt);
debt_size = newDebt;
}
/*
- * $Id: HttpHeader.cc,v 1.129 2007/04/28 22:26:37 hno Exp $
+ * $Id: HttpHeader.cc,v 1.130 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 55 HTTP Header
* AUTHOR: Alex Rousskov
if (field_end - value_start > 65534) {
/* String must be LESS THAN 64K and it adds a terminating NULL */
- debugs(55, 1, "WARNING: ignoring '" << name.buf() << "' header of " << (int) (field_end - value_start) << " bytes");
+ debugs(55, 1, "WARNING: ignoring '" << name.buf() << "' header of " << (field_end - value_start) << " bytes");
if (id == HDR_OTHER)
name.clean();
/*
- * $Id: HttpRequestMethod.cc,v 1.3 2007/04/28 22:26:37 hno Exp $
+ * $Id: HttpRequestMethod.cc,v 1.4 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 73 HTTP Request
* AUTHOR: Duane Wessels
/* Don't free statically allocated "%EXTnn" string */
RequestMethodStr[method] = xstrdup(mstr);
- debugs(23, 1, "Extension method '" << mstr << "' added, enum=" << (int) method);
+ debugs(23, 1, "Extension method '" << mstr << "' added, enum=" << method);
return;
}
/*
- * $Id: LeakFinder.cc,v 1.5 2007/04/28 22:26:37 hno Exp $
+ * $Id: LeakFinder.cc,v 1.6 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 45 Callback Data Registry
* AUTHOR: Duane Wessels
LeakFinderPtr *c;
while ((c = (LeakFinderPtr *)hash_next(table))) {
- debugs(45, 1, std::setw(20) << c->key << " last used " << std::setw(9) << (int)(squid_curtime - c->when) <<
+ debugs(45, 1, std::setw(20) << c->key << " last used " << std::setw(9) << (squid_curtime - c->when) <<
" seconds ago by " << c->file << ":" << c->line);
}
}
/*
- * $Id: MemObject.cc,v 1.25 2007/04/28 22:26:37 hno Exp $
+ * $Id: MemObject.cc,v 1.26 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 19 Store Memory Primitives
* AUTHOR: Robert Collins
MemObject::write ( StoreIOBuffer writeBuffer, STMCB *callback, void *callbackData)
{
PROF_start(MemObject_write);
- debugs(19, 6, "memWrite: offset " << (unsigned long)writeBuffer.offset << " len " << (long)writeBuffer.length);
+ debugs(19, 6, "memWrite: offset " << writeBuffer.offset << " len " << writeBuffer.length);
/* the offset is into the content, not the headers */
writeBuffer.offset += (_reply ? _reply->hdr_sz : 0);
debugs(20, 1, "MemObject->data.origin_offset: " << (data_hdr.head ? data_hdr.head->nodeBuffer.offset : 0));
#endif
- debugs(20, 1, "MemObject->start_ping: " << (int) start_ping.tv_sec << "."<< std::setfill('0') << std::setw(6) << (int) start_ping.tv_usec);
- debugs(20, 1, "MemObject->inmem_hi: " << (int) data_hdr.endOffset());
- debugs(20, 1, "MemObject->inmem_lo: " << (int) inmem_lo);
+ debugs(20, 1, "MemObject->start_ping: " << start_ping.tv_sec << "."<< std::setfill('0') << std::setw(6) << start_ping.tv_usec);
+ debugs(20, 1, "MemObject->inmem_hi: " << data_hdr.endOffset());
+ debugs(20, 1, "MemObject->inmem_lo: " << inmem_lo);
debugs(20, 1, "MemObject->nclients: " << nclients);
debugs(20, 1, "MemObject->reply: " << _reply);
debugs(20, 1, "MemObject->request: " << request);
/*
- * $Id: Server.cc,v 1.9 2007/04/28 22:26:37 hno Exp $
+ * $Id: Server.cc,v 1.10 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG:
* AUTHOR: Duane Wessels
void
ServerStateData::sentRequestBody(int fd, size_t size, comm_err_t errflag)
{
- debugs(11, 5, "sentRequestBody: FD " << fd << ": size " << (int) size << ": errflag " << errflag << ".");
+ debugs(11, 5, "sentRequestBody: FD " << fd << ": size " << size << ": errflag " << errflag << ".");
debugs(32,3,HERE << "sentRequestBody called");
requestSender = NULL;
/*
- * $Id: StoreMetaUnpacker.cc,v 1.4 2007/04/28 22:26:37 hno Exp $
+ * $Id: StoreMetaUnpacker.cc,v 1.5 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 20 Storage Manager Swapfile Unpacker
* AUTHOR: Robert Collins
if (position + length > *hdr_len) {
debugs(20, 0, "storeSwapMetaUnpack: overflow!");
- debugs(20, 0, "\ttype=" << type << ", length=" << length << ", *hdr_len=" << *hdr_len << ", offset=" << (int) position);
+ debugs(20, 0, "\ttype=" << type << ", length=" << length << ", *hdr_len=" << *hdr_len << ", offset=" << position);
return false;
}
/*
- * $Id: SwapDir.cc,v 1.10 2007/04/28 22:26:37 hno Exp $
+ * $Id: SwapDir.cc,v 1.11 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 20 Swap Dir base object
* AUTHOR: Robert Collins
ssize_t size = xatoi(value);
if (reconfiguring && max_objsize != size)
- debugs(3, 1, "Cache dir '" << path << "' max object size now " << (long int) size);
+ debugs(3, 1, "Cache dir '" << path << "' max object size now " << size);
max_objsize = size;
/*
- * $Id: asn.cc,v 1.111 2007/04/28 22:26:37 hno Exp $
+ * $Id: asn.cc,v 1.112 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 53 AS Number handling
* AUTHOR: Duane Wessels, Kostas Anagnostakis
asState->reqofs = leftoversz;
- debugs(53, 3, "asState->offset = " << (long int) asState->offset);
+ debugs(53, 3, "asState->offset = " << asState->offset);
if (e->store_status == STORE_PENDING) {
debugs(53, 3, "asHandleReply: store_status == STORE_PENDING: " << e->url() );
/*
- * $Id: auth_digest.cc,v 1.51 2007/04/28 22:26:49 hno Exp $
+ * $Id: auth_digest.cc,v 1.52 2007/04/30 16:56:15 wessels Exp $
*
* DEBUG: section 29 Authenticator
* AUTHOR: Robert Collins
/* the cache's link */
authDigestNonceLink(newnonce);
newnonce->flags.incache = 1;
- debugs(29, 5, "authenticateDigestNonceNew: created nonce " << newnonce << " at " << (long int) newnonce->noncedata.creationtime);
+ debugs(29, 5, "authenticateDigestNonceNew: created nonce " << newnonce << " at " << newnonce->noncedata.creationtime);
return newnonce;
}
*/
digest_nonce_h *nonce;
debugs(29, 3, "authenticateDigestNonceCacheCleanup: Cleaning the nonce cache now");
- debugs(29, 3, "authenticateDigestNonceCacheCleanup: Current time: " << (long int) current_time.tv_sec);
+ debugs(29, 3, "authenticateDigestNonceCacheCleanup: Current time: " << current_time.tv_sec);
hash_first(digest_nonce_cache);
while ((nonce = ((digest_nonce_h *) hash_next(digest_nonce_cache)))) {
debugs(29, 3, "authenticateDigestNonceCacheCleanup: nonce entry : " << nonce << " '" << (char *) nonce->key << "'");
- debugs(29, 4, "authenticateDigestNonceCacheCleanup: Creation time: " << (long int) nonce->noncedata.creationtime);
+ debugs(29, 4, "authenticateDigestNonceCacheCleanup: Creation time: " << nonce->noncedata.creationtime);
if (authDigestNonceIsStale(nonce)) {
debugs(29, 4, "authenticateDigestNonceCacheCleanup: Removing nonce " << (char *) nonce->key << " from cache due to timeout.");
/* has it's max duration expired? */
if (nonce->noncedata.creationtime + digestConfig.noncemaxduration < current_time.tv_sec) {
debugs(29, 4, "authDigestNonceIsStale: Nonce is too old. " <<
- (long int) nonce->noncedata.creationtime << " " <<
- (int) digestConfig.noncemaxduration << " " <<
- (long int) current_time.tv_sec);
+ nonce->noncedata.creationtime << " " <<
+ digestConfig.noncemaxduration << " " <<
+ current_time.tv_sec);
nonce->flags.valid = 0;
return -1;
/*
- * $Id: client_side.cc,v 1.751 2007/04/28 22:26:37 hno Exp $
+ * $Id: client_side.cc,v 1.752 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 33 Client-side Routines
* AUTHOR: Duane Wessels
clientPackTermBound(String boundary, MemBuf * mb)
{
mb->Printf("\r\n--%s--\r\n", boundary.buf());
- debugs(33, 6, "clientPackTermBound: buf offset: " << (long int) mb->size);
+ debugs(33, 6, "clientPackTermBound: buf offset: " << mb->size);
}
/* appends a "part" HTTP header (as in a multi-part/range reply) to the buffer */
/*
* append content
*/
- debugs(33, 3, "clientPackRange: appending " << (long int) copy_sz << " bytes");
+ debugs(33, 3, "clientPackRange: appending " << copy_sz << " bytes");
noteSentBodyBytes (copy_sz);
/* account for range content */
clen += (*pos)->length;
- debugs(33, 6, "clientMRangeCLen: (clen += " << (long int) mb.size << " + " << (long int) (*pos)->length << ") == " << clen);
+ debugs(33, 6, "clientMRangeCLen: (clen += " << mb.size << " + " << (*pos)->length << ") == " << clen);
++pos;
}
{
if (getAvailableBufferLength() < 2) {
in.buf = (char *)memReallocBuf(in.buf, in.allocatedSize * 2, &in.allocatedSize);
- debugs(33, 2, "growing request buffer: notYetUsed=" << (long) in.notYetUsed << " size=" << (long) in.allocatedSize);
+ debugs(33, 2, "growing request buffer: notYetUsed=" << in.notYetUsed << " size=" << in.allocatedSize);
}
}
ClientSocketContext *context = parseHttpRequestAbort(conn, "error:request-too-large");
clientStreamNode *node = context->getClientReplyContext();
assert(!connKeepReadingIncompleteRequest(conn));
- debugs(33, 1, "Request header is too large (" << (unsigned) conn->in.notYetUsed << " bytes)");
- debugs(33, 1, "Config 'request_header_max_size'= " << (long int) Config.maxRequestHeaderSize << " bytes.");
+ debugs(33, 1, "Request header is too large (" << conn->in.notYetUsed << " bytes)");
+ debugs(33, 1, "Config 'request_header_max_size'= " << Config.maxRequestHeaderSize << " bytes.");
clientReplyContext *repContext = dynamic_cast<clientReplyContext *>(node->data.getRaw());
assert (repContext);
repContext->setReplyToError(ERR_TOO_BIG,
/*
- * $Id: client_side_reply.cc,v 1.121 2007/04/28 22:26:37 hno Exp $
+ * $Id: client_side_reply.cc,v 1.122 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 88 Client-side Reply Routines
* AUTHOR: Robert Collins (Originally Duane Wessels in client_side.c)
#endif
http->request->lastmod = old_entry->lastmod;
- debugs(88, 5, "clientReplyContext::processExpired : lastmod " << (long int) entry->lastmod );
+ debugs(88, 5, "clientReplyContext::processExpired : lastmod " << entry->lastmod );
http->storeEntry(entry);
assert(http->out.offset == 0);
HttpRequest *r = http->request;
- debugs(88, 3, "clientCacheHit: " << http->uri << ", " << (unsigned int)result.length << " bytes");
+ debugs(88, 3, "clientCacheHit: " << http->uri << ", " << result.length << " bytes");
if (http->storeEntry() == NULL) {
debugs(88, 3, "clientCacheHit: request aborted");
if (http->out.size > 0x7FFF0000) {
debugs(88, 1, "WARNING: closing FD " << fd << " to prevent counter overflow" );
debugs(88, 1, "\tclient " << (inet_ntoa(http->getConn() != NULL ? http->getConn()->peer.sin_addr : no_addr)) );
- debugs(88, 1, "\treceived " << (int) http->out.size << " bytes" );
+ debugs(88, 1, "\treceived " << http->out.size << " bytes" );
debugs(88, 1, "\tURI " << http->log_uri );
return 1;
}
if (http->out.offset > 0x7FFF0000) {
debugs(88, 1, "WARNING: closing FD " << fd << " to prevent counter overflow" );
debugs(88, 1, "\tclient " << (inet_ntoa(http->getConn() != NULL ? http->getConn()->peer.sin_addr : no_addr)) );
- debugs(88, 1, "\treceived " << (int) http->out.size << " bytes (offset " << (int) http->out.offset << ")" );
+ debugs(88, 1, "\treceived " << http->out.size << " bytes (offset " << http->out.offset << ")" );
debugs(88, 1, "\tURI " << http->log_uri );
return 1;
}
for (l = Config.ReplyBodySize; l; l = l -> next) {
if (ch->matchAclListFast(l->aclList)) {
if (l->size != static_cast<size_t>(-1)) {
- debugs(58, 3, "clientReplyContext: Setting maxBodySize to " << (long int) l->size);
+ debugs(58, 3, "clientReplyContext: Setting maxBodySize to " << l->size);
http->maxReplyBodySize(l->size);
}
debugs(88, 5, "clientReplyContext::sendMoreData: " << http->uri << ", " <<
(int) reqofs << " bytes (" << (unsigned int)result.length <<
" new bytes)");
- debugs(88, 5, "clientReplyContext::sendMoreData: FD " << fd << " '" << entry->url() << "', out.offset=" << (long int) http->out.offset << " " );
+ debugs(88, 5, "clientReplyContext::sendMoreData: FD " << fd << " '" << entry->url() << "', out.offset=" << http->out.offset << " " );
/* update size of the request */
reqsize = reqofs;
/*
- * $Id: comm.cc,v 1.429 2007/04/28 22:26:37 hno Exp $
+ * $Id: comm.cc,v 1.430 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 5 Socket Functions
* AUTHOR: Harvest Derived
}
F->local_port = ntohs(addr.sin_port);
- debugs(5, 6, "comm_local_port: FD " << fd << ": port " << (int) F->local_port);
+ debugs(5, 6, "comm_local_port: FD " << fd << ": port " << F->local_port);
return F->local_port;
}
commConnectStart(int fd, const char *host, u_short port, CNCB * callback, void *data)
{
ConnectStateData *cs;
- debugs(5, 3, "commConnectStart: FD " << fd << ", data " << data << ", " << host << ":" << (int) port);
+ debugs(5, 3, "commConnectStart: FD " << fd << ", data " << data << ", " << host << ":" << port);
cs = new ConnectStateData;
cs->fd = fd;
cs->host = xstrdup(host);
/*
- * $Id: comm_poll.cc,v 1.20 2007/04/28 22:26:37 hno Exp $
+ * $Id: comm_poll.cc,v 1.21 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 5 Socket Functions
*
return COMM_OK;
} while (timeout > current_dtime);
- debugs(5, 8, "comm_poll: time out: " << (long int) squid_curtime << ".");
+ debugs(5, 8, "comm_poll: time out: " << squid_curtime << ".");
return COMM_TIMEOUT;
}
/*
- * $Id: comm_select.cc,v 1.78 2007/04/28 22:26:37 hno Exp $
+ * $Id: comm_select.cc,v 1.79 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 5 Socket Functions
*
} while (timeout > current_dtime)
;
- debugs(5, 8, "comm_select: time out: " << (int) squid_curtime);
+ debugs(5, 8, "comm_select: time out: " << squid_curtime);
return COMM_TIMEOUT;
}
/*
- * $Id: comm_select_win32.cc,v 1.3 2007/04/28 22:26:37 hno Exp $
+ * $Id: comm_select_win32.cc,v 1.4 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 5 Socket Functions
*
} while (timeout > current_dtime)
;
- debugs(5, 8, "comm_select: time out: " << (int) squid_curtime);
+ debugs(5, 8, "comm_select: time out: " << squid_curtime);
return COMM_TIMEOUT;
}
/*
- * $Id: disk.cc,v 1.172 2007/04/28 22:26:37 hno Exp $
+ * $Id: disk.cc,v 1.173 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 6 Disk I/O Routines
* AUTHOR: Harvest Derived
assert(fdd->write_q->len > fdd->write_q->buf_offset);
- debugs(6, 3, "diskHandleWrite: FD " << fd << " writing " << (int) (fdd->write_q->len - fdd->write_q->buf_offset) << " bytes");
+ debugs(6, 3, "diskHandleWrite: FD " << fd << " writing " << (fdd->write_q->len - fdd->write_q->buf_offset) << " bytes");
errno = 0;
PROF_start(diskHandleRead);
if (F->disk.offset != ctrl_dat->offset) {
- debugs(6, 3, "diskHandleRead: FD " << fd << " seeking to offset " << (int) ctrl_dat->offset);
+ debugs(6, 3, "diskHandleRead: FD " << fd << " seeking to offset " << ctrl_dat->offset);
lseek(fd, ctrl_dat->offset, SEEK_SET); /* XXX ignore return? */
statCounter.syscalls.disk.seeks++;
F->disk.offset = ctrl_dat->offset;
/*
- * $Id: dns_internal.cc,v 1.97 2007/04/28 22:26:37 hno Exp $
+ * $Id: dns_internal.cc,v 1.98 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 78 DNS lookups; interacts with lib/rfc1035.c
* AUTHOR: Duane Wessels
fd_bytes(DnsSocket, len, FD_READ);
assert(N);
(*N)++;
- debugs(78, 3, "idnsRead: FD " << fd << ": received " << (int) len << " bytes from " << inet_ntoa(from.sin_addr) << ".");
+ debugs(78, 3, "idnsRead: FD " << fd << ": received " << len << " bytes from " << inet_ntoa(from.sin_addr) << ".");
ns = idnsFromKnownNameserver(&from);
if (ns >= 0) {
if (tvSubDsec(q->start_t, current_time) < Config.Timeout.idns_query) {
idnsSendQuery(q);
} else {
- debugs(78, 2, "idnsCheckQueue: ID " << std::hex << (int) q->id <<
+ debugs(78, 2, "idnsCheckQueue: ID " << std::hex << q->id <<
": giving up after " << std::dec << q->nsends << " tries and " <<
std::setw(5)<< std::setprecision(2) << tvSubDsec(q->start_t, current_time) << " seconds");
return;
}
- debugs(78, 3, "idnsALookup: buf is " << (int) q->sz << " bytes for " << q->name <<
+ debugs(78, 3, "idnsALookup: buf is " << q->sz << " bytes for " << q->name <<
", id = 0x" << std::hex << q->id);
q->callback = callback;
return;
}
- debugs(78, 3, "idnsPTRLookup: buf is " << (int) q->sz << " bytes for " << ip <<
+ debugs(78, 3, "idnsPTRLookup: buf is " << q->sz << " bytes for " << ip <<
", id = 0x" << std::hex << q->id);
q->callback = callback;
/*
- * $Id: errorpage.cc,v 1.223 2007/04/28 22:26:37 hno Exp $
+ * $Id: errorpage.cc,v 1.224 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 4 Error Generation
* AUTHOR: Duane Wessels
errorSendComplete(int fd, char *bufnotused, size_t size, comm_err_t errflag, int xerrno, void *data)
{
ErrorState *err = static_cast<ErrorState *>(data);
- debugs(4, 3, "errorSendComplete: FD " << fd << ", size=" << (long int) size);
+ debugs(4, 3, "errorSendComplete: FD " << fd << ", size=" << size);
if (errflag != COMM_ERR_CLOSING) {
if (err->callback) {
/*
- * $Id: filemap.cc,v 1.43 2007/04/28 22:26:37 hno Exp $
+ * $Id: filemap.cc,v 1.44 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 8 Swap File Bitmap
* AUTHOR: Harvest Derived
fm->max_n_files = FM_INITIAL_NUMBER;
fm->nwords = fm->max_n_files >> LONG_BIT_SHIFT;
debugs(8, 3, "file_map_create: creating space for " << fm->max_n_files << " files");
- debugs(8, 5, "--> " << fm->nwords << " words of " << (int) sizeof(*fm->file_map) << " bytes each");
+ debugs(8, 5, "--> " << fm->nwords << " words of " << sizeof(*fm->file_map) << " bytes each");
fm->file_map = (unsigned long *)xcalloc(fm->nwords, sizeof(*fm->file_map));
/* XXX account fm->file_map */
return fm;
/*
- * $Id: forward.cc,v 1.162 2007/04/29 17:35:52 hno Exp $
+ * $Id: forward.cc,v 1.163 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 17 Request Forwarding
* AUTHOR: Duane Wessels
if (checkRetry()) {
int originserver = (servers->_peer == NULL);
- debugs(17, 3, "fwdServerClosed: re-forwarding (" << n_tries << " tries, " << (int) (squid_curtime - start_t) << " secs)");
+ debugs(17, 3, "fwdServerClosed: re-forwarding (" << n_tries << " tries, " << (squid_curtime - start_t) << " secs)");
if (servers->next) {
/* use next, or cycle if origin server isn't last */
}
s = e->getReply()->sline.status;
- debugs(17, 3, "fwdReforward: status " << (int) s);
+ debugs(17, 3, "fwdReforward: status " << s);
return reforwardableStatus(s);
}
/*
- * $Id: store_dir_coss.cc,v 1.72 2007/04/28 22:26:50 hno Exp $
+ * $Id: store_dir_coss.cc,v 1.73 2007/04/30 16:56:16 wessels Exp $
* vim: set et :
*
* DEBUG: section 47 Store COSS Directory Routines
CossWrite* cossWrite= dynamic_cast<CossWrite *>(writeRequest.getRaw());
assert (cossWrite);
- debugs(79, 3, "storeCossWriteMemBufDone: buf " << cossWrite->membuf << ", len " << (long int) len);
+ debugs(79, 3, "storeCossWriteMemBufDone: buf " << cossWrite->membuf << ", len " << len);
if (errflag) {
/*
- * $Id: store_io_coss.cc,v 1.31 2007/04/28 22:26:51 hno Exp $
+ * $Id: store_io_coss.cc,v 1.32 2007/04/30 16:56:16 wessels Exp $
*
* DEBUG: section 79 Storage Manager COSS Interface
* AUTHOR: Eric Stern
current_membuf->flags.full = 1;
current_offset = current_membuf->diskend;
current_membuf->maybeWrite(this);
- debugs(79, 2, "CossSwapDir::allocate: New offset - " << (long int) current_offset);
+ debugs(79, 2, "CossSwapDir::allocate: New offset - " << current_offset);
newmb = createMemBuf(current_offset, checkf, &coll);
current_membuf = newmb;
}
assert(read.callback_data == NULL);
read.callback = callback;
read.callback_data = cbdataReference(callback_data);
- debugs(79, 3, "storeCossRead: offset " << (long int) offset);
+ debugs(79, 3, "storeCossRead: offset " << offset);
offset_ = offset;
flags.reading = 1;
assert(e->mem_obj->object_sz != -1);
StoreFScoss::GetInstance().stats.write.ops++;
- debugs(79, 3, "storeCossWrite: offset " << (long int) offset_ << ", len " << (unsigned long int) size);
+ debugs(79, 3, "storeCossWrite: offset " << offset_ << ", len " << (unsigned long int) size);
diskoffset = SD->storeCossFilenoToDiskOffset(swap_filen) + offset_;
CossSwapDir *SD = (CossSwapDir *)INDEXSD(swap_dirn);
dest = SD->storeCossMemPointerFromDiskOffset(diskoffset, &membuf);
CossMemBuf::write(CossSwapDir * SD)
{
StoreFScoss::GetInstance().stats.stripe_write.ops++;
- debugs(79, 3, "CossMemBuf::write: offset " << (long int) diskstart << ", len " << (long int) (diskend - diskstart));
+ debugs(79, 3, "CossMemBuf::write: offset " << diskstart << ", len " << (diskend - diskstart));
flags.writing = 1;
/* XXX Remember that diskstart/diskend are block offsets! */
SD->theFile->write(new CossWrite(WriteRequest((char const *)&buffer, diskstart, diskend - diskstart, NULL), this));
CBDATA_INIT_TYPE_FREECB(CossMemBuf, NULL);
newmb = cbdataAlloc(CossMemBuf);
newmb->diskstart = start;
- debugs(79, 3, "CossSwapDir::createMemBuf: creating new membuf at " << (long int) newmb->diskstart);
+ debugs(79, 3, "CossSwapDir::createMemBuf: creating new membuf at " << newmb->diskstart);
debugs(79, 3, "CossSwapDir::createMemBuf: at " << newmb);
newmb->diskend = newmb->diskstart + COSS_MEMBUF_SZ;
newmb->flags.full = 0;
/*
- * $Id: store_dir_ufs.cc,v 1.81 2007/04/28 22:26:51 hno Exp $
+ * $Id: store_dir_ufs.cc,v 1.82 2007/04/30 16:56:17 wessels Exp $
*
* DEBUG: section 47 Store Directory Routines
* AUTHOR: Duane Wessels
if ((off_t)e.swap_file_sz != sb.st_size) {
debugs(47, 0, "UFSSwapDir::doubleCheck: SIZE MISMATCH");
- debugs(47, 0, "UFSSwapDir::doubleCheck: ENTRY SIZE: " << (long int) e.swap_file_sz << ", FILE SIZE: " << (long int) sb.st_size);
+ debugs(47, 0, "UFSSwapDir::doubleCheck: ENTRY SIZE: " << e.swap_file_sz << ", FILE SIZE: " << sb.st_size);
dumpEntry(e);
return true;
}
/*
- * $Id: store_io_ufs.cc,v 1.37 2007/04/28 22:26:51 hno Exp $
+ * $Id: store_io_ufs.cc,v 1.38 2007/04/30 16:56:17 wessels Exp $
*
* DEBUG: section 79 Storage Manager UFS Interface
* AUTHOR: Duane Wessels
if (NULL == q)
return false;
- debugs(79, 3, "UFSStoreState::kickReadQueue: reading queued request of " << (long int) q->size << " bytes");
+ debugs(79, 3, "UFSStoreState::kickReadQueue: reading queued request of " << q->size << " bytes");
void *cbdata;
/*
- * $Id: ftp.cc,v 1.418 2007/04/28 22:26:37 hno Exp $
+ * $Id: ftp.cc,v 1.419 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 9 File Transfer Protocol (FTP)
* AUTHOR: Harvest Derived
usable = end - sbuf;
- debugs(9, 3, "ftpParseListing: usable = " << (int) usable);
+ debugs(9, 3, "ftpParseListing: usable = " << usable);
if (usable == 0) {
debugs(9, 3, "ftpParseListing: didn't find end for " << e->url() );
{
FtpStateData *ftpState = (FtpStateData *)data;
- debugs(9, 7, "ftpWriteCommandCallback: wrote " << (int) size << " bytes");
+ debugs(9, 7, "ftpWriteCommandCallback: wrote " << size << " bytes");
if (size > 0) {
fd_bytes(fd, size, FD_WRITE);
return NULL;
}
- debugs(9, 3, "ftpParseControlReply: " << (int) len << " bytes to play with");
+ debugs(9, 3, "ftpParseControlReply: " << len << " bytes to play with");
end++;
s = sbuf;
s += strspn(s, crlf);
{
FtpStateData *ftpState = (FtpStateData *)data;
StoreEntry *entry = ftpState->entry;
- debugs(9, 5, "ftpReadControlReply: FD " << fd << ", Read " << (int)len << " bytes");
+ debugs(9, 5, "ftpReadControlReply: FD " << fd << ", Read " << len << " bytes");
if (len > 0) {
kb_incr(&statCounter.server.all.kbytes_in, len);
/*
- * $Id: gopher.cc,v 1.203 2007/04/28 22:26:37 hno Exp $
+ * $Id: gopher.cc,v 1.204 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 10 Gopher
* AUTHOR: Harvest Derived
kb_incr(&statCounter.server.other.kbytes_in, len);
}
- debugs(10, 5, "gopherReadReply: FD " << fd << " read len=" << (int)len);
+ debugs(10, 5, "gopherReadReply: FD " << fd << " read len=" << len);
if (flag == COMM_OK && len > 0) {
commSetTimeout(fd, Config.Timeout.read, NULL, NULL);
{
GopherStateData *gopherState = (GopherStateData *) data;
StoreEntry *entry = gopherState->entry;
- debugs(10, 5, "gopherSendComplete: FD " << fd << " size: " << (int) size << " errflag: " << errflag);
+ debugs(10, 5, "gopherSendComplete: FD " << fd << " size: " << size << " errflag: " << errflag);
if (size > 0) {
fd_bytes(fd, size, FD_WRITE);
/*
- * $Id: helper.cc,v 1.80 2007/04/28 22:26:37 hno Exp $
+ * $Id: helper.cc,v 1.81 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 84 Helper process maintenance
* AUTHOR: Harvest Derived?
return;
}
- debugs(84, 5, "helperHandleRead: " << (int)len << " bytes from " << hlp->id_name << " #" << srv->index + 1 << ".");
+ debugs(84, 5, "helperHandleRead: " << len << " bytes from " << hlp->id_name << " #" << srv->index + 1 << ".");
if (flag != COMM_OK || len <= 0) {
if (len < 0)
return;
}
- debugs(84, 5, "helperStatefulHandleRead: " << (int)len << " bytes from " <<
+ debugs(84, 5, "helperStatefulHandleRead: " << len << " bytes from " <<
hlp->id_name << " #" << srv->index + 1 << ".");
srv, NULL); /* Handler-data, free func */
}
- debugs(84, 5, "helperDispatch: Request sent to " << hlp->id_name << " #" << srv->index + 1 << ", " << (int) strlen(r->buf) << " bytes");
+ debugs(84, 5, "helperDispatch: Request sent to " << hlp->id_name << " #" << srv->index + 1 << ", " << strlen(r->buf) << " bytes");
srv->stats.uses++;
hlp->stats.requests++;
/*
- * $Id: htcp.cc,v 1.75 2007/04/28 22:26:37 hno Exp $
+ * $Id: htcp.cc,v 1.76 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 31 Hypertext Caching Protocol
* AUTHOR: Duane Wesssels
off += s;
- debugs(31, 3, "htcpBuildSpecifier: size " << (int) off);
+ debugs(31, 3, "htcpBuildSpecifier: size " << off);
return off;
}
off += op_data_sz;
- debugs(31, 3, "htcpBuildData: hdr.length = " << (int) off);
+ debugs(31, 3, "htcpBuildData: hdr.length = " << off);
hdr.length = (u_int16_t) off;
xmemcpy(buf, &hdrSquid, hdr_sz);
}
- debugs(31, 3, "htcpBuildData: size " << (int) off);
+ debugs(31, 3, "htcpBuildData: size " << off);
return off;
}
xmemcpy(buf, &hdr, hdr_sz);
- debugs(31, 3, "htcpBuildPacket: size " << (int) off);
+ debugs(31, 3, "htcpBuildPacket: size " << off);
return off;
}
htcpHandleTst(htcpDataHeader * hdr, char *buf, int sz, struct sockaddr_in *from)
{
- debugs(31, 3, "htcpHandleTst: sz = " << (int) sz);
+ debugs(31, 3, "htcpHandleTst: sz = " << sz);
if (hdr->RR == RR_REQUEST)
htcpHandleTstRequest(hdr, buf, sz, from);
}
htcpReply.msg_id = hdr->msg_id;
- debugs(31, 3, "htcpHandleTstResponse: msg_id = " << (int) htcpReply.msg_id);
+ debugs(31, 3, "htcpHandleTstResponse: msg_id = " << htcpReply.msg_id);
htcpReply.hit = hdr->response ? 0 : 1;
if (hdr->F1)
hdr.length = ntohs(hdr.length);
hdr.msg_id = ntohl(hdr.msg_id);
debugs(31, 3, "htcpHandleData: sz = " << sz);
- debugs(31, 3, "htcpHandleData: length = " << (int) hdr.length);
+ debugs(31, 3, "htcpHandleData: length = " << hdr.length);
if (hdr.opcode >= HTCP_END)
{
- debugs(31, 1, "htcpHandleData: client " << inet_ntoa(from->sin_addr) << ", opcode " << (int) hdr.opcode << " out of range");
+ debugs(31, 1, "htcpHandleData: client " << inet_ntoa(from->sin_addr) << ", opcode " << hdr.opcode << " out of range");
return;
}
- debugs(31, 3, "htcpHandleData: opcode = " << (int) hdr.opcode << " " << htcpOpcodeStr[hdr.opcode]);
- debugs(31, 3, "htcpHandleData: response = " << (int) hdr.response);
- debugs(31, 3, "htcpHandleData: F1 = " << (int) hdr.F1);
- debugs(31, 3, "htcpHandleData: RR = " << (int) hdr.RR);
- debugs(31, 3, "htcpHandleData: msg_id = " << (int) hdr.msg_id);
+ debugs(31, 3, "htcpHandleData: opcode = " << hdr.opcode << " " << htcpOpcodeStr[hdr.opcode]);
+ debugs(31, 3, "htcpHandleData: response = " << hdr.response);
+ debugs(31, 3, "htcpHandleData: F1 = " << hdr.F1);
+ debugs(31, 3, "htcpHandleData: RR = " << hdr.RR);
+ debugs(31, 3, "htcpHandleData: msg_id = " << hdr.msg_id);
if (sz < hdr.length)
{
else
old_squid_format = 0;
- debugs(31, 3, "htcpHandle: htcpHdr.length = " << (int) htcpHdr.length);
- debugs(31, 3, "htcpHandle: htcpHdr.major = " << (int) htcpHdr.major);
- debugs(31, 3, "htcpHandle: htcpHdr.minor = " << (int) htcpHdr.minor);
+ debugs(31, 3, "htcpHandle: htcpHdr.length = " << htcpHdr.length);
+ debugs(31, 3, "htcpHandle: htcpHdr.major = " << htcpHdr.major);
+ debugs(31, 3, "htcpHandle: htcpHdr.minor = " << htcpHdr.minor);
if (sz != htcpHdr.length)
{
commSetSelect(htcpInSocket, COMM_SELECT_READ, htcpRecv, NULL, 0);
- debugs(31, 1, "Accepting HTCP messages on port " << (int) Config.Port.htcp << ", FD " << htcpInSocket << ".");
+ debugs(31, 1, "Accepting HTCP messages on port " << Config.Port.htcp << ", FD " << htcpInSocket << ".");
if (Config.Addrs.udp_outgoing.s_addr != no_addr.s_addr) {
enter_suid();
commSetSelect(htcpOutSocket, COMM_SELECT_READ, htcpRecv, NULL, 0);
- debugs(31, 1, "Outgoing HTCP messages on port " << (int) Config.Port.htcp << ", FD " << htcpOutSocket << ".");
+ debugs(31, 1, "Outgoing HTCP messages on port " << Config.Port.htcp << ", FD " << htcpOutSocket << ".");
fd_note(htcpInSocket, "Incoming HTCP socket");
} else {
/*
- * $Id: http.cc,v 1.517 2007/04/28 22:26:37 hno Exp $
+ * $Id: http.cc,v 1.518 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 11 Hypertext Transfer Protocol (HTTP)
* AUTHOR: Harvest Derived
errno = 0;
/* prepare the read size for the next read (if any) */
- debugs(11, 5, "httpReadReply: FD " << fd << ": len " << (int)len << ".");
+ debugs(11, 5, "httpReadReply: FD " << fd << ": len " << len << ".");
if (flag == COMM_OK && len > 0) {
readBuf->appended(len);
HttpStateData::SendComplete(int fd, char *bufnotused, size_t size, comm_err_t errflag, int xerrno, void *data)
{
HttpStateData *httpState = static_cast<HttpStateData *>(data);
- debugs(11, 5, "httpSendComplete: FD " << fd << ": size " << (int) size << ": errflag " << errflag << ".");
+ debugs(11, 5, "httpSendComplete: FD " << fd << ": size " << size << ": errflag " << errflag << ".");
#if URL_CHECKSUM_DEBUG
entry->mem_obj->checkUrlChecksum();
/*
- * $Id: icmp.cc,v 1.92 2007/04/29 17:35:52 hno Exp $
+ * $Id: icmp.cc,v 1.93 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 37 ICMP Routines
* AUTHOR: Duane Wessels
break;
default:
- debugs(37, 1, "icmpRecv: Bad opcode: " << (int) preply.opcode);
+ debugs(37, 1, "icmpRecv: Bad opcode: " << preply.opcode);
break;
}
}
#ifdef _SQUID_MSWIN_
- debugs(37, 4, "Pinger handle: 0x" << std::hex << (unsigned)hIpc << std::dec << ", PID: " << pid);
+ debugs(37, 4, "Pinger handle: 0x" << std::hex << hIpc << std::dec << ", PID: " << pid);
#endif
#endif
if (hIpc) {
if (WaitForSingleObject(hIpc, 12000) != WAIT_OBJECT_0) {
getCurrentTime();
- debugs(37, 1, "icmpClose: WARNING: (pinger," << (long int)pid << ") didn't exit in 12 seconds");
+ debugs(37, 1, "icmpClose: WARNING: (pinger," << pid << ") didn't exit in 12 seconds");
}
CloseHandle(hIpc);
/*
- * $Id: icp_v2.cc,v 1.98 2007/04/28 22:26:37 hno Exp $
+ * $Id: icp_v2.cc,v 1.99 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 12 Internet Cache Protocol
* AUTHOR: Duane Wessels
struct IN_ADDR a;
- debugs(12, 9, "opcode: " << std::setw(3) << (int) pkt->opcode << " " << icp_opcode_str[pkt->opcode]);
- debugs(12, 9, "version: "<< std::left << std::setw(8) << (int) pkt->version);
- debugs(12, 9, "length: "<< std::left << std::setw(8) << (int) ntohs(pkt->length));
+ debugs(12, 9, "opcode: " << std::setw(3) << pkt->opcode << " " << icp_opcode_str[pkt->opcode]);
+ debugs(12, 9, "version: "<< std::left << std::setw(8) << pkt->version);
+ debugs(12, 9, "length: "<< std::left << std::setw(8) << ntohs(pkt->length));
debugs(12, 9, "reqnum: "<< std::left << std::setw(8) << ntohl(pkt->reqnum));
debugs(12, 9, "flags: "<< std::left << std::hex << std::setw(8) << ntohl(pkt->flags));
a.s_addr = pkt->shostid;
NULL,
0);
- debugs(12, 1, "Outgoing ICP messages on port " << (int) port << ", FD " << theOutIcpConnection << ".");
+ debugs(12, 1, "Outgoing ICP messages on port " << port << ", FD " << theOutIcpConnection << ".");
fd_note(theOutIcpConnection, "Outgoing ICP socket");
/*
- * $Id: ipc_win32.cc,v 1.3 2007/04/28 22:26:37 hno Exp $
+ * $Id: ipc_win32.cc,v 1.4 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 54 Windows Interprocess Communication
* AUTHOR: Andrey Shorin <tolsty@tushino.com>
if (-1 == ipcSend(cwfd, buf1, strlen(buf1)))
goto cleanup;
- debugs(54, 2, "ipc(" << prog << "," << (long int) pid << "): started successfully");
+ debugs(54, 2, "ipc(" << prog << "," << pid << "): started successfully");
/* cycle */
for (;;) {
/*
- * $Id: main.cc,v 1.446 2007/04/28 22:26:37 hno Exp $
+ * $Id: main.cc,v 1.447 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 1 Startup and Main Loop
* AUTHOR: Harvest Derived
} else if (do_shutdown) {
time_t wait = do_shutdown > 0 ? (int) Config.shutdownLifetime : 0;
debugs(1, 1, "Preparing for shutdown after " << statCounter.client_http.requests << " requests");
- debugs(1, 1, "Waiting " << (int) wait << " seconds for active connections to finish");
+ debugs(1, 1, "Waiting " << wait << " seconds for active connections to finish");
do_shutdown = 0;
shutting_down = 1;
#if USE_WIN32_SERVICE
/*
- * $Id: neighbors.cc,v 1.348 2007/04/28 22:26:37 hno Exp $
+ * $Id: neighbors.cc,v 1.349 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 15 Neighbor Routines
* AUTHOR: Harvest Derived
q->rr_count += weighted_rtt;
- debugs(15, 3, "getWeightedRoundRobinParent: weighted_rtt " << (int) weighted_rtt);
+ debugs(15, 3, "getWeightedRoundRobinParent: weighted_rtt " << weighted_rtt);
}
debugs(15, 3, "getWeightedRoundRobinParent: returning " << (q ? q->host : "NULL"));
char *opcode_d;
icp_opcode opcode = (icp_opcode) header->opcode;
- debugs(15, 6, "neighborsUdpAck: opcode " << (int) opcode << " '" << storeKeyText(key) << "'");
+ debugs(15, 6, "neighborsUdpAck: opcode " << opcode << " '" << storeKeyText(key) << "'");
if (NULL != (entry = Store::Root().get(key)))
mem = entry->mem_obj;
/*
- * $Id: net_db.cc,v 1.193 2007/04/28 22:26:37 hno Exp $
+ * $Id: net_db.cc,v 1.194 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 38 Network Measurement Database
* AUTHOR: Duane Wessels
rec_sz += 1 + sizeof(addr.s_addr);
rec_sz += 1 + sizeof(int);
rec_sz += 1 + sizeof(int);
- debugs(38, 3, "netdbExchangeHandleReply: " << (int) recievedData.length << " read bytes");
+ debugs(38, 3, "netdbExchangeHandleReply: " << recievedData.length << " read bytes");
if (!cbdataReferenceValid(ex->p)) {
debugs(38, 3, "netdbExchangeHandleReply: Peer became invalid");
" entries, (x " << rec_sz << " bytes) == " << nused * rec_sz <<
" bytes total");
- debugs(38, 3, "netdbExchangeHandleReply: used " << (long int) ex->used);
+ debugs(38, 3, "netdbExchangeHandleReply: used " << ex->used);
if (EBIT_TEST(ex->e->flags, ENTRY_ABORTED)) {
debugs(38, 3, "netdbExchangeHandleReply: ENTRY_ABORTED");
/*
- * $Id: pconn.cc,v 1.49 2007/04/28 22:26:37 hno Exp $
+ * $Id: pconn.cc,v 1.50 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 48 Persistent Connections
* AUTHOR: Duane Wessels
void
IdleConnList::read(int fd, char *buf, size_t len, comm_err_t flag, int xerrno, void *data)
{
- debugs(48, 3, "IdleConnList::read: " << (int) len << " bytes from FD " << fd);
+ debugs(48, 3, "IdleConnList::read: " << len << " bytes from FD " << fd);
if (flag == COMM_ERR_CLOSING) {
/* Bail out early on COMM_ERR_CLOSING - close handlers will tidy up for us */
/*
- * $Id: peer_digest.cc,v 1.122 2007/04/28 22:26:37 hno Exp $
+ * $Id: peer_digest.cc,v 1.123 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 72 Peer Digest Routines
* AUTHOR: Alex Rousskov
{
eventAdd("peerDigestCheck", peerDigestCheck, pd, (double) delay, 1);
pd->times.next_check = squid_curtime + delay;
- debugs(72, 3, "peerDigestSetCheck: will check peer " << pd->host.buf() << " in " << (int) delay << " secs");
+ debugs(72, 3, "peerDigestSetCheck: will check peer " << pd->host.buf() << " in " << delay << " secs");
}
/*
}
debugs(72, 3, "peerDigestCheck: peer " << pd->peer->host << ":" << pd->peer->http_port);
- debugs(72, 3, "peerDigestCheck: time: " << (long int) squid_curtime <<
+ debugs(72, 3, "peerDigestCheck: time: " << squid_curtime <<
", last received: " << (long int) pd->times.received << " (" <<
std::showpos << (int) (squid_curtime - pd->times.received) << ")");
/*
- * $Id: peer_select.cc,v 1.146 2007/04/28 22:26:37 hno Exp $
+ * $Id: peer_select.cc,v 1.147 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 44 Peer Selection Algorithm
* AUTHOR: Duane Wessels
#endif
else
- debugs(44, 1, "peerHandlePingReply: unknown protocol_t " << (int) proto);
+ debugs(44, 1, "peerHandlePingReply: unknown protocol_t " << proto);
}
static void
/*
- * $Id: pinger.cc,v 1.58 2007/04/28 22:26:37 hno Exp $
+ * $Id: pinger.cc,v 1.59 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 42 ICMP Pinger program
* AUTHOR: Duane Wessels
pingerLog(struct icmphdr *icmp, struct IN_ADDR addr, int rtt, int hops)
{
- debugs(42, 2, "pingerLog: " << std::setw(9) << (int) current_time.tv_sec <<
+ debugs(42, 2, "pingerLog: " << std::setw(9) << current_time.tv_sec <<
"."<< std::setfill('0') << std::setw(6) <<
- (int) current_time.tv_usec << " "<< std::left << std::setfill(' ')<<
- std::setw(16) << inet_ntoa(addr) << " "<< (int) icmp->icmp_type <<
+ current_time.tv_usec << " "<< std::left << std::setfill(' ')<<
+ std::setw(16) << inet_ntoa(addr) << " "<< icmp->icmp_type <<
" " << std::setw(15) << icmpPktStr[icmp->icmp_type] << " " << rtt <<
"ms " << hops << " hops");
}
/*
- * $Id: refresh.cc,v 1.74 2007/04/28 22:26:37 hno Exp $
+ * $Id: refresh.cc,v 1.75 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 22 Refresh Calculation
* AUTHOR: Harvest Derived
sf->expires = true;
if (entry->expires > check_time) {
- debugs(22, 3, "FRESH: expires " << (int) entry->expires <<
- " >= check_time " << (int) check_time << " ");
+ debugs(22, 3, "FRESH: expires " << entry->expires <<
+ " >= check_time " << check_time << " ");
return -1;
} else {
- debugs(22, 3, "STALE: expires " << (int) entry->expires <<
- " < check_time " << (int) check_time << " ");
+ debugs(22, 3, "STALE: expires " << entry->expires <<
+ " < check_time " << check_time << " ");
return (check_time - entry->expires);
}
*/
if (age > R->max) {
- debugs(22, 3, "STALE: age " << (int) age << " > max " << (int) R->max << " ");
+ debugs(22, 3, "STALE: age " << age << " > max " << R->max << " ");
sf->max = true;
return (age - R->max);
}
sf->lmfactor = true;
if (age >= stale_age) {
- debugs(22, 3, "STALE: age " << (int) age << " > stale_age " << (int) stale_age);
+ debugs(22, 3, "STALE: age " << age << " > stale_age " << stale_age);
return (age - stale_age);
} else {
- debugs(22, 3, "FRESH: age " << (int) age << " <= stale_age " << (int) stale_age);
+ debugs(22, 3, "FRESH: age " << age << " <= stale_age " << stale_age);
return -1;
}
}
* configured minimum age.
*/
if (age <= R->min) {
- debugs(22, 3, "FRESH: age " << (int) age << " <= min " << (int) R->min);
+ debugs(22, 3, "FRESH: age " << age << " <= min " << R->min);
sf->min = true;
return -1;
}
- debugs(22, 3, "STALE: age " << (int) age << " > min " << (int) R->min);
+ debugs(22, 3, "STALE: age " << age << " > min " << R->min);
return (age - R->min);
}
(int) R->max << "'");
- debugs(22, 3, "refreshCheck: age = " << (int) age);
+ debugs(22, 3, "refreshCheck: age = " << age);
debugs(22, 3, "\tcheck_time:\t" << mkrfc1123(check_time));
/*
- * $Id: store_repl_heap.cc,v 1.24 2007/04/28 22:26:51 hno Exp $
+ * $Id: store_repl_heap.cc,v 1.25 2007/04/30 16:56:19 wessels Exp $
*
* DEBUG: section 81 Store HEAP Removal Policies
* AUTHOR: Henrik Nordstrom
if (heap_walker->min_age > 0) {
heap->theHeap->age = heap_walker->min_age;
- debugs(81, 3, "heap_purgeDone: Heap age set to " << (double) heap->theHeap->age );
+ debugs(81, 3, "heap_purgeDone: Heap age set to " << heap->theHeap->age );
}
/*
/*
- * $Id: snmp_core.cc,v 1.77 2007/04/28 22:26:37 hno Exp $
+ * $Id: snmp_core.cc,v 1.78 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 49 SNMP support
* AUTHOR: Glenn Chisholm
commSetSelect(theInSnmpConnection, COMM_SELECT_READ, snmpHandleUdp, NULL, 0);
- debugs(1, 1, "Accepting SNMP messages on port " << (int) port << ", FD " << theInSnmpConnection << ".");
+ debugs(1, 1, "Accepting SNMP messages on port " << port << ", FD " << theInSnmpConnection << ".");
if (Config.Addrs.snmp_outgoing.s_addr != no_addr.s_addr) {
enter_suid();
snmpHandleUdp,
NULL, 0);
- debugs(1, 1, "Outgoing SNMP messages on port " << (int) port << ", FD " << theOutSnmpConnection << ".");
+ debugs(1, 1, "Outgoing SNMP messages on port " << port << ", FD " << theOutSnmpConnection << ".");
fd_note(theOutSnmpConnection, "Outgoing SNMP socket");
/*
- * $Id: store.cc,v 1.610 2007/04/28 22:26:37 hno Exp $
+ * $Id: store.cc,v 1.611 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 20 Storage Manager
* AUTHOR: Harvest Derived
debugs(20, l, "StoreEntry->key: " << getMD5Text());
debugs(20, l, "StoreEntry->next: " << next);
debugs(20, l, "StoreEntry->mem_obj: " << mem_obj);
- debugs(20, l, "StoreEntry->timestamp: " << (int) timestamp);
- debugs(20, l, "StoreEntry->lastref: " << (int) lastref);
- debugs(20, l, "StoreEntry->expires: " << (int) expires);
- debugs(20, l, "StoreEntry->lastmod: " << (int) lastmod);
- debugs(20, l, "StoreEntry->swap_file_sz: " << (int) swap_file_sz);
+ debugs(20, l, "StoreEntry->timestamp: " << timestamp);
+ debugs(20, l, "StoreEntry->lastref: " << lastref);
+ debugs(20, l, "StoreEntry->expires: " << expires);
+ debugs(20, l, "StoreEntry->lastmod: " << lastmod);
+ debugs(20, l, "StoreEntry->swap_file_sz: " << swap_file_sz);
debugs(20, l, "StoreEntry->refcount: " << refcount);
debugs(20, l, "StoreEntry->flags: " << storeEntryFlags(this));
- debugs(20, l, "StoreEntry->swap_dirn: " << (int) swap_dirn);
- debugs(20, l, "StoreEntry->swap_filen: " << (int) swap_filen);
- debugs(20, l, "StoreEntry->lock_count: " << (int) lock_count);
- debugs(20, l, "StoreEntry->mem_status: " << (int) mem_status);
- debugs(20, l, "StoreEntry->ping_status: " << (int) ping_status);
- debugs(20, l, "StoreEntry->store_status: " << (int) store_status);
- debugs(20, l, "StoreEntry->swap_status: " << (int) swap_status);
+ debugs(20, l, "StoreEntry->swap_dirn: " << swap_dirn);
+ debugs(20, l, "StoreEntry->swap_filen: " << swap_filen);
+ debugs(20, l, "StoreEntry->lock_count: " << lock_count);
+ debugs(20, l, "StoreEntry->mem_status: " << mem_status);
+ debugs(20, l, "StoreEntry->ping_status: " << ping_status);
+ debugs(20, l, "StoreEntry->store_status: " << store_status);
+ debugs(20, l, "StoreEntry->swap_status: " << swap_status);
}
/*
debugs(88, 3, "modifiedSince: '" << url() << "'");
- debugs(88, 3, "modifiedSince: mod_time = " << (long int) mod_time);
+ debugs(88, 3, "modifiedSince: mod_time = " << mod_time);
if (mod_time < 0)
return true;
/*
- * $Id: store_client.cc,v 1.156 2007/04/28 22:26:38 hno Exp $
+ * $Id: store_client.cc,v 1.157 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 90 Storage Manager Client-Side Interface
* AUTHOR: Duane Wessels
assert(sc->flags.disk_io_pending);
sc->flags.disk_io_pending = 0;
assert(sc->_callback.pending());
- debugs(90, 3, "storeClientReadBody: len " << (int) len << "");
+ debugs(90, 3, "storeClientReadBody: len " << len << "");
if (sc->copyInto.offset == 0 && len > 0 && sc->entry->getReply()->sline.status == 0) {
/* Our structure ! */
void
store_client::unpackHeader(char const *buf, ssize_t len)
{
- debugs(90, 3, "store_client::unpackHeader: len " << (int) len << "");
+ debugs(90, 3, "store_client::unpackHeader: len " << len << "");
if (len < 0) {
debugs(90, 3, "store_client::unpackHeader: " << xstrerror() << "");
*/
size_t copy_sz = XMIN(copyInto.length, body_sz)
;
- debugs(90, 3, "storeClientReadHeader: copying " << (int) copy_sz << " bytes of body");
+ debugs(90, 3, "storeClientReadHeader: copying " << copy_sz << " bytes of body");
xmemmove(copyInto.data, copyInto.data + mem->swap_hdr_sz, copy_sz);
if (copyInto.offset == 0 && len > 0 && entry->getReply()->sline.status == 0) {
/*
- * $Id: store_digest.cc,v 1.74 2007/04/28 22:26:38 hno Exp $
+ * $Id: store_digest.cc,v 1.75 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 71 Store Digest Manager
* AUTHOR: Alex Rousskov
/* still here? check staleness */
/* Note: We should use the time of the next rebuild, not (cur_time+period) */
if (refreshCheckDigest(e, Config.digest.rebuild_period)) {
- debugs(71, 6, "storeDigestAdd: entry expires within " << (int) Config.digest.rebuild_period << " secs, ignoring");
+ debugs(71, 6, "storeDigestAdd: entry expires within " << Config.digest.rebuild_period << " secs, ignoring");
return 0;
}
rep->setHeaders(version, HTTP_OK, "Cache Digest OK",
"application/cache-digest", store_digest->mask_size + sizeof(sd_state.cblock),
squid_curtime, squid_curtime + Config.digest.rewrite_period);
- debugs(71, 3, "storeDigestRewrite: entry expires on " << (long int) rep->expires <<
+ debugs(71, 3, "storeDigestRewrite: entry expires on " << rep->expires <<
" (" << std::showpos << (int) (rep->expires - squid_curtime) << ")");
e->buffer();
e->replaceHttpReply(rep);
assert(e == sd_state.rewrite_lock);
e->complete();
e->timestampsSet();
- debugs(71, 2, "storeDigestRewriteFinish: digest expires at " << (long int) e->expires <<
+ debugs(71, 2, "storeDigestRewriteFinish: digest expires at " << e->expires <<
" (" << std::showpos << (int) (e->expires - squid_curtime) << ")");
/* is this the write order? @?@ */
e->mem_obj->unlinkRequest();
return NULL;
}
- debugs(20, 2, "storeCreate: Selected dir '" << dirn << "' for obj size '" << (long int) objsize << "'");
+ debugs(20, 2, "storeCreate: Selected dir '" << dirn << "' for obj size '" << objsize << "'");
SD = dynamic_cast<SwapDir *>(INDEXSD(dirn));
/* Now that we have a fs to use, call its storeCreate function */
/*
- * $Id: store_swapout.cc,v 1.116 2007/04/28 22:26:38 hno Exp $
+ * $Id: store_swapout.cc,v 1.117 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 20 Storage Manager Swapout Functions
* AUTHOR: Duane Wessels
*/
ssize_t swap_buf_len = mem->swapout.memnode->nodeBuffer.length;
- debugs(20, 3, "storeSwapOut: swap_buf_len = " << (int) swap_buf_len);
+ debugs(20, 3, "storeSwapOut: swap_buf_len = " << swap_buf_len);
assert(swap_buf_len > 0);
- debugs(20, 3, "storeSwapOut: swapping out " << (long int) swap_buf_len << " bytes from " << (long int) mem->swapout.queue_offset);
+ debugs(20, 3, "storeSwapOut: swapping out " << swap_buf_len << " bytes from " << mem->swapout.queue_offset);
mem->swapout.queue_offset += swap_buf_len;
if (!swapoutPossible())
return;
- debugs(20, 7, "storeSwapOut: mem_obj->inmem_lo = " << (int) mem_obj->inmem_lo);
- debugs(20, 7, "storeSwapOut: mem_obj->endOffset() = " << (int) mem_obj->endOffset());
- debugs(20, 7, "storeSwapOut: swapout.queue_offset = " << (int) mem_obj->swapout.queue_offset);
+ debugs(20, 7, "storeSwapOut: mem_obj->inmem_lo = " << mem_obj->inmem_lo);
+ debugs(20, 7, "storeSwapOut: mem_obj->endOffset() = " << mem_obj->endOffset());
+ debugs(20, 7, "storeSwapOut: swapout.queue_offset = " << mem_obj->swapout.queue_offset);
if (mem_obj->swapout.sio != NULL)
- debugs(20, 7, "storeSwapOut: storeOffset() = " << (int) mem_obj->swapout.sio->offset() );
+ debugs(20, 7, "storeSwapOut: storeOffset() = " << mem_obj->swapout.sio->offset() );
ssize_t swapout_maxsize = (ssize_t) (mem_obj->endOffset() - mem_obj->swapout.queue_offset);
off_t const lowest_offset = mem_obj->lowestMemReaderOffset();
- debugs(20, 7, "storeSwapOut: lowest_offset = " << (int) lowest_offset);
+ debugs(20, 7, "storeSwapOut: lowest_offset = " << lowest_offset);
/*
* Grab the swapout_size and check to see whether we're going to defer
if (!swapOutAble())
return;
- debugs(20, 7, "storeSwapOut: swapout_size = " << (int) swapout_maxsize);
+ debugs(20, 7, "storeSwapOut: swapout_size = " << swapout_maxsize);
if (swapout_maxsize == 0) {
if (store_status == STORE_OK)
/*
- * $Id: stub_MemObject.cc,v 1.6 2007/04/28 22:26:52 hno Exp $
+ * $Id: stub_MemObject.cc,v 1.7 2007/04/30 16:56:19 wessels Exp $
*
* DEBUG: section 84 Helper process maintenance
* AUTHOR: Robert Collins
MemObject::write(StoreIOBuffer writeBuffer, STMCB *callback, void *callbackData)
{
PROF_start(MemObject_write);
- debugs(19, 6, "memWrite: offset " << (unsigned long)writeBuffer.offset << " len " << (long)writeBuffer.length);
+ debugs(19, 6, "memWrite: offset " << writeBuffer.offset << " len " << writeBuffer.length);
/* the offset is into the content, not the headers */
writeBuffer.offset += (_reply ? _reply->hdr_sz : 0);
/*
- * $Id: tunnel.cc,v 1.167 2007/04/28 22:26:38 hno Exp $
+ * $Id: tunnel.cc,v 1.168 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 26 Secure Sockets Layer Proxy
* AUTHOR: Duane Wessels
if (errcode == COMM_ERR_CLOSING)
return;
- debugs(26, 3, "sslReadServer: FD " << server.fd() << ", read " << (int)len << " bytes");
+ debugs(26, 3, "sslReadServer: FD " << server.fd() << ", read " << len << " bytes");
if (len > 0) {
server.bytesIn(len);
if (errcode == COMM_ERR_CLOSING)
return;
- debugs(26, 3, "sslReadClient: FD " << client.fd() << ", read " << (int) len << " bytes");
+ debugs(26, 3, "sslReadClient: FD " << client.fd() << ", read " << len << " bytes");
if (len > 0) {
client.bytesIn(len);
void
SslStateData::writeServerDone(char *buf, size_t len, comm_err_t flag, int xerrno)
{
- debugs(26, 3, "sslWriteServer: FD " << server.fd() << ", " << (int)len << " bytes written");
+ debugs(26, 3, "sslWriteServer: FD " << server.fd() << ", " << len << " bytes written");
/* Error? */
if (len < 0 || flag != COMM_OK) {
void
SslStateData::writeClientDone(char *buf, size_t len, comm_err_t flag, int xerrno)
{
- debugs(26, 3, "sslWriteClient: FD " << client.fd() << ", " << (int)len << " bytes written");
+ debugs(26, 3, "sslWriteClient: FD " << client.fd() << ", " << len << " bytes written");
/* Error? */
if (len < 0 || flag != COMM_OK) {
/*
- * $Id: unlinkd.cc,v 1.63 2007/04/29 17:35:52 hno Exp $
+ * $Id: unlinkd.cc,v 1.64 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 2 Unlink Daemon
* AUTHOR: Duane Wessels
#ifdef _SQUID_MSWIN_
- debugs(2, 4, "Unlinkd handle: 0x" << std::hex << (unsigned)hIpc << std::dec << ", PID: " << pid);
+ debugs(2, 4, "Unlinkd handle: 0x" << std::hex << hIpc << std::dec << ", PID: " << pid);
#endif
/*
- * $Id: wccp.cc,v 1.42 2007/04/28 22:26:38 hno Exp $
+ * $Id: wccp.cc,v 1.43 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 80 WCCP Support
* AUTHOR: Glenn Chisholm
NULL,
0);
- debugs(1, 1, "Accepting WCCP messages on port " << (int) port << ", FD " << theWccpConnection << ".");
+ debugs(1, 1, "Accepting WCCP messages on port " << port << ", FD " << theWccpConnection << ".");
router_len = sizeof(router);
/*
- * $Id: wccp2.cc,v 1.15 2007/04/28 22:26:38 hno Exp $
+ * $Id: wccp2.cc,v 1.16 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 80 WCCP Support
* AUTHOR: Steven Wilton
NULL,
0);
- debugs(80, 1, "Accepting WCCPv2 messages on port " << (int) port << ", FD " << theWccp2Connection << ".");
+ debugs(80, 1, "Accepting WCCPv2 messages on port " << port << ", FD " << theWccp2Connection << ".");
debugs(80, 1, "Initialising all WCCPv2 lists");
/* Initialise all routers on all services */
eventDelete(wccp2AssignBuckets, NULL);
eventAdd("wccp2AssignBuckets", wccp2AssignBuckets, NULL, 15.0, 1);
} else {
- debugs(80, 5, "Change not detected (" << (int) ntohl(router_view_header->change_number) << " = " << router_list_ptr->member_change << ")");
+ debugs(80, 5, "Change not detected (" << ntohl(router_view_header->change_number) << " = " << router_list_ptr->member_change << ")");
}
} else {
eventDelete(wccp2AssignBuckets, NULL);
wccp2_update_md5_security(service_list_ptr->wccp_password, (char *) service_list_ptr->security_info, service_list_ptr->wccp_packet, service_list_ptr->wccp_packet_size);
}
- debugs(80, 3, "Sending HereIam packet size " << (int) service_list_ptr->wccp_packet_size);
+ debugs(80, 3, "Sending HereIam packet size " << service_list_ptr->wccp_packet_size);
/* Send the packet */
if (wccp2_numrouters > 1) {
/*
- * $Id: whois.cc,v 1.42 2007/04/30 16:38:19 wessels Exp $
+ * $Id: whois.cc,v 1.43 2007/04/30 16:56:09 wessels Exp $
*
* DEBUG: section 75 WHOIS protocol
* AUTHOR: Duane Wessels, Kostas Anagnostakis
}
buf[len] = '\0';
- debugs(75, 3, "whoisReadReply: FD " << fd << " read " << (int)len << " bytes");
+ debugs(75, 3, "whoisReadReply: FD " << fd << " read " << len << " bytes");
debugs(75, 5, "{" << buf << "}");
if (flag == COMM_OK && len > 0) {