• Home
  • Raw
  • Download

Lines Matching refs:client

118 	struct p9_client *client;  member
221 p9_client_cb(m->client, req, REQ_STATUS_ERROR); in p9_conn_cancel()
226 p9_fd_poll(struct p9_client *client, struct poll_table_struct *pt, int *err) in p9_fd_poll() argument
231 if (client && client->status == Connected) in p9_fd_poll()
232 ts = client->trans; in p9_fd_poll()
254 static int p9_fd_read(struct p9_client *client, void *v, int len) in p9_fd_read() argument
260 if (client && client->status != Disconnected) in p9_fd_read()
261 ts = client->trans; in p9_fd_read()
272 client->status = Disconnected; in p9_fd_read()
305 err = p9_fd_read(m->client, m->rc.sdata + m->rc.offset, in p9_read_work()
329 if (m->rc.size >= m->client->msize) { in p9_read_work()
341 m->rreq = p9_tag_lookup(m->client, m->rc.tag); in p9_read_work()
353 p9_req_put(m->client, m->rreq); in p9_read_work()
372 p9_client_cb(m->client, m->rreq, REQ_STATUS_RCVD); in p9_read_work()
389 p9_req_put(m->client, m->rreq); in p9_read_work()
400 n = p9_fd_poll(m->client, NULL, NULL); in p9_read_work()
422 static int p9_fd_write(struct p9_client *client, void *v, int len) in p9_fd_write() argument
427 if (client && client->status != Disconnected) in p9_fd_write()
428 ts = client->trans; in p9_fd_write()
438 client->status = Disconnected; in p9_fd_write()
487 err = p9_fd_write(m->client, m->wbuf + m->wpos, m->wsize - m->wpos); in p9_write_work()
503 p9_req_put(m->client, m->wreq); in p9_write_work()
514 n = p9_fd_poll(m->client, NULL, NULL); in p9_write_work()
587 static void p9_conn_create(struct p9_client *client) in p9_conn_create() argument
590 struct p9_trans_fd *ts = client->trans; in p9_conn_create()
593 p9_debug(P9_DEBUG_TRANS, "client %p msize %d\n", client, client->msize); in p9_conn_create()
596 m->client = client; in p9_conn_create()
606 n = p9_fd_poll(client, &m->pt, NULL); in p9_conn_create()
632 n = p9_fd_poll(m->client, NULL, &err); in p9_poll_mux()
669 static int p9_fd_request(struct p9_client *client, struct p9_req_t *req) in p9_fd_request() argument
672 struct p9_trans_fd *ts = client->trans; in p9_fd_request()
688 n = p9_fd_poll(m->client, NULL, NULL); in p9_fd_request()
696 static int p9_fd_cancel(struct p9_client *client, struct p9_req_t *req) in p9_fd_cancel() argument
698 struct p9_trans_fd *ts = client->trans; in p9_fd_cancel()
702 p9_debug(P9_DEBUG_TRANS, "client %p req %p\n", client, req); in p9_fd_cancel()
709 p9_req_put(client, req); in p9_fd_cancel()
717 static int p9_fd_cancelled(struct p9_client *client, struct p9_req_t *req) in p9_fd_cancelled() argument
719 struct p9_trans_fd *ts = client->trans; in p9_fd_cancelled()
722 p9_debug(P9_DEBUG_TRANS, "client %p req %p\n", client, req); in p9_fd_cancelled()
740 p9_req_put(client, req); in p9_fd_cancelled()
826 static int p9_fd_open(struct p9_client *client, int rfd, int wfd) in p9_fd_open() argument
854 client->trans = ts; in p9_fd_open()
855 client->status = Connected; in p9_fd_open()
868 static int p9_socket_open(struct p9_client *client, struct socket *csocket) in p9_socket_open() argument
890 client->trans = p; in p9_socket_open()
891 client->status = Connected; in p9_socket_open()
895 p9_conn_create(client); in p9_socket_open()
913 p9_req_put(m->client, m->rreq); in p9_conn_destroy()
918 p9_req_put(m->client, m->wreq); in p9_conn_destroy()
924 m->client = NULL; in p9_conn_destroy()
933 static void p9_fd_close(struct p9_client *client) in p9_fd_close() argument
937 if (!client) in p9_fd_close()
940 ts = client->trans; in p9_fd_close()
944 client->status = Disconnected; in p9_fd_close()
992 p9_fd_create_tcp(struct p9_client *client, const char *addr, char *args) in p9_fd_create_tcp() argument
1008 client->trans_opts.tcp.port = opts.port; in p9_fd_create_tcp()
1009 client->trans_opts.tcp.privport = opts.privport; in p9_fd_create_tcp()
1041 return p9_socket_open(client, csocket); in p9_fd_create_tcp()
1045 p9_fd_create_unix(struct p9_client *client, const char *addr, char *args) in p9_fd_create_unix() argument
1081 return p9_socket_open(client, csocket); in p9_fd_create_unix()
1085 p9_fd_create(struct p9_client *client, const char *addr, char *args) in p9_fd_create() argument
1091 client->trans_opts.fd.rfd = opts.rfd; in p9_fd_create()
1092 client->trans_opts.fd.wfd = opts.wfd; in p9_fd_create()
1099 err = p9_fd_open(client, opts.rfd, opts.wfd); in p9_fd_create()
1103 p9_conn_create(client); in p9_fd_create()