diff options
Diffstat (limited to 'mgmt.c')
-rw-r--r-- | mgmt.c | 6 |
1 files changed, 3 insertions, 3 deletions
@@ -72,7 +72,7 @@ MOG_NOINLINE static void mgmt_close(struct mog_fd *mfd) { struct mog_mgmt *mgmt = &mfd->as.mgmt; - mog_rbuf_free(mgmt->rbuf); + mog_rbuf_reattach_and_null(&mgmt->rbuf); assert((mgmt->wbuf == NULL || mgmt->wbuf == MOG_WR_ERROR) && "would leak mgmt->wbuf on close"); @@ -99,7 +99,7 @@ void mog_mgmt_writev(struct mog_mgmt *mgmt, struct iovec *iov, int iovcnt) static enum mog_next mgmt_iostat_forever(struct mog_mgmt *mgmt) { - mog_rbuf_free_and_null(&mgmt->rbuf); /* no coming back from this */ + mog_rbuf_reattach_and_null(&mgmt->rbuf); /* no coming back from this */ mog_notify(MOG_NOTIFY_DEVICE_REFRESH); mog_svc_devstats_subscribe(mgmt); @@ -136,7 +136,7 @@ mgmt_defer_rbuf(struct mog_mgmt *mgmt, struct mog_rbuf *rbuf, size_t buf_len) assert(defer_bytes <= MOG_RBUF_MAX_SIZE && "defer bytes overflow"); if (defer_bytes == 0) { - mog_rbuf_free_and_null(&mgmt->rbuf); + mog_rbuf_reattach_and_null(&mgmt->rbuf); } else if (old) { /* no allocation needed, reuse existing */ assert(old == rbuf && "mgmt->rbuf not reused properly"); memmove(old->rptr, src, defer_bytes); |