Polished StoreEntry creation/destruction debugging.
CollapsedForwarding::HandleNotification(const Ipc::TypedMsgHdr &msg)
{
const int from = msg.getInt();
- debugs(17, 7, HERE << "from " << from);
+ debugs(17, 7, "from " << from);
assert(queue.get());
queue->clearReaderSignal(from);
HandleNewData("after notification");
// objects of unknown size are not allowed into memory cache, for now
if (expectedSize < 0) {
- debugs(20, 5, HERE << "Unknown expected size: " << e);
+ debugs(20, 5, "Unknown expected size: " << e);
return false;
}
}
if (EBIT_TEST(e.flags, ENTRY_SPECIAL)) {
- debugs(20, 5, HERE << "Not mem-caching ENTRY_SPECIAL " << e);
+ debugs(20, 5, "Not mem-caching ENTRY_SPECIAL " << e);
return false;
}
if (http->redirect.status) {
/** \li If redirection status is True force this to be a MISS */
- debugs(85, 3, HERE << "REDIRECT status forced StoreEntry to NULL (no body on 3XX responses) " << *e);
+ debugs(85, 3, "REDIRECT status forced StoreEntry to NULL (no body on 3XX responses) " << *e);
forgetHit();
http->logType = LOG_TCP_REDIRECT;
doGetMoreData();
void
Rock::Rebuild::loadingSteps()
{
- debugs(47,5, HERE << sd->index << " slot " << loadingPos << " at " <<
+ debugs(47,5, sd->index << " slot " << loadingPos << " at " <<
dbOffset << " <= " << dbSize);
// Balance our desire to maximize the number of entries processed at once
void
Rock::Rebuild::loadOneSlot()
{
- debugs(47,5, HERE << sd->index << " slot " << loadingPos << " at " <<
+ debugs(47,5, sd->index << " slot " << loadingPos << " at " <<
dbOffset << " <= " << dbSize);
++counts.scancount;
void
Rock::Rebuild::failure(const char *msg, int errNo)
{
- debugs(47,5, HERE << sd->index << " slot " << loadingPos << " at " <<
+ debugs(47,5, sd->index << " slot " << loadingPos << " at " <<
dbOffset << " <= " << dbSize);
if (errNo)
Ipc::BaseMultiQueue::clearReaderSignal(const int remoteProcessId)
{
QueueReader &reader = localReader();
- debugs(54, 7, HERE << "reader: " << reader.id);
+ debugs(54, 7, "reader: " << reader.id);
reader.clearSignal();
Must(queues->theCapacity == metadata->theGroupASize * metadata->theGroupBSize * 2);
Must(readers->theCapacity == metadata->theGroupASize + metadata->theGroupBSize);
- debugs(54, 7, HERE << "queue " << id << " reader: " << localReader().id);
+ debugs(54, 7, "queue " << id << " reader: " << localReader().id);
}
int
Must(queues->theCapacity == metadata->theProcessCount * metadata->theProcessCount);
Must(readers->theCapacity == metadata->theProcessCount);
- debugs(54, 7, HERE << "queue " << id << " reader: " << localReader().id);
+ debugs(54, 7, "queue " << id << " reader: " << localReader().id);
}
bool
if (s.waitingToBeFreed) {
s.lock.unlockShared();
- debugs(54, 7, HERE << "cannot open marked entry " << fileno <<
+ debugs(54, 7, "cannot open marked entry " << fileno <<
" for reading " << path);
return NULL;
}
swap_status(SWAPOUT_NONE),
lock_count(0)
{
- debugs(20, 3, HERE << "new StoreEntry " << this);
+ debugs(20, 5, "StoreEntry constructed, this=" << this);
}
StoreEntry::~StoreEntry()
{
+ debugs(20, 5, "StoreEntry destructed, this=" << this);
}
#if USE_ADAPTATION
// TODO: consume parsed metadata?
- debugs(47,7, HERE << "successful swap meta unpacking; swap_file_sz=" << tmpe.swap_file_sz);
+ debugs(47,7, "successful swap meta unpacking; swap_file_sz=" << tmpe.swap_file_sz);
memset(key, '\0', SQUID_MD5_DIGEST_LENGTH);
InitStoreEntry visitor(&tmpe, key);
// if we swapped out already, do not start over
if (swap_status == SWAPOUT_DONE) {
- debugs(20, 3, HERE << "already did");
+ debugs(20, 3, "already did");
decision = MemObject::SwapOut::swImpossible;
return false;
}