ksock_route_t *
ksocknal_create_route (__u32 ipaddr, int port, int buffer_size,
ksock_route_t *
ksocknal_create_route (__u32 ipaddr, int port, int buffer_size,
route->ksnr_eager = eager;
route->ksnr_connecting = 0;
route->ksnr_connected = 0;
route->ksnr_eager = eager;
route->ksnr_connecting = 0;
route->ksnr_connected = 0;
int
ksocknal_add_route (ptl_nid_t nid, __u32 ipaddr, int port, int bufnob,
int
ksocknal_add_route (ptl_nid_t nid, __u32 ipaddr, int port, int bufnob,
return (-ENOMEM);
route = ksocknal_create_route (ipaddr, port, bufnob,
return (-ENOMEM);
route = ksocknal_create_route (ipaddr, port, bufnob,
pcfg->pcfg_count = route->ksnr_conn_count;
pcfg->pcfg_size = route->ksnr_buffer_size;
pcfg->pcfg_wait = route->ksnr_sharecount;
pcfg->pcfg_count = route->ksnr_conn_count;
pcfg->pcfg_size = route->ksnr_buffer_size;
pcfg->pcfg_wait = route->ksnr_sharecount;
case NAL_CMD_ADD_AUTOCONN: {
rc = ksocknal_add_route (pcfg->pcfg_nid, pcfg->pcfg_id,
pcfg->pcfg_misc, pcfg->pcfg_size,
case NAL_CMD_ADD_AUTOCONN: {
rc = ksocknal_add_route (pcfg->pcfg_nid, pcfg->pcfg_id,
pcfg->pcfg_misc, pcfg->pcfg_size,
(pcfg->pcfg_flags & 0x02) != 0,
(pcfg->pcfg_flags & 0x04) != 0,
(pcfg->pcfg_flags & 0x08) != 0);
(pcfg->pcfg_flags & 0x02) != 0,
(pcfg->pcfg_flags & 0x04) != 0,
(pcfg->pcfg_flags & 0x08) != 0);
for (i = 0; i < ksocknal_data.ksnd_peer_hash_size; i++) {
LASSERT (list_empty (&ksocknal_data.ksnd_peers[i]));
}
for (i = 0; i < ksocknal_data.ksnd_peer_hash_size; i++) {
LASSERT (list_empty (&ksocknal_data.ksnd_peers[i]));
}
LASSERT (list_empty (&ksocknal_data.ksnd_zombie_conns));
LASSERT (list_empty (&ksocknal_data.ksnd_autoconnectd_routes));
LASSERT (list_empty (&ksocknal_data.ksnd_small_fmp.fmp_blocked_conns));
LASSERT (list_empty (&ksocknal_data.ksnd_zombie_conns));
LASSERT (list_empty (&ksocknal_data.ksnd_autoconnectd_routes));
LASSERT (list_empty (&ksocknal_data.ksnd_small_fmp.fmp_blocked_conns));
INIT_LIST_HEAD(&ksocknal_data.ksnd_large_fmp.fmp_blocked_conns);
spin_lock_init (&ksocknal_data.ksnd_reaper_lock);
INIT_LIST_HEAD(&ksocknal_data.ksnd_large_fmp.fmp_blocked_conns);
spin_lock_init (&ksocknal_data.ksnd_reaper_lock);
INIT_LIST_HEAD (&ksocknal_data.ksnd_zombie_conns);
INIT_LIST_HEAD (&ksocknal_data.ksnd_deathrow_conns);
init_waitqueue_head(&ksocknal_data.ksnd_reaper_waitq);
INIT_LIST_HEAD (&ksocknal_data.ksnd_zombie_conns);
INIT_LIST_HEAD (&ksocknal_data.ksnd_deathrow_conns);
init_waitqueue_head(&ksocknal_data.ksnd_reaper_waitq);