blob: fe0affedd709ff72a03044dd6407683a2f80851a [file] [log] [blame]
#include <net-snmp/net-snmp-config.h>
#include <stdio.h>
#if HAVE_STRING_H
#include <string.h>
#else
#include <strings.h>
#endif
#include <sys/types.h>
#if HAVE_STDLIB_H
#include <stdlib.h>
#endif
#if HAVE_UNISTD_H
#include <unistd.h>
#endif
#if HAVE_DMALLOC_H
#include <dmalloc.h>
#endif
#include <net-snmp/output_api.h>
#include <net-snmp/utilities.h>
#include <net-snmp/library/snmp_transport.h>
#include <net-snmp/library/snmpUDPDomain.h>
#ifdef NETSNMP_TRANSPORT_TLS_DOMAIN
#include <net-snmp/library/snmpTLSDomain.h>
#endif
#ifdef NETSNMP_TRANSPORT_STD_DOMAIN
#include <net-snmp/library/snmpSTDDomain.h>
#endif
#ifdef NETSNMP_TRANSPORT_TCP_DOMAIN
#include <net-snmp/library/snmpTCPDomain.h>
#endif
#ifdef NETSNMP_TRANSPORT_IPX_DOMAIN
#include <net-snmp/library/snmpIPXDomain.h>
#endif
#ifdef NETSNMP_TRANSPORT_UNIX_DOMAIN
#include <net-snmp/library/snmpUnixDomain.h>
#endif
#ifdef NETSNMP_TRANSPORT_AAL5PVC_DOMAIN
#include <net-snmp/library/snmpAAL5PVCDomain.h>
#endif
#ifdef NETSNMP_TRANSPORT_UDPIPV6_DOMAIN
#include <net-snmp/library/snmpUDPIPv6Domain.h>
#endif
#ifdef NETSNMP_TRANSPORT_TCPIPV6_DOMAIN
#include <net-snmp/library/snmpTCPIPv6Domain.h>
#endif
#include <net-snmp/library/snmp_api.h>
#include <net-snmp/library/snmp_service.h>
/*
* Our list of supported transport domains.
*/
static netsnmp_tdomain *domain_list = NULL;
/*
* The standard SNMP domains.
*/
oid netsnmpUDPDomain[] = { 1, 3, 6, 1, 6, 1, 1 };
size_t netsnmpUDPDomain_len = OID_LENGTH(netsnmpUDPDomain);
oid netsnmpCLNSDomain[] = { 1, 3, 6, 1, 6, 1, 2 };
size_t netsnmpCLNSDomain_len = OID_LENGTH(netsnmpCLNSDomain);
oid netsnmpCONSDomain[] = { 1, 3, 6, 1, 6, 1, 3 };
size_t netsnmpCONSDomain_len = OID_LENGTH(netsnmpCONSDomain);
oid netsnmpDDPDomain[] = { 1, 3, 6, 1, 6, 1, 4 };
size_t netsnmpDDPDomain_len = OID_LENGTH(netsnmpDDPDomain);
oid netsnmpIPXDomain[] = { 1, 3, 6, 1, 6, 1, 5 };
size_t netsnmpIPXDomain_len = OID_LENGTH(netsnmpIPXDomain);
static void netsnmp_tdomain_dump(void);
/*
* Make a deep copy of an netsnmp_transport.
*/
netsnmp_transport *
netsnmp_transport_copy(netsnmp_transport *t)
{
netsnmp_transport *n = NULL;
n = (netsnmp_transport *) malloc(sizeof(netsnmp_transport));
if (n == NULL) {
return NULL;
}
memset(n, 0, sizeof(netsnmp_transport));
if (t->domain != NULL) {
n->domain = t->domain;
n->domain_length = t->domain_length;
} else {
n->domain = NULL;
n->domain_length = 0;
}
if (t->local != NULL) {
n->local = (u_char *) malloc(t->local_length);
if (n->local == NULL) {
netsnmp_transport_free(n);
return NULL;
}
n->local_length = t->local_length;
memcpy(n->local, t->local, t->local_length);
} else {
n->local = NULL;
n->local_length = 0;
}
if (t->remote != NULL) {
n->remote = (u_char *) malloc(t->remote_length);
if (n->remote == NULL) {
netsnmp_transport_free(n);
return NULL;
}
n->remote_length = t->remote_length;
memcpy(n->remote, t->remote, t->remote_length);
} else {
n->remote = NULL;
n->remote_length = 0;
}
if (t->data != NULL && t->data_length > 0) {
n->data = malloc(t->data_length);
if (n->data == NULL) {
netsnmp_transport_free(n);
return NULL;
}
n->data_length = t->data_length;
memcpy(n->data, t->data, t->data_length);
} else {
n->data = NULL;
n->data_length = 0;
}
n->msgMaxSize = t->msgMaxSize;
n->f_accept = t->f_accept;
n->f_recv = t->f_recv;
n->f_send = t->f_send;
n->f_close = t->f_close;
n->f_fmtaddr = t->f_fmtaddr;
n->sock = t->sock;
n->flags = t->flags;
return n;
}
void
netsnmp_transport_free(netsnmp_transport *t)
{
if (NULL == t)
return;
if (t->local != NULL) {
SNMP_FREE(t->local);
}
if (t->remote != NULL) {
SNMP_FREE(t->remote);
}
if (t->data != NULL) {
SNMP_FREE(t->data);
}
SNMP_FREE(t);
}
int
netsnmp_tdomain_support(const oid * in_oid,
size_t in_len,
const oid ** out_oid, size_t * out_len)
{
netsnmp_tdomain *d = NULL;
for (d = domain_list; d != NULL; d = d->next) {
if (netsnmp_oid_equals(in_oid, in_len, d->name, d->name_length) == 0) {
if (out_oid != NULL && out_len != NULL) {
*out_oid = d->name;
*out_len = d->name_length;
}
return 1;
}
}
return 0;
}
void
netsnmp_tdomain_init(void)
{
DEBUGMSGTL(("tdomain", "netsnmp_tdomain_init() called\n"));
netsnmp_udp_ctor();
#ifdef NETSNMP_TRANSPORT_STD_DOMAIN
netsnmp_std_ctor();
#endif
#ifdef NETSNMP_TRANSPORT_TCP_DOMAIN
netsnmp_tcp_ctor();
#endif
#ifdef NETSNMP_TRANSPORT_IPX_DOMAIN
netsnmp_ipx_ctor();
#endif
#ifdef NETSNMP_TRANSPORT_UNIX_DOMAIN
netsnmp_unix_ctor();
#endif
#ifdef NETSNMP_TRANSPORT_AAL5PVC_DOMAIN
netsnmp_aal5pvc_ctor();
#endif
#ifdef NETSNMP_TRANSPORT_UDPIPV6_DOMAIN
netsnmp_udp6_ctor();
#endif
#ifdef NETSNMP_TRANSPORT_TCPIPV6_DOMAIN
netsnmp_tcp6_ctor();
#endif
netsnmp_tdomain_dump();
}
void
netsnmp_clear_tdomain_list(void)
{
netsnmp_tdomain *list = domain_list, *next = NULL;
DEBUGMSGTL(("tdomain", "clear_tdomain_list() called\n"));
while (list != NULL) {
next = list->next;
SNMP_FREE(list->prefix);
/* attention!! list itself is not in the heap, so we must not free it! */
list = next;
}
domain_list = NULL;
}
static void
netsnmp_tdomain_dump(void)
{
netsnmp_tdomain *d;
int i = 0;
DEBUGMSGTL(("tdomain", "domain_list -> "));
for (d = domain_list; d != NULL; d = d->next) {
DEBUGMSG(("tdomain", "{ "));
DEBUGMSGOID(("tdomain", d->name, d->name_length));
DEBUGMSG(("tdomain", ", \""));
for (i = 0; d->prefix[i] != NULL; i++) {
DEBUGMSG(("tdomain", "%s%s", d->prefix[i],
(d->prefix[i + 1]) ? "/" : ""));
}
DEBUGMSG(("tdomain", "\" } -> "));
}
DEBUGMSG(("tdomain", "[NIL]\n"));
}
int
netsnmp_tdomain_register(netsnmp_tdomain *n)
{
netsnmp_tdomain **prevNext = &domain_list, *d;
if (n != NULL) {
for (d = domain_list; d != NULL; d = d->next) {
if (netsnmp_oid_equals(n->name, n->name_length,
d->name, d->name_length) == 0) {
/*
* Already registered.
*/
return 0;
}
prevNext = &(d->next);
}
n->next = NULL;
*prevNext = n;
return 1;
} else {
return 0;
}
}
int
netsnmp_tdomain_unregister(netsnmp_tdomain *n)
{
netsnmp_tdomain **prevNext = &domain_list, *d;
if (n != NULL) {
for (d = domain_list; d != NULL; d = d->next) {
if (netsnmp_oid_equals(n->name, n->name_length,
d->name, d->name_length) == 0) {
*prevNext = n->next;
SNMP_FREE(n->prefix);
return 1;
}
prevNext = &(d->next);
}
return 0;
} else {
return 0;
}
}
static netsnmp_tdomain *
find_tdomain(const char* spec)
{
netsnmp_tdomain *d;
for (d = domain_list; d != NULL; d = d->next) {
int i;
for (i = 0; d->prefix[i] != NULL; i++)
if (strcasecmp(d->prefix[i], spec) == 0) {
DEBUGMSGTL(("tdomain",
"Found domain \"%s\" from specifier \"%s\"\n",
d->prefix[0], spec));
return d;
}
}
DEBUGMSGTL(("tdomain", "Found no domain from specifier \"%s\"\n", spec));
return NULL;
}
/*
* Locate the appropriate transport domain and call the create function for
* it.
*/
netsnmp_transport *
netsnmp_tdomain_transport_full(const char *application,
const char *str, int local,
const char *default_domain,
const char *default_target)
{
netsnmp_tdomain *match = NULL;
const char *addr = NULL;
const char * const *spec = NULL;
int any_found = 0;
extern char *curfilename; /* from read_config.c */
char *prev_curfilename;
DEBUGMSGTL(("tdomain",
"tdomain_transport_full(\"%s\", \"%s\", %d, \"%s\", \"%s\")\n",
application, str ? str : "[NIL]", local,
default_domain ? default_domain : "[NIL]",
default_target ? default_target : "[NIL]"));
prev_curfilename = curfilename;
/* First try - assume that there is a domain in str (domain:target) */
if (str != NULL) {
char *cp;
if ((cp = strchr(str, ':')) != NULL) {
char* mystring = (char*)malloc(cp + 1 - str);
memcpy(mystring, str, cp - str);
mystring[cp - str] = '\0';
addr = cp + 1;
match = find_tdomain(mystring);
free(mystring);
}
}
/*
* Second try, if there is no domain in str (target), then try the
* default domain
*/
if (match == NULL) {
addr = str;
if (addr && *addr == '/') {
DEBUGMSGTL(("tdomain",
"Address starts with '/', so assume \"unix\" "
"domain\n"));
match = find_tdomain("unix");
} else if (default_domain) {
DEBUGMSGTL(("tdomain",
"Use user specified default domain \"%s\"\n",
default_domain));
match = find_tdomain(default_domain);
} else {
spec = netsnmp_lookup_default_domains(application);
if (spec == NULL) {
DEBUGMSGTL(("tdomain",
"No default domain found, assume \"udp\"\n"));
match = find_tdomain("udp");
} else {
const char * const * r = spec;
DEBUGMSGTL(("tdomain",
"Use application default domains"));
while(*r) {
DEBUGMSG(("tdomain", " \"%s\"", *r));
++r;
}
DEBUGMSG(("tdomain", "\n"));
}
}
}
for(;;) {
if (match) {
netsnmp_transport *t = NULL;
const char* addr2;
any_found = 1;
/*
* Ok, we know what domain to try, lets see what default data
* should be used with it
*/
if (default_target != NULL)
addr2 = default_target;
else
addr2 = netsnmp_lookup_default_target(application,
match->prefix[0]);
DEBUGMSGTL(("tdomain",
"trying domain \"%s\" address \"%s\" "
"default address \"%s\"\n",
match->prefix[0], addr ? addr : "[NIL]",
addr2 ? addr2 : "[NIL]"));
if (match->f_create_from_tstring)
t = match->f_create_from_tstring(addr, local);
else
t = match->f_create_from_tstring_new(addr, local, addr2);
if (t) {
curfilename = prev_curfilename;
return t;
}
}
addr = str;
if (spec && *spec)
match = find_tdomain(*spec++);
else
break;
}
if (!any_found)
snmp_log(LOG_ERR, "No support for any checked transport domain\n");
curfilename = prev_curfilename;
return NULL;
}
netsnmp_transport *
netsnmp_tdomain_transport(const char *str, int local,
const char *default_domain)
{
return netsnmp_tdomain_transport_full("snmp", str, local, default_domain,
NULL);
}
netsnmp_transport *
netsnmp_tdomain_transport_oid(const oid * dom,
size_t dom_len,
const u_char * o, size_t o_len, int local)
{
netsnmp_tdomain *d;
int i;
DEBUGMSGTL(("tdomain", "domain \""));
DEBUGMSGOID(("tdomain", dom, dom_len));
DEBUGMSG(("tdomain", "\"\n"));
for (d = domain_list; d != NULL; d = d->next) {
for (i = 0; d->prefix[i] != NULL; i++) {
if (netsnmp_oid_equals(dom, dom_len, d->name, d->name_length) ==
0) {
return d->f_create_from_ostring(o, o_len, local);
}
}
}
snmp_log(LOG_ERR, "No support for requested transport domain\n");
return NULL;
}
netsnmp_transport*
netsnmp_transport_open(const char* application, const char* str, int local)
{
return netsnmp_tdomain_transport_full(application, str, local, NULL, NULL);
}
netsnmp_transport*
netsnmp_transport_open_server(const char* application, const char* str)
{
return netsnmp_tdomain_transport_full(application, str, 1, NULL, NULL);
}
netsnmp_transport*
netsnmp_transport_open_client(const char* application, const char* str)
{
return netsnmp_tdomain_transport_full(application, str, 0, NULL, NULL);
}
/** adds a transport to a linked list of transports.
Returns 1 on failure, 0 on success */
int
netsnmp_transport_add_to_list(netsnmp_transport_list **transport_list,
netsnmp_transport *transport)
{
netsnmp_transport_list *newptr =
SNMP_MALLOC_TYPEDEF(netsnmp_transport_list);
if (!newptr)
return 1;
newptr->next = *transport_list;
newptr->transport = transport;
*transport_list = newptr;
return 0;
}
/** removes a transport from a linked list of transports.
Returns 1 on failure, 0 on success */
int
netsnmp_transport_remove_from_list(netsnmp_transport_list **transport_list,
netsnmp_transport *transport)
{
netsnmp_transport_list *ptr = *transport_list, *lastptr = NULL;
while (ptr && ptr->transport != transport) {
lastptr = ptr;
ptr = ptr->next;
}
if (!ptr)
return 1;
if (lastptr)
lastptr->next = ptr->next;
else
*transport_list = ptr->next;
SNMP_FREE(ptr);
return 0;
}