/*
- * $Id: HttpHdrRange.cc,v 1.14 1998/09/24 20:16:24 rousskov Exp $
+ * $Id: HttpHdrRange.cc,v 1.15 1998/09/29 16:33:39 wessels Exp $
*
* DEBUG: section 64 HTTP Range Header
* AUTHOR: Alex Rousskov
spec = NULL;
i++; /* progress */
}
- if (spec) /* last "merge" may not be pushed yet */
+ if (spec) /* last "merge" may not be pushed yet */
stackPush(&range->specs, spec);
debug(64, 3) ("httpHdrRangeCanonize: had %d specs, merged %d specs\n",
goods.count, goods.count - range->specs.count);
/* check that all rangers are in "strong" order, */
/* as far as we can tell without the content length */
while ((spec = httpHdrRangeGetSpec(range, &pos))) {
- if (!known_spec(spec->offset)) /* ignore unknowns */
+ if (!known_spec(spec->offset)) /* ignore unknowns */
continue;
if (spec->offset < offset)
return 1;
offset = spec->offset;
- if (known_spec(spec->length)) /* avoid unknowns */
+ if (known_spec(spec->length)) /* avoid unknowns */
offset += spec->length;
}
return 0;
/*
- * $Id: HttpHeader.cc,v 1.56 1998/09/24 20:20:22 rousskov Exp $
+ * $Id: HttpHeader.cc,v 1.57 1998/09/29 16:33:40 wessels Exp $
*
* DEBUG: section 55 HTTP Header
* AUTHOR: Alex Rousskov
{"Public", HDR_PUBLIC, ftStr},
{"Range", HDR_RANGE, ftPRange},
{"Referer", HDR_REFERER, ftStr},
- {"Request-Range", HDR_REQUEST_RANGE, ftPRange}, /* usually matches HDR_RANGE */
+ {"Request-Range", HDR_REQUEST_RANGE, ftPRange}, /* usually matches HDR_RANGE */
{"Retry-After", HDR_RETRY_AFTER, ftStr}, /* for now (ftDate_1123 or ftInt!) */
{"Server", HDR_SERVER, ftStr},
{"Set-Cookie", HDR_SET_COOKIE, ftStr},
{
HDR_AUTHORIZATION, HDR_FROM, HDR_HOST, HDR_IF_MODIFIED_SINCE,
HDR_IF_RANGE, HDR_MAX_FORWARDS, HDR_PROXY_CONNECTION,
- HDR_PROXY_AUTHORIZATION, HDR_RANGE, HDR_REFERER, HDR_REQUEST_RANGE,
+ HDR_PROXY_AUTHORIZATION, HDR_RANGE, HDR_REFERER, HDR_REQUEST_RANGE,
HDR_USER_AGENT, HDR_X_FORWARDED_FOR
};
+
/*
- * $Id: client.cc,v 1.75 1998/09/19 17:05:58 wessels Exp $
+ * $Id: client.cc,v 1.76 1998/09/29 16:33:41 wessels Exp $
*
* DEBUG: section 0 WWW Client
* AUTHOR: Harvest Derived
/*
- * $Id: client_db.cc,v 1.40 1998/09/23 21:22:50 glenn Exp $
+ * $Id: client_db.cc,v 1.41 1998/09/29 16:33:42 wessels Exp $
*
* DEBUG: section 0 Client Database
* AUTHOR: Duane Wessels
snmp_var_free(Answer);
return (NULL);
}
- switch (Var->name[LEN_SQ_NET+2]) {
+ switch (Var->name[LEN_SQ_NET + 2]) {
case MESH_CTBL_ADDR:
Answer->type = SMI_IPADDRESS;
Answer->val_len = sizeof(snint);
return Answer;
}
-#endif /*SQUID_SNMP*/
+#endif /*SQUID_SNMP */
/*
- * $Id: client_side.cc,v 1.402 1998/09/24 20:41:19 rousskov Exp $
+ * $Id: client_side.cc,v 1.403 1998/09/29 16:33:43 wessels Exp $
*
* DEBUG: section 33 Client-side Routines
* AUTHOR: Duane Wessels
url_sz = strlen(url) + 32 + Config.appendDomainLen;
http->uri = xcalloc(url_sz, 1);
#if IPF_TRANSPARENT
- natLookup.nl_inport = http->conn->me.sin_port;
- natLookup.nl_outport = http->conn->peer.sin_port;
- natLookup.nl_inip = http->conn->me.sin_addr;
- natLookup.nl_outip = http->conn->peer.sin_addr;
- natLookup.nl_flags = IPN_TCP;
- if (natfd < 0)
- natfd = open(IPL_NAT, O_RDONLY,0 );
- if (natfd < 0) {
- debug(50,1)("parseHttpRequest: NAT open failed: %s\n",
- xstrerror());
- return NULL;
+ natLookup.nl_inport = http->conn->me.sin_port;
+ natLookup.nl_outport = http->conn->peer.sin_port;
+ natLookup.nl_inip = http->conn->me.sin_addr;
+ natLookup.nl_outip = http->conn->peer.sin_addr;
+ natLookup.nl_flags = IPN_TCP;
+ if (natfd < 0)
+ natfd = open(IPL_NAT, O_RDONLY, 0);
+ if (natfd < 0) {
+ debug(50, 1) ("parseHttpRequest: NAT open failed: %s\n",
+ xstrerror());
+ return NULL;
}
- if (ioctl(natfd, SIOCGNATL, &natLookup) < 0) {
- debug(50,1)("parseHttpRequest: NAT lookup failed: %s\n",
- xstrerror());
- close(natfd);
- natfd = -1;
- return NULL;
- }
- snprintf(http->uri, url_sz, "http://%s:%d%s",
- inet_ntoa(natLookup.nl_realip),
- (int)Config.Accel.port,
- url);
+ if (ioctl(natfd, SIOCGNATL, &natLookup) < 0) {
+ debug(50, 1) ("parseHttpRequest: NAT lookup failed: %s\n",
+ xstrerror());
+ close(natfd);
+ natfd = -1;
+ return NULL;
+ }
+ snprintf(http->uri, url_sz, "http://%s:%d%s",
+ inet_ntoa(natLookup.nl_realip),
+ (int) Config.Accel.port,
+ url);
#else
snprintf(http->uri, url_sz, "http://%s:%d%s",
inet_ntoa(http->conn->me.sin_addr),
/*
- * $Id: dns.cc,v 1.65 1998/09/23 21:23:33 glenn Exp $
+ * $Id: dns.cc,v 1.66 1998/09/29 16:33:44 wessels Exp $
*
* DEBUG: section 34 Dnsserver interface
* AUTHOR: Harvest Derived
#ifdef SQUID_SNMP
/*
- The function to return the DNS via SNMP
-*/
+ * The function to return the DNS via SNMP
+ */
variable_list *
snmp_netDnsFn(variable_list * Var, snint * ErrP)
variable_list *Answer;
debug(49, 5) ("snmp_netDnsFn: Processing request:\n", Var->name[LEN_SQ_NET +
- 1]);
+ 1]);
snmpDebugOid(5, Var->name, Var->name_length);
Answer = snmp_var_new(Var->name, Var->name_length);
Answer->val.integer = xmalloc(Answer->val_len);
Answer->type = SMI_COUNTER32;
- switch (Var->name[LEN_SQ_NET+1]) {
+ switch (Var->name[LEN_SQ_NET + 1]) {
case DNS_REQ:
- *(Answer->val.integer) = DnsStats.requests;
- break;
+ *(Answer->val.integer) = DnsStats.requests;
+ break;
case DNS_REP:
- *(Answer->val.integer) = DnsStats.replies;
- break;
+ *(Answer->val.integer) = DnsStats.replies;
+ break;
case DNS_SERVERS:
- *(Answer->val.integer) = NDnsServersAlloc;
- break;
+ *(Answer->val.integer) = NDnsServersAlloc;
+ break;
default:
- *ErrP = SNMP_ERR_NOSUCHNAME;
- snmp_var_free(Answer);
- return (NULL);
+ *ErrP = SNMP_ERR_NOSUCHNAME;
+ snmp_var_free(Answer);
+ return (NULL);
}
return Answer;
}
-#endif /*SQUID_SNMP*/
+#endif /*SQUID_SNMP */
/*
- * $Id: enums.h,v 1.132 1998/09/24 20:20:20 rousskov Exp $
+ * $Id: enums.h,v 1.133 1998/09/29 16:33:45 wessels Exp $
*
*
* SQUID Internet Object Cache http://squid.nlanr.net/Squid/
HDR_PROXY_CONNECTION,
HDR_PUBLIC,
HDR_RANGE,
- HDR_REQUEST_RANGE, /* some clients use this, sigh */
+ HDR_REQUEST_RANGE, /* some clients use this, sigh */
HDR_REFERER,
HDR_RETRY_AFTER,
HDR_SERVER,
/*
- * $Id: fqdncache.cc,v 1.119 1998/09/23 21:29:07 glenn Exp $
+ * $Id: fqdncache.cc,v 1.120 1998/09/29 16:33:45 wessels Exp $
*
* DEBUG: section 35 FQDN Cache
* AUTHOR: Harvest Derived
#ifdef SQUID_SNMP
/*
- The function to return the fqdn statistics via SNMP
-*/
+ * The function to return the fqdn statistics via SNMP
+ */
variable_list *
snmp_netFqdnFn(variable_list * Var, snint * ErrP)
variable_list *Answer;
debug(49, 5) ("snmp_netFqdnFn: Processing request:\n", Var->name[LEN_SQ_NET +
- 1]);
+ 1]);
snmpDebugOid(5, Var->name, Var->name_length);
Answer = snmp_var_new(Var->name, Var->name_length);
Answer->val.integer = xmalloc(Answer->val_len);
Answer->type = SMI_COUNTER32;
- switch (Var->name[LEN_SQ_NET+1]) {
+ switch (Var->name[LEN_SQ_NET + 1]) {
case FQDN_ENT:
- *(Answer->val.integer) = memInUse(MEM_FQDNCACHE_ENTRY);
- Answer->type = SMI_GAUGE32;
- break;
+ *(Answer->val.integer) = memInUse(MEM_FQDNCACHE_ENTRY);
+ Answer->type = SMI_GAUGE32;
+ break;
case FQDN_REQ:
- *(Answer->val.integer) = FqdncacheStats.requests;
- break;
+ *(Answer->val.integer) = FqdncacheStats.requests;
+ break;
case FQDN_HITS:
- *(Answer->val.integer) = FqdncacheStats.hits;
- break;
+ *(Answer->val.integer) = FqdncacheStats.hits;
+ break;
case FQDN_PENDHIT:
- *(Answer->val.integer) = FqdncacheStats.pending_hits;
- Answer->type = SMI_GAUGE32;
- break;
+ *(Answer->val.integer) = FqdncacheStats.pending_hits;
+ Answer->type = SMI_GAUGE32;
+ break;
case FQDN_NEGHIT:
- *(Answer->val.integer) = FqdncacheStats.negative_hits;
- break;
+ *(Answer->val.integer) = FqdncacheStats.negative_hits;
+ break;
case FQDN_MISS:
- *(Answer->val.integer) = FqdncacheStats.misses;
- break;
+ *(Answer->val.integer) = FqdncacheStats.misses;
+ break;
case FQDN_GHBN:
- *(Answer->val.integer) = FqdncacheStats.ghba_calls;
- break;
+ *(Answer->val.integer) = FqdncacheStats.ghba_calls;
+ break;
case FQDN_LENG:
- *(Answer->val.integer) = queue_length;
- Answer->type = SMI_GAUGE32;
- break;
+ *(Answer->val.integer) = queue_length;
+ Answer->type = SMI_GAUGE32;
+ break;
default:
- *ErrP = SNMP_ERR_NOSUCHNAME;
- snmp_var_free(Answer);
- return (NULL);
+ *ErrP = SNMP_ERR_NOSUCHNAME;
+ snmp_var_free(Answer);
+ return (NULL);
}
return Answer;
}
-#endif /*SQUID_SNMP*/
+#endif /*SQUID_SNMP */
/*
- * $Id: ipcache.cc,v 1.202 1998/09/23 21:24:37 glenn Exp $
+ * $Id: ipcache.cc,v 1.203 1998/09/29 16:33:47 wessels Exp $
*
* DEBUG: section 14 IP Cache
* AUTHOR: Harvest Derived
#ifdef SQUID_SNMP
/*
- The function to return the ip cache statistics to via SNMP
-*/
+ * The function to return the ip cache statistics to via SNMP
+ */
variable_list *
snmp_netIpFn(variable_list * Var, snint * ErrP)
Answer->val.integer = xmalloc(Answer->val_len);
Answer->type = SMI_COUNTER32;
- switch (Var->name[LEN_SQ_NET+1]) {
+ switch (Var->name[LEN_SQ_NET + 1]) {
case IP_ENT:
*(Answer->val.integer) = memInUse(MEM_IPCACHE_ENTRY);
Answer->type = SMI_GAUGE32;
- break;
+ break;
case IP_REQ:
*(Answer->val.integer) = IpcacheStats.requests;
- break;
+ break;
case IP_HITS:
*(Answer->val.integer) = IpcacheStats.hits;
- break;
+ break;
case IP_PENDHIT:
*(Answer->val.integer) = IpcacheStats.pending_hits;
Answer->type = SMI_GAUGE32;
- break;
+ break;
case IP_NEGHIT:
*(Answer->val.integer) = IpcacheStats.negative_hits;
- break;
+ break;
case IP_MISS:
*(Answer->val.integer) = IpcacheStats.misses;
- break;
+ break;
case IP_GHBN:
*(Answer->val.integer) = IpcacheStats.ghbn_calls;
- break;
+ break;
case IP_LOC:
*(Answer->val.integer) = IpcacheStats.release_locked;
- break;
+ break;
case IP_LENG:
*(Answer->val.integer) = queue_length;
Answer->type = SMI_GAUGE32;
- break;
+ break;
default:
- *ErrP = SNMP_ERR_NOSUCHNAME;
- snmp_var_free(Answer);
- return (NULL);
+ *ErrP = SNMP_ERR_NOSUCHNAME;
+ snmp_var_free(Answer);
+ return (NULL);
}
return Answer;
}
-#endif /*SQUID_SNMP*/
+#endif /*SQUID_SNMP */
/*
- * $Id: peer_digest.cc,v 1.55 1998/09/24 20:29:13 rousskov Exp $
+ * $Id: peer_digest.cc,v 1.56 1998/09/29 16:33:48 wessels Exp $
*
* DEBUG: section 72 Peer Digest Routines
* AUTHOR: Alex Rousskov
#define StoreDigestCBlockSize sizeof(StoreDigestCBlock)
/* min interval for requesting digests from the same peer */
-static const time_t PeerDigestRequestMinGap = 5 * 60; /* seconds */
+static const time_t PeerDigestRequestMinGap = 5 * 60; /* seconds */
/* min interval for requesting digests at start */
-static const time_t GlobalDigestRequestMinGap = 1 * 60; /* seconds */
+static const time_t GlobalDigestRequestMinGap = 1 * 60; /* seconds */
/* local vars */
{
peer *p = data;
assert(p);
- if (!cbdataValid(p)) { /* peer disappeared */
+ if (!cbdataValid(p)) { /* peer disappeared */
cbdataUnlock(p);
return;
}
if (pcb_valid)
debug(72, 6) ("%s: %s offset: %d size: %d.\n",
step_name, fetch->peer->host, fetch->offset, size);
-
+
/* test exiting conditions */
if (!fcb_valid)
reason = "fetch aborted?";
- else
- if (!pcb_valid)
+ else if (!pcb_valid)
reason = "peer disappeared";
else if (size < 0)
reason = "swap failure";
/*
- * $Id: snmp_agent.cc,v 1.57 1998/09/23 23:15:53 glenn Exp $
+ * $Id: snmp_agent.cc,v 1.58 1998/09/29 16:33:49 wessels Exp $
*
* DEBUG: section 49 SNMP Interface
* AUTHOR: Kostas Anagnostakis
*(Answer->val.integer) = store_swap_size;
break;
case SYS_UPTIME:
- Answer->val_len = sizeof(snint);
- Answer->val.integer = xmalloc(Answer->val_len);
- Answer->type = SMI_TIMETICKS;
- *(Answer->val.integer) = tvSubDsec(squid_start, current_time)*100;
- break;
+ Answer->val_len = sizeof(snint);
+ Answer->val.integer = xmalloc(Answer->val_len);
+ Answer->type = SMI_TIMETICKS;
+ *(Answer->val.integer) = tvSubDsec(squid_start, current_time) * 100;
+ break;
default:
*ErrP = SNMP_ERR_NOSUCHNAME;
snmp_var_free(Answer);
break;
case PERF_SYS_CURLRUEXP:
Answer->type = SMI_TIMETICKS;
- *(Answer->val.integer) = (snint) (storeExpiredReferenceAge()*100);
+ *(Answer->val.integer) = (snint) (storeExpiredReferenceAge() * 100);
break;
case PERF_SYS_CURUNLREQ:
*(Answer->val.integer) = (snint) Counter.unlink.requests;
/*
- * $Id: snmp_core.cc,v 1.11 1998/09/23 21:26:06 glenn Exp $
+ * $Id: snmp_core.cc,v 1.12 1998/09/29 16:33:51 wessels Exp $
*
* DEBUG: section 49 SNMP support
* AUTHOR: Kostas Anagnostakis
#endif
return &maddr;
}
-
/*
- * $Id: store_client.cc,v 1.46 1998/09/20 01:14:25 wessels Exp $
+ * $Id: store_client.cc,v 1.47 1998/09/29 16:33:53 wessels Exp $
*
* DEBUG: section 20 Storage Manager Client-Side Interface
* AUTHOR: Duane Wessels
}
static store_client_t
-storeClientType(StoreEntry *e)
+storeClientType(StoreEntry * e)
{
MemObject *mem = e->mem_obj;
if (mem->inmem_lo)
return STORE_DISK_CLIENT;
if (e->store_status == STORE_ABORTED) {
/* I don't think we should be adding clients to aborted entries */
- debug(20,1)("storeClientType: adding to STORE_ABORTED entry\n");
+ debug(20, 1) ("storeClientType: adding to STORE_ABORTED entry\n");
return STORE_MEM_CLIENT;
}
if (e->store_status == STORE_OK) {
/*
- * $Id: store_swapout.cc,v 1.34 1998/09/20 01:14:25 wessels Exp $
+ * $Id: store_swapout.cc,v 1.35 1998/09/29 16:33:54 wessels Exp $
*
* DEBUG: section 20 Storage Manager Swapout Functions
* AUTHOR: Duane Wessels
* If there are DISK clients, we must write to disk
* even if its not cachable
*/
- for (sc = e->mem_obj->clients; sc; sc=sc->next)
+ for (sc = e->mem_obj->clients; sc; sc = sc->next)
if (sc->type == STORE_DISK_CLIENT)
return 1;
return EBIT_TEST(e->flags, ENTRY_CACHABLE);
+
/*
- * $Id: structs.h,v 1.235 1998/09/23 20:13:56 wessels Exp $
+ * $Id: structs.h,v 1.236 1998/09/29 16:33:55 wessels Exp $
*
*
* SQUID Internet Object Cache http://squid.nlanr.net/Squid/