delay_id type name.
/*
- * $Id: delay_pools.cc,v 1.27 2002/10/13 23:48:24 hno Exp $
+ * $Id: delay_pools.cc,v 1.28 2002/10/14 07:35:45 hno Exp $
*
* DEBUG: section 77 Delay Pools
* AUTHOR: David Luyer <david@luyer.net>
static delay_id
delayId(unsigned short pool, unsigned short position)
{
- return (pool << 16) | position;
+ return (delay_id)((pool << 16) | position);
}
delay_id
wanted = sc->copyInto.length;
if (wanted > max)
wanted = max;
- i = delayBytesWanted(sc->delay_id, i, wanted);
+ i = delayBytesWanted(sc->delayId, i, wanted);
found = 1;
}
return found ? i : max;
continue;
if (sc->type != STORE_MEM_CLIENT)
continue;
- j = delayBytesWanted(sc->delay_id, 0, sc->copyInto.length);
+ j = delayBytesWanted(sc->delayId, 0, sc->copyInto.length);
if (j > jmax) {
jmax = j;
- d = sc->delay_id;
+ d = sc->delayId;
}
}
return d;
}
void
-delaySetStoreClient(store_client * sc, delay_id delay_id)
+delaySetStoreClient(store_client * sc, delay_id delayId)
{
assert(sc != NULL);
- sc->delay_id = delay_id;
- delayRegisterDelayIdPtr(&sc->delay_id);
+ sc->delayId = delayId;
+ delayRegisterDelayIdPtr(&sc->delayId);
}
static void
/*
- * $Id: ftp.cc,v 1.329 2002/10/13 20:35:01 robertc Exp $
+ * $Id: ftp.cc,v 1.330 2002/10/14 07:35:45 hno Exp $
*
* DEBUG: section 9 File Transfer Protocol (FTP)
* AUTHOR: Harvest Derived
size_t read_sz;
#if DELAY_POOLS
MemObject *mem = entry->mem_obj;
- delay_id delay_id = delayMostBytesAllowed(mem);
+ delay_id delayId = delayMostBytesAllowed(mem);
#endif
assert(fd == ftpState->data.fd);
if (EBIT_TEST(entry->flags, ENTRY_ABORTED)) {
errno = 0;
read_sz = ftpState->data.size - ftpState->data.offset;
#if DELAY_POOLS
- read_sz = delayBytesWanted(delay_id, 1, read_sz);
+ read_sz = delayBytesWanted(delayId, 1, read_sz);
#endif
memset(ftpState->data.buf + ftpState->data.offset, '\0', read_sz);
statCounter.syscalls.sock.reads++;
if (len > 0) {
fd_bytes(fd, len, FD_READ);
#if DELAY_POOLS
- delayBytesIn(delay_id, len);
+ delayBytesIn(delayId, len);
#endif
kb_incr(&statCounter.server.all.kbytes_in, len);
kb_incr(&statCounter.server.ftp.kbytes_in, len);
/*
- * $Id: gopher.cc,v 1.173 2002/10/13 20:35:01 robertc Exp $
+ * $Id: gopher.cc,v 1.174 2002/10/14 07:35:45 hno Exp $
*
* DEBUG: section 10 Gopher
* AUTHOR: Harvest Derived
int bin;
size_t read_sz;
#if DELAY_POOLS
- delay_id delay_id = delayMostBytesAllowed(entry->mem_obj);
+ delay_id delayId = delayMostBytesAllowed(entry->mem_obj);
#endif
if (EBIT_TEST(entry->flags, ENTRY_ABORTED)) {
comm_close(fd);
buf = (char *)memAllocate(MEM_4K_BUF);
read_sz = 4096 - 1; /* leave room for termination */
#if DELAY_POOLS
- read_sz = delayBytesWanted(delay_id, 1, read_sz);
+ read_sz = delayBytesWanted(delayId, 1, read_sz);
#endif
/* leave one space for \0 in gopherToHTML */
statCounter.syscalls.sock.reads++;
if (len > 0) {
fd_bytes(fd, len, FD_READ);
#if DELAY_POOLS
- delayBytesIn(delay_id, len);
+ delayBytesIn(delayId, len);
#endif
kb_incr(&statCounter.server.all.kbytes_in, len);
kb_incr(&statCounter.server.other.kbytes_in, len);
/*
- * $Id: http.cc,v 1.395 2002/10/13 20:35:01 robertc Exp $
+ * $Id: http.cc,v 1.396 2002/10/14 07:35:46 hno Exp $
*
* DEBUG: section 11 Hypertext Transfer Protocol (HTTP)
* AUTHOR: Harvest Derived
int clen;
size_t read_sz;
#if DELAY_POOLS
- delay_id delay_id;
+ delay_id delayId;
/* special "if" only for http (for nodelay proxy conns) */
if (delayIsNoDelay(fd))
- delay_id = 0;
+ delayId = 0;
else
- delay_id = delayMostBytesAllowed(entry->mem_obj);
+ delayId = delayMostBytesAllowed(entry->mem_obj);
#endif
if (EBIT_TEST(entry->flags, ENTRY_ABORTED)) {
comm_close(fd);
errno = 0;
read_sz = SQUID_TCP_SO_RCVBUF;
#if DELAY_POOLS
- read_sz = delayBytesWanted(delay_id, 1, read_sz);
+ read_sz = delayBytesWanted(delayId, 1, read_sz);
#endif
statCounter.syscalls.sock.reads++;
len = FD_READ_METHOD(fd, buf, read_sz);
if (len > 0) {
fd_bytes(fd, len, FD_READ);
#if DELAY_POOLS
- delayBytesIn(delay_id, len);
+ delayBytesIn(delayId, len);
#endif
kb_incr(&statCounter.server.all.kbytes_in, len);
kb_incr(&statCounter.server.http.kbytes_in, len);
/*
- * $Id: ssl.cc,v 1.124 2002/10/13 20:35:03 robertc Exp $
+ * $Id: ssl.cc,v 1.125 2002/10/14 07:35:46 hno Exp $
*
* DEBUG: section 26 Secure Sockets Layer Proxy
* AUTHOR: Duane Wessels
size_t *size_ptr; /* pointer to size in an ConnStateData for logging */
int *status_ptr; /* pointer to status for logging */
#if DELAY_POOLS
- delay_id delay_id;
+ delay_id delayId;
#endif
} SslStateData;
requestUnlink(sslState->request);
sslState->request = NULL;
#if DELAY_POOLS
- delayUnregisterDelayIdPtr(&sslState->delay_id);
+ delayUnregisterDelayIdPtr(&sslState->delayId);
#endif
cbdataFree(sslState);
}
sslDeferServerRead(int fdnotused, void *data)
{
SslStateData *s = (SslStateData *)data;
- int i = delayBytesWanted(s->delay_id, 0, INT_MAX);
+ int i = delayBytesWanted(s->delayId, 0, INT_MAX);
if (i == INT_MAX)
return 0;
if (i == 0)
* no data flowing in the other direction. Hence the argument of
* 1 as min.
*/
- read_sz = delayBytesWanted(sslState->delay_id, 1, read_sz);
+ read_sz = delayBytesWanted(sslState->delayId, 1, read_sz);
#endif
if ((size_t)sslState->server.len < read_sz) {
/* Have room to read more */
fd, (int) read_sz, sslState->server.len);
errno = 0;
#if DELAY_POOLS
- read_sz = delayBytesWanted(sslState->delay_id, 1, read_sz);
+ read_sz = delayBytesWanted(sslState->delayId, 1, read_sz);
#endif
statCounter.syscalls.sock.reads++;
len = FD_READ_METHOD(fd, sslState->server.buf + sslState->server.len, read_sz);
if (len > 0) {
fd_bytes(fd, len, FD_READ);
#if DELAY_POOLS
- delayBytesIn(sslState->delay_id, len);
+ delayBytesIn(sslState->delayId, len);
#endif
kb_incr(&statCounter.server.all.kbytes_in, len);
kb_incr(&statCounter.server.other.kbytes_in, len);
CBDATA_INIT_TYPE(SslStateData);
sslState = cbdataAlloc(SslStateData);
#if DELAY_POOLS
- sslState->delay_id = delayClient(http);
- delayRegisterDelayIdPtr(&sslState->delay_id);
+ sslState->delayId = delayClient(http);
+ delayRegisterDelayIdPtr(&sslState->delayId);
#endif
sslState->url = xstrdup(url);
sslState->request = requestLink(request);
}
#if DELAY_POOLS
/* no point using the delayIsNoDelay stuff since ssl is nice and simple */
- if (g && g->options.no_delay && sslState->delay_id) {
- delayUnregisterDelayIdPtr(&sslState->delay_id);
- sslState->delay_id = 0;
+ if (g && g->options.no_delay && sslState->delayId) {
+ delayUnregisterDelayIdPtr(&sslState->delayId);
+ sslState->delayId = 0;
}
#endif
commConnectStart(sslState->server.fd,
/*
- * $Id: store_client.cc,v 1.115 2002/10/13 20:35:05 robertc Exp $
+ * $Id: store_client.cc,v 1.116 2002/10/14 07:35:46 hno Exp $
*
* DEBUG: section 20 Storage Manager Client-Side Interface
* AUTHOR: Duane Wessels
assert(e->swap_filen > -1 || storeSwapOutAble(e));
dlinkAdd(sc, &sc->node, &mem->clients);
#if DELAY_POOLS
- sc->delay_id = 0;
+ sc->delayId = 0;
#endif
return sc;
}
storeClientCallback(sc, -1);
}
#if DELAY_POOLS
- delayUnregisterDelayIdPtr(&sc->delay_id);
+ delayUnregisterDelayIdPtr(&sc->delayId);
#endif
#if STORE_CLIENT_LIST_DEBUG
cbdataReferenceDone(sc->owner);
/*
- * $Id: tunnel.cc,v 1.124 2002/10/13 20:35:03 robertc Exp $
+ * $Id: tunnel.cc,v 1.125 2002/10/14 07:35:46 hno Exp $
*
* DEBUG: section 26 Secure Sockets Layer Proxy
* AUTHOR: Duane Wessels
size_t *size_ptr; /* pointer to size in an ConnStateData for logging */
int *status_ptr; /* pointer to status for logging */
#if DELAY_POOLS
- delay_id delay_id;
+ delay_id delayId;
#endif
} SslStateData;
requestUnlink(sslState->request);
sslState->request = NULL;
#if DELAY_POOLS
- delayUnregisterDelayIdPtr(&sslState->delay_id);
+ delayUnregisterDelayIdPtr(&sslState->delayId);
#endif
cbdataFree(sslState);
}
sslDeferServerRead(int fdnotused, void *data)
{
SslStateData *s = (SslStateData *)data;
- int i = delayBytesWanted(s->delay_id, 0, INT_MAX);
+ int i = delayBytesWanted(s->delayId, 0, INT_MAX);
if (i == INT_MAX)
return 0;
if (i == 0)
* no data flowing in the other direction. Hence the argument of
* 1 as min.
*/
- read_sz = delayBytesWanted(sslState->delay_id, 1, read_sz);
+ read_sz = delayBytesWanted(sslState->delayId, 1, read_sz);
#endif
if ((size_t)sslState->server.len < read_sz) {
/* Have room to read more */
fd, (int) read_sz, sslState->server.len);
errno = 0;
#if DELAY_POOLS
- read_sz = delayBytesWanted(sslState->delay_id, 1, read_sz);
+ read_sz = delayBytesWanted(sslState->delayId, 1, read_sz);
#endif
statCounter.syscalls.sock.reads++;
len = FD_READ_METHOD(fd, sslState->server.buf + sslState->server.len, read_sz);
if (len > 0) {
fd_bytes(fd, len, FD_READ);
#if DELAY_POOLS
- delayBytesIn(sslState->delay_id, len);
+ delayBytesIn(sslState->delayId, len);
#endif
kb_incr(&statCounter.server.all.kbytes_in, len);
kb_incr(&statCounter.server.other.kbytes_in, len);
CBDATA_INIT_TYPE(SslStateData);
sslState = cbdataAlloc(SslStateData);
#if DELAY_POOLS
- sslState->delay_id = delayClient(http);
- delayRegisterDelayIdPtr(&sslState->delay_id);
+ sslState->delayId = delayClient(http);
+ delayRegisterDelayIdPtr(&sslState->delayId);
#endif
sslState->url = xstrdup(url);
sslState->request = requestLink(request);
}
#if DELAY_POOLS
/* no point using the delayIsNoDelay stuff since ssl is nice and simple */
- if (g && g->options.no_delay && sslState->delay_id) {
- delayUnregisterDelayIdPtr(&sslState->delay_id);
- sslState->delay_id = 0;
+ if (g && g->options.no_delay && sslState->delayId) {
+ delayUnregisterDelayIdPtr(&sslState->delayId);
+ sslState->delayId = 0;
}
#endif
commConnectStart(sslState->server.fd,
/*
- * $Id: wais.cc,v 1.140 2002/10/13 20:35:06 robertc Exp $
+ * $Id: wais.cc,v 1.141 2002/10/14 07:35:46 hno Exp $
*
* DEBUG: section 24 WAIS Relay
* AUTHOR: Harvest Derived
int bin;
size_t read_sz;
#if DELAY_POOLS
- delay_id delay_id = delayMostBytesAllowed(entry->mem_obj);
+ delay_id delayId = delayMostBytesAllowed(entry->mem_obj);
#endif
if (EBIT_TEST(entry->flags, ENTRY_ABORTED)) {
comm_close(fd);
errno = 0;
read_sz = 4096;
#if DELAY_POOLS
- read_sz = delayBytesWanted(delay_id, 1, read_sz);
+ read_sz = delayBytesWanted(delayId, 1, read_sz);
#endif
statCounter.syscalls.sock.reads++;
len = FD_READ_METHOD(fd, buf, read_sz);
if (len > 0) {
fd_bytes(fd, len, FD_READ);
#if DELAY_POOLS
- delayBytesIn(delay_id, len);
+ delayBytesIn(delayId, len);
#endif
kb_incr(&statCounter.server.all.kbytes_in, len);
kb_incr(&statCounter.server.other.kbytes_in, len);