Lines Matching refs:client
115 struct p9_client *client; member
219 p9_client_cb(m->client, req, REQ_STATUS_ERROR); in p9_conn_cancel()
224 p9_fd_poll(struct p9_client *client, struct poll_table_struct *pt, int *err) in p9_fd_poll() argument
229 if (client && client->status == Connected) in p9_fd_poll()
230 ts = client->trans; in p9_fd_poll()
252 static int p9_fd_read(struct p9_client *client, void *v, int len) in p9_fd_read() argument
258 if (client && client->status != Disconnected) in p9_fd_read()
259 ts = client->trans; in p9_fd_read()
270 client->status = Disconnected; in p9_fd_read()
303 err = p9_fd_read(m->client, m->rc.sdata + m->rc.offset, in p9_read_work()
331 m->rreq = p9_tag_lookup(m->client, m->rc.tag); in p9_read_work()
351 p9_req_put(m->client, m->rreq); in p9_read_work()
370 p9_client_cb(m->client, m->rreq, REQ_STATUS_RCVD); in p9_read_work()
387 p9_req_put(m->client, m->rreq); in p9_read_work()
398 n = p9_fd_poll(m->client, NULL, NULL); in p9_read_work()
420 static int p9_fd_write(struct p9_client *client, void *v, int len) in p9_fd_write() argument
425 if (client && client->status != Disconnected) in p9_fd_write()
426 ts = client->trans; in p9_fd_write()
436 client->status = Disconnected; in p9_fd_write()
485 err = p9_fd_write(m->client, m->wbuf + m->wpos, m->wsize - m->wpos); in p9_write_work()
501 p9_req_put(m->client, m->wreq); in p9_write_work()
512 n = p9_fd_poll(m->client, NULL, NULL); in p9_write_work()
585 static void p9_conn_create(struct p9_client *client) in p9_conn_create() argument
588 struct p9_trans_fd *ts = client->trans; in p9_conn_create()
591 p9_debug(P9_DEBUG_TRANS, "client %p msize %d\n", client, client->msize); in p9_conn_create()
594 m->client = client; in p9_conn_create()
604 n = p9_fd_poll(client, &m->pt, NULL); in p9_conn_create()
630 n = p9_fd_poll(m->client, NULL, &err); in p9_poll_mux()
667 static int p9_fd_request(struct p9_client *client, struct p9_req_t *req) in p9_fd_request() argument
671 struct p9_trans_fd *ts = client->trans; in p9_fd_request()
692 n = p9_fd_poll(m->client, NULL, NULL); in p9_fd_request()
700 static int p9_fd_cancel(struct p9_client *client, struct p9_req_t *req) in p9_fd_cancel() argument
702 struct p9_trans_fd *ts = client->trans; in p9_fd_cancel()
706 p9_debug(P9_DEBUG_TRANS, "client %p req %p\n", client, req); in p9_fd_cancel()
713 p9_req_put(client, req); in p9_fd_cancel()
721 static int p9_fd_cancelled(struct p9_client *client, struct p9_req_t *req) in p9_fd_cancelled() argument
723 struct p9_trans_fd *ts = client->trans; in p9_fd_cancelled()
726 p9_debug(P9_DEBUG_TRANS, "client %p req %p\n", client, req); in p9_fd_cancelled()
744 p9_req_put(client, req); in p9_fd_cancelled()
830 static int p9_fd_open(struct p9_client *client, int rfd, int wfd) in p9_fd_open() argument
858 client->trans = ts; in p9_fd_open()
859 client->status = Connected; in p9_fd_open()
872 static int p9_socket_open(struct p9_client *client, struct socket *csocket) in p9_socket_open() argument
895 client->trans = p; in p9_socket_open()
896 client->status = Connected; in p9_socket_open()
900 p9_conn_create(client); in p9_socket_open()
918 p9_req_put(m->client, m->rreq); in p9_conn_destroy()
923 p9_req_put(m->client, m->wreq); in p9_conn_destroy()
929 m->client = NULL; in p9_conn_destroy()
938 static void p9_fd_close(struct p9_client *client) in p9_fd_close() argument
942 if (!client) in p9_fd_close()
945 ts = client->trans; in p9_fd_close()
949 client->status = Disconnected; in p9_fd_close()
984 p9_fd_create_tcp(struct p9_client *client, const char *addr, char *args) in p9_fd_create_tcp() argument
1007 client->trans_opts.tcp.port = opts.port; in p9_fd_create_tcp()
1008 client->trans_opts.tcp.privport = opts.privport; in p9_fd_create_tcp()
1037 return p9_socket_open(client, csocket); in p9_fd_create_tcp()
1041 p9_fd_create_unix(struct p9_client *client, const char *addr, char *args) in p9_fd_create_unix() argument
1077 return p9_socket_open(client, csocket); in p9_fd_create_unix()
1081 p9_fd_create(struct p9_client *client, const char *addr, char *args) in p9_fd_create() argument
1089 client->trans_opts.fd.rfd = opts.rfd; in p9_fd_create()
1090 client->trans_opts.fd.wfd = opts.wfd; in p9_fd_create()
1097 err = p9_fd_open(client, opts.rfd, opts.wfd); in p9_fd_create()
1101 p9_conn_create(client); in p9_fd_create()