Lines Matching refs:nsw
291 static int o2net_prep_nsw(struct o2net_node *nn, struct o2net_status_wait *nsw)
296 ret = idr_alloc(&nn->nn_status_idr, nsw, 0, 0, GFP_ATOMIC);
298 nsw->ns_id = ret;
299 list_add_tail(&nsw->ns_node_item, &nn->nn_status_list);
305 init_waitqueue_head(&nsw->ns_wq);
306 nsw->ns_sys_status = O2NET_ERR_NONE;
307 nsw->ns_status = 0;
312 struct o2net_status_wait *nsw,
318 if (!list_empty(&nsw->ns_node_item)) {
319 list_del_init(&nsw->ns_node_item);
320 nsw->ns_sys_status = sys_status;
321 nsw->ns_status = status;
322 idr_remove(&nn->nn_status_idr, nsw->ns_id);
323 wake_up(&nsw->ns_wq);
328 struct o2net_status_wait *nsw,
333 if (nsw == NULL) {
337 nsw = idr_find(&nn->nn_status_idr, id);
338 if (nsw == NULL)
342 o2net_complete_nsw_locked(nn, nsw, sys_status, status);
351 struct o2net_status_wait *nsw, *tmp;
356 list_for_each_entry_safe(nsw, tmp, &nn->nn_status_list, ns_node_item) {
357 o2net_complete_nsw_locked(nn, nsw, O2NET_ERR_DIED, 0);
366 struct o2net_status_wait *nsw)
370 completed = list_empty(&nsw->ns_node_item);
1025 struct o2net_status_wait nsw = {
1026 .ns_node_item = LIST_HEAD_INIT(nsw.ns_node_item),
1087 ret = o2net_prep_nsw(nn, &nsw);
1091 msg->msg_num = cpu_to_be32(nsw.ns_id);
1092 o2net_set_nst_msg_id(&nst, nsw.ns_id);
1110 wait_event(nsw.ns_wq, o2net_nsw_completed(nn, &nsw));
1117 ret = o2net_sys_err_to_errno(nsw.ns_sys_status);
1119 *status = nsw.ns_status;
1122 ret, nsw.ns_status);
1129 o2net_complete_nsw(nn, &nsw, 0, 0, 0);