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