开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Linux/Unix编程 > 网络 > 查看源码
smux.c
资源名称：zebra-0.95a.tar.gz　[点击查看]
上传用户：xiaozhuqw
上传日期：2009-11-15
资源大小：1338k
文件大小：35k
源码类别：

网络

开发平台：

Unix_Linux

smux.c：源码内容
  1. /* SNMP support
  2.  * Copyright (C) 1999 Kunihiro Ishiguro <kunihiro@zebra.org>
  3.  *
  4.  * This file is part of GNU Zebra.
  5.  *
  6.  * GNU Zebra is free software; you can redistribute it and/or modify it
  7.  * under the terms of the GNU General Public License as published by the
  8.  * Free Software Foundation; either version 2, or (at your option) any
  9.  * later version.
  10.  *
  11.  * GNU Zebra is distributed in the hope that it will be useful, but
  12.  * WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14.  * General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with GNU Zebra; see the file COPYING.  If not, write to the Free
  18.  * Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
  19.  * 02111-1307, USA.  
  20.  */
  22. #include <zebra.h>
  24. #ifdef HAVE_SNMP
  26. #ifdef HAVE_NETSNMP
  27. #include <net-snmp/net-snmp-config.h>
  28. #endif /* HAVE_NETSNMP */
  30. #include <asn1.h>
  31. #include <snmp.h>
  32. #include <snmp_impl.h>
  34. #include "smux.h"
  35. #include "log.h"
  36. #include "thread.h"
  37. #include "linklist.h"
  38. #include "command.h"
  39. #include "version.h"
  40. #include "memory.h"
  41. #include "sockunion.h"
  43. #define min(A,B) ((A) < (B) ? (A) : (B))
  45. enum smux_event {SMUX_SCHEDULE, SMUX_CONNECT, SMUX_READ};
  47. void smux_event (enum smux_event, int);
  50. /* SMUX socket. */
  51. int smux_sock = -1;
  53. /* SMUX subtree list. */
  54. struct list *treelist;
  56. /* SMUX oid. */
  57. oid *smux_oid;
  58. size_t smux_oid_len;
  60. /* SMUX default oid. */
  61. oid *smux_default_oid;
  62. size_t smux_default_oid_len;
  64. /* SMUX password. */
  65. char *smux_passwd;
  66. char *smux_default_passwd = "";
  68. /* SMUX read threads. */
  69. struct thread *smux_read_thread;
  71. /* SMUX connect thrads. */
  72. struct thread *smux_connect_thread;
  74. /* SMUX debug flag. */
  75. int debug_smux = 0;
  77. /* SMUX failure count. */
  78. int fail = 0;
  80. /* SMUX node. */
  81. struct cmd_node smux_node =
  82. {
  83.   SMUX_NODE,
  84.   ""                            /* SMUX has no interface. */
  85. };
  87. void *
  88. oid_copy (void *dest, void *src, size_t size)
  89. {
  90.   return memcpy (dest, src, size * sizeof (oid));
  91. }
  93. void
  94. oid2in_addr (oid oid[], int len, struct in_addr *addr)
  95. {
  96.   int i;
  97.   u_char *pnt;
  98.   
  99.   if (len == 0)
  100.     return;
  102.   pnt = (u_char *) addr;
  104.   for (i = 0; i < len; i++)
  105.     *pnt++ = oid[i];
  106. }
  108. void
  109. oid_copy_addr (oid oid[], struct in_addr *addr, int len)
  110. {
  111.   int i;
  112.   u_char *pnt;
  113.   
  114.   if (len == 0)
  115.     return;
  117.   pnt = (u_char *) addr;
  119.   for (i = 0; i < len; i++)
  120.     oid[i] = *pnt++;
  121. }
  123. int
  124. oid_compare (oid *o1, int o1_len, oid *o2, int o2_len)
  125. {
  126.   int i;
  128.   for (i = 0; i < min (o1_len, o2_len); i++)
  129.     {
  130.       if (o1[i] < o2[i])
  131. return -1;
  132.       else if (o1[i] > o2[i])
  133. return 1;
  134.     }
  135.   if (o1_len < o2_len)
  136.     return -1;
  137.   if (o1_len > o2_len)
  138.     return 1;
  140.   return 0;
  141. }
  143. int
  144. oid_compare_part (oid *o1, int o1_len, oid *o2, int o2_len)
  145. {
  146.   int i;
  148.   for (i = 0; i < min (o1_len, o2_len); i++)
  149.     {
  150.       if (o1[i] < o2[i])
  151. return -1;
  152.       else if (o1[i] > o2[i])
  153. return 1;
  154.     }
  155.   if (o1_len < o2_len)
  156.     return -1;
  158.   return 0;
  159. }
  161. void
  162. smux_oid_dump (char *prefix, oid *oid, size_t oid_len)
  163. {
  164.   int i;
  165.   int first = 1;
  166.   char buf[MAX_OID_LEN * 3];
  168.   buf[0] = '';
  170.   for (i = 0; i < oid_len; i++)
  171.     {
  172.       sprintf (buf + strlen (buf), "%s%d", first ? "" : ".", (int) oid[i]);
  173.       first = 0;
  174.     }
  175.   zlog_info ("%s: %s", prefix, buf);
  176. }
  178. int
  179. smux_socket ()
  180. {
  181.   int ret;
  182. #ifdef HAVE_IPV6
  183.   struct addrinfo hints, *res0, *res;
  184.   int gai;
  185. #else
  186.   struct sockaddr_in serv;
  187.   struct servent *sp;
  188. #endif
  189.   int sock = 0;
  191. #ifdef HAVE_IPV6
  192.   memset(&hints, 0, sizeof(hints));
  193.   hints.ai_family = PF_UNSPEC;
  194.   hints.ai_socktype = SOCK_STREAM;
  195.   gai = getaddrinfo(NULL, "smux", &hints, &res0);
  196.   if (gai == EAI_SERVICE)
  197.     {
  198.       char servbuf[NI_MAXSERV];
  199.       sprintf(servbuf,"%d",SMUX_PORT_DEFAULT);
  200.       servbuf[sizeof (servbuf) - 1] = '';
  201.       gai = getaddrinfo(NULL, servbuf, &hints, &res0);
  202.     }
  203.   if (gai)
  204.     {
  205.       zlog_warn("Cannot locate loopback service smux");
  206.       return -1;
  207.     }
  208.   for(res=res0; res; res=res->ai_next)
  209.     {
  210.       if (res->ai_family != AF_INET 
  211. #ifdef HAVE_IPV6
  212.   && res->ai_family != AF_INET6
  213. #endif /* HAVE_IPV6 */
  214.   )
  215. continue;
  217.       sock = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
  218.       if (sock < 0)
  219. continue;
  220.       sockopt_reuseaddr (sock);
  221.       sockopt_reuseport (sock);
  222.       ret = connect (sock, res->ai_addr, res->ai_addrlen);
  223.       if (ret < 0)
  224. {
  225.   close(sock);
  226.   sock = -1;
  227.   continue;
  228. }
  229.       break;
  230.     }
  231.   freeaddrinfo(res0);
  232.   if (sock < 0)
  233.     zlog_warn ("Can't connect to SNMP agent with SMUX");
  234. #else
  235.   sock = socket (AF_INET, SOCK_STREAM, 0);
  236.   if (sock < 0)
  237.     {
  238.       zlog_warn ("Can't make socket for SNMP");
  239.       return -1;
  240.     }
  242.   memset (&serv, 0, sizeof (struct sockaddr_in));
  243.   serv.sin_family = AF_INET;
  244. #ifdef HAVE_SIN_LEN
  245.   serv.sin_len = sizeof (struct sockaddr_in);
  246. #endif /* HAVE_SIN_LEN */
  248.   sp = getservbyname ("smux", "tcp");
  249.   if (sp != NULL) 
  250.     serv.sin_port = sp->s_port;
  251.   else
  252.     serv.sin_port = htons (SMUX_PORT_DEFAULT);
  254.   serv.sin_addr.s_addr = htonl (INADDR_LOOPBACK);
  256.   sockopt_reuseaddr (sock);
  257.   sockopt_reuseport (sock);
  259.   ret = connect (sock, (struct sockaddr *) &serv, sizeof (struct sockaddr_in));
  260.   if (ret < 0)
  261.     {
  262.       close (sock);
  263.       smux_sock = -1;
  264.       zlog_warn ("Can't connect to SNMP agent with SMUX");
  265.       return -1;
  266.     }
  267. #endif
  268.   return sock;
  269. }
  271. void
  272. smux_getresp_send (oid objid[], size_t objid_len, long reqid, long errstat,
  273.    long errindex, u_char val_type, void *arg, size_t arg_len)
  274. {
  275.   int ret;
  276.   u_char buf[BUFSIZ];
  277.   u_char *ptr, *h1, *h1e, *h2, *h2e;
  278.   int len, length;
  280.   ptr = buf;
  281.   len = BUFSIZ;
  282.   length = len;
  284.   if (debug_smux)
  285.     {
  286.       zlog_info ("SMUX GETRSP send");
  287.       zlog_info ("SMUX GETRSP reqid: %ld", reqid);
  288.     }
  290.   h1 = ptr;
  291.   /* Place holder h1 for complete sequence */
  292.   ptr = asn_build_sequence (ptr, &len, (u_char) SMUX_GETRSP, 0);
  293.   h1e = ptr;
  294.  
  295.   ptr = asn_build_int (ptr, &len,
  296.        (u_char) (ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_INTEGER),
  297.        &reqid, sizeof (reqid));
  299.   if (debug_smux)
  300.     zlog_info ("SMUX GETRSP errstat: %ld", errstat);
  302.   ptr = asn_build_int (ptr, &len,
  303.        (u_char) (ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_INTEGER),
  304.        &errstat, sizeof (errstat));
  305.   if (debug_smux)
  306.     zlog_info ("SMUX GETRSP errindex: %ld", errindex);
  308.   ptr = asn_build_int (ptr, &len,
  309.        (u_char) (ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_INTEGER),
  310.        &errindex, sizeof (errindex));
  312.   h2 = ptr;
  313.   /* Place holder h2 for one variable */
  314.   ptr = asn_build_sequence (ptr, &len, 
  315.    (u_char)(ASN_SEQUENCE | ASN_CONSTRUCTOR),
  316.    0);
  317.   h2e = ptr;
  319.   ptr = snmp_build_var_op (ptr, objid, &objid_len, 
  320.    val_type, arg_len, arg, &len);
  322.   /* Now variable size is known, fill in size */
  323.   asn_build_sequence(h2,&length,(u_char)(ASN_SEQUENCE|ASN_CONSTRUCTOR),ptr-h2e);
  325.   /* Fill in size of whole sequence */
  326.   asn_build_sequence(h1,&length,(u_char)SMUX_GETRSP,ptr-h1e);
  328.   if (debug_smux)
  329.     zlog_info ("SMUX getresp send: %d", ptr - buf);
  330.   
  331.   ret = send (smux_sock, buf, (ptr - buf), 0);
  332. }
  334. char *
  335. smux_var (char *ptr, int len, oid objid[], size_t *objid_len,
  336.           size_t *var_val_len,
  337.           u_char *var_val_type,
  338.           void **var_value)
  339. {
  340.   u_char type;
  341.   u_char val_type;
  342.   size_t val_len;
  343.   u_char *val;
  345.   if (debug_smux)
  346.     zlog_info ("SMUX var parse: len %d", len);
  348.   /* Parse header. */
  349.   ptr = asn_parse_header (ptr, &len, &type);
  350.   
  351.   if (debug_smux)
  352.     {
  353.       zlog_info ("SMUX var parse: type %d len %d", type, len);
  354.       zlog_info ("SMUX var parse: type must be %d", 
  355.  (ASN_SEQUENCE | ASN_CONSTRUCTOR));
  356.     }
  358.   /* Parse var option. */
  359.   *objid_len = MAX_OID_LEN;
  360.   ptr = snmp_parse_var_op(ptr, objid, objid_len, &val_type, 
  361.   &val_len, &val, &len);
  363.   if (var_val_len)
  364.     *var_val_len = val_len;
  366.   if (var_value)
  367.     *var_value = (void*) val;
  369.   if (var_val_type)
  370.     *var_val_type = val_type;
  372.   /* Requested object id length is objid_len. */
  373.   if (debug_smux)
  374.     smux_oid_dump ("Request OID", objid, *objid_len);
  376.   if (debug_smux)
  377.     zlog_info ("SMUX val_type: %d", val_type);
  379.   /* Check request value type. */
  380.   if (debug_smux)
  381.   switch (val_type)
  382.     {
  383.     case ASN_NULL:
  384.       /* In case of SMUX_GET or SMUX_GET_NEXT val_type is set to
  385.          ASN_NULL. */
  386.       zlog_info ("ASN_NULL");
  387.       break;
  389.     case ASN_INTEGER:
  390.       zlog_info ("ASN_INTEGER");
  391.       break;
  392.     case ASN_COUNTER:
  393.     case ASN_GAUGE:
  394.     case ASN_TIMETICKS:
  395.     case ASN_UINTEGER:
  396.       zlog_info ("ASN_COUNTER");
  397.       break;
  398.     case ASN_COUNTER64:
  399.       zlog_info ("ASN_COUNTER64");
  400.       break;
  401.     case ASN_IPADDRESS:
  402.       zlog_info ("ASN_IPADDRESS");
  403.       break;
  404.     case ASN_OCTET_STR:
  405.       zlog_info ("ASN_OCTET_STR");
  406.       break;
  407.     case ASN_OPAQUE:
  408.     case ASN_NSAP:
  409.     case ASN_OBJECT_ID:
  410.       zlog_info ("ASN_OPAQUE");
  411.       break;
  412.     case SNMP_NOSUCHOBJECT:
  413.       zlog_info ("SNMP_NOSUCHOBJECT");
  414.       break;
  415.     case SNMP_NOSUCHINSTANCE:
  416.       zlog_info ("SNMP_NOSUCHINSTANCE");
  417.       break;
  418.     case SNMP_ENDOFMIBVIEW:
  419.       zlog_info ("SNMP_ENDOFMIBVIEW");
  420.       break;
  421.     case ASN_BIT_STR:
  422.       zlog_info ("ASN_BIT_STR");
  423.       break;
  424.     default:
  425.       zlog_info ("Unknown type");
  426.       break;
  427.     }
  428.   return ptr;
  429. }
  431. /* NOTE: all 3 functions (smux_set, smux_get & smux_getnext) are based on
  432.    ucd-snmp smux and as such suppose, that the peer receives in the message
  433.    only one variable. Fortunately, IBM seems to do the same in AIX. */
  435. int
  436. smux_set (oid *reqid, size_t *reqid_len,
  437.           u_char val_type, void *val, size_t val_len, int action)
  438. {
  439.   int j;
  440.   struct subtree *subtree;
  441.   struct variable *v;
  442.   int subresult;
  443.   oid *suffix;
  444.   int suffix_len;
  445.   int result;
  446.   u_char *statP = NULL;
  447.   WriteMethod *write_method = NULL;
  448.   struct listnode *node;
  450.   /* Check */
  451.   for (node = treelist->head; node; node = node->next)
  452.     {
  453.       subtree = node->data;
  454.       subresult = oid_compare_part (reqid, *reqid_len,
  455.                                     subtree->name, subtree->name_len);
  457.       /* Subtree matched. */
  458.       if (subresult == 0)
  459.         {
  460.           /* Prepare suffix. */
  461.           suffix = reqid + subtree->name_len;
  462.           suffix_len = *reqid_len - subtree->name_len;
  463.           result = subresult;
  465.           /* Check variables. */
  466.           for (j = 0; j < subtree->variables_num; j++)
  467.             {
  468.               v = &subtree->variables[j];
  470.               /* Always check suffix */
  471.               result = oid_compare_part (suffix, suffix_len,
  472.                                          v->name, v->namelen);
  474.               /* This is exact match so result must be zero. */
  475.               if (result == 0)
  476.                 {
  477.                   if (debug_smux)
  478.                     zlog_info ("SMUX function call index is %d", v->magic);
  479.   
  480.                   statP = (*v->findVar) (v, suffix, &suffix_len, 1,
  481.  &val_len, &write_method);
  483.                   if (write_method)
  484.                     {
  485.                       return (*write_method)(action, val, val_type, val_len,
  486.      statP, suffix, suffix_len, v);
  487.                     }
  488.                   else
  489.                     {
  490.                       return SNMP_ERR_READONLY;
  491.                     }
  492.                 }
  494.               /* If above execution is failed or oid is small (so
  495.                  there is no further match). */
  496.               if (result < 0)
  497.                 return SNMP_ERR_NOSUCHNAME;
  498.             }
  499.         }
  500.     }
  501.   return SNMP_ERR_NOSUCHNAME;
  502. }
  504. int
  505. smux_get (oid *reqid, size_t *reqid_len, int exact, 
  506.   u_char *val_type,void **val, size_t *val_len)
  507. {
  508.   int j;
  509.   struct subtree *subtree;
  510.   struct variable *v;
  511.   int subresult;
  512.   oid *suffix;
  513.   int suffix_len;
  514.   int result;
  515.   WriteMethod *write_method=NULL;
  516.   struct listnode *node;
  518.   /* Check */
  519.   for (node = treelist->head; node; node = node->next)
  520.     {
  521.       subtree = node->data;
  522.       subresult = oid_compare_part (reqid, *reqid_len, 
  523.     subtree->name, subtree->name_len);
  525.       /* Subtree matched. */
  526.       if (subresult == 0)
  527. {
  528.   /* Prepare suffix. */
  529.   suffix = reqid + subtree->name_len;
  530.   suffix_len = *reqid_len - subtree->name_len;
  531.   result = subresult;
  533.   /* Check variables. */
  534.   for (j = 0; j < subtree->variables_num; j++)
  535.     {
  536.       v = &subtree->variables[j];
  538.       /* Always check suffix */
  539.       result = oid_compare_part (suffix, suffix_len,
  540.  v->name, v->namelen);
  542.       /* This is exact match so result must be zero. */
  543.       if (result == 0)
  544. {
  545.   if (debug_smux)
  546.     zlog_info ("SMUX function call index is %d", v->magic);
  548.   *val = (*v->findVar) (v, suffix, &suffix_len, exact,
  549. val_len, &write_method);
  551.   /* There is no instance. */
  552.   if (*val == NULL)
  553.     return SNMP_NOSUCHINSTANCE;
  555.   /* Call is suceed. */
  556.   *val_type = v->type;
  558.   return 0;
  559. }
  561.       /* If above execution is failed or oid is small (so
  562.                  there is no further match). */
  563.       if (result < 0)
  564. return SNMP_ERR_NOSUCHNAME;
  565.     }
  566. }
  567.     }
  568.   return SNMP_ERR_NOSUCHNAME;
  569. }
  571. int
  572. smux_getnext (oid *reqid, size_t *reqid_len, int exact, 
  573.       u_char *val_type,void **val, size_t *val_len)
  574. {
  575.   int j;
  576.   oid save[MAX_OID_LEN];
  577.   int savelen = 0;
  578.   struct subtree *subtree;
  579.   struct variable *v;
  580.   int subresult;
  581.   oid *suffix;
  582.   int suffix_len;
  583.   int result;
  584.   WriteMethod *write_method=NULL;
  585.   struct listnode *node;
  588.   /* Save incoming request. */
  589.   oid_copy (save, reqid, *reqid_len);
  590.   savelen = *reqid_len;
  592.   /* Check */
  593.   for (node = treelist->head; node; node = node->next)
  594.     {
  595.       subtree = node->data;
  596.       subresult = oid_compare_part (reqid, *reqid_len, 
  597.     subtree->name, subtree->name_len);
  599.       /* If request is in the tree. The agent has to make sure we
  600.          only receive requests we have registered for. */
  601.       /* Unfortunately, that's not true. In fact, a SMUX subagent has to
  602.          behave as if it manages the whole SNMP MIB tree itself. It's the
  603.          duty of the master agent to collect the best answer and return it
  604.          to the manager. See RFC 1227 chapter 3.1.6 for the glory details
  605.          :-). ucd-snmp really behaves bad here as it actually might ask
  606.          multiple times for the same GETNEXT request as it throws away the
  607.          answer when it expects it in a different subtree and might come
  608.          back later with the very same request. --jochen */
  610.       if (subresult <= 0)
  611. {
  612.   /* Prepare suffix. */
  613.   suffix = reqid + subtree->name_len;
  614.   suffix_len = *reqid_len - subtree->name_len;
  615.   if (subresult < 0)
  616.     {
  617.       oid_copy(reqid, subtree->name, subtree->name_len);
  618.       *reqid_len = subtree->name_len;
  619.     }
  620.   for (j = 0; j < subtree->variables_num; j++)
  621.     {
  622.       result = subresult;
  623.       v = &subtree->variables[j];
  625.       /* Next then check result >= 0. */
  626.       if (result == 0)
  627. result = oid_compare_part (suffix, suffix_len,
  628.    v->name, v->namelen);
  630.       if (result <= 0)
  631. {
  632.   if (debug_smux)
  633.     zlog_info ("SMUX function call index is %d", v->magic);
  634.   if(result<0)
  635.     {
  636.       oid_copy(suffix, v->name, v->namelen);
  637.       suffix_len = v->namelen;
  638.     }
  639.   *val = (*v->findVar) (v, suffix, &suffix_len, exact,
  640. val_len, &write_method);
  641.   *reqid_len = suffix_len + subtree->name_len;
  642.   if (*val)
  643.     {
  644.       *val_type = v->type;
  645.       return 0;
  646.     }
  647. }
  648.     }
  649. }
  650.     }
  651.   memcpy (reqid, save, savelen * sizeof(oid));
  652.   *reqid_len = savelen;
  654.   return SNMP_ERR_NOSUCHNAME;
  655. }
  657. /* GET message header. */
  658. char *
  659. smux_parse_get_header (char *ptr, size_t *len, long *reqid)
  660. {
  661.   u_char type;
  662.   long errstat;
  663.   long errindex;
  665.   /* Request ID. */
  666.   ptr = asn_parse_int (ptr, len, &type, reqid, sizeof (*reqid));
  668.   if (debug_smux)
  669.     zlog_info ("SMUX GET reqid: %d len: %d", (int) *reqid, (int) *len);
  671.   /* Error status. */
  672.   ptr = asn_parse_int (ptr, len, &type, &errstat, sizeof (errstat));
  674.   if (debug_smux)
  675.     zlog_info ("SMUX GET errstat %ld len: %d", errstat, *len);
  677.   /* Error index. */
  678.   ptr = asn_parse_int (ptr, len, &type, &errindex, sizeof (errindex));
  680.   if (debug_smux)
  681.     zlog_info ("SMUX GET errindex %ld len: %d", errindex, *len);
  683.   return ptr;
  684. }
  686. void
  687. smux_parse_set (char *ptr, size_t len, int action)
  688. {
  689.   long reqid;
  690.   oid oid[MAX_OID_LEN];
  691.   size_t oid_len;
  692.   u_char val_type;
  693.   void *val;
  694.   size_t val_len;
  695.   int ret;
  697.   if (debug_smux)
  698.     zlog_info ("SMUX SET(%s) message parse: len %d",
  699.                (RESERVE1 == action) ? "RESERVE1" : ((FREE == action) ? "FREE" : "COMMIT"),
  700.                len);
  702.   /* Parse SET message header. */
  703.   ptr = smux_parse_get_header (ptr, &len, &reqid);
  705.   /* Parse SET message object ID. */
  706.   ptr = smux_var (ptr, len, oid, &oid_len, &val_len, &val_type, &val);
  708.   ret = smux_set (oid, &oid_len, val_type, val, val_len, action);
  709.   if (debug_smux)
  710.     zlog_info ("SMUX SET ret %d", ret);
  712.   /* Return result. */
  713.   if (RESERVE1 == action)
  714.     smux_getresp_send (oid, oid_len, reqid, ret, 3, ASN_NULL, NULL, 0);
  715. }
  717. void
  718. smux_parse_get (char *ptr, size_t len, int exact)
  719. {
  720.   long reqid;
  721.   oid oid[MAX_OID_LEN];
  722.   size_t oid_len;
  723.   u_char val_type;
  724.   void *val;
  725.   size_t val_len;
  726.   int ret;
  728.   if (debug_smux)
  729.     zlog_info ("SMUX GET message parse: len %d", len);
  730.   
  731.   /* Parse GET message header. */
  732.   ptr = smux_parse_get_header (ptr, &len, &reqid);
  733.   
  734.   /* Parse GET message object ID. We needn't the value come */
  735.   ptr = smux_var (ptr, len, oid, &oid_len, NULL, NULL, NULL);
  737.   /* Traditional getstatptr. */
  738.   if (exact)
  739.     ret = smux_get (oid, &oid_len, exact, &val_type, &val, &val_len);
  740.   else
  741.     ret = smux_getnext (oid, &oid_len, exact, &val_type, &val, &val_len);
  743.   /* Return result. */
  744.   if (ret == 0)
  745.     smux_getresp_send (oid, oid_len, reqid, 0, 0, val_type, val, val_len);
  746.   else
  747.     smux_getresp_send (oid, oid_len, reqid, ret, 3, ASN_NULL, NULL, 0);
  748. }
  750. /* Parse SMUX_CLOSE message. */
  751. void
  752. smux_parse_close (char *ptr, int len)
  753. {
  754.   long reason = 0;
  756.   while (len--)
  757.     {
  758.       reason = (reason << 8) | (long) *ptr;
  759.       ptr++;
  760.     }
  761.   zlog_info ("SMUX_CLOSE with reason: %ld", reason);
  762. }
  764. /* SMUX_RRSP message. */
  765. void
  766. smux_parse_rrsp (char *ptr, int len)
  767. {
  768.   char val;
  769.   long errstat;
  770.   
  771.   ptr = asn_parse_int (ptr, &len, &val, &errstat, sizeof (errstat));
  773.   if (debug_smux)
  774.     zlog_info ("SMUX_RRSP value: %d errstat: %ld", val, errstat);
  775. }
  777. /* Parse SMUX message. */
  778. int
  779. smux_parse (char *ptr, int len)
  780. {
  781.   /* This buffer we'll use for SOUT message. We could allocate it with
  782.      malloc and save only static pointer/lenght, but IMHO static
  783.      buffer is a faster solusion. */
  784.   static u_char sout_save_buff[SMUXMAXPKTSIZE];
  785.   static int sout_save_len = 0;
  787.   int len_income = len; /* see note below: YYY */
  788.   u_char type;
  789.   u_char rollback;
  791.   rollback = ptr[2]; /* important only for SMUX_SOUT */
  793. process_rest: /* see note below: YYY */
  795.   /* Parse SMUX message type and subsequent length. */
  796.   ptr = asn_parse_header (ptr, &len, &type);
  798.   if (debug_smux)
  799.     zlog_info ("SMUX message received type: %d rest len: %d", type, len);
  801.   switch (type)
  802.     {
  803.     case SMUX_OPEN:
  804.       /* Open must be not send from SNMP agent. */
  805.       zlog_warn ("SMUX_OPEN received: resetting connection.");
  806.       return -1;
  807.       break;
  808.     case SMUX_RREQ:
  809.       /* SMUX_RREQ message is invalid for us. */
  810.       zlog_warn ("SMUX_RREQ received: resetting connection.");
  811.       return -1;
  812.       break;
  813.     case SMUX_SOUT:
  814.       /* SMUX_SOUT message is now valied for us. */
  815.       if (debug_smux)
  816.         zlog_info ("SMUX_SOUT(%s)", rollback ? "rollback" : "commit");
  818.       if (sout_save_len > 0)
  819.         {
  820.           smux_parse_set (sout_save_buff, sout_save_len, rollback ? FREE : COMMIT);
  821.           sout_save_len = 0;
  822.         }
  823.       else
  824.         zlog_warn ("SMUX_SOUT sout_save_len=%d - invalid", (int) sout_save_len);
  826.       if (len_income > 3) 
  827.         {
  828.           /* YYY: this strange code has to solve the "slow peer"
  829.              problem: When agent sends SMUX_SOUT message it doesn't
  830.              wait any responce and may send some next message to
  831.              subagent. Then the peer in 'smux_read()' will recieve
  832.              from socket the 'concatenated' buffer, contaning both
  833.              SMUX_SOUT message and the next one
  834.              (SMUX_GET/SMUX_GETNEXT/SMUX_GET). So we should check: if
  835.              the buffer is longer than 3 ( length of SMUX_SOUT ), we
  836.              must process the rest of it.  This effect may be observed
  837.              if 'debug_smux' is set to '1' */
  838.           ptr++;
  839.           len = len_income - 3;
  840.           goto process_rest;
  841.         }
  842.       break;
  843.     case SMUX_GETRSP:
  844.       /* SMUX_GETRSP message is invalid for us. */
  845.       zlog_warn ("SMUX_GETRSP received: resetting connection.");
  846.       return -1;
  847.       break;
  848.     case SMUX_CLOSE:
  849.       /* Close SMUX connection. */
  850.       if (debug_smux)
  851. zlog_info ("SMUX_CLOSE");
  852.       smux_parse_close (ptr, len);
  853.       return -1;
  854.       break;
  855.     case SMUX_RRSP:
  856.       /* This is response for register message. */
  857.       if (debug_smux)
  858. zlog_info ("SMUX_RRSP");
  859.       smux_parse_rrsp (ptr, len);
  860.       break;
  861.     case SMUX_GET:
  862.       /* Exact request for object id. */
  863.       if (debug_smux)
  864. zlog_info ("SMUX_GET");
  865.       smux_parse_get (ptr, len, 1);
  866.       break;
  867.     case SMUX_GETNEXT:
  868.       /* Next request for object id. */
  869.       if (debug_smux)
  870. zlog_info ("SMUX_GETNEXT");
  871.       smux_parse_get (ptr, len, 0);
  872.       break;
  873.     case SMUX_SET:
  874.       /* SMUX_SET is supported with some limitations. */
  875.       if (debug_smux)
  876. zlog_info ("SMUX_SET");
  878.       /* save the data for future SMUX_SOUT */
  879.       memcpy (sout_save_buff, ptr, len);
  880.       sout_save_len = len;
  881.       smux_parse_set (ptr, len, RESERVE1);
  882.       break;
  883.     default:
  884.       zlog_info ("Unknown type: %d", type);
  885.       break;
  886.     }
  887.   return 0;
  888. }
  890. /* SMUX message read function. */
  891. int
  892. smux_read (struct thread *t)
  893. {
  894.   int sock;
  895.   int len;
  896.   u_char buf[SMUXMAXPKTSIZE];
  897.   int ret;
  899.   /* Clear thread. */
  900.   sock = THREAD_FD (t);
  901.   smux_read_thread = NULL;
  903.   if (debug_smux)
  904.     zlog_info ("SMUX read start");
  906.   /* Read message from SMUX socket. */
  907.   len = recv (sock, buf, SMUXMAXPKTSIZE, 0);
  909.   if (len < 0)
  910.     {
  911.       zlog_warn ("Can't read all SMUX packet: %s", strerror (errno));
  912.       close (sock);
  913.       smux_sock = -1;
  914.       smux_event (SMUX_CONNECT, 0);
  915.       return -1;
  916.     }
  918.   if (len == 0)
  919.     {
  920.       zlog_warn ("SMUX connection closed: %d", sock);
  921.       close (sock);
  922.       smux_sock = -1;
  923.       smux_event (SMUX_CONNECT, 0);
  924.       return -1;
  925.     }
  927.   if (debug_smux)
  928.     zlog_info ("SMUX read len: %d", len);
  930.   /* Parse the message. */
  931.   ret = smux_parse (buf, len);
  933.   if (ret < 0)
  934.     {
  935.       close (sock);
  936.       smux_sock = -1;
  937.       smux_event (SMUX_CONNECT, 0);
  938.       return -1;
  939.     }
  941.   /* Regiser read thread. */
  942.   smux_event (SMUX_READ, sock);
  944.   return 0;
  945. }
  947. int
  948. smux_open (int sock)
  949. {
  950.   u_char buf[BUFSIZ];
  951.   u_char *ptr;
  952.   int len;
  953.   u_long version;
  954.   u_char progname[] = "zebra-" ZEBRA_VERSION;
  956.   if (debug_smux)
  957.     {
  958.       smux_oid_dump ("SMUX open oid", smux_oid, smux_oid_len);
  959.       zlog_info ("SMUX open progname: %s", progname);
  960.       zlog_info ("SMUX open password: %s", smux_passwd);
  961.     }
  963.   ptr = buf;
  964.   len = BUFSIZ;
  966.   /* SMUX Header.  As placeholder. */
  967.   ptr = asn_build_header (ptr, &len, (u_char) SMUX_OPEN, 0);
  969.   /* SMUX Open. */
  970.   version = 0;
  971.   ptr = asn_build_int (ptr, &len, 
  972.        (u_char)(ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_INTEGER),
  973.        &version, sizeof (u_long));
  975.   /* SMUX connection oid. */
  976.   ptr = asn_build_objid (ptr, &len,
  977.  (u_char) 
  978.  (ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_OBJECT_ID),
  979.  smux_oid, smux_oid_len);
  981.   /* SMUX connection description. */
  982.   ptr = asn_build_string (ptr, &len, 
  983.   (u_char)
  984.   (ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_OCTET_STR),
  985.   progname, strlen (progname));
  987.   /* SMUX connection password. */
  988.   ptr = asn_build_string (ptr, &len, 
  989.   (u_char)
  990.   (ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_OCTET_STR),
  991.   smux_passwd, strlen (smux_passwd));
  993.   /* Fill in real SMUX header.  We exclude ASN header size (2). */
  994.   len = BUFSIZ;
  995.   asn_build_header (buf, &len, (u_char) SMUX_OPEN, (ptr - buf) - 2);
  997.   return send (sock, buf, (ptr - buf), 0);
  998. }
  1000. int
  1001. smux_trap (oid *name, size_t namelen,
  1002.    oid *iname, size_t inamelen,
  1003.    struct trap_object *trapobj, size_t trapobjlen,
  1004.    unsigned int tick, u_char sptrap)
  1005. {
  1006.   int i;
  1007.   u_char buf[BUFSIZ];
  1008.   u_char *ptr;
  1009.   int len, length;
  1010.   struct in_addr addr;
  1011.   unsigned long val;
  1012.   u_char *h1, *h1e;
  1014.   ptr = buf;
  1015.   len = BUFSIZ;
  1016.   length = len;
  1018.   /* When SMUX connection is not established. */
  1019.   if (smux_sock < 0)
  1020.     return 0;
  1022.   /* SMUX header. */
  1023.   ptr = asn_build_header (ptr, &len, (u_char) SMUX_TRAP, 0);
  1025.   /* Sub agent enterprise oid. */
  1026.   ptr = asn_build_objid (ptr, &len,
  1027.  (u_char) 
  1028.  (ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_OBJECT_ID),
  1029.  smux_oid, smux_oid_len);
  1031.   /* IP address. */
  1032.   addr.s_addr = 0;
  1033.   ptr = asn_build_string (ptr, &len, 
  1034.   (u_char)
  1035.   (ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_IPADDRESS),
  1036.   (u_char *)&addr, sizeof (struct in_addr));
  1038.   /* Generic trap integer. */
  1039.   val = SNMP_TRAP_ENTERPRISESPECIFIC;
  1040.   ptr = asn_build_int (ptr, &len, 
  1041.        (u_char)(ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_INTEGER),
  1042.        &val, sizeof (int));
  1044.   /* Specific trap integer. */
  1045.   val = sptrap;
  1046.   ptr = asn_build_int (ptr, &len, 
  1047.        (u_char)(ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_INTEGER),
  1048.        &val, sizeof (int));
  1050.   /* Timeticks timestamp. */
  1051.   val = 0;
  1052.   ptr = asn_build_unsigned_int (ptr, &len, 
  1053. (u_char)(ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_TIMETICKS),
  1054. &val, sizeof (int));
  1055.   
  1056.   /* Variables. */
  1057.   h1 = ptr;
  1058.   ptr = asn_build_sequence (ptr, &len, 
  1059.     (u_char) (ASN_SEQUENCE | ASN_CONSTRUCTOR),
  1060.     0);
  1063.   /* Iteration for each objects. */
  1064.   h1e = ptr;
  1065.   for (i = 0; i < trapobjlen; i++)
  1066.     {
  1067.       int ret;
  1068.       oid oid[MAX_OID_LEN];
  1069.       size_t oid_len;
  1070.       void *val;
  1071.       size_t val_len;
  1072.       u_char val_type;
  1074.       /* Make OID. */
  1075.       oid_copy (oid, name, namelen);
  1076.       oid_copy (oid + namelen, trapobj[i].name, trapobj[i].namelen);
  1077.       oid_copy (oid + namelen + trapobj[i].namelen, iname, inamelen);
  1078.       oid_len = namelen + trapobj[i].namelen + inamelen;
  1080.       if (debug_smux)
  1081. smux_oid_dump ("Trap", oid, oid_len);
  1083.       ret = smux_get (oid, &oid_len, 1, &val_type, &val, &val_len);
  1085.       if (debug_smux)
  1086. zlog_info ("smux_get result %d", ret);
  1088.       if (ret == 0)
  1089. ptr = snmp_build_var_op (ptr, oid, &oid_len,
  1090.  val_type, val_len, val, &len);
  1091.     }
  1093.   /* Now variable size is known, fill in size */
  1094.   asn_build_sequence(h1, &length,
  1095.      (u_char) (ASN_SEQUENCE | ASN_CONSTRUCTOR),
  1096.      ptr - h1e);
  1098.   /* Fill in size of whole sequence */
  1099.   len = BUFSIZ;
  1100.   asn_build_header (buf, &len, (u_char) SMUX_TRAP, (ptr - buf) - 2);
  1102.   return send (smux_sock, buf, (ptr - buf), 0);
  1103. }
  1105. int
  1106. smux_register (int sock)
  1107. {
  1108.   u_char buf[BUFSIZ];
  1109.   u_char *ptr;
  1110.   int len, ret;
  1111.   long priority;
  1112.   long operation;
  1113.   struct subtree *subtree;
  1114.   struct listnode *node;
  1116.   ret = 0;
  1118.   for (node = treelist->head; node; node = node->next)
  1119.     {
  1120.       ptr = buf;
  1121.       len = BUFSIZ;
  1123.       subtree = node->data;
  1125.       /* SMUX RReq Header. */
  1126.       ptr = asn_build_header (ptr, &len, (u_char) SMUX_RREQ, 0);
  1128.       /* Register MIB tree. */
  1129.       ptr = asn_build_objid (ptr, &len,
  1130.     (u_char)
  1131.     (ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_OBJECT_ID),
  1132.     subtree->name, subtree->name_len);
  1134.       /* Priority. */
  1135.       priority = -1;
  1136.       ptr = asn_build_int (ptr, &len, 
  1137.           (u_char)(ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_INTEGER),
  1138.           &priority, sizeof (u_long));
  1140.       /* Operation. */
  1141.       operation = 2; /* Register R/W */
  1142.       ptr = asn_build_int (ptr, &len, 
  1143.           (u_char)(ASN_UNIVERSAL | ASN_PRIMITIVE | ASN_INTEGER),
  1144.           &operation, sizeof (u_long));
  1146.       if (debug_smux)
  1147.         {
  1148.           smux_oid_dump ("SMUX register oid", subtree->name, subtree->name_len);
  1149.           zlog_info ("SMUX register priority: %ld", priority);
  1150.           zlog_info ("SMUX register operation: %ld", operation);
  1151.         }
  1153.       len = BUFSIZ;
  1154.       asn_build_header (buf, &len, (u_char) SMUX_RREQ, (ptr - buf) - 2);
  1155.       ret = send (sock, buf, (ptr - buf), 0);
  1156.       if (ret < 0)
  1157.         return ret;
  1158.     }
  1159.   return ret;
  1160. }
  1162. /* Try to connect to SNMP agent. */
  1163. int
  1164. smux_connect (struct thread *t)
  1165. {
  1166.   int ret;
  1168.   if (debug_smux)
  1169.     zlog_info ("SMUX connect try %d", fail + 1);
  1171.   /* Clear thread poner of myself. */
  1172.   smux_connect_thread = NULL;
  1174.   /* Make socket.  Try to connect. */
  1175.   smux_sock = smux_socket ();
  1176.   if (smux_sock < 0)
  1177.     {
  1178.       if (++fail < SMUX_MAX_FAILURE)
  1179. smux_event (SMUX_CONNECT, 0);
  1180.       return 0;
  1181.     }
  1183.   /* Send OPEN PDU. */
  1184.   ret = smux_open (smux_sock);
  1185.   if (ret < 0)
  1186.     {
  1187.       zlog_warn ("SMUX open message send failed: %s", strerror (errno));
  1188.       close (smux_sock);
  1189.       smux_sock = -1;
  1190.       if (++fail < SMUX_MAX_FAILURE)
  1191. smux_event (SMUX_CONNECT, 0);
  1192.       return -1;
  1193.     }
  1195.   /* Send any outstanding register PDUs. */
  1196.   ret = smux_register (smux_sock);
  1197.   if (ret < 0)
  1198.     {
  1199.       zlog_warn ("SMUX register message send failed: %s", strerror (errno));
  1200.       close (smux_sock);
  1201.       smux_sock = -1;
  1202.       if (++fail < SMUX_MAX_FAILURE)
  1203. smux_event (SMUX_CONNECT, 0);
  1204.       return -1;
  1205.     }
  1207.   /* Everything goes fine. */
  1208.   smux_event (SMUX_READ, smux_sock);
  1210.   return 0;
  1211. }
  1213. /* Clear all SMUX related resources. */
  1214. void
  1215. smux_stop ()
  1216. {
  1217.   if (smux_read_thread)
  1218.     thread_cancel (smux_read_thread);
  1219.   if (smux_connect_thread)
  1220.     thread_cancel (smux_connect_thread);
  1222.   if (smux_sock >= 0)
  1223.     {
  1224.       close (smux_sock);
  1225.       smux_sock = -1;
  1226.     }
  1227. }
  1229. extern struct thread_master *master;
  1231. void
  1232. smux_event (enum smux_event event, int sock)
  1233. {
  1234.   switch (event)
  1235.     {
  1236.     case SMUX_SCHEDULE:
  1237.       smux_connect_thread = thread_add_event (master, smux_connect, NULL, 0);
  1238.       break;
  1239.     case SMUX_CONNECT:
  1240.       smux_connect_thread = thread_add_timer (master, smux_connect, NULL, 10);
  1241.       break;
  1242.     case SMUX_READ:
  1243.       smux_read_thread = thread_add_read (master, smux_read, NULL, sock);
  1244.       break;
  1245.     default:
  1246.       break;
  1247.     }
  1248. }
  1250. int
  1251. smux_str2oid (char *str, oid *oid, size_t *oid_len)
  1252. {
  1253.   int len;
  1254.   int val;
  1256.   len = 0;
  1257.   val = 0;
  1258.   *oid_len = 0;
  1260.   if (*str == '.')
  1261.     str++;
  1262.   if (*str == '')
  1263.     return 0;
  1265.   while (1)
  1266.     {
  1267.       if (! isdigit (*str))
  1268. return -1;
  1270.       while (isdigit (*str))
  1271. {
  1272.   val *= 10;
  1273.   val += (*str - '0');
  1274.   str++;
  1275. }
  1277.       if (*str == '')
  1278. break;
  1279.       if (*str != '.')
  1280. return -1;
  1282.       oid[len++] = val;
  1283.       val = 0;
  1284.       str++;
  1285.     }
  1287.   oid[len++] = val;
  1288.   *oid_len = len;
  1290.   return 0;
  1291. }
  1293. oid *
  1294. smux_oid_dup (oid *objid, size_t objid_len)
  1295. {
  1296.   oid *new;
  1298.   new = XMALLOC (MTYPE_TMP, sizeof (oid) * objid_len);
  1299.   oid_copy (new, objid, objid_len);
  1301.   return new;
  1302. }
  1304. int
  1305. smux_peer_oid (struct vty *vty, char *oid_str, char *passwd_str)
  1306. {
  1307.   int ret;
  1308.   oid oid[MAX_OID_LEN];
  1309.   size_t oid_len;
  1311.   ret = smux_str2oid (oid_str, oid, &oid_len);
  1312.   if (ret != 0)
  1313.     {
  1314.       vty_out (vty, "object ID malformed%s", VTY_NEWLINE);
  1315.       return CMD_WARNING;
  1316.     }
  1318.   if (smux_oid && smux_oid != smux_default_oid)
  1319.     free (smux_oid);
  1321.   if (smux_passwd && smux_passwd != smux_default_passwd)
  1322.     {
  1323.       free (smux_passwd);
  1324.       smux_passwd = NULL;
  1325.     }
  1327.   smux_oid = smux_oid_dup (oid, oid_len);
  1328.   smux_oid_len = oid_len;
  1330.   if (passwd_str)
  1331.     smux_passwd = strdup (passwd_str);
  1333.   return CMD_SUCCESS;
  1334. }
  1336. int
  1337. smux_header_generic (struct variable *v, oid *name, size_t *length, int exact,
  1338.      size_t *var_len, WriteMethod **write_method)
  1339. {
  1340.   oid fulloid[MAX_OID_LEN];
  1341.   int ret;
  1343.   oid_copy (fulloid, v->name, v->namelen);
  1344.   fulloid[v->namelen] = 0;
  1345.   /* Check against full instance. */
  1346.   ret = oid_compare (name, *length, fulloid, v->namelen + 1);
  1348.   /* Check single instance. */
  1349.   if ((exact && (ret != 0)) || (!exact && (ret >= 0)))
  1350. return MATCH_FAILED;
  1352.   /* In case of getnext, fill in full instance. */
  1353.   memcpy (name, fulloid, (v->namelen + 1) * sizeof (oid));
  1354.   *length = v->namelen + 1;
  1356.   *write_method = 0;
  1357.   *var_len = sizeof(long);    /* default to 'long' results */
  1359.   return MATCH_SUCCEEDED;
  1360. }
  1362. int
  1363. smux_peer_default ()
  1364. {
  1365.   if (smux_oid != smux_default_oid)
  1366.     {
  1367.       free (smux_oid);
  1368.       smux_oid = smux_default_oid;
  1369.       smux_oid_len = smux_default_oid_len;
  1370.     }
  1371.   if (smux_passwd != smux_default_passwd)
  1372.     {
  1373.       free (smux_passwd);
  1374.       smux_passwd = smux_default_passwd;
  1375.     }
  1376.   return CMD_SUCCESS;
  1377. }
  1379. DEFUN (smux_peer,
  1380.        smux_peer_cmd,
  1381.        "smux peer OID",
  1382.        "SNMP MUX protocol settingsn"
  1383.        "SNMP MUX peer settingsn"
  1384.        "Object ID used in SMUX peeringn")
  1385. {
  1386.   return smux_peer_oid (vty, argv[0], NULL);
  1387. }
  1389. DEFUN (smux_peer_password,
  1390.        smux_peer_password_cmd,
  1391.        "smux peer OID PASSWORD",
  1392.        "SNMP MUX protocol settingsn"
  1393.        "SNMP MUX peer settingsn"
  1394.        "SMUX peering object IDn"
  1395.        "SMUX peering passwordn")
  1396. {
  1397.   return smux_peer_oid (vty, argv[0], argv[1]);
  1398. }
  1400. DEFUN (no_smux_peer,
  1401.        no_smux_peer_cmd,
  1402.        "no smux peer OID",
  1403.        NO_STR
  1404.        "SNMP MUX protocol settingsn"
  1405.        "SNMP MUX peer settingsn"
  1406.        "Object ID used in SMUX peeringn")
  1407. {
  1408.   return smux_peer_default ();
  1409. }
  1411. DEFUN (no_smux_peer_password,
  1412.        no_smux_peer_password_cmd,
  1413.        "no smux peer OID PASSWORD",
  1414.        NO_STR
  1415.        "SNMP MUX protocol settingsn"
  1416.        "SNMP MUX peer settingsn"
  1417.        "SMUX peering object IDn"
  1418.        "SMUX peering passwordn")
  1419. {
  1420.   return smux_peer_default ();
  1421. }
  1423. int
  1424. config_write_smux (struct vty *vty)
  1425. {
  1426.   int first = 1;
  1427.   int i;
  1429.   if (smux_oid != smux_default_oid || smux_passwd != smux_default_passwd)
  1430.     {
  1431.       vty_out (vty, "smux peer ");
  1432.       for (i = 0; i < smux_oid_len; i++)
  1433. {
  1434.   vty_out (vty, "%s%d", first ? "" : ".", (int) smux_oid[i]);
  1435.   first = 0;
  1436. }
  1437.       vty_out (vty, " %s%s", smux_passwd, VTY_NEWLINE);
  1438.     }
  1439.   return 0;
  1440. }
  1442. /* Register subtree to smux master tree. */
  1443. void
  1444. smux_register_mib (char *descr, struct variable *var, size_t width, int num, 
  1445.    oid name[], size_t namelen)
  1446. {
  1447.   struct subtree *tree;
  1449.   tree = (struct subtree *)malloc(sizeof(struct subtree));
  1450.   oid_copy (tree->name, name, namelen);
  1451.   tree->name_len = namelen;
  1452.   tree->variables = var;
  1453.   tree->variables_num = num;
  1454.   tree->variables_width = width;
  1455.   tree->registered = 0;
  1456.   listnode_add_sort(treelist, tree);
  1457. }
  1459. void
  1460. smux_reset ()
  1461. {
  1462.   /* Setting configuration to default. */
  1463.   smux_peer_default ();
  1464. }
  1466. /* Compare function to keep treelist sorted */
  1467. static int
  1468. smux_tree_cmp(struct subtree *tree1, struct subtree *tree2)
  1469. {
  1470.   return oid_compare(tree1->name, tree1->name_len, 
  1471.      tree2->name, tree2->name_len);
  1472. }
  1474. /* Initialize some values then schedule first SMUX connection. */
  1475. void
  1476. smux_init (oid defoid[], size_t defoid_len)
  1477. {
  1478.   /* Set default SMUX oid. */
  1479.   smux_default_oid = defoid;
  1480.   smux_default_oid_len = defoid_len;
  1482.   smux_oid = smux_default_oid;
  1483.   smux_oid_len = smux_default_oid_len;
  1484.   smux_passwd = smux_default_passwd;
  1485.   
  1486.   /* Make MIB tree. */
  1487.   treelist = list_new();
  1488.   treelist->cmp = (int (*)(void *, void *))smux_tree_cmp;
  1490.   /* Install commands. */
  1491.   install_node (&smux_node, config_write_smux);
  1493.   install_element (CONFIG_NODE, &smux_peer_cmd);
  1494.   install_element (CONFIG_NODE, &smux_peer_password_cmd);
  1495.   install_element (CONFIG_NODE, &no_smux_peer_cmd);
  1496.   install_element (CONFIG_NODE, &no_smux_peer_password_cmd);
  1497. }
  1499. void
  1500. smux_start(void)
  1501. {
  1502.   /* Schedule first connection. */
  1503.   smux_event (SMUX_SCHEDULE, 0);
  1504. }
  1505. #endif /* HAVE_SNMP */