Lines Matching refs:req
92 struct l9p_request *req;
95 req = l9p_calloc(1, sizeof (struct l9p_request));
96 req->lr_aux = aux;
97 req->lr_conn = conn;
99 req->lr_req_msg.lm_mode = L9P_UNPACK;
100 req->lr_req_msg.lm_niov = niov;
101 memcpy(req->lr_req_msg.lm_iov, iov, sizeof (struct iovec) * niov);
103 req->lr_resp_msg.lm_mode = L9P_PACK;
105 if (l9p_pufcall(&req->lr_req_msg, &req->lr_req, conn->lc_version) != 0) {
107 l9p_freefcall(&req->lr_req);
108 free(req);
112 if (ht_add(&conn->lc_requests, req->lr_req.hdr.tag, req)) {
114 req->lr_req.hdr.tag);
115 l9p_freefcall(&req->lr_req);
116 free(req);
120 error = conn->lc_lt.lt_get_response_buffer(req,
121 req->lr_resp_msg.lm_iov,
122 &req->lr_resp_msg.lm_niov,
126 ht_remove(&conn->lc_requests, req->lr_req.hdr.tag);
127 l9p_freefcall(&req->lr_req);
128 free(req);
137 l9p_threadpool_run(&conn->lc_tp, req);
145 struct l9p_request *req;
153 while ((req = ht_next(&iter)) != NULL) {
158 req->lr_error = EINTR;
159 l9p_respond(req, false, false);
162 l9p_respond(req, true, false); /* use no-answer path */