/*
- * $Id: peer_digest.cc,v 1.60 1998/11/19 22:28:51 rousskov Exp $
+ * $Id: peer_digest.cc,v 1.61 1998/11/25 09:00:23 wessels Exp $
*
* DEBUG: section 72 Peer Digest Routines
* AUTHOR: Alex Rousskov
/* local vars */
-static time_t pd_last_req_time = 0; /* last call to Check */
+static time_t pd_last_req_time = 0; /* last call to Check */
/* initialize peer digest */
static void
-peerDigestInit(PeerDigest *pd, peer *p)
+peerDigestInit(PeerDigest * pd, peer * p)
{
assert(pd && p);
}
static void
-peerDigestClean(PeerDigest *pd)
+peerDigestClean(PeerDigest * pd)
{
assert(pd);
if (pd->cd)
/* allocate new peer digest, call Init, and lock everything */
PeerDigest *
-peerDigestCreate(peer *p)
+peerDigestCreate(peer * p)
{
PeerDigest *pd;
- assert(p);
+ assert(p);
/* cannot check cbdataValid(p) because p may not be locked yet */
pd = memAllocate(MEM_PEER_DIGEST);
cbdataAdd(pd, MEM_PEER_DIGEST);
peerDigestInit(pd, p);
- cbdataLock(pd->peer); /* we will use the peer */
+ cbdataLock(pd->peer); /* we will use the peer */
return pd;
}
/* call Clean and free/unlock everything */
void
-peerDigestDestroy(PeerDigest *pd)
+peerDigestDestroy(PeerDigest * pd)
{
assert(pd);
assert(cbdataValid(pd));
/* inform peer (if any) that we are gone */
if (cbdataValid(pd->peer))
peerNoteDigestGone(pd->peer);
- cbdataUnlock(pd->peer); /* must unlock, valid or not */
+ cbdataUnlock(pd->peer); /* must unlock, valid or not */
pd->peer = NULL;
peerDigestClean(pd);
/* called by peer to indicate that somebody actually needs this digest */
void
-peerDigestNeeded(PeerDigest *pd)
+peerDigestNeeded(PeerDigest * pd)
{
assert(pd);
assert(!pd->flags.needed);
pd->flags.needed = 1;
pd->times.needed = squid_curtime;
- peerDigestSetCheck(pd, 0); /* check asap */
+ peerDigestSetCheck(pd, 0); /* check asap */
}
/* currently we do not have a reason to disable without destroying */
-#if FUTURE_CODE
+#if FUTURE_CODE
/* disables peer for good */
static void
-peerDigestDisable(PeerDigest *pd)
+peerDigestDisable(PeerDigest * pd)
{
- debug(72, 2) ("peerDigestDisable: peer %s disabled for good\n",
+ debug(72, 2) ("peerDigestDisable: peer %s disabled for good\n",
strBuf(pd->host));
pd->times.disabled = squid_curtime;
- pd->times.next_check = -1; /* never */
+ pd->times.next_check = -1; /* never */
pd->flags.usable = 0;
if (pd->cd) {
/* increment retry delay [after an unsuccessful attempt] */
static time_t
-peerDigestIncDelay(const PeerDigest *pd)
+peerDigestIncDelay(const PeerDigest * pd)
{
assert(pd);
return pd->times.retry_delay > 0 ?
- 2*pd->times.retry_delay : /* exponential backoff */
- PeerDigestReqMinGap; /* minimal delay */
+ 2 * pd->times.retry_delay : /* exponential backoff */
+ PeerDigestReqMinGap; /* minimal delay */
}
/* artificially increases Expires: setting to avoid race conditions
/* called only when cbdataValid(pd) and
* peer is about to disappear or have already disappeared */
void
-peerDigestNotePeerGone(PeerDigest *pd) {
+peerDigestNotePeerGone(PeerDigest * pd)
+{
assert(cbdataValid(pd));
if (pd->flags.requested) {
debug(72, 2) ("peerDigest: peer %s is gone, will destroy after fetch.\n", strBuf(pd->host));
cbdataUnlock(pd);
return;
}
- cbdataUnlock(pd); /* non-blocking event is over */
+ cbdataUnlock(pd); /* non-blocking event is over */
assert(!pd->flags.requested);
- pd->times.next_check = 0; /* unknown */
+ pd->times.next_check = 0; /* unknown */
if (!cbdataValid(pd->peer)) {
peerDigestNotePeerGone(pd);
return;
}
-
debug(72, 3) ("peerDigestCheck: peer %s:%d\n", pd->peer->host, pd->peer->http_port);
debug(72, 3) ("peerDigestCheck: time: %d, last received: %d (%+d)\n",
- squid_curtime, pd->times.received, (squid_curtime-pd->times.received));
+ squid_curtime, pd->times.received, (squid_curtime - pd->times.received));
/* decide when we should send the request:
* request now unless too close to other requests */
/* per-peer limit */
if (req_time - pd->times.received < PeerDigestReqMinGap) {
debug(72, 2) ("peerDigestCheck: %s, avoiding close peer requests (%d < %d secs).\n",
- strBuf(pd->host), req_time - pd->times.received,
+ strBuf(pd->host), req_time - pd->times.received,
PeerDigestReqMinGap);
req_time = pd->times.received + PeerDigestReqMinGap;
}
GlobDigestReqMinGap);
req_time = pd_last_req_time + GlobDigestReqMinGap;
}
-
if (req_time <= squid_curtime)
- peerDigestRequest(pd); /* will set pd->flags.requested */
+ peerDigestRequest(pd); /* will set pd->flags.requested */
else
peerDigestSetCheck(pd, req_time - squid_curtime);
}
status = reply->sline.status;
debug(72, 3) ("peerDigestFetchReply: %s status: %d, expires: %d (%+d)\n",
strBuf(pd->host), status,
- reply->expires, reply->expires-squid_curtime);
+ reply->expires, reply->expires - squid_curtime);
/* this "if" is based on clientHandleIMSReply() */
if (status == HTTP_NOT_MODIFIED) {
peerDigestFetchedEnough(DigestFetchState * fetch, char *buf, ssize_t size, const char *step_name)
{
PeerDigest *pd = NULL;
- const char *host = "<unknown>"; /* peer host */
- const char *reason = NULL; /* reason for completion */
- const char *no_bug = NULL; /* successful completion if set */
+ const char *host = "<unknown>"; /* peer host */
+ const char *reason = NULL; /* reason for completion */
+ const char *no_bug = NULL; /* successful completion if set */
const int fcb_valid = cbdataValid(fetch);
const int pdcb_valid = fcb_valid && cbdataValid(fetch->pd);
const int pcb_valid = pdcb_valid && cbdataValid(fetch->pd->peer);
if (!reason) {
if (!fcb_valid)
- reason = "fetch aborted?!";
+ reason = "fetch aborted?!";
else if (!(pd = fetch->pd))
reason = "peer digest disappeared?!";
else if (!cbdataValid(pd))
else
host = strBuf(pd->host);
}
-
debug(72, 6) ("%s: peer %s, offset: %d size: %d.\n",
step_name, host, fcb_valid ? fetch->offset : -1, size);
else if (fetch->entry->store_status == STORE_ABORTED)
reason = "swap aborted";
}
-
/* continue checking (maybe-successful eof case) */
if (!reason && !size) {
if (!pd->cd)
else
reason = no_bug = "success";
}
-
/* finish if we have a reason */
if (reason) {
const int level = strstr(reason, "?!") ? 1 : 3;
/* complete the digest transfer, update stats, unlock/release everything */
static void
peerDigestReqFinish(DigestFetchState * fetch, char *buf,
- int fcb_valid, int pdcb_valid, int pcb_valid,
+ int fcb_valid, int pdcb_valid, int pcb_valid,
const char *reason, int err)
{
assert(reason);
fetch->pd->flags.requested = 0;
fetch->pd->req_result = reason;
}
-
/* schedule next check if peer is still out there */
if (pcb_valid) {
PeerDigest *pd = fetch->pd;
peerDigestSetCheck(pd, peerDigestNewDelay(fetch->entry));
}
}
-
/* note: order is significant */
if (fcb_valid)
peerDigestFetchSetStats(fetch);
pd->times.received = squid_curtime;
pd->times.req_delay = fetch->resp_time;
- kb_incr(&pd->stats.sent.kbytes, (size_t)fetch->sent.bytes);
- kb_incr(&pd->stats.recv.kbytes, (size_t)fetch->recv.bytes);
+ kb_incr(&pd->stats.sent.kbytes, (size_t) fetch->sent.bytes);
+ kb_incr(&pd->stats.recv.kbytes, (size_t) fetch->recv.bytes);
pd->stats.sent.msgs += fetch->sent.msg;
pd->stats.recv.msgs += fetch->recv.msg;
cacheDigestDestroy(pd->cd);
pd->cd = NULL;
}
-
pd->flags.usable = 0;
if (!pcb_valid)
storeUnlockObject(fetch->old_entry);
fetch->old_entry = NULL;
}
-
/* update global stats */
kb_incr(&Counter.cd.kbytes_sent, (size_t) fetch->sent.bytes);
kb_incr(&Counter.cd.kbytes_recv, (size_t) fetch->recv.bytes);
debug(72, 3) ("peerDigestFetchFinish: recv %d bytes in %d secs\n",
fetch->recv.bytes, fetch->resp_time);
debug(72, 3) ("peerDigestFetchFinish: expires: %d (%+d), lmt: %d (%+d)\n",
- fetch->expires, fetch->expires-squid_curtime,
- fetch->entry->lastmod, fetch->entry->lastmod-squid_curtime);
+ fetch->expires, fetch->expires - squid_curtime,
+ fetch->entry->lastmod, fetch->entry->lastmod - squid_curtime);
}
static int
-peerDigestSetCBlock(PeerDigest *pd, const char *buf)
+peerDigestSetCBlock(PeerDigest * pd, const char *buf)
{
StoreDigestCBlock cblock;
int freed_size = 0;
/* check size changes */
if (pd->cd && cblock.mask_size != pd->cd->mask_size) {
debug(72, 2) ("%s digest changed size: %d -> %d\n",
- host, cblock.mask_size, pd->cd->mask_size);
+ host, cblock.mask_size, pd->cd->mask_size);
freed_size = pd->cd->mask_size;
cacheDigestDestroy(pd->cd);
pd->cd = NULL;
}
static int
-peerDigestUseful(const PeerDigest *pd)
+peerDigestUseful(const PeerDigest * pd)
{
/* TODO: we should calculate the prob of a false hit instead of bit util */
const int bit_util = cacheDigestBitUtil(pd->cd);
static int
saneDiff(time_t diff)
{
- return abs(diff) > squid_curtime/2 ? 0 : diff;
+ return abs(diff) > squid_curtime / 2 ? 0 : diff;
}
void
-peerDigestStatsReport(const PeerDigest *pd, StoreEntry * e)
+peerDigestStatsReport(const PeerDigest * pd, StoreEntry * e)
{
#define f2s(flag) (pd->flags.flag ? "yes" : "no")
#define appendTime(tm) storeAppendPrintf(e, "%s\t %10d\t %+d\t %+d\n", \
/*
- * $Id: snmp_core.cc,v 1.18 1998/11/18 00:16:39 glenn Exp $
+ * $Id: snmp_core.cc,v 1.19 1998/11/25 09:00:25 wessels Exp $
*
* DEBUG: section 49 SNMP support
* AUTHOR: Glenn Chisholm
#ifdef __STDC__
static mib_tree_entry *snmpAddNode(oid * name, int len, oid_ParseFn * parsefunction, int children,...);
static oid *snmpCreateOid(int length,...);
-#else
+#else
static mib_tree_entry *snmpAddNode();
static oid *snmpCreateOid();
-#endif
+#endif
extern void (*snmplib_debug_hook) (int, char *);
-static void snmpDecodePacket(snmp_request_t * rq);
+static void snmpDecodePacket(snmp_request_t * rq);
static void snmpConstructReponse(snmp_request_t * rq, struct snmp_session *Session);
static struct snmp_pdu *snmpAgentResponse(struct snmp_pdu *PDU);
static void snmpUdpSend(int, const struct sockaddr_in *, void *, int);
LEN_SQ_PRF + 3, snmp_prfProtoFn, 0),
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 13),
LEN_SQ_PRF + 3, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 14),
- LEN_SQ_PRF + 3, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 14),
+ LEN_SQ_PRF + 3, snmp_prfProtoFn, 0),
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 3, SQ_PRF, 2, 1, 15),
LEN_SQ_PRF + 3, snmp_prfProtoFn, 0)),
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 2, SQ_PRF, 2, 2),
LEN_SQ_PRF + 4, NULL, 3,
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 1, 1),
LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 1, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 1, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 1, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 1, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 2),
LEN_SQ_PRF + 4, NULL, 3,
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 2, 1),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 2, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 2, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 2, 1),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 2, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 2, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 3),
LEN_SQ_PRF + 4, NULL, 3,
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 3, 1),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 3, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 3, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 3, 1),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 3, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 3, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 4),
LEN_SQ_PRF + 4, NULL, 3,
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 4, 1),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 4, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 4, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 4, 1),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 4, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 4, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 5),
LEN_SQ_PRF + 4, NULL, 3,
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 5, 1),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 5, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 5, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 5, 1),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 5, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 5, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 6),
LEN_SQ_PRF + 4, NULL, 3,
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 6, 1),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 6, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 6, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 6, 1),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 6, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 6, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 7),
LEN_SQ_PRF + 4, NULL, 3,
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 7, 1),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 7, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 7, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 8),
- LEN_SQ_PRF + 4, NULL, 3,
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 8, 1),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 8, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 8, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 9),
- LEN_SQ_PRF + 4, NULL, 3,
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 9, 1),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 9, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 9, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 10),
- LEN_SQ_PRF + 4, NULL, 3,
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 10, 1),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 10, 5),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
- snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 10, 60),
- LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)))))),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 7, 1),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 7, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 7, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 8),
+ LEN_SQ_PRF + 4, NULL, 3,
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 8, 1),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 8, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 8, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 9),
+ LEN_SQ_PRF + 4, NULL, 3,
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 9, 1),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 9, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 9, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 4, SQ_PRF, 2, 2, 1, 10),
+ LEN_SQ_PRF + 4, NULL, 3,
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 10, 1),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 10, 5),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0),
+ snmpAddNode(snmpCreateOid(LEN_SQ_PRF + 5, SQ_PRF, 2, 2, 1, 10, 60),
+ LEN_SQ_PRF + 5, snmp_prfProtoFn, 0)))))),
snmpAddNode(snmpCreateOid(LEN_SQ_NET, SQ_NET),
LEN_SQ_NET, NULL, 3,
snmpAddNode(snmpCreateOid(LEN_SQ_NET + 1, SQ_NET, 1),
mibTreeEntry = mib_tree_head;
if (Current[count] == mibTreeEntry->name[count]) {
- count++;
- while ((mibTreeEntry) && (count < CurrentLen)) {
- mibTreeEntry = snmpTreeEntry(Current[count], count, mibTreeEntry);
- count++;
- }
+ count++;
+ while ((mibTreeEntry) && (count < CurrentLen)) {
+ mibTreeEntry = snmpTreeEntry(Current[count], count, mibTreeEntry);
+ count++;
+ }
}
if (mibTreeEntry) {
- Fn = mibTreeEntry->parsefunction;
+ Fn = mibTreeEntry->parsefunction;
}
debug(49, 5) ("snmpTreeGet: return\n");
return (Fn);
if ((mibTreeEntry) && (mibTreeEntry->parsefunction)) {
count--;
nextoid = snmpTreeSiblingEntry(Current[count], count, mibTreeEntry->parent);
- if(nextoid){
+ if (nextoid) {
mibTreeEntry = nextoid;
count++;
- }else{
+ } else {
debug(49, 5) ("snmpTreeNext: Attempting to recurse up for next object\n");
- while(!nextoid){
+ while (!nextoid) {
count--;
nextoid = mibTreeEntry->parent;
mibTreeEntry = snmpTreeEntry(Current[count] + 1, count, nextoid->parent);
- if(!mibTreeEntry){
- mibTreeEntry = nextoid;
+ if (!mibTreeEntry) {
+ mibTreeEntry = nextoid;
nextoid = NULL;
- }
+ }
}
}
}
debug(49, 5) ("snmpTreeNext: Past Second\n");
while ((mibTreeEntry) && (!mibTreeEntry->parsefunction)) {
- mibTreeEntry = mibTreeEntry->leaves[0];
+ mibTreeEntry = mibTreeEntry->leaves[0];
}
}
if (mibTreeEntry) {
{
mib_tree_entry *next = NULL;
int count = 0;
-
+
while ((!next) && (count < current->children)) {
- if (current->leaves[count]->name[len] == entry) {
- next = current->leaves[count];
- }
- count++;
+ if (current->leaves[count]->name[len] == entry) {
+ next = current->leaves[count];
+ }
+ count++;
}
- if(count < current->children){
+ if (count < current->children) {
next = current->leaves[count];
- }else{
+ } else {
next = NULL;
}
return (next);
/*
* Returns the list of parameters in an oid[]
*/
-#ifdef __STDC__
+#ifdef __STDC__
oid *
snmpCreateOid(int length,...)
{
va_start(args, length);
#else
-oid *
+oid *
snmpCreateOid(va_alist)
va_dcl
{
va_list args;
int length = 0, loop;
oid *new_oid;
-
+
va_start(args);
length va_arg(args, int);
#endif
-
+
new_oid = xmalloc(sizeof(oid) * length);
if (length > 0) {