Wed, 15 Mar 2023 19:46:02 +0100
minimal support for ldap groups
/* * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. * * Copyright 2018 Olaf Wintermann. All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. */ #include <stdio.h> #include <stdlib.h> #include <string.h> #include "writer.h" void writer_init(Writer *w, SYS_NETFD fd, char *buf, size_t len) { w->fd = fd; w->write = (wr_writefunc)net_write; w->buffer = buf; w->size = len; w->pos = 0; w->error = 0; } void writer_init_with_stream(Writer *w, void *stream, wr_writefunc writefunc, char *buf, size_t len) { w->fd = stream; w->write = writefunc; w->buffer = buf; w->size = len; w->pos = 0; w->error = 0; } int writer_flush(Writer *w) { if(w->error) { return w->error; } size_t pos = 0; size_t len = w->pos; while(len > 0) { //fwrite(w->buffer+pos, 1, len, stdout); //fflush(stdout); ssize_t r = w->write(w->fd, w->buffer + pos, len); if(r <= 0) { break; } len -= r; pos += r; } if(pos != w->pos) { w->error = 1; return 1; } w->pos = 0; return 0; } int writer_put(Writer *w, const char *s, size_t len) { if(w->error) { return w->error; } // available bytes size_t a = w->size - w->pos; if(a == 0) { if(writer_flush(w)) { return 1; } } size_t cplen = len > a ? a : len; // number of bytes we can copy memcpy(w->buffer+w->pos, s, cplen); w->pos += cplen; if(cplen < len) { // not all bytes copied -> call writer_put again // the number of available bytes is 0 then, therefore flush is called return writer_put(w, s + cplen, len - cplen); } else { return 0; } } int writer_puts(Writer *w, cxstring s) { return writer_put(w, s.ptr, s.length); } int writer_putc(Writer *w, char c) { if(w->pos == w->size) { if(writer_flush(w)) { return 1; } } w->buffer[w->pos++] = c; return 0; } int writer_fwrite(const void *s, size_t size, size_t nelem, Writer *out) { int w = writer_put(out, s, size*nelem); return w/size; }