diff options
Diffstat (limited to 'ot_sync.c')
| -rw-r--r-- | ot_sync.c | 6 |
1 files changed, 3 insertions, 3 deletions
| @@ -77,7 +77,7 @@ static void sync_make(size_t *iovec_entries, struct iovec **iovector) { | |||
| 77 | /* Setup return vector... */ | 77 | /* Setup return vector... */ |
| 78 | *iovec_entries = 0; | 78 | *iovec_entries = 0; |
| 79 | *iovector = NULL; | 79 | *iovector = NULL; |
| 80 | if (!(r = iovec_increase(iovec_entries, iovector, OT_SYNC_CHUNK_SIZE))) | 80 | if (!(r = iovec_new_chunk(iovec_entries, iovector, OT_SYNC_CHUNK_SIZE))) |
| 81 | return; | 81 | return; |
| 82 | 82 | ||
| 83 | /* ... and pointer to end of current output buffer. | 83 | /* ... and pointer to end of current output buffer. |
| @@ -105,7 +105,7 @@ static void sync_make(size_t *iovec_entries, struct iovec **iovector) { | |||
| 105 | 105 | ||
| 106 | /* Allocate a fresh output buffer at the end of our buffers list | 106 | /* Allocate a fresh output buffer at the end of our buffers list |
| 107 | release bucket and return, if that fails */ | 107 | release bucket and return, if that fails */ |
| 108 | if (!(r = iovec_fix_increase_or_free(iovec_entries, iovector, r, OT_SYNC_CHUNK_SIZE))) | 108 | if (!(r = iovec_next_chunk(iovec_entries, iovector, r, OT_SYNC_CHUNK_SIZE))) |
| 109 | return mutex_bucket_unlock(bucket); | 109 | return mutex_bucket_unlock(bucket); |
| 110 | 110 | ||
| 111 | /* Adjust new end of output buffer */ | 111 | /* Adjust new end of output buffer */ |
| @@ -131,7 +131,7 @@ static void sync_make(size_t *iovec_entries, struct iovec **iovector) { | |||
| 131 | *r++ = 'e'; | 131 | *r++ = 'e'; |
| 132 | 132 | ||
| 133 | /* Release unused memory in current output buffer */ | 133 | /* Release unused memory in current output buffer */ |
| 134 | iovec_fixlast(iovec_entries, iovector, r); | 134 | iovec_trim_last(iovec_entries, iovector, r); |
| 135 | } | 135 | } |
| 136 | 136 | ||
| 137 | /* This is the entry point into this worker thread | 137 | /* This is the entry point into this worker thread |
