diff options
| author | Luke T. Shumaker <lukeshu@lukeshu.com> | 2024-10-23 15:21:09 -0600 |
|---|---|---|
| committer | Luke T. Shumaker <lukeshu@lukeshu.com> | 2024-10-23 15:21:09 -0600 |
| commit | e7378b9f9b122e05baebce387fe9c3844c0736b6 (patch) | |
| tree | ce921a21811cb4ded792f61f2d933cf4e8f87a96 /lib9p | |
| parent | 9940877f4bb44bc69fecf7fb5afcf3cbab90f088 (diff) | |
wip
Diffstat (limited to 'lib9p')
| -rw-r--r-- | lib9p/include/lib9p/srv.h | 2 | ||||
| -rw-r--r-- | lib9p/srv.c | 14 |
2 files changed, 8 insertions, 8 deletions
diff --git a/lib9p/include/lib9p/srv.h b/lib9p/include/lib9p/srv.h index 797695c..b9669d5 100644 --- a/lib9p/include/lib9p/srv.h +++ b/lib9p/include/lib9p/srv.h @@ -115,7 +115,7 @@ struct lib9p_srv { * @errno LINUX_ERANGE R-message does not fit into max_msg_size */ -__attribute__ ((noreturn)) void lib9p_srv_read_cr(struct lib9p_srv *srv, implements_net_listener *listener); +__attribute__ ((noreturn)) void lib9p_srv_read_cr(struct lib9p_srv *srv, implements_net_stream_listener *listener); COROUTINE lib9p_srv_write_cr(void *_srv); #endif /* _LIB9P_SRV_H_ */ diff --git a/lib9p/srv.c b/lib9p/srv.c index cc4a048..8eef372 100644 --- a/lib9p/srv.c +++ b/lib9p/srv.c @@ -56,11 +56,11 @@ struct _srv_fidinfo { struct _srv_conn { /* immutable */ - struct lib9p_srv *parent_srv; - implements_net_conn *fd; - cid_t reader; /* the lib9p_srv_read_cr() coroutine */ + struct lib9p_srv *parent_srv; + implements_net_stream_conn *fd; + cid_t reader; /* the lib9p_srv_read_cr() coroutine */ /* mutable */ - cr_mutex_t writelock; + cr_mutex_t writelock; }; struct _srv_sess { @@ -139,7 +139,7 @@ static void respond_error(struct _lib9p_srv_req *req) { struct _srv_sess *sess = req->parent_sess; /* Truncate the error-string if necessary to avoid needing to - * return ERANGE. The assert() in + * return LINUX_ERANGE. The assert() in * rerror_overhead_for_version() has checked that this * addition doesn't overflow. */ if (((uint32_t)host.ename.len) + sess->rerror_overhead > sess->max_msg_size) @@ -158,7 +158,7 @@ static void respond_error(struct _lib9p_srv_req *req) { /* read coroutine *************************************************************/ -static bool read_at_least(implements_net_conn *fd, uint8_t *buf, size_t goal, size_t *done) { +static bool read_at_least(implements_net_stream_conn *fd, uint8_t *buf, size_t goal, size_t *done) { assert(buf); assert(goal); assert(done); @@ -179,7 +179,7 @@ static bool read_at_least(implements_net_conn *fd, uint8_t *buf, size_t goal, si static void handle_message(struct _lib9p_srv_req *ctx); -__attribute__ ((noreturn)) void lib9p_srv_read_cr(struct lib9p_srv *srv, implements_net_listener *listener) { +__attribute__ ((noreturn)) void lib9p_srv_read_cr(struct lib9p_srv *srv, implements_net_stream_listener *listener) { uint8_t buf[CONFIG_9P_MAX_MSG_SIZE]; assert(srv); |