Lines Matching refs:work
186 struct delayed_work work; member
197 struct cm_work work; /* Must be first. */ member
247 static void cm_work_handler(struct work_struct *work);
578 __be32 remote_id = timewait_info->work.remote_id; in cm_insert_remote_id()
584 if (be32_lt(remote_id, cur_timewait_info->work.remote_id)) in cm_insert_remote_id()
586 else if (be32_gt(remote_id, cur_timewait_info->work.remote_id)) in cm_insert_remote_id()
610 if (be32_lt(remote_id, timewait_info->work.remote_id)) in cm_find_remote_id()
612 else if (be32_gt(remote_id, timewait_info->work.remote_id)) in cm_find_remote_id()
733 struct cm_work *work; in cm_dequeue_work() local
738 work = list_entry(cm_id_priv->work_list.next, struct cm_work, list); in cm_dequeue_work()
739 list_del(&work->list); in cm_dequeue_work()
740 return work; in cm_dequeue_work()
743 static void cm_free_work(struct cm_work *work) in cm_free_work() argument
745 if (work->mad_recv_wc) in cm_free_work()
746 ib_free_recv_mad(work->mad_recv_wc); in cm_free_work()
747 kfree(work); in cm_free_work()
796 timewait_info->work.local_id = local_id; in cm_create_timewait_info()
797 INIT_DELAYED_WORK(&timewait_info->work.work, cm_work_handler); in cm_create_timewait_info()
798 timewait_info->work.cm_event.event = IB_CM_TIMEWAIT_EXIT; in cm_create_timewait_info()
819 queue_delayed_work(cm.wq, &cm_id_priv->timewait_info->work.work, in cm_enter_timewait()
841 struct cm_work *work; in cm_destroy_id() local
922 while ((work = cm_dequeue_work(cm_id_priv)) != NULL) in cm_destroy_id()
923 cm_free_work(work); in cm_destroy_id()
1286 static void cm_format_req_event(struct cm_work *work, in cm_format_req_event() argument
1293 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad; in cm_format_req_event()
1294 param = &work->cm_event.param.req_rcvd; in cm_format_req_event()
1297 param->primary_path = &work->path[0]; in cm_format_req_event()
1299 param->alternate_path = &work->path[1]; in cm_format_req_event()
1317 work->cm_event.private_data = &req_msg->private_data; in cm_format_req_event()
1321 struct cm_work *work) in cm_process_work() argument
1326 ret = cm_id_priv->id.cm_handler(&cm_id_priv->id, &work->cm_event); in cm_process_work()
1327 cm_free_work(work); in cm_process_work()
1331 work = cm_dequeue_work(cm_id_priv); in cm_process_work()
1333 BUG_ON(!work); in cm_process_work()
1335 &work->cm_event); in cm_process_work()
1336 cm_free_work(work); in cm_process_work()
1399 static void cm_dup_req_handler(struct cm_work *work, in cm_dup_req_handler() argument
1405 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_dup_req_handler()
1412 ret = cm_alloc_response_msg(work->port, work->mad_recv_wc, &msg); in cm_dup_req_handler()
1442 static struct cm_id_private * cm_match_req(struct cm_work *work, in cm_match_req() argument
1449 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad; in cm_match_req()
1455 cur_cm_id_priv = cm_get_id(timewait_info->work.local_id, in cm_match_req()
1456 timewait_info->work.remote_id); in cm_match_req()
1459 cm_dup_req_handler(work, cur_cm_id_priv); in cm_match_req()
1470 cm_issue_rej(work->port, work->mad_recv_wc, in cm_match_req()
1483 cm_issue_rej(work->port, work->mad_recv_wc, in cm_match_req()
1525 static int cm_req_handler(struct cm_work *work) in cm_req_handler() argument
1532 req_msg = (struct cm_req_msg *)work->mad_recv_wc->recv_buf.mad; in cm_req_handler()
1534 cm_id = ib_create_cm_id(work->port->cm_dev->ib_device, NULL, NULL); in cm_req_handler()
1540 cm_init_av_for_response(work->port, work->mad_recv_wc->wc, in cm_req_handler()
1541 work->mad_recv_wc->recv_buf.grh, in cm_req_handler()
1549 cm_id_priv->timewait_info->work.remote_id = req_msg->local_comm_id; in cm_req_handler()
1553 listen_cm_id_priv = cm_match_req(work, cm_id_priv); in cm_req_handler()
1565 cm_process_routed_req(req_msg, work->mad_recv_wc->wc); in cm_req_handler()
1566 cm_format_paths_from_req(req_msg, &work->path[0], &work->path[1]); in cm_req_handler()
1568 memcpy(work->path[0].dmac, cm_id_priv->av.ah_attr.dmac, ETH_ALEN); in cm_req_handler()
1569 work->path[0].vlan_id = cm_id_priv->av.ah_attr.vlan_id; in cm_req_handler()
1570 ret = cm_init_av_by_path(&work->path[0], &cm_id_priv->av); in cm_req_handler()
1572 ib_get_cached_gid(work->port->cm_dev->ib_device, in cm_req_handler()
1573 work->port->port_num, 0, &work->path[0].sgid); in cm_req_handler()
1575 &work->path[0].sgid, sizeof work->path[0].sgid, in cm_req_handler()
1580 ret = cm_init_av_by_path(&work->path[1], &cm_id_priv->alt_av); in cm_req_handler()
1583 &work->path[0].sgid, in cm_req_handler()
1584 sizeof work->path[0].sgid, NULL, 0); in cm_req_handler()
1602 cm_format_req_event(work, cm_id_priv, &listen_cm_id_priv->id); in cm_req_handler()
1603 cm_process_work(cm_id_priv, work); in cm_req_handler()
1758 static void cm_format_rep_event(struct cm_work *work, enum ib_qp_type qp_type) in cm_format_rep_event() argument
1763 rep_msg = (struct cm_rep_msg *)work->mad_recv_wc->recv_buf.mad; in cm_format_rep_event()
1764 param = &work->cm_event.param.rep_rcvd; in cm_format_rep_event()
1776 work->cm_event.private_data = &rep_msg->private_data; in cm_format_rep_event()
1779 static void cm_dup_rep_handler(struct cm_work *work) in cm_dup_rep_handler() argument
1786 rep_msg = (struct cm_rep_msg *) work->mad_recv_wc->recv_buf.mad; in cm_dup_rep_handler()
1792 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_dup_rep_handler()
1794 ret = cm_alloc_response_msg(work->port, work->mad_recv_wc, &msg); in cm_dup_rep_handler()
1822 static int cm_rep_handler(struct cm_work *work) in cm_rep_handler() argument
1828 rep_msg = (struct cm_rep_msg *)work->mad_recv_wc->recv_buf.mad; in cm_rep_handler()
1831 cm_dup_rep_handler(work); in cm_rep_handler()
1835 cm_format_rep_event(work, cm_id_priv->qp_type); in cm_rep_handler()
1848 cm_id_priv->timewait_info->work.remote_id = rep_msg->local_comm_id; in cm_rep_handler()
1867 cm_issue_rej(work->port, work->mad_recv_wc, in cm_rep_handler()
1895 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_rep_handler()
1899 cm_process_work(cm_id_priv, work); in cm_rep_handler()
1909 static int cm_establish_handler(struct cm_work *work) in cm_establish_handler() argument
1915 cm_id_priv = cm_acquire_id(work->local_id, work->remote_id); in cm_establish_handler()
1928 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_establish_handler()
1932 cm_process_work(cm_id_priv, work); in cm_establish_handler()
1941 static int cm_rtu_handler(struct cm_work *work) in cm_rtu_handler() argument
1947 rtu_msg = (struct cm_rtu_msg *)work->mad_recv_wc->recv_buf.mad; in cm_rtu_handler()
1953 work->cm_event.private_data = &rtu_msg->private_data; in cm_rtu_handler()
1959 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_rtu_handler()
1968 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_rtu_handler()
1972 cm_process_work(cm_id_priv, work); in cm_rtu_handler()
2131 static int cm_dreq_handler(struct cm_work *work) in cm_dreq_handler() argument
2138 dreq_msg = (struct cm_dreq_msg *)work->mad_recv_wc->recv_buf.mad; in cm_dreq_handler()
2142 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_dreq_handler()
2144 cm_issue_drep(work->port, work->mad_recv_wc); in cm_dreq_handler()
2148 work->cm_event.private_data = &dreq_msg->private_data; in cm_dreq_handler()
2167 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_dreq_handler()
2169 if (cm_alloc_response_msg(work->port, work->mad_recv_wc, &msg)) in cm_dreq_handler()
2181 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_dreq_handler()
2191 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_dreq_handler()
2195 cm_process_work(cm_id_priv, work); in cm_dreq_handler()
2205 static int cm_drep_handler(struct cm_work *work) in cm_drep_handler() argument
2211 drep_msg = (struct cm_drep_msg *)work->mad_recv_wc->recv_buf.mad; in cm_drep_handler()
2217 work->cm_event.private_data = &drep_msg->private_data; in cm_drep_handler()
2230 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_drep_handler()
2234 cm_process_work(cm_id_priv, work); in cm_drep_handler()
2304 static void cm_format_rej_event(struct cm_work *work) in cm_format_rej_event() argument
2309 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad; in cm_format_rej_event()
2310 param = &work->cm_event.param.rej_rcvd; in cm_format_rej_event()
2314 work->cm_event.private_data = &rej_msg->private_data; in cm_format_rej_event()
2334 (timewait_info->work.local_id ^ in cm_acquire_rejected_id()
2351 static int cm_rej_handler(struct cm_work *work) in cm_rej_handler() argument
2357 rej_msg = (struct cm_rej_msg *)work->mad_recv_wc->recv_buf.mad; in cm_rej_handler()
2362 cm_format_rej_event(work); in cm_rej_handler()
2404 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_rej_handler()
2408 cm_process_work(cm_id_priv, work); in cm_rej_handler()
2509 static int cm_mra_handler(struct cm_work *work) in cm_mra_handler() argument
2515 mra_msg = (struct cm_mra_msg *)work->mad_recv_wc->recv_buf.mad; in cm_mra_handler()
2520 work->cm_event.private_data = &mra_msg->private_data; in cm_mra_handler()
2521 work->cm_event.param.mra_rcvd.service_timeout = in cm_mra_handler()
2548 atomic_long_inc(&work->port-> in cm_mra_handler()
2557 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_mra_handler()
2568 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_mra_handler()
2572 cm_process_work(cm_id_priv, work); in cm_mra_handler()
2690 static int cm_lap_handler(struct cm_work *work) in cm_lap_handler() argument
2699 lap_msg = (struct cm_lap_msg *)work->mad_recv_wc->recv_buf.mad; in cm_lap_handler()
2705 param = &work->cm_event.param.lap_rcvd; in cm_lap_handler()
2706 param->alternate_path = &work->path[0]; in cm_lap_handler()
2708 work->cm_event.private_data = &lap_msg->private_data; in cm_lap_handler()
2719 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_lap_handler()
2721 if (cm_alloc_response_msg(work->port, work->mad_recv_wc, &msg)) in cm_lap_handler()
2735 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_lap_handler()
2744 cm_init_av_for_response(work->port, work->mad_recv_wc->wc, in cm_lap_handler()
2745 work->mad_recv_wc->recv_buf.grh, in cm_lap_handler()
2750 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_lap_handler()
2754 cm_process_work(cm_id_priv, work); in cm_lap_handler()
2830 static int cm_apr_handler(struct cm_work *work) in cm_apr_handler() argument
2836 apr_msg = (struct cm_apr_msg *)work->mad_recv_wc->recv_buf.mad; in cm_apr_handler()
2842 work->cm_event.param.apr_rcvd.ap_status = apr_msg->ap_status; in cm_apr_handler()
2843 work->cm_event.param.apr_rcvd.apr_info = &apr_msg->info; in cm_apr_handler()
2844 work->cm_event.param.apr_rcvd.info_len = apr_msg->info_length; in cm_apr_handler()
2845 work->cm_event.private_data = &apr_msg->private_data; in cm_apr_handler()
2860 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_apr_handler()
2864 cm_process_work(cm_id_priv, work); in cm_apr_handler()
2873 static int cm_timewait_handler(struct cm_work *work) in cm_timewait_handler() argument
2879 timewait_info = (struct cm_timewait_info *)work; in cm_timewait_handler()
2884 cm_id_priv = cm_acquire_id(timewait_info->work.local_id, in cm_timewait_handler()
2885 timewait_info->work.remote_id); in cm_timewait_handler()
2898 list_add_tail(&work->list, &cm_id_priv->work_list); in cm_timewait_handler()
2902 cm_process_work(cm_id_priv, work); in cm_timewait_handler()
2975 static void cm_format_sidr_req_event(struct cm_work *work, in cm_format_sidr_req_event() argument
2982 work->mad_recv_wc->recv_buf.mad; in cm_format_sidr_req_event()
2983 param = &work->cm_event.param.sidr_req_rcvd; in cm_format_sidr_req_event()
2986 param->port = work->port->port_num; in cm_format_sidr_req_event()
2987 work->cm_event.private_data = &sidr_req_msg->private_data; in cm_format_sidr_req_event()
2990 static int cm_sidr_req_handler(struct cm_work *work) in cm_sidr_req_handler() argument
2997 cm_id = ib_create_cm_id(work->port->cm_dev->ib_device, NULL, NULL); in cm_sidr_req_handler()
3004 work->mad_recv_wc->recv_buf.mad; in cm_sidr_req_handler()
3005 wc = work->mad_recv_wc->wc; in cm_sidr_req_handler()
3008 cm_init_av_for_response(work->port, work->mad_recv_wc->wc, in cm_sidr_req_handler()
3009 work->mad_recv_wc->recv_buf.grh, in cm_sidr_req_handler()
3019 atomic_long_inc(&work->port->counter_group[CM_RECV_DUPLICATES]. in cm_sidr_req_handler()
3041 cm_format_sidr_req_event(work, &cur_cm_id_priv->id); in cm_sidr_req_handler()
3042 cm_process_work(cm_id_priv, work); in cm_sidr_req_handler()
3118 static void cm_format_sidr_rep_event(struct cm_work *work) in cm_format_sidr_rep_event() argument
3124 work->mad_recv_wc->recv_buf.mad; in cm_format_sidr_rep_event()
3125 param = &work->cm_event.param.sidr_rep_rcvd; in cm_format_sidr_rep_event()
3131 work->cm_event.private_data = &sidr_rep_msg->private_data; in cm_format_sidr_rep_event()
3134 static int cm_sidr_rep_handler(struct cm_work *work) in cm_sidr_rep_handler() argument
3140 work->mad_recv_wc->recv_buf.mad; in cm_sidr_rep_handler()
3154 cm_format_sidr_rep_event(work); in cm_sidr_rep_handler()
3155 cm_process_work(cm_id_priv, work); in cm_sidr_rep_handler()
3257 struct cm_work *work = container_of(_work, struct cm_work, work.work); in cm_work_handler() local
3260 switch (work->cm_event.event) { in cm_work_handler()
3262 ret = cm_req_handler(work); in cm_work_handler()
3265 ret = cm_mra_handler(work); in cm_work_handler()
3268 ret = cm_rej_handler(work); in cm_work_handler()
3271 ret = cm_rep_handler(work); in cm_work_handler()
3274 ret = cm_rtu_handler(work); in cm_work_handler()
3277 ret = cm_establish_handler(work); in cm_work_handler()
3280 ret = cm_dreq_handler(work); in cm_work_handler()
3283 ret = cm_drep_handler(work); in cm_work_handler()
3286 ret = cm_sidr_req_handler(work); in cm_work_handler()
3289 ret = cm_sidr_rep_handler(work); in cm_work_handler()
3292 ret = cm_lap_handler(work); in cm_work_handler()
3295 ret = cm_apr_handler(work); in cm_work_handler()
3298 ret = cm_timewait_handler(work); in cm_work_handler()
3305 cm_free_work(work); in cm_work_handler()
3311 struct cm_work *work; in cm_establish() local
3315 work = kmalloc(sizeof *work, GFP_ATOMIC); in cm_establish()
3316 if (!work) in cm_establish()
3337 kfree(work); in cm_establish()
3347 INIT_DELAYED_WORK(&work->work, cm_work_handler); in cm_establish()
3348 work->local_id = cm_id->local_id; in cm_establish()
3349 work->remote_id = cm_id->remote_id; in cm_establish()
3350 work->mad_recv_wc = NULL; in cm_establish()
3351 work->cm_event.event = IB_CM_USER_ESTABLISHED; in cm_establish()
3352 queue_delayed_work(cm.wq, &work->work, 0); in cm_establish()
3399 struct cm_work *work; in cm_recv_handler() local
3450 work = kmalloc(sizeof *work + sizeof(struct ib_sa_path_rec) * paths, in cm_recv_handler()
3452 if (!work) { in cm_recv_handler()
3457 INIT_DELAYED_WORK(&work->work, cm_work_handler); in cm_recv_handler()
3458 work->cm_event.event = event; in cm_recv_handler()
3459 work->mad_recv_wc = mad_recv_wc; in cm_recv_handler()
3460 work->port = port; in cm_recv_handler()
3461 queue_delayed_work(cm.wq, &work->work, 0); in cm_recv_handler()
3922 cancel_delayed_work(&timewait_info->work.work); in ib_cm_cleanup()