#include <net-snmp/net-snmp-config.h>
#include <net-snmp/net-snmp-features.h>
#include <net-snmp/net-snmp-includes.h>
#include <net-snmp/agent/net-snmp-agent-includes.h>
#include <net-snmp/agent/scalar.h>
#ifdef HAVE_STRING_H
#include <string.h>
#else
#include <strings.h>
#endif
#include <net-snmp/agent/cache_handler.h>
#include "agent/nsCache.h"
netsnmp_feature_require(cache_get_head)
/*
* use unadvertised function to get cache head. You really should not
* do this, since the internal storage mechanism might change.
*/
extern netsnmp_cache *netsnmp_cache_get_head(void);
#define nsCache 1, 3, 6, 1, 4, 1, 8072, 1, 5
/*
* OIDs for the cacheging control scalar objects
*
* Note that these we're registering the full object rather
* than the (sole) valid instance in each case, in order
* to handle requests for invalid instances properly.
*/
/*
* ... and for the cache table.
*/
#define NSCACHE_TIMEOUT 2
#define NSCACHE_STATUS 3
#define NSCACHE_STATUS_ENABLED 1
#define NSCACHE_STATUS_DISABLED 2
#define NSCACHE_STATUS_EMPTY 3
#define NSCACHE_STATUS_ACTIVE 4
#define NSCACHE_STATUS_EXPIRED 5
NETSNMP_IMPORT struct snmp_alarm *
sa_find_specific(unsigned int clientreg);
void
init_nsCache(void)
{
const oid nsCacheTimeout_oid[] = { nsCache, 1 };
const oid nsCacheEnabled_oid[] = { nsCache, 2 };
const oid nsCacheTable_oid[] = { nsCache, 3 };
netsnmp_table_registration_info *table_info;
netsnmp_iterator_info *iinfo;
/*
* Register the scalar objects...
*/
DEBUGMSGTL(("nsCacheScalars", "Initializing\n"));
netsnmp_register_scalar(
netsnmp_create_handler_registration(
"nsCacheTimeout", handle_nsCacheTimeout,
nsCacheTimeout_oid, OID_LENGTH(nsCacheTimeout_oid),
HANDLER_CAN_RWRITE)
);
netsnmp_register_scalar(
netsnmp_create_handler_registration(
"nsCacheEnabled", handle_nsCacheEnabled,
nsCacheEnabled_oid, OID_LENGTH(nsCacheEnabled_oid),
HANDLER_CAN_RWRITE)
);
/*
* ... and the table.
* We need to define the column structure and indexing....
*/
table_info = SNMP_MALLOC_TYPEDEF(netsnmp_table_registration_info);
if (!table_info) {
return;
}
netsnmp_table_helper_add_indexes(table_info, ASN_PRIV_IMPLIED_OBJECT_ID, 0);
table_info->min_column = NSCACHE_TIMEOUT;
table_info->max_column = NSCACHE_STATUS;
/*
* .... and the iteration information ....
*/
iinfo = SNMP_MALLOC_TYPEDEF(netsnmp_iterator_info);
if (!iinfo) {
SNMP_FREE(table_info);
return;
}
iinfo->get_first_data_point = get_first_cache_entry;
iinfo->get_next_data_point = get_next_cache_entry;
iinfo->table_reginfo = table_info;
/*
* .... and register the table with the agent.
*/
netsnmp_register_table_iterator2(
netsnmp_create_handler_registration(
"tzCacheTable", handle_nsCacheTable,
nsCacheTable_oid, OID_LENGTH(nsCacheTable_oid),
HANDLER_CAN_RWRITE),
iinfo);
}
/*
* nsCache scalar handling
*/
int
handle_nsCacheTimeout(netsnmp_mib_handler *handler,
netsnmp_handler_registration *reginfo,
netsnmp_agent_request_info *reqinfo,
netsnmp_request_info *requests)
{
long cache_default_timeout =
netsnmp_ds_get_int(NETSNMP_DS_APPLICATION_ID,
NETSNMP_DS_AGENT_CACHE_TIMEOUT);
netsnmp_request_info *request=NULL;
switch (reqinfo->mode) {
case MODE_GET:
for (request = requests; request; request=request->next) {
snmp_set_var_typed_value(request->requestvb, ASN_INTEGER,
(u_char*)&cache_default_timeout,
sizeof(cache_default_timeout));
}
break;
#ifndef NETSNMP_NO_WRITE_SUPPORT
case MODE_SET_RESERVE1:
for (request = requests; request; request=request->next) {
if ( request->status != 0 ) {
return SNMP_ERR_NOERROR; /* Already got an error */
}
if ( request->requestvb->type != ASN_INTEGER ) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_WRONGTYPE);
return SNMP_ERR_WRONGTYPE;
}
if ( *request->requestvb->val.integer < 0 ) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_WRONGVALUE);
return SNMP_ERR_WRONGVALUE;
}
}
break;
case MODE_SET_COMMIT:
netsnmp_ds_set_int(NETSNMP_DS_APPLICATION_ID,
NETSNMP_DS_AGENT_CACHE_TIMEOUT,
*requests->requestvb->val.integer);
break;
#endif /* !NETSNMP_NO_WRITE_SUPPORT */
}
return SNMP_ERR_NOERROR;
}
int
handle_nsCacheEnabled(netsnmp_mib_handler *handler,
netsnmp_handler_registration *reginfo,
netsnmp_agent_request_info *reqinfo,
netsnmp_request_info *requests)
{
long enabled;
netsnmp_request_info *request=NULL;
switch (reqinfo->mode) {
case MODE_GET:
enabled = (netsnmp_ds_get_boolean(NETSNMP_DS_APPLICATION_ID,
NETSNMP_DS_AGENT_NO_CACHING)
? NSCACHE_STATUS_ENABLED /* Actually True/False */
: NSCACHE_STATUS_DISABLED );
for (request = requests; request; request=request->next) {
snmp_set_var_typed_value(request->requestvb, ASN_INTEGER,
(u_char*)&enabled, sizeof(enabled));
}
break;
#ifndef NETSNMP_NO_WRITE_SUPPORT
case MODE_SET_RESERVE1:
for (request = requests; request; request=request->next) {
if ( request->status != 0 ) {
return SNMP_ERR_NOERROR; /* Already got an error */
}
if ( request->requestvb->type != ASN_INTEGER ) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_WRONGTYPE);
return SNMP_ERR_WRONGTYPE;
}
if ((*request->requestvb->val.integer != NSCACHE_STATUS_ENABLED) &&
(*request->requestvb->val.integer != NSCACHE_STATUS_DISABLED)) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_WRONGVALUE);
return SNMP_ERR_WRONGVALUE;
}
}
break;
case MODE_SET_COMMIT:
enabled = *requests->requestvb->val.integer;
if (enabled == NSCACHE_STATUS_DISABLED)
enabled = 0;
netsnmp_ds_set_boolean(NETSNMP_DS_APPLICATION_ID,
NETSNMP_DS_AGENT_NO_CACHING, enabled);
break;
#endif /* !NETSNMP_NO_WRITE_SUPPORT */
}
return SNMP_ERR_NOERROR;
}
/*
* nsCacheTable handling
*/
netsnmp_variable_list *
get_first_cache_entry(void **loop_context, void **data_context,
netsnmp_variable_list *index,
netsnmp_iterator_info *data)
{
netsnmp_cache *cache_head = netsnmp_cache_get_head();
if ( !cache_head )
return NULL;
snmp_set_var_value(index, (u_char*)cache_head->rootoid,
sizeof(oid) * cache_head->rootoid_len);
*loop_context = (void*)cache_head;
*data_context = (void*)cache_head;
return index;
}
netsnmp_variable_list *
get_next_cache_entry(void **loop_context, void **data_context,
netsnmp_variable_list *index,
netsnmp_iterator_info *data)
{
netsnmp_cache *cache = (netsnmp_cache *)*loop_context;
cache = cache->next;
if ( !cache )
return NULL;
snmp_set_var_value(index, (u_char*)cache->rootoid,
sizeof(oid) * cache->rootoid_len);
*loop_context = (void*)cache;
*data_context = (void*)cache;
return index;
}
int
handle_nsCacheTable(netsnmp_mib_handler *handler,
netsnmp_handler_registration *reginfo,
netsnmp_agent_request_info *reqinfo,
netsnmp_request_info *requests)
{
long status;
netsnmp_request_info *request = NULL;
netsnmp_table_request_info *table_info = NULL;
netsnmp_cache *cache_entry = NULL;
switch (reqinfo->mode) {
case MODE_GET:
for (request=requests; request; request=request->next) {
if (request->processed != 0)
continue;
cache_entry = (netsnmp_cache*)netsnmp_extract_iterator_context(request);
table_info = netsnmp_extract_table_info(request);
switch (table_info->colnum) {
case NSCACHE_TIMEOUT:
if (!cache_entry) {
netsnmp_set_request_error(reqinfo, request, SNMP_NOSUCHINSTANCE);
continue;
}
status = cache_entry->timeout;
snmp_set_var_typed_value(request->requestvb, ASN_INTEGER,
(u_char*)&status, sizeof(status));
break;
case NSCACHE_STATUS:
if (!cache_entry) {
netsnmp_set_request_error(reqinfo, request, SNMP_NOSUCHINSTANCE);
continue;
}
status = (cache_entry->enabled ?
(cache_entry->timestampM ?
(cache_entry->timeout >= 0 &&
!netsnmp_ready_monotonic(cache_entry->timestampM,
1000*cache_entry->timeout) ?
NSCACHE_STATUS_ACTIVE:
NSCACHE_STATUS_EXPIRED) :
NSCACHE_STATUS_EMPTY) :
NSCACHE_STATUS_DISABLED);
snmp_set_var_typed_value(request->requestvb, ASN_INTEGER,
(u_char*)&status, sizeof(status));
break;
default:
netsnmp_set_request_error(reqinfo, request, SNMP_NOSUCHOBJECT);
continue;
}
}
break;
#ifndef NETSNMP_NO_WRITE_SUPPORT
case MODE_SET_RESERVE1:
for (request=requests; request; request=request->next) {
if (request->processed != 0)
continue;
if ( request->status != 0 ) {
return SNMP_ERR_NOERROR; /* Already got an error */
}
cache_entry = (netsnmp_cache*)netsnmp_extract_iterator_context(request);
table_info = netsnmp_extract_table_info(request);
switch (table_info->colnum) {
case NSCACHE_TIMEOUT:
if (!cache_entry) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_NOCREATION);
return SNMP_ERR_NOCREATION;
}
if ( request->requestvb->type != ASN_INTEGER ) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_WRONGTYPE);
return SNMP_ERR_WRONGTYPE;
}
if (*request->requestvb->val.integer < 0 ) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_WRONGVALUE);
return SNMP_ERR_WRONGVALUE;
}
break;
case NSCACHE_STATUS:
if (!cache_entry) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_NOCREATION);
return SNMP_ERR_NOCREATION;
}
if ( request->requestvb->type != ASN_INTEGER ) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_WRONGTYPE);
return SNMP_ERR_WRONGTYPE;
}
status = *request->requestvb->val.integer;
if (!((status == NSCACHE_STATUS_ENABLED ) ||
(status == NSCACHE_STATUS_DISABLED ) ||
(status == NSCACHE_STATUS_EMPTY ))) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_WRONGVALUE);
return SNMP_ERR_WRONGVALUE;
}
break;
default:
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_NOCREATION);
return SNMP_ERR_NOCREATION; /* XXX - is this right ? */
}
}
break;
case MODE_SET_COMMIT:
for (request=requests; request; request=request->next) {
if (request->processed != 0)
continue;
if ( request->status != 0 ) {
return SNMP_ERR_NOERROR; /* Already got an error */
}
cache_entry = (netsnmp_cache*)netsnmp_extract_iterator_context(request);
if (!cache_entry) {
netsnmp_set_request_error(reqinfo, request, SNMP_ERR_COMMITFAILED);
return SNMP_ERR_COMMITFAILED; /* Shouldn't happen! */
}
table_info = netsnmp_extract_table_info(request);
switch (table_info->colnum) {
case NSCACHE_TIMEOUT:
cache_entry->timeout = *request->requestvb->val.integer;
/*
* check for auto repeat
*/
if (cache_entry->timer_id) {
struct snmp_alarm * sa =
sa_find_specific(cache_entry->timer_id);
if (NULL != sa)
sa->t.tv_sec = cache_entry->timeout;
}
break;
case NSCACHE_STATUS:
switch (*request->requestvb->val.integer) {
case NSCACHE_STATUS_ENABLED:
cache_entry->enabled = 1;
break;
case NSCACHE_STATUS_DISABLED:
cache_entry->enabled = 0;
break;
case NSCACHE_STATUS_EMPTY:
cache_entry->free_cache(cache_entry, cache_entry->magic);
free(cache_entry->timestampM);
cache_entry->timestampM = NULL;
break;
}
break;
}
}
break;
#endif /* !NETSNMP_NO_WRITE_SUPPORT */
}
return SNMP_ERR_NOERROR;
}