src/cx/buffer.h

Sun, 24 Apr 2022 14:54:50 +0200

author
Mike Becker <universe@uap-core.de>
date
Sun, 24 Apr 2022 14:54:50 +0200
changeset 529
814d51173f20
parent 501
9a08f5e515cc
child 530
e866516cac17
permissions
-rw-r--r--

#171 const qualifier and nonnull attributes

Also removes cxBufferExtract temporarily.

universe@483 1 /*
universe@483 2 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
universe@483 3 *
universe@483 4 * Copyright 2021 Mike Becker, Olaf Wintermann All rights reserved.
universe@483 5 *
universe@483 6 * Redistribution and use in source and binary forms, with or without
universe@483 7 * modification, are permitted provided that the following conditions are met:
universe@483 8 *
universe@483 9 * 1. Redistributions of source code must retain the above copyright
universe@483 10 * notice, this list of conditions and the following disclaimer.
universe@483 11 *
universe@483 12 * 2. Redistributions in binary form must reproduce the above copyright
universe@483 13 * notice, this list of conditions and the following disclaimer in the
universe@483 14 * documentation and/or other materials provided with the distribution.
universe@483 15 *
universe@483 16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
universe@483 17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
universe@483 18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
universe@483 19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
universe@483 20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
universe@483 21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
universe@483 22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
universe@483 23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
universe@483 24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
universe@483 25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
universe@483 26 * POSSIBILITY OF SUCH DAMAGE.
universe@483 27 */
universe@483 28
universe@483 29 /**
universe@483 30 * \file buffer.h
universe@483 31 *
universe@483 32 * \brief Advanced buffer implementation.
universe@483 33 *
universe@483 34 * Instances of CxBuffer can be used to read from or to write to like one
universe@483 35 * would do with a stream.
universe@483 36 *
universe@483 37 * Some features for convenient use of the buffer
universe@483 38 * can be enabled. See the documentation of the macro constants for more
universe@483 39 * information.
universe@483 40 *
universe@483 41 * \author Mike Becker
universe@483 42 * \author Olaf Wintermann
universe@483 43 * \version 3.0
universe@483 44 * \copyright 2-Clause BSD License
universe@483 45 */
universe@483 46
universe@483 47 #ifndef UCX_BUFFER_H
universe@484 48 #define UCX_BUFFER_H
universe@483 49
universe@484 50 #include "common.h"
universe@501 51 #include "allocator.h"
universe@483 52 #include <stdio.h>
universe@483 53
universe@483 54 #ifdef __cplusplus
universe@483 55 extern "C" {
universe@483 56 #endif
universe@483 57
universe@483 58 /**
universe@483 59 * No buffer features enabled (all flags cleared).
universe@483 60 */
universe@483 61 #define CX_BUFFER_DEFAULT 0x00
universe@483 62
universe@483 63 /**
universe@483 64 * If this flag is enabled, the buffer will automatically free its contents when destroyed.
universe@483 65 */
universe@483 66 #define CX_BUFFER_FREE_CONTENTS 0x01
universe@483 67
universe@483 68 /**
universe@483 69 * If this flag is enabled, the buffer will automatically extends its capacity.
universe@483 70 */
universe@483 71 #define CX_BUFFER_AUTO_EXTEND 0x02
universe@483 72
universe@483 73 /** Structure for the UCX buffer data. */
universe@483 74 typedef struct {
universe@483 75 /** A pointer to the buffer contents. */
universe@483 76 union {
universe@483 77 /**
universe@483 78 * Data is interpreted as text.
universe@483 79 */
universe@483 80 char *space;
universe@483 81 /**
universe@483 82 * Data is interpreted as binary.
universe@483 83 */
universe@483 84 unsigned char *bytes;
universe@483 85 };
universe@501 86 /** The allocator to use for automatic memory management. */
universe@529 87 CxAllocator const *allocator;
universe@483 88 /** Current position of the buffer. */
universe@483 89 size_t pos;
universe@483 90 /** Current capacity (i.e. maximum size) of the buffer. */
universe@483 91 size_t capacity;
universe@483 92 /** Current size of the buffer content. */
universe@483 93 size_t size;
universe@483 94 /**
universe@483 95 * Flag register for buffer features.
universe@485 96 * @see #CX_BUFFER_DEFAULT
universe@485 97 * @see #CX_BUFFER_FREE_CONTENTS
universe@485 98 * @see #CX_BUFFER_AUTO_EXTEND
universe@483 99 */
universe@483 100 int flags;
universe@483 101 } cx_buffer_s;
universe@483 102
universe@483 103 /**
universe@483 104 * UCX buffer.
universe@483 105 */
universe@500 106 typedef cx_buffer_s CxBuffer;
universe@483 107
universe@483 108 /**
universe@501 109 * Initializes a fresh buffer.
universe@483 110 *
universe@483 111 * \note You may provide \c NULL as argument for \p space.
universe@483 112 * Then this function will allocate the space and enforce
universe@483 113 * the #CX_BUFFER_FREE_CONTENTS flag.
universe@483 114 *
universe@501 115 * @param buffer the buffer to initialize
universe@501 116 * @param space pointer to the memory area, or \c NULL to allocate
universe@483 117 * new memory
universe@485 118 * @param capacity the capacity of the buffer
universe@501 119 * @param allocator the allocator this buffer shall use for automatic memory management
universe@485 120 * @param flags buffer features (see cx_buffer_s.flags)
universe@501 121 * @return zero on success, non-zero if a required allocation failed
universe@483 122 */
universe@529 123 __attribute__((__nonnull__(1, 4)))
universe@501 124 int cxBufferInit(
universe@501 125 CxBuffer *buffer,
universe@483 126 void *space,
universe@483 127 size_t capacity,
universe@529 128 CxAllocator const *allocator,
universe@483 129 int flags
universe@483 130 );
universe@483 131
universe@483 132 /**
universe@501 133 * Destroys the buffer contents.
universe@483 134 *
universe@501 135 * Has no effect if the #CX_BUFFER_FREE_CONTENTS feature is not enabled.
universe@483 136 *
universe@501 137 * @param buffer the buffer which contents shall be destroyed
universe@483 138 */
universe@529 139 __attribute__((__nonnull__))
universe@500 140 void cxBufferDestroy(CxBuffer *buffer);
universe@483 141
universe@483 142 /**
universe@483 143 * Shifts the contents of the buffer by the given offset.
universe@483 144 *
universe@483 145 * If the offset is positive, the contents are shifted to the right.
universe@483 146 * If auto extension is enabled, the buffer grows, if necessary.
universe@483 147 * In case the auto extension fails, this function returns a non-zero value and
universe@483 148 * no contents are changed.
universe@483 149 * If auto extension is disabled, the contents that do not fit into the buffer
universe@483 150 * are discarded.
universe@483 151 *
universe@483 152 * If the offset is negative, the contents are shifted to the left where the
universe@483 153 * first \p shift bytes are discarded.
universe@483 154 * The new size of the buffer is the old size minus the absolute shift value.
universe@483 155 * If this value is larger than the buffer size, the buffer is emptied (but
universe@483 156 * not cleared, see the security note below).
universe@483 157 *
universe@483 158 * The buffer position gets shifted alongside with the content but is kept
universe@483 159 * within the boundaries of the buffer.
universe@483 160 *
universe@483 161 * \note For situations where \c off_t is not large enough, there are specialized cxBufferShiftLeft() and
universe@483 162 * cxBufferShiftRight() functions using a \c size_t as parameter type.
universe@483 163 *
universe@485 164 * \attention
universe@485 165 * Security Note: The shifting operation does \em not erase the previously occupied memory cells.
universe@485 166 * But you can easily do that manually, e.g. by calling
universe@483 167 * <code>memset(buffer->bytes, 0, shift)</code> for a right shift or
universe@483 168 * <code>memset(buffer->size, 0, buffer->capacity - buffer->size)</code>
universe@483 169 * for a left shift.
universe@483 170 *
universe@485 171 * @param buffer the buffer
universe@485 172 * @param shift the shift offset (negative means left shift)
universe@485 173 * @return 0 on success, non-zero if a required auto-extension fails
universe@483 174 */
universe@529 175 __attribute__((__nonnull__))
universe@483 176 int cxBufferShift(
universe@500 177 CxBuffer *buffer,
universe@483 178 off_t shift
universe@483 179 );
universe@483 180
universe@483 181 /**
universe@483 182 * Shifts the buffer to the right.
universe@483 183 * See cxBufferShift() for details.
universe@483 184 *
universe@485 185 * @param buffer the buffer
universe@485 186 * @param shift the shift offset
universe@485 187 * @return 0 on success, non-zero if a required auto-extension fails
universe@485 188 * @see cxBufferShift()
universe@483 189 */
universe@529 190 __attribute__((__nonnull__))
universe@483 191 int cxBufferShiftRight(
universe@500 192 CxBuffer *buffer,
universe@483 193 size_t shift
universe@483 194 );
universe@483 195
universe@483 196 /**
universe@483 197 * Shifts the buffer to the left.
universe@483 198 * See cxBufferShift() for details.
universe@483 199 *
universe@483 200 * \note Since a left shift cannot fail due to memory allocation problems, this
universe@483 201 * function always returns zero.
universe@483 202 *
universe@485 203 * @param buffer the buffer
universe@485 204 * @param shift the positive shift offset
universe@485 205 * @return always zero
universe@485 206 * @see cxBufferShift()
universe@483 207 */
universe@529 208 __attribute__((__nonnull__))
universe@483 209 int cxBufferShiftLeft(
universe@500 210 CxBuffer *buffer,
universe@483 211 size_t shift
universe@483 212 );
universe@483 213
universe@483 214
universe@483 215 /**
universe@483 216 * Moves the position of the buffer.
universe@483 217 *
universe@483 218 * The new position is relative to the \p whence argument.
universe@483 219 *
universe@483 220 * \li \c SEEK_SET marks the start of the buffer.
universe@483 221 * \li \c SEEK_CUR marks the current position.
universe@483 222 * \li \c SEEK_END marks the end of the buffer.
universe@483 223 *
universe@483 224 * With an offset of zero, this function sets the buffer position to zero
universe@483 225 * (\c SEEK_SET), the buffer size (\c SEEK_END) or leaves the buffer position
universe@483 226 * unchanged (\c SEEK_CUR).
universe@483 227 *
universe@485 228 * @param buffer the buffer
universe@485 229 * @param offset position offset relative to \p whence
universe@485 230 * @param whence one of \c SEEK_SET, \c SEEK_CUR or \c SEEK_END
universe@485 231 * @return 0 on success, non-zero if the position is invalid
universe@483 232 *
universe@483 233 */
universe@529 234 __attribute__((__nonnull__))
universe@483 235 int cxBufferSeek(
universe@500 236 CxBuffer *buffer,
universe@483 237 off_t offset,
universe@483 238 int whence
universe@483 239 );
universe@483 240
universe@483 241 /**
universe@483 242 * Clears the buffer by resetting the position and deleting the data.
universe@483 243 *
universe@483 244 * The data is deleted by zeroing it with a call to memset().
universe@483 245 *
universe@485 246 * @param buffer the buffer to be cleared
universe@483 247 */
universe@529 248 __attribute__((__nonnull__))
universe@529 249 void cxBufferClear(CxBuffer *buffer);
universe@483 250
universe@483 251 /**
universe@483 252 * Tests, if the buffer position has exceeded the buffer capacity.
universe@483 253 *
universe@485 254 * @param buffer the buffer to test
universe@485 255 * @return non-zero, if the current buffer position has exceeded the last
universe@483 256 * available byte of the buffer.
universe@483 257 */
universe@529 258 __attribute__((__nonnull__))
universe@529 259 int cxBufferEof(CxBuffer const *buffer);
universe@483 260
universe@483 261
universe@483 262 /**
universe@483 263 * Ensures that the buffer has a minimum capacity.
universe@483 264 *
universe@483 265 * If the current capacity is not sufficient, the buffer will be extended.
universe@483 266 *
universe@485 267 * @param buffer the buffer
universe@485 268 * @param capacity the minimum required capacity for this buffer
universe@485 269 * @return 0 on success or a non-zero value on failure
universe@483 270 */
universe@529 271 __attribute__((__nonnull__))
universe@483 272 int cxBufferMinimumCapacity(
universe@500 273 CxBuffer *buffer,
universe@483 274 size_t capacity
universe@483 275 );
universe@483 276
universe@483 277 /**
universe@483 278 * Writes data to a CxBuffer.
universe@483 279 *
universe@483 280 * The position of the buffer is increased by the number of bytes written.
universe@483 281 *
universe@483 282 * \note The signature is compatible with the fwrite() family of functions.
universe@483 283 *
universe@485 284 * @param ptr a pointer to the memory area containing the bytes to be written
universe@485 285 * @param size the length of one element
universe@485 286 * @param nitems the element count
universe@485 287 * @param buffer the CxBuffer to write to
universe@485 288 * @return the total count of bytes written
universe@483 289 */
universe@529 290 __attribute__((__nonnull__))
universe@483 291 size_t cxBufferWrite(
universe@489 292 void const *ptr,
universe@483 293 size_t size,
universe@483 294 size_t nitems,
universe@500 295 CxBuffer *buffer
universe@483 296 );
universe@483 297
universe@483 298 /**
universe@483 299 * Reads data from a CxBuffer.
universe@483 300 *
universe@483 301 * The position of the buffer is increased by the number of bytes read.
universe@483 302 *
universe@483 303 * \note The signature is compatible with the fread() family of functions.
universe@483 304 *
universe@485 305 * @param ptr a pointer to the memory area where to store the read data
universe@485 306 * @param size the length of one element
universe@485 307 * @param nitems the element count
universe@485 308 * @param buffer the CxBuffer to read from
universe@485 309 * @return the total number of elements read
universe@483 310 */
universe@529 311 __attribute__((__nonnull__))
universe@483 312 size_t cxBufferRead(
universe@483 313 void *ptr,
universe@483 314 size_t size,
universe@483 315 size_t nitems,
universe@500 316 CxBuffer *buffer
universe@483 317 );
universe@483 318
universe@483 319 /**
universe@483 320 * Writes a character to a buffer.
universe@483 321 *
universe@483 322 * The least significant byte of the argument is written to the buffer. If the
universe@483 323 * end of the buffer is reached and #CX_BUFFER_AUTO_EXTEND feature is enabled,
universe@483 324 * the buffer capacity is extended by cxBufferMinimumCapacity(). If the feature is
universe@483 325 * disabled or buffer extension fails, \c EOF is returned.
universe@483 326 *
universe@483 327 * On successful write, the position of the buffer is increased.
universe@483 328 *
universe@485 329 * @param buffer the buffer to write to
universe@485 330 * @param c the character to write
universe@485 331 * @return the byte that has bean written or \c EOF when the end of the stream is
universe@483 332 * reached and automatic extension is not enabled or not possible
universe@483 333 */
universe@529 334 __attribute__((__nonnull__))
universe@483 335 int cxBufferPut(
universe@500 336 CxBuffer *buffer,
universe@483 337 int c
universe@483 338 );
universe@483 339
universe@483 340 /**
universe@529 341 * Writes a string to a buffer.
universe@529 342 *
universe@529 343 * @param buffer the buffer
universe@529 344 * @param str the zero-terminated string
universe@529 345 * @return the number of bytes written
universe@529 346 */
universe@529 347 __attribute__((__nonnull__))
universe@529 348 size_t cxBufferPutString(
universe@529 349 CxBuffer *buffer,
universe@529 350 const char *str
universe@529 351 );
universe@529 352
universe@529 353 /**
universe@483 354 * Gets a character from a buffer.
universe@483 355 *
universe@483 356 * The current position of the buffer is increased after a successful read.
universe@483 357 *
universe@485 358 * @param buffer the buffer to read from
universe@485 359 * @return the character or \c EOF, if the end of the buffer is reached
universe@483 360 */
universe@529 361 __attribute__((__nonnull__))
universe@500 362 int cxBufferGet(CxBuffer *buffer);
universe@483 363
universe@483 364 #ifdef __cplusplus
universe@483 365 }
universe@483 366 #endif
universe@483 367
universe@483 368 #endif /* UCX_BUFFER_H */

mercurial