squid-3.0.PRE3-PURIFY.patch

   1 Index: squid3/src/DelayId.cc
   2 diff -c squid3/src/DelayId.cc:1.13 squid3/src/DelayId.cc:1.14
   3 *** squid3/src/DelayId.cc:1.13  Sun Aug 10 05:00:40 2003
   4 --- squid3/src/DelayId.cc       Sat Sep  6 06:47:34 2003
   5 ***************
   6 *** 171,179 ****
   7       if (markedAsNoDelay)
   8           return;
   9
  10 !     unsigned short tempPool = pool() - 1;
  11 !
  12 !     assert (tempPool != 0xFFFF);
  13
  14       if (compositeId.getRaw())
  15           compositeId->bytesIn(qty);
  16 --- 171,177 ----
  17       if (markedAsNoDelay)
  18           return;
  19
  20 !     assert ((unsigned short)(pool() - 1) != 0xFFFF);
  21
  22       if (compositeId.getRaw())
  23           compositeId->bytesIn(qty);
  24 Index: squid3/src/client_side.cc
  25 diff -c squid3/src/client_side.cc:1.658 squid3/src/client_side.cc:1.659
  26 *** squid3/src/client_side.cc:1.658     Sun Aug 31 21:49:38 2003
  27 --- squid3/src/client_side.cc   Sat Sep  6 06:47:34 2003
  28 ***************
  29 *** 142,148 ****
  30 --- 142,150 ----
  31   static void clientUpdateHierCounters(HierarchyLogEntry *);
  32   static bool clientPingHasFinished(ping_data const *aPing);
  33   static void clientPrepareLogWithRequestDetails(HttpRequest *, AccessLogEntry *);
  34 + #ifndef PURIFY
  35   static int connIsUsable(ConnStateData::Pointer conn);
  36 + #endif
  37   static int responseFinishedOrFailed(HttpReply * rep, StoreIOBuffer const &recievedData);
  38   static void ClientSocketContextPushDeferredIfNeeded(ClientSocketContext::Pointer deferredRequest, ConnStateData::Pointer & conn);
  39   static void clientUpdateSocketStats(log_type logType, size_t size);
  40 ***************
  41 *** 692,697 ****
  42 --- 694,700 ----
  43       return 0;
  44   }
  45
  46 + #ifndef PURIFY
  47   int
  48   connIsUsable(ConnStateData::Pointer conn)
  49   {
  50 ***************
  51 *** 701,706 ****
  52 --- 704,711 ----
  53       return 1;
  54   }
  55
  56 + #endif
  57 +
  58   ClientSocketContext::Pointer
  59   ConnStateData::getCurrentContext() const
  60   {
  61 ***************
  62 *** 1243,1251 ****
  63       assert(cbdataReferenceValid(node));
  64       /* Set null by ContextFree */
  65       assert(node->node.next == NULL);
  66 -     ClientSocketContext *context = dynamic_cast<ClientSocketContext *>(node->data.getRaw());
  67       /* this is the assert discussed above */
  68 !     assert(context == NULL);
  69       /* We are only called when the client socket shutsdown.
  70        * Tell the prev pipeline member we're finished
  71        */
  72 --- 1248,1255 ----
  73       assert(cbdataReferenceValid(node));
  74       /* Set null by ContextFree */
  75       assert(node->node.next == NULL);
  76       /* this is the assert discussed above */
  77 !     assert(NULL == dynamic_cast<ClientSocketContext *>(node->data.getRaw()));
  78       /* We are only called when the client socket shutsdown.
  79        * Tell the prev pipeline member we're finished
  80        */
  81 Index: squid3/src/client_side_request.cc
  82 diff -c squid3/src/client_side_request.cc:1.33 squid3/src/client_side_request.cc:1.34
  83 *** squid3/src/client_side_request.cc:1.33      Sun Aug 31 21:49:38 2003
  84 --- squid3/src/client_side_request.cc   Sat Sep  6 06:47:34 2003
  85 ***************
  86 *** 800,806 ****
  87   ClientRequestContext::CheckNoCacheDone(int answer, void *data)
  88   {
  89       void *temp;
  90 !     bool valid = cbdataReferenceValidDone(data, &temp);
  91       /* acl NB calls cannot invalidate cbdata in the normal course of things */
  92       assert (valid);
  93       ClientRequestContext *context = (ClientRequestContext *)temp;
  94 --- 800,810 ----
  95   ClientRequestContext::CheckNoCacheDone(int answer, void *data)
  96   {
  97       void *temp;
  98 ! #ifndef PURIFY
  99 !
 100 !     bool valid =
 101 ! #endif
 102 !         cbdataReferenceValidDone(data, &temp);
 103       /* acl NB calls cannot invalidate cbdata in the normal course of things */
 104       assert (valid);
 105       ClientRequestContext *context = (ClientRequestContext *)temp;
 106 Index: squid3/src/comm.cc
 107 diff -c squid3/src/comm.cc:1.388 squid3/src/comm.cc:1.389
 108 *** squid3/src/comm.cc:1.388    Sat Aug 30 19:22:05 2003
 109 --- squid3/src/comm.cc  Sat Sep  6 06:47:34 2003
 110 ***************
 111 *** 713,721 ****
 112
 113       fill->amountDone += len;
 114
 115 !     StoreIOBuffer *sb = &fdc_table[fd].fill.requestedData;
 116 !
 117 !     assert(fill->amountDone <= sb->length);
 118
 119       comm_add_fill_callback(fd, fill->amountDone, COMM_OK, 0);
 120   }
 121 --- 713,719 ----
 122
 123       fill->amountDone += len;
 124
 125 !     assert(fill->amountDone <= fdc_table[fd].fill.requestedData.length);
 126
 127       comm_add_fill_callback(fd, fill->amountDone, COMM_OK, 0);
 128   }
 129 Index: squid3/src/errorpage.cc
 130 diff -c squid3/src/errorpage.cc:1.191 squid3/src/errorpage.cc:1.192
 131 *** squid3/src/errorpage.cc:1.191       Sun Aug 31 21:49:38 2003
 132 --- squid3/src/errorpage.cc     Sat Sep  6 06:47:35 2003
 133 ***************
 134 *** 344,351 ****
 135   errorAppendEntry(StoreEntry * entry, ErrorState * err)
 136   {
 137       HttpReply *rep;
 138 !     MemObject *mem = entry->mem_obj;
 139 !     assert(mem != NULL);
 140       assert (entry->isEmpty());
 141
 142       if (entry->store_status != STORE_PENDING) {
 143 --- 344,350 ----
 144   errorAppendEntry(StoreEntry * entry, ErrorState * err)
 145   {
 146       HttpReply *rep;
 147 !     assert(entry->mem_obj != NULL);
 148       assert (entry->isEmpty());
 149
 150       if (entry->store_status != STORE_PENDING) {
 151 Index: squid3/src/peer_digest.cc
 152 diff -c squid3/src/peer_digest.cc:1.99 squid3/src/peer_digest.cc:1.100
 153 *** squid3/src/peer_digest.cc:1.99      Sun Aug 10 05:00:44 2003
 154 --- squid3/src/peer_digest.cc   Sat Sep  6 06:47:35 2003
 155 ***************
 156 *** 400,411 ****
 157   peerDigestHandleReply(void *data, StoreIOBuffer recievedData)
 158   {
 159       DigestFetchState *fetch = (DigestFetchState *)data;
 160 -     PeerDigest *pd = fetch->pd;
 161       int retsize = -1;
 162       digest_read_state_t prevstate;
 163       int newsize;
 164
 165 !     assert(pd && recievedData.data);
 166       /* The existing code assumes that the recieved pointer is
 167        * where we asked the data to be put
 168        */
 169 --- 400,410 ----
 170   peerDigestHandleReply(void *data, StoreIOBuffer recievedData)
 171   {
 172       DigestFetchState *fetch = (DigestFetchState *)data;
 173       int retsize = -1;
 174       digest_read_state_t prevstate;
 175       int newsize;
 176
 177 !     assert(fetch->pd && recievedData.data);
 178       /* The existing code assumes that the recieved pointer is
 179        * where we asked the data to be put
 180        */
 181 ***************
 182 *** 649,657 ****
 183
 184       if (size >= (ssize_t)StoreDigestCBlockSize) {
 185           PeerDigest *pd = fetch->pd;
 186 -         HttpReply const *rep = fetch->entry->getReply();
 187
 188 !         assert(pd && rep);
 189
 190           if (peerDigestSetCBlock(pd, buf)) {
 191               /* XXX: soon we will have variable header size */
 192 --- 648,655 ----
 193
 194       if (size >= (ssize_t)StoreDigestCBlockSize) {
 195           PeerDigest *pd = fetch->pd;
 196
 197 !         assert(pd && fetch->entry->getReply());
 198
 199           if (peerDigestSetCBlock(pd, buf)) {
 200               /* XXX: soon we will have variable header size */
 201 Index: squid3/src/stmem.cc
 202 diff -c squid3/src/stmem.cc:1.80 squid3/src/stmem.cc:1.81
 203 *** squid3/src/stmem.cc:1.80    Mon Aug  4 16:14:42 2003
 204 --- squid3/src/stmem.cc Sat Sep  6 06:47:35 2003
 205 ***************
 206 *** 112,119 ****
 207       assert (aNode->canAccept (location));
 208
 209       /* these two can go I think */
 210 !     size_t copyOffset = location - aNode->nodeBuffer.offset;
 211 !     assert (copyOffset == aNode->nodeBuffer.length);
 212       size_t copyLen = XMIN (amount, aNode->space());
 213
 214       xmemcpy(aNode->nodeBuffer.data + aNode->nodeBuffer.length, source, copyLen);
 215 --- 112,118 ----
 216       assert (aNode->canAccept (location));
 217
 218       /* these two can go I think */
 219 !     assert (location - aNode->nodeBuffer.offset == aNode->nodeBuffer.length);
 220       size_t copyLen = XMIN (amount, aNode->space());
 221
 222       xmemcpy(aNode->nodeBuffer.data + aNode->nodeBuffer.length, source, copyLen);
 223 Index: squid3/src/fs/diskd/store_io_diskd.cc
 224 diff -c squid3/src/fs/diskd/store_io_diskd.cc:1.38 squid3/src/fs/diskd/store_io_diskd.cc:1.39
 225 *** squid3/src/fs/diskd/store_io_diskd.cc:1.38  Sat Aug 23 06:33:04 2003
 226 --- squid3/src/fs/diskd/store_io_diskd.cc       Sat Sep  6 06:47:36 2003
 227 ***************
 228 *** 334,341 ****
 229   {
 230       assert (ioRequestor.getRaw() != NULL);
 231       off_t shm_offset;
 232 !     char *rbuf = (char *)IO->shm.get(&shm_offset);
 233 !     assert(rbuf);
 234       ioAway();
 235       int x = storeDiskdSend(_MQD_READ,
 236                              IO,
 237 --- 334,340 ----
 238   {
 239       assert (ioRequestor.getRaw() != NULL);
 240       off_t shm_offset;
 241 !     IO->shm.get(&shm_offset);
 242       ioAway();
 243       int x = storeDiskdSend(_MQD_READ,
 244                              IO,
 245 ***************
 246 *** 691,697 ****
 247       } else {
 248           debug(79, 1) ("storeDiskdSend: msgsnd: %s\n", xstrerror());
 249           cbdataReferenceDone(M.callback_data);
 250 !         assert(++send_errors < 100);
 251           IO->shm.put (shm_offset);
 252       }
 253
 254 --- 690,699 ----
 255       } else {
 256           debug(79, 1) ("storeDiskdSend: msgsnd: %s\n", xstrerror());
 257           cbdataReferenceDone(M.callback_data);
 258 !
 259 !         if (++send_errors > 100)
 260 !             fatal ("over 100 errors sending to the daemon - aborting\n");
 261 !
 262           IO->shm.put (shm_offset);
 263       }
 264
 265 ***************
 266 *** 751,757 ****
 267       } else {
 268           debug(79, 1) ("storeDiskdSend: msgsnd: %s\n", xstrerror());
 269           cbdataReferenceDone(M.callback_data);
 270 !         assert(++send_errors < 100);
 271       }
 272
 273       /*
 274 --- 753,761 ----
 275       } else {
 276           debug(79, 1) ("storeDiskdSend: msgsnd: %s\n", xstrerror());
 277           cbdataReferenceDone(M.callback_data);
 278 !
 279 !         if (++send_errors > 100)
 280 !             fatal ("over 100 errors sending to the daemon - aborting\n");
 281       }
 282
 283       /*
 284 Index: squid3/src/repl/heap/store_repl_heap.cc
 285 diff -c squid3/src/repl/heap/store_repl_heap.cc:1.13 squid3/src/repl/heap/store_repl_heap.cc:1.14
 286 *** squid3/src/repl/heap/store_repl_heap.cc:1.13        Fri Feb 21 15:50:50 2003
 287 --- squid3/src/repl/heap/store_repl_heap.cc     Sat Sep  6 06:47:36 2003
 288 ***************
 289 *** 298,304 ****
 290       assert(heap->nwalkers);
 291       assert(heap->count);
 292       /* Ok, time to destroy this policy */
 293 !     safe_free(policy->_data);
 294       memset(policy, 0, sizeof(*policy));
 295       cbdataFree(policy);
 296   }
 297 --- 298,304 ----
 298       assert(heap->nwalkers);
 299       assert(heap->count);
 300       /* Ok, time to destroy this policy */
 301 !     safe_free(heap);
 302       memset(policy, 0, sizeof(*policy));
 303       cbdataFree(policy);
 304   }
 305 Index: squid3/src/repl/lru/store_repl_lru.cc
 306 diff -c squid3/src/repl/lru/store_repl_lru.cc:1.14 squid3/src/repl/lru/store_repl_lru.cc:1.15
 307 *** squid3/src/repl/lru/store_repl_lru.cc:1.14  Fri Feb 21 15:50:50 2003
 308 --- squid3/src/repl/lru/store_repl_lru.cc       Sat Sep  6 06:47:39 2003
 309 ***************
 310 *** 317,323 ****
 311       assert(lru->nwalkers);
 312       assert(lru->count);
 313       /* Ok, time to destroy this policy */
 314 !     safe_free(policy->_data);
 315       memset(policy, 0, sizeof(*policy));
 316       cbdataFree(policy);
 317   }
 318 --- 317,323 ----
 319       assert(lru->nwalkers);
 320       assert(lru->count);
 321       /* Ok, time to destroy this policy */
 322 !     safe_free(lru);
 323       memset(policy, 0, sizeof(*policy));
 324       cbdataFree(policy);
 325   }