tsock = &scm->test_socket[i];
#ifdef VCL_TEST
tsock->fd =
- vppcom_session_create (VPPCOM_VRF_DEFAULT, VPPCOM_PROTO_TCP,
- 1 /* is_nonblocking */ );
+ vppcom_session_create (VPPCOM_PROTO_TCP, 1 /* is_nonblocking */ );
if (tsock->fd < 0)
{
errno = -tsock->fd;
}
else
{
- ctrl->fd = vppcom_session_create (VPPCOM_VRF_DEFAULT, VPPCOM_PROTO_TCP,
+ ctrl->fd = vppcom_session_create (VPPCOM_PROTO_TCP,
0 /* is_nonblocking */ );
if (ctrl->fd < 0)
{
scm->server_addr.sin_port = htons (atoi (argv[optind]));
#ifdef VCL_TEST
- scm->server_endpt.vrf = VPPCOM_VRF_DEFAULT;
scm->server_endpt.is_ip4 = (scm->server_addr.sin_family == AF_INET);
scm->server_endpt.ip = (uint8_t *) & scm->server_addr.sin_addr;
scm->server_endpt.port = (uint16_t) scm->server_addr.sin_port;
((sock_type == SOCK_STREAM) || (sock_type == SOCK_DGRAM)))
{
int sid;
- u32 vrf = VPPCOM_VRF_DEFAULT;
u8 proto = ((sock_type == SOCK_DGRAM) ?
VPPCOM_PROTO_UDP : VPPCOM_PROTO_TCP);
func_str = "vppcom_session_create";
if (VCOM_DEBUG > 0)
- clib_warning ("LDP<%d>: : calling %s(): vrf %u, "
+ clib_warning ("LDP<%d>: : calling %s(): "
"proto %u (%s), is_nonblocking %u",
- getpid (), func_str, vrf, proto,
+ getpid (), func_str, proto,
vppcom_proto_str (proto), is_nonblocking);
- sid = vppcom_session_create (vrf, proto, is_nonblocking);
+ sid = vppcom_session_create (proto, is_nonblocking);
if (sid < 0)
{
errno = -sid;
func_str = "vppcom_session_bind";
- ep.vrf = VPPCOM_VRF_DEFAULT;
switch (addr->sa_family)
{
case AF_INET:
func_str = "vppcom_session_connect";
- ep.vrf = VPPCOM_VRF_DEFAULT;
switch (addr->sa_family)
{
case AF_INET:
if (addr)
{
ep = &_ep;
- ep->vrf = VPPCOM_VRF_DEFAULT;
switch (addr->sa_family)
{
case AF_INET:
u32 wait_cont_idx;
vppcom_epoll_t vep;
int libc_epfd;
- u32 vrf;
vppcom_ip46_t lcl_addr;
vppcom_ip46_t peer_addr;
u16 lcl_port; // network order
cmp->client_index = vcm->my_client_index;
cmp->context = session_index;
- cmp->vrf = session->vrf;
cmp->is_ip4 = session->peer_addr.is_ip4;
clib_memcpy (cmp->ip, &session->peer_addr.ip46, sizeof (cmp->ip));
cmp->port = session->peer_port;
bmp->_vl_msg_id = ntohs (VL_API_BIND_SOCK);
bmp->client_index = vcm->my_client_index;
bmp->context = session_index;
- bmp->vrf = session->vrf;
bmp->is_ip4 = session->lcl_addr.is_ip4;
clib_memcpy (bmp->ip, &session->lcl_addr.ip46, sizeof (bmp->ip));
bmp->port = session->lcl_port;
}
int
-vppcom_session_create (u32 vrf, u8 proto, u8 is_nonblocking)
+vppcom_session_create (u8 proto, u8 is_nonblocking)
{
session_t *session;
u32 session_index;
memset (session, 0, sizeof (*session));
session_index = session - vcm->sessions;
- session->vrf = vrf;
session->proto = proto;
session->state = STATE_START;
session->is_nonblocking = is_nonblocking ? 1 : 0;
/* *INDENT-OFF* */
ELOG_TYPE_DECLARE (e) =
{
- .format = "session_create:vrf:%d proto:%d state:%d is_nonblocking:%d",
- .format_args = "i4i4i4i4",
+ .format = "session_create:proto:%d state:%d is_nonblocking:%d",
+ .format_args = "i4i4i4",
};
struct
{
- u32 data[4];
+ u32 data[3];
} *ed;
ed = ELOG_TRACK_DATA (&vcm->elog_main, e, session->elog_track);
- ed->data[0] = session->vrf;
- ed->data[1] = session->proto;
- ed->data[2] = session->state;
- ed->data[3] = session->is_nonblocking;
+ ed->data[0] = session->proto;
+ ed->data[1] = session->state;
+ ed->data[2] = session->is_nonblocking;
/* *INDENT-ON* */
}
goto done;
}
- session->vrf = ep->vrf;
session->lcl_addr.is_ip4 = ep->is_ip4;
session->lcl_addr.ip46 = to_ip46 (!ep->is_ip4, ep->ip);
session->lcl_port = ep->port;
if (ep)
{
- ep->vrf = client_session->vrf;
ep->is_cut_thru = client_session->is_cut_thru;
ep->is_ip4 = client_session->peer_addr.is_ip4;
ep->port = client_session->peer_port;
goto done;
}
- session->vrf = server_ep->vrf;
session->peer_addr.is_ip4 = server_ep->is_ip4;
session->peer_addr.ip46 = to_ip46 (!server_ep->is_ip4, server_ep->ip);
session->peer_port = server_ep->port;
if (PREDICT_TRUE (buffer && buflen &&
(*buflen >= sizeof (*ep)) && ep->ip))
{
- ep->vrf = session->vrf;
ep->is_ip4 = session->peer_addr.is_ip4;
ep->port = session->peer_port;
if (session->peer_addr.is_ip4)
if (PREDICT_TRUE (buffer && buflen &&
(*buflen >= sizeof (*ep)) && ep->ip))
{
- ep->vrf = session->vrf;
ep->is_ip4 = session->lcl_addr.is_ip4;
ep->port = session->lcl_port;
if (session->lcl_addr.is_ip4)
clib_spinlock_unlock (&vcm->sessions_lockp);
goto done;
}
- ep->vrf = session->vrf;
ep->is_ip4 = session->peer_addr.is_ip4;
ep->port = session->peer_port;
if (session->peer_addr.is_ip4)
* VPPCOM Public API Definitions, Enums, and Data Structures
*/
#define INVALID_SESSION_ID (~0)
-#define VPPCOM_VRF_DEFAULT 0
#define VPPCOM_CONF_DEFAULT "/etc/vpp/vcl.conf"
#define VPPCOM_ENV_CONF "VCL_CONFIG"
#define VPPCOM_ENV_DEBUG "VCL_DEBUG"
typedef struct vppcom_endpt_t_
{
- uint32_t vrf;
uint8_t is_cut_thru;
uint8_t is_ip4;
uint8_t *ip;
extern int vppcom_app_create (char *app_name);
extern void vppcom_app_destroy (void);
-extern int vppcom_session_create (uint32_t vrf, uint8_t proto,
- uint8_t is_nonblocking);
+extern int vppcom_session_create (uint8_t proto, uint8_t is_nonblocking);
extern int vppcom_session_close (uint32_t session_index);
extern int vppcom_session_bind (uint32_t session_index, vppcom_endpt_t * ep);