buffer.c File Reference

#include "buffer.h"

Go to the source code of this file.

Functions
void	buffer_init (buffer *s, BufferOp op, int fd, char *buf, ut32 len)
static int	allwrite (BufferOp op, int fd, const char *buf, ut32 len)
int	buffer_flush (buffer *s)
int	buffer_putalign (buffer *s, const char *buf, ut32 len)
int	buffer_putflush (buffer *s, const char *buf, ut32 len)

Function Documentation

allwrite()

static int allwrite ( BufferOp  op, int  fd, const char *  buf, ut32  len  )

static

Definition at line 14 of file buffer.c.

                                                                    {
    ut32 w;
    while (len > 0) {
        w = op(fd, buf, len);
        if (w != len) {
            return 0;
        }
        buf += w;
        len -= w;
    }
    return 1;
}

References fd, len, op, and w.

Referenced by buffer_flush(), and buffer_putflush().

buffer_flush()

int buffer_flush

(

buffer *

s

)

Definition at line 27 of file buffer.c.

                            {
    int p = s->p;
    if (!p) {
        return 1;
    }
    s->p = 0;
    return allwrite(s->op, s->fd, s->x, p);
}

References allwrite(), rz_socket_t::fd, p, and s.

Referenced by buffer_putalign(), buffer_putflush(), and cdb_make_finish().

buffer_init()

void buffer_init	(	buffer *	s,
		BufferOp	op,
		int	fd,
		char *	buf,
		ut32	len
	)

Definition at line 6 of file buffer.c.

                                                                      {
    s->x = buf;
    s->fd = fd;
    s->op = op;
    s->p = 0;
    s->n = len;
}

References fd, rz_socket_t::fd, len, op, and s.

Referenced by cdb_make_start().

buffer_putalign()

int buffer_putalign	(	buffer *	s,
		const char *	buf,
		ut32	len
	)

Definition at line 36 of file buffer.c.

                                                          {
    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;
}

References buffer_flush(), len, memcpy(), n, and s.

Referenced by cdb_make_add(), cdb_make_addbegin(), and cdb_make_finish().

buffer_putflush()

int buffer_putflush	(	buffer *	s,
		const char *	buf,
		ut32	len
	)

Definition at line 56 of file buffer.c.

                                                          {
    if (!buffer_flush(s)) {
        return 0;
    }
    return allwrite(s->op, s->fd, buf, len);
}

References allwrite(), buffer_flush(), rz_socket_t::fd, len, and s.

Referenced by cdb_make_finish().