Lines Matching refs:conn
56 l9p_connection_init(struct l9p_server *server, struct l9p_connection **conn) in l9p_connection_init() argument
61 assert(conn != NULL); in l9p_connection_init()
75 *conn = newconn; in l9p_connection_init()
81 l9p_connection_free(struct l9p_connection *conn) in l9p_connection_free() argument
84 LIST_REMOVE(conn, lc_link); in l9p_connection_free()
85 free(conn); in l9p_connection_free()
89 l9p_connection_recv(struct l9p_connection *conn, const struct iovec *iov, in l9p_connection_recv() argument
97 req->lr_conn = conn; in l9p_connection_recv()
105 if (l9p_pufcall(&req->lr_req_msg, &req->lr_req, conn->lc_version) != 0) { in l9p_connection_recv()
112 if (ht_add(&conn->lc_requests, req->lr_req.hdr.tag, req)) { in l9p_connection_recv()
120 error = conn->lc_lt.lt_get_response_buffer(req, in l9p_connection_recv()
123 conn->lc_lt.lt_aux); in l9p_connection_recv()
126 ht_remove(&conn->lc_requests, req->lr_req.hdr.tag); in l9p_connection_recv()
137 l9p_threadpool_run(&conn->lc_tp, req); in l9p_connection_recv()
141 l9p_connection_close(struct l9p_connection *conn) in l9p_connection_close() argument
148 l9p_threadpool_shutdown(&conn->lc_tp); in l9p_connection_close()
152 ht_iter(&conn->lc_requests, &iter); in l9p_connection_close()
168 ht_iter(&conn->lc_files, &iter); in l9p_connection_close()
170 conn->lc_server->ls_backend->freefid( in l9p_connection_close()
171 conn->lc_server->ls_backend->softc, fid); in l9p_connection_close()
176 ht_destroy(&conn->lc_requests); in l9p_connection_close()
177 ht_destroy(&conn->lc_files); in l9p_connection_close()
181 l9p_connection_alloc_fid(struct l9p_connection *conn, uint32_t fid) in l9p_connection_alloc_fid() argument
194 if (ht_add(&conn->lc_files, fid, file) != 0) { in l9p_connection_alloc_fid()
203 l9p_connection_remove_fid(struct l9p_connection *conn, struct l9p_fid *fid) in l9p_connection_remove_fid() argument
210 be = conn->lc_server->ls_backend; in l9p_connection_remove_fid()
213 ht_remove(&conn->lc_files, fid->lo_fid); in l9p_connection_remove_fid()