sdp_sk(sk)->qp_active = 1;
sdp_sk(sk)->context.device = device;
- init_waitqueue_head(&sdp_sk(sk)->wq);
-
sdp_dbg(sk, "%s done\n", __func__);
return 0;
sdp_cleanup_sdp_buf(ssk, tx_req, skb->len - skb->data_len, DMA_TO_DEVICE);
sdp_set_error(&ssk->isk.sk, -ECONNRESET);
- wake_up(&ssk->wq);
goto err;
}
sdp_dbg_data(sk, "Send completion with error. "
"Status %d\n", wc->status);
sdp_set_error(sk, -ECONNRESET);
- wake_up(&ssk->wq);
queue_work(sdp_wq, &ssk->destroy_work);
}
return;
sdp_set_error(&ssk->isk.sk, -ECONNRESET);
- wake_up(&ssk->wq);
}
static int sdp_process_tx_cq(struct sdp_sock *ssk)
sdp_dbg(&ssk->isk.sk,
"ib_post_keepalive failed with status %d.\n", rc);
sdp_set_error(&ssk->isk.sk, -ECONNRESET);
- wake_up(&ssk->wq);
}
sdp_cnt(sdp_keepalive_probes_sent);
sdp_dbg_data(sk, "both SrcAvail and SrcAvailCancel timedout."
" closing connection\n");
sdp_set_error(sk, -ECONNRESET);
- wake_up(&ssk->wq);
release_sock(sk);
}
if (unlikely(rc)) {
sdp_warn(sk, "ib_post_send failed with status %d.\n", rc);
sdp_set_error(&ssk->isk.sk, -ECONNRESET);
- wake_up(&ssk->wq);
goto err_post_send;
}