buffer.c

Go to the documentation of this file.

// SPDX-FileCopyrightText: unknown
// SPDX-License-Identifier: CC-PDDC
 
#include "buffer.h"
 
void buffer_init(buffer *s, BufferOp op, int fd, char *buf, ut32 len) {
    s->x = buf;
    s->fd = fd;
    s->op = op;
    s->p = 0;
    s->n = len;
}
 
static int allwrite(BufferOp op, int fd, const char *buf, ut32 len) {
    ut32 w;
    while (len > 0) {
        w = op(fd, buf, len);
        if (w != len) {
            return 0;
        }
        buf += w;
        len -= w;
    }
    return 1;
}
 
int buffer_flush(buffer *s) {
    int p = s->p;
    if (!p) {
        return 1;
    }
    s->p = 0;
    return allwrite(s->op, s->fd, s->x, p);
}
 
int buffer_putalign(buffer *s, const char *buf, ut32 len) {
    ut32 n;
    if (!s || !s->x || !buf) {
        return 0;
    }
    while (len > (n = s->n - s->p)) {
        memcpy(s->x + s->p, buf, n);
        s->p += n;
        buf += n;
        len -= n;
        if (!buffer_flush(s)) {
            return 0;
        }
    }
    /* now len <= s->n - s->p */
    memcpy(s->x + s->p, buf, len);
    s->p += len;
    return 1;
}
 
int buffer_putflush(buffer *s, const char *buf, ut32 len) {
    if (!buffer_flush(s)) {
        return 0;
    }
    return allwrite(s->op, s->fd, buf, len);
}