ldp/ldp_init.c

   1
   2 /*
   3  *  Copyright (C) James R. Leu 2000
   4  *  jleu@mindspring.com
   5  *
   6  *  This software is covered under the LGPL, for more
   7  *  info check out http://www.gnu.org/copyleft/lgpl.html
   8  */
   9
  10 #include "ldp_struct.h"
  11 #include "ldp_mesg.h"
  12 #include "ldp_entity.h"
  13 #include "ldp_nortel.h"
  14 #include "ldp_buf.h"
  15 #include "ldp_pdu_setup.h"
  16
  17 #include "mpls_assert.h"
  18 #include "mpls_socket_impl.h"
  19 #include "mpls_trace_impl.h"
  20 #if MPLS_USE_LSR
  21 #include "lsr_cfg.h"
  22 #else
  23 #include "mpls_mpls_impl.h"
  24 #endif
  25
  26 void ldp_init_prepare(ldp_mesg * msg, ldp_global * g, uint32_t msgid,
  27   ldp_session * s)
  28 {
  29   mplsLdpInitMsg_t *init = NULL;
  30   uint32_t remote_labelspace;
  31   uint32_t path_vector_limit;
  32   uint32_t remote_lsraddr;
  33   uint8_t direction = 0;
  34   ldp_adj *a = MPLS_LIST_HEAD(&s->adj_root);
  35   uint32_t loop = 0;
  36   uint8_t merge = 0;
  37   mpls_range range;
  38   uint8_t len = 0;
  39
  40   MPLS_ASSERT(s && a);
  41
  42   LDP_ENTER(g->user_data, "ldp_init_create");
  43
  44   ldp_mesg_prepare(msg, MPLS_INIT_MSGTYPE, msgid);
  45   init = &msg->u.init;
  46
  47   remote_lsraddr = a->remote_lsr_address.u.ipv4;
  48   remote_labelspace = a->remote_label_space;
  49
  50   loop = (s->cfg_loop_detection_mode == LDP_LOOP_NONE) ? (0) : (1);
  51   if (loop == LDP_LOOP_NONE) {
  52     path_vector_limit = 0;
  53   } else {
  54     path_vector_limit = s->cfg_path_vector_limit;
  55   }
  56
  57   init->cspExists = 1;
  58
  59   init->baseMsg.msgLength += setupCspTlv(&(init->csp), s->cfg_keepalive,
  60     s->cfg_distribution_mode, loop, path_vector_limit, s->cfg_max_pdu,
  61     remote_lsraddr, remote_labelspace, 0);
  62
  63   init->aspExists = 0;
  64   init->fspExists = 0;
  65
  66   range.label_space = s->cfg_label_space;
  67 #if MPLS_USE_LSR
  68 #else
  69   mpls_mpls_get_label_space_range(g->mpls_handle,&range);
  70 #endif
  71
  72   switch (range.type) {
  73     case MPLS_LABEL_RANGE_ATM_VP:
  74       MPLS_ASSERT(0);
  75     case MPLS_LABEL_RANGE_ATM_VC:
  76     case MPLS_LABEL_RANGE_ATM_VP_VC:
  77       init->aspExists = 1;
  78       init->baseMsg.msgLength += setupAspTlv(&(init->asp), merge, direction);
  79       init->baseMsg.msgLength += addLblRng2AspTlv(&(init->asp),
  80         range.min.u.atm.vpi, range.min.u.atm.vci, range.max.u.atm.vpi,
  81         range.max.u.atm.vci);
  82       break;
  83     case MPLS_LABEL_RANGE_FR_10:
  84       len = 0;                /* Section 3.5.3 fspTlv */
  85     case MPLS_LABEL_RANGE_FR_24:
  86       init->fspExists = 1;
  87
  88       if (range.type == MPLS_LABEL_RANGE_FR_24) {
  89         len = 2;              /* Section 3.5.3 fspTlv */
  90       }
  91
  92       init->baseMsg.msgLength += setupFspTlv(&(init->fsp), merge, direction);
  93       init->baseMsg.msgLength += addLblRng2FspTlv(&(init->fsp), 0, len,
  94         range.min.u.fr.dlci, 0, range.max.u.fr.dlci);
  95       break;
  96     case MPLS_LABEL_RANGE_GENERIC:
  97       break;
  98   }
  99   LDP_EXIT(g->user_data, "ldp_init_create");
 100 }
 101
 102 mpls_return_enum ldp_init_send(ldp_global * g, ldp_session * s)
 103 {
 104   mpls_return_enum result = MPLS_FAILURE;
 105
 106   MPLS_ASSERT(s);
 107
 108   LDP_ENTER(g->user_data, "ldp_init_send");
 109
 110   ldp_init_prepare(s->tx_message, g, g->message_identifier++, s);
 111
 112   LDP_TRACE_LOG(g->user_data, MPLS_TRACE_STATE_SEND, LDP_TRACE_FLAG_INIT,
 113     "Init Send: session(%d)\n", s->index);
 114
 115   result = ldp_mesg_send_tcp(g, s, s->tx_message);
 116
 117   LDP_EXIT(g->user_data, "ldp_init_send");
 118
 119   return result;
 120 }
 121
 122 mpls_return_enum ldp_init_process(ldp_global * g, ldp_session * s,
 123   ldp_mesg * msg)
 124 {
 125   mpls_range range;
 126
 127   MPLS_MSGPTR(Init);
 128
 129   MPLS_ASSERT(s);
 130
 131   LDP_ENTER(g->user_data, "ldp_init_process");
 132
 133   LDP_TRACE_LOG(g->user_data, MPLS_TRACE_STATE_RECV, LDP_TRACE_FLAG_INIT,
 134     "Init Recv: session(%d)\n", s->index);
 135
 136   MPLS_MSGPARAM(Init) = &msg->u.init;
 137
 138   range.label_space = s->cfg_label_space;
 139
 140 #if MPLS_USE_LSR
 141 #else
 142   mpls_mpls_get_label_space_range(g->mpls_handle, &range);
 143 #endif
 144
 145   if (MPLS_MSGPARAM(Init)->csp.rcvLsrAddress != g->lsr_identifier.u.ipv4 ||
 146     MPLS_MSGPARAM(Init)->csp.rcvLsId != range.label_space) {
 147     LDP_EXIT(g->user_data, "ldp_init_process-error");
 148     s->shutdown_notif = LDP_NOTIF_BAD_LDP_ID;
 149     s->shutdown_fatal = MPLS_BOOL_FALSE;
 150     return MPLS_FAILURE;
 151   }
 152
 153   if (MPLS_MSGPARAM(Init)->csp.holdTime == 0) {
 154     LDP_EXIT(g->user_data, "ldp_init_process-error");
 155     s->shutdown_notif = LDP_NOTIF_SESSION_REJECTED_BAD_KEEPALIVE_TIME;
 156     s->shutdown_fatal = MPLS_BOOL_FALSE;
 157     return MPLS_FAILURE;
 158   }
 159
 160   if (MPLS_MSGPARAM(Init)->csp.maxPduLen <= 255)
 161     MPLS_MSGPARAM(Init)->csp.maxPduLen = 4096; /* Section 3.5.3. */
 162
 163   s->remote_max_pdu = MPLS_MSGPARAM(Init)->csp.maxPduLen;
 164   s->remote_keepalive = MPLS_MSGPARAM(Init)->csp.holdTime;
 165   s->remote_path_vector_limit = MPLS_MSGPARAM(Init)->csp.flags.flags.pvl;
 166   s->remote_distribution_mode =
 167     (ldp_distribution_mode) MPLS_MSGPARAM(Init)->csp.flags.flags.lad;
 168
 169   if (s->remote_keepalive < s->cfg_keepalive) {
 170     s->oper_keepalive = s->remote_keepalive;
 171   } else {
 172     s->oper_keepalive = s->cfg_keepalive;
 173   }
 174
 175   /* JLEU: eventually this should be configured by the user */
 176   s->oper_keepalive_interval = s->oper_keepalive / 3;
 177
 178   if (MPLS_MSGPARAM(Init)->csp.flags.flags.ld == 0) {
 179     s->remote_loop_detection = MPLS_BOOL_FALSE;
 180   } else {
 181     s->remote_loop_detection = MPLS_BOOL_TRUE;
 182   }
 183
 184   if (s->remote_max_pdu < s->cfg_max_pdu) {
 185     s->oper_max_pdu = s->remote_max_pdu;
 186   }
 187
 188   if (s->remote_distribution_mode != s->cfg_distribution_mode) {
 189     if (range.type == MPLS_LABEL_RANGE_GENERIC) {
 190       s->oper_distribution_mode = LDP_DISTRIBUTION_UNSOLICITED;
 191     } else {
 192       s->oper_distribution_mode = LDP_DISTRIBUTION_ONDEMAND;
 193     }
 194   }
 195
 196   if ((s->remote_loop_detection == MPLS_BOOL_TRUE) &&
 197     (g->loop_detection_mode != LDP_LOOP_NONE)) {
 198     s->oper_loop_detection = s->cfg_loop_detection_mode;
 199   } else {
 200     s->oper_loop_detection = LDP_LOOP_NONE;
 201   }
 202
 203   if (MPLS_MSGPARAM(Init)->aspExists) {
 204     if (range.type >= MPLS_LABEL_RANGE_ATM_VP && range.type <= MPLS_LABEL_RANGE_ATM_VP_VC) {
 205       MPLS_ASSERT(0);
 206     } else {
 207       s->shutdown_notif = LDP_NOTIF_SESSION_REJECTED_PARAMETERS_LABEL_RANGE;
 208       s->shutdown_fatal = MPLS_BOOL_FALSE;
 209       return MPLS_FAILURE;
 210     }
 211   } else if (MPLS_MSGPARAM(Init)->fspExists) {
 212     if (range.type >= MPLS_LABEL_RANGE_FR_10 && range.type <= MPLS_LABEL_RANGE_FR_24) {
 213       MPLS_ASSERT(0);
 214     } else {
 215       s->shutdown_notif = LDP_NOTIF_SESSION_REJECTED_PARAMETERS_LABEL_RANGE;
 216       s->shutdown_fatal = MPLS_BOOL_FALSE;
 217       return MPLS_FAILURE;
 218     }
 219   }
 220
 221   LDP_EXIT(g->user_data, "ldp_init_process");
 222
 223   return MPLS_SUCCESS;
 224 }