diff options
Diffstat (limited to 'mgmt.c')
-rw-r--r-- | mgmt.c | 15 |
1 files changed, 11 insertions, 4 deletions
@@ -214,6 +214,15 @@ static enum mog_next mgmt_run(struct mog_fd *mfd, struct mog_rbuf *rbuf, return mgmt->wbuf ? MOG_NEXT_WAIT_WR : MOG_NEXT_ACTIVE; } +MOG_NOINLINE static char * +mgmt_rbuf_grow(struct mog_fd *mfd, struct mog_rbuf **rbuf, size_t buf_len) +{ + struct mog_mgmt *mgmt = &mfd->as.mgmt; + (*rbuf)->rsize = buf_len; + mgmt->rbuf = *rbuf = mog_rbuf_grow(*rbuf); + return *rbuf ? (*rbuf)->rptr : NULL; +} + /* * this is the main event callback and called whenever mgmt * is pulled out of a queue (either idle or active) @@ -265,11 +274,9 @@ parse: assert(mgmt->wbuf == NULL && "tried to write (and failed) with partial req"); if (mgmt->buf_off >= rbuf->rcapa) { - rbuf->rsize = buf_len; - mgmt->rbuf = rbuf = mog_rbuf_grow(rbuf); - if (!rbuf) + buf = mgmt_rbuf_grow(mfd, &rbuf, buf_len); + if (!buf) goto too_large; - buf = rbuf->rptr; } off = mgmt->buf_off; goto reread; |