diff options
Diffstat (limited to 'server/nss/nsssrv_packet.c')
| -rw-r--r-- | server/nss/nsssrv_packet.c | 185 |
1 files changed, 185 insertions, 0 deletions
diff --git a/server/nss/nsssrv_packet.c b/server/nss/nsssrv_packet.c new file mode 100644 index 00000000..e33568a3 --- /dev/null +++ b/server/nss/nsssrv_packet.c @@ -0,0 +1,185 @@ +/* + SSSD + + NSS Responder, command parser + + Copyright (C) Simo Sorce <ssorce@redhat.com> 2008 + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 3 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program. If not, see <http://www.gnu.org/licenses/>. +*/ + +#include <sys/types.h> +#include <sys/socket.h> +#include <string.h> +#include <errno.h> +#include "../talloc/talloc.h" +#include "util/util.h" +#include "nss/nsssrv.h" + +#define NSSSRV_PACKET_MEM_SIZE 512 + +struct nss_packet { + size_t memsize; + uint8_t *buffer; + + /* header */ + uint32_t *len; + uint32_t *cmd; + uint32_t *status; + uint32_t *reserved; + + uint8_t *body; + + /* io pointer */ + size_t iop; +}; + +/* + * Allocate a new packet structure + * + * - if size is defined use it otherwise the default packet will be + * NSSSRV_PACKET_MEM_SIZE bytes. + * - if buf is provided also give back the pointer to the base of + * the buffer (the header), so that a packet can be written into + * firecgtly from the wire + */ +int nss_packet_new(TALLOC_CTX *mem_ctx, size_t size, + struct nss_packet **rpacket) +{ + struct nss_packet *packet; + + packet = talloc(mem_ctx, struct nss_packet); + if (!packet) return RES_NOMEM; + + if (size) { + int n = size % NSSSRV_PACKET_MEM_SIZE; + packet->memsize = (n + 1) * NSSSRV_PACKET_MEM_SIZE; + } else { + packet->memsize = NSSSRV_PACKET_MEM_SIZE; + } + + packet->buffer = talloc_size(packet, packet->memsize); + if (!packet->buffer) { + talloc_free(packet); + return RES_NOMEM; + } + memset(packet->buffer, 0, SSS_NSS_HEADER_SIZE); + + packet->len = &((uint32_t *)packet->buffer)[0]; + packet->cmd = &((uint32_t *)packet->buffer)[1]; + packet->status = &((uint32_t *)packet->buffer)[2]; + packet->reserved = &((uint32_t *)packet->buffer)[3]; + packet->body = (uint8_t *)&((uint32_t *)packet->buffer)[4]; + + *(packet->len) = size?size:SSS_NSS_HEADER_SIZE; + + *rpacket = packet; + + return RES_SUCCESS; +} + +/* grows a packet size only in NSSSRV_PACKET_MEM_SIZE chunks */ +int nss_packet_grow(struct nss_packet *packet, size_t size) +{ + size_t totlen, len; + uint8_t *newmem; + + if (size == 0) { + return RES_SUCCESS; + } + + totlen = packet->memsize; + len = *packet->len + size; + + /* make sure we do not overflow */ + if (totlen < len) { + int n = len % NSSSRV_PACKET_MEM_SIZE + 1; + totlen += n * NSSSRV_PACKET_MEM_SIZE; + if (totlen < len) { + return RES_INVALID_DATA; + } + } + + if (totlen > packet->memsize) { + newmem = talloc_realloc_size(packet, packet->buffer, totlen); + if (!newmem) { + return RES_NOMEM; + } + + packet->memsize = totlen; + packet->buffer = newmem; + packet->len = &((uint32_t *)packet->buffer)[0]; + packet->cmd = &((uint32_t *)packet->buffer)[1]; + packet->status = &((uint32_t *)packet->buffer)[2]; + packet->reserved = &((uint32_t *)packet->buffer)[3]; + packet->body = (uint8_t *)&((uint32_t *)packet->buffer)[4]; + } + + *(packet->len) += size; + + return 0; +} + +int nss_packet_recv(struct nss_packet *packet, int fd) +{ + size_t rb; + size_t len; + void *buf; + + buf = packet->buffer + packet->iop; + if (packet->iop > 4) len = *packet->len; + else len = packet->memsize; + + errno = 0; + rb = recv(fd, buf, len, 0); + + if (rb == -1 && errno == EAGAIN) { + return RES_RETRY; + } + + packet->iop += rb; + if (packet->iop < 4) { + return RES_RETRY; + } + + if (packet->iop < *packet->len) { + return RES_RETRY; + } + + return RES_SUCCESS; +} + +int nss_packet_send(struct nss_packet *packet, int fd) +{ + size_t rb; + size_t len; + void *buf; + + buf = packet->buffer + packet->iop; + len = *packet->len - packet->iop; + + errno = 0; + rb = send(fd, buf, len, 0); + + if (rb == -1 && errno == EAGAIN) { + return RES_RETRY; + } + + packet->iop += rb; + if (packet->iop < *packet->len) { + return RES_RETRY; + } + + return RES_SUCCESS; +} |