1 f36fd90a 2022-07-09 op #include "config.h"
   2 f36fd90a 2022-07-09 op #if !HAVE_ERR
   3 f36fd90a 2022-07-09 op /*
   4 f36fd90a 2022-07-09 op  * Copyright (c) 1993
   5 f36fd90a 2022-07-09 op  *      The Regents of the University of California.  All rights reserved.
   6 f36fd90a 2022-07-09 op  *
   7 f36fd90a 2022-07-09 op  * Redistribution and use in source and binary forms, with or without
   8 f36fd90a 2022-07-09 op  * modification, are permitted provided that the following conditions
   9 f36fd90a 2022-07-09 op  * are met:
  10 f36fd90a 2022-07-09 op  * 1. Redistributions of source code must retain the above copyright
  11 f36fd90a 2022-07-09 op  *    notice, this list of conditions and the following disclaimer.
  12 f36fd90a 2022-07-09 op  * 2. Redistributions in binary form must reproduce the above copyright
  13 f36fd90a 2022-07-09 op  *    notice, this list of conditions and the following disclaimer in the
  14 f36fd90a 2022-07-09 op  *    documentation and/or other materials provided with the distribution.
  15 f36fd90a 2022-07-09 op  * 3. Neither the name of the University nor the names of its contributors
  16 f36fd90a 2022-07-09 op  *    may be used to endorse or promote products derived from this software
  17 f36fd90a 2022-07-09 op  *    without specific prior written permission.
  18 f36fd90a 2022-07-09 op  *
  19 f36fd90a 2022-07-09 op  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  20 f36fd90a 2022-07-09 op  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  21 f36fd90a 2022-07-09 op  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  22 f36fd90a 2022-07-09 op  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  23 f36fd90a 2022-07-09 op  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  24 f36fd90a 2022-07-09 op  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  25 f36fd90a 2022-07-09 op  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  26 f36fd90a 2022-07-09 op  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  27 f36fd90a 2022-07-09 op  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  28 f36fd90a 2022-07-09 op  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  29 f36fd90a 2022-07-09 op  * SUCH DAMAGE.
  30 f36fd90a 2022-07-09 op  */
  31 f36fd90a 2022-07-09 op 
  32 f36fd90a 2022-07-09 op #include <errno.h>
  33 f36fd90a 2022-07-09 op #include <stdarg.h>
  34 f36fd90a 2022-07-09 op #include <stdio.h>
  35 f36fd90a 2022-07-09 op #include <stdlib.h>
  36 f36fd90a 2022-07-09 op #include <string.h>
  37 f36fd90a 2022-07-09 op 
  38 f36fd90a 2022-07-09 op void
  39 f36fd90a 2022-07-09 op vwarnx(const char *fmt, va_list ap)
  40 f36fd90a 2022-07-09 op {
  41 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s: ", getprogname());
  42 f36fd90a 2022-07-09 op 	if (fmt != NULL)
  43 f36fd90a 2022-07-09 op 		vfprintf(stderr, fmt, ap);
  44 f36fd90a 2022-07-09 op 	fprintf(stderr, "\n");
  45 f36fd90a 2022-07-09 op }
  46 f36fd90a 2022-07-09 op 
  47 f36fd90a 2022-07-09 op void
  48 f36fd90a 2022-07-09 op vwarnc(int code, const char *fmt, va_list ap)
  49 f36fd90a 2022-07-09 op {
  50 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s: ", getprogname());
  51 f36fd90a 2022-07-09 op 	if (fmt != NULL) {
  52 f36fd90a 2022-07-09 op 		vfprintf(stderr, fmt, ap);
  53 f36fd90a 2022-07-09 op 		fprintf(stderr, ": ");
  54 f36fd90a 2022-07-09 op 	}
  55 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s\n", strerror(code));
  56 f36fd90a 2022-07-09 op }
  57 f36fd90a 2022-07-09 op 
  58 f36fd90a 2022-07-09 op void
  59 f36fd90a 2022-07-09 op vwarn(const char *fmt, va_list ap)
  60 f36fd90a 2022-07-09 op {
  61 f36fd90a 2022-07-09 op 	int sverrno;
  62 f36fd90a 2022-07-09 op 
  63 f36fd90a 2022-07-09 op 	sverrno = errno;
  64 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s: ", getprogname());
  65 f36fd90a 2022-07-09 op 	if (fmt != NULL) {
  66 f36fd90a 2022-07-09 op 		vfprintf(stderr, fmt, ap);
  67 f36fd90a 2022-07-09 op 		fprintf(stderr, ": ");
  68 f36fd90a 2022-07-09 op 	}
  69 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s\n", strerror(sverrno));
  70 f36fd90a 2022-07-09 op }
  71 f36fd90a 2022-07-09 op 
  72 f36fd90a 2022-07-09 op void
  73 f36fd90a 2022-07-09 op verrc(int eval, int code, const char *fmt, va_list ap)
  74 f36fd90a 2022-07-09 op {
  75 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s: ", getprogname());
  76 f36fd90a 2022-07-09 op 	if (fmt != NULL) {
  77 f36fd90a 2022-07-09 op 		vfprintf(stderr, fmt, ap);
  78 f36fd90a 2022-07-09 op 		fprintf(stderr, ": ");
  79 f36fd90a 2022-07-09 op 	}
  80 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s\n", strerror(code));
  81 f36fd90a 2022-07-09 op 	exit(eval);
  82 f36fd90a 2022-07-09 op }
  83 f36fd90a 2022-07-09 op 
  84 f36fd90a 2022-07-09 op void
  85 f36fd90a 2022-07-09 op verrx(int eval, const char *fmt, va_list ap)
  86 f36fd90a 2022-07-09 op {
  87 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s: ", getprogname());
  88 f36fd90a 2022-07-09 op 	if (fmt != NULL)
  89 f36fd90a 2022-07-09 op 		vfprintf(stderr, fmt, ap);
  90 f36fd90a 2022-07-09 op 	fprintf(stderr, "\n");
  91 f36fd90a 2022-07-09 op 	exit(eval);
  92 f36fd90a 2022-07-09 op }
  93 f36fd90a 2022-07-09 op 
  94 f36fd90a 2022-07-09 op void
  95 f36fd90a 2022-07-09 op verr(int eval, const char *fmt, va_list ap)
  96 f36fd90a 2022-07-09 op {
  97 f36fd90a 2022-07-09 op 	int sverrno;
  98 f36fd90a 2022-07-09 op 
  99 f36fd90a 2022-07-09 op 	sverrno = errno;
 100 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s: ", getprogname());
 101 f36fd90a 2022-07-09 op 	if (fmt != NULL) {
 102 f36fd90a 2022-07-09 op 		vfprintf(stderr, fmt, ap);
 103 f36fd90a 2022-07-09 op 		fprintf(stderr, ": ");
 104 f36fd90a 2022-07-09 op 	}
 105 f36fd90a 2022-07-09 op 	fprintf(stderr, "%s\n", strerror(sverrno));
 106 f36fd90a 2022-07-09 op 	exit(eval);
 107 f36fd90a 2022-07-09 op }
 108 f36fd90a 2022-07-09 op 
 109 f36fd90a 2022-07-09 op void
 110 f36fd90a 2022-07-09 op err(int eval, const char *fmt, ...)
 111 f36fd90a 2022-07-09 op {
 112 f36fd90a 2022-07-09 op 	va_list ap;
 113 f36fd90a 2022-07-09 op 
 114 f36fd90a 2022-07-09 op 	va_start(ap, fmt);
 115 f36fd90a 2022-07-09 op 	verr(eval, fmt, ap);
 116 f36fd90a 2022-07-09 op 	va_end(ap);
 117 f36fd90a 2022-07-09 op }
 118 f36fd90a 2022-07-09 op 
 119 f36fd90a 2022-07-09 op void
 120 f36fd90a 2022-07-09 op errc(int eval, int code, const char *fmt, ...)
 121 f36fd90a 2022-07-09 op {
 122 f36fd90a 2022-07-09 op 	va_list ap;
 123 f36fd90a 2022-07-09 op 
 124 f36fd90a 2022-07-09 op 	va_start(ap, fmt);
 125 f36fd90a 2022-07-09 op 	verrc(eval, code, fmt, ap);
 126 f36fd90a 2022-07-09 op 	va_end(ap);
 127 f36fd90a 2022-07-09 op }
 128 f36fd90a 2022-07-09 op 
 129 f36fd90a 2022-07-09 op void
 130 f36fd90a 2022-07-09 op errx(int eval, const char *fmt, ...)
 131 f36fd90a 2022-07-09 op {
 132 f36fd90a 2022-07-09 op 	va_list ap;
 133 f36fd90a 2022-07-09 op 
 134 f36fd90a 2022-07-09 op 	va_start(ap, fmt);
 135 f36fd90a 2022-07-09 op 	verrx(eval, fmt, ap);
 136 f36fd90a 2022-07-09 op 	va_end(ap);
 137 f36fd90a 2022-07-09 op }
 138 f36fd90a 2022-07-09 op 
 139 f36fd90a 2022-07-09 op void
 140 f36fd90a 2022-07-09 op warn(const char *fmt, ...)
 141 f36fd90a 2022-07-09 op {
 142 f36fd90a 2022-07-09 op 	va_list ap;
 143 f36fd90a 2022-07-09 op 
 144 f36fd90a 2022-07-09 op 	va_start(ap, fmt);
 145 f36fd90a 2022-07-09 op 	vwarn(fmt, ap);
 146 f36fd90a 2022-07-09 op 	va_end(ap);
 147 f36fd90a 2022-07-09 op }
 148 f36fd90a 2022-07-09 op 
 149 f36fd90a 2022-07-09 op void
 150 f36fd90a 2022-07-09 op warnc(int code, const char *fmt, ...)
 151 f36fd90a 2022-07-09 op {
 152 f36fd90a 2022-07-09 op 	va_list ap;
 153 f36fd90a 2022-07-09 op 
 154 f36fd90a 2022-07-09 op 	va_start(ap, fmt);
 155 f36fd90a 2022-07-09 op 	vwarnc(code, fmt, ap);
 156 f36fd90a 2022-07-09 op 	va_end(ap);
 157 f36fd90a 2022-07-09 op }
 158 f36fd90a 2022-07-09 op 
 159 f36fd90a 2022-07-09 op void
 160 f36fd90a 2022-07-09 op warnx(const char *fmt, ...)
 161 f36fd90a 2022-07-09 op {
 162 f36fd90a 2022-07-09 op 	va_list ap;
 163 f36fd90a 2022-07-09 op 
 164 f36fd90a 2022-07-09 op 	va_start(ap, fmt);
 165 f36fd90a 2022-07-09 op 	vwarnx(fmt, ap);
 166 f36fd90a 2022-07-09 op 	va_end(ap);
 167 f36fd90a 2022-07-09 op }
 168 f36fd90a 2022-07-09 op #endif /* !HAVE_ERR */
 169 f36fd90a 2022-07-09 op #if !HAVE_FLOCK
 170 f36fd90a 2022-07-09 op #include <errno.h>
 171 f36fd90a 2022-07-09 op #include <fcntl.h>
 172 f36fd90a 2022-07-09 op #include <string.h>
 173 f36fd90a 2022-07-09 op 
 174 f36fd90a 2022-07-09 op /*
 175 f36fd90a 2022-07-09 op  * flock(2) emulation on top of fcntl advisory locks.  This is "good
 176 f36fd90a 2022-07-09 op  * enough" for amused, not a _real_ emulation.  flock and fcntl locks
 177 f36fd90a 2022-07-09 op  * have subtly different behaviours!
 178 f36fd90a 2022-07-09 op  */
 179 f36fd90a 2022-07-09 op int
 180 f36fd90a 2022-07-09 op flock(int fd, int op)
 181 f36fd90a 2022-07-09 op {
 182 f36fd90a 2022-07-09 op 	struct flock l;
 183 f36fd90a 2022-07-09 op 	int cmd;
 184 f36fd90a 2022-07-09 op 
 185 f36fd90a 2022-07-09 op 	memset(&l, 0, sizeof(l));
 186 f36fd90a 2022-07-09 op 	l.l_whence = SEEK_SET;
 187 f36fd90a 2022-07-09 op 
 188 f36fd90a 2022-07-09 op 	if (op & LOCK_SH)
 189 f36fd90a 2022-07-09 op 		l.l_type = F_RDLCK;
 190 f36fd90a 2022-07-09 op 	else if (op & LOCK_EX)
 191 f36fd90a 2022-07-09 op 		l.l_type = F_WRLCK;
 192 f36fd90a 2022-07-09 op 	else {
 193 f36fd90a 2022-07-09 op 		errno = EINVAL;
 194 f36fd90a 2022-07-09 op 		return -1;
 195 f36fd90a 2022-07-09 op 	}
 196 f36fd90a 2022-07-09 op 
 197 f36fd90a 2022-07-09 op 	cmd = F_SETLKW;
 198 f36fd90a 2022-07-09 op 	if (op & LOCK_NB)
 199 f36fd90a 2022-07-09 op 		cmd = F_SETLK;
 200 f36fd90a 2022-07-09 op 
 201 f36fd90a 2022-07-09 op 	return fcntl(fd, cmd, &l);
 202 f36fd90a 2022-07-09 op }
 203 f36fd90a 2022-07-09 op #endif /* HAVE_FLOCK */
 204 f36fd90a 2022-07-09 op #if !HAVE_FREEZERO
 205 f36fd90a 2022-07-09 op #include <stdlib.h>
 206 f36fd90a 2022-07-09 op #include <string.h>
 207 f36fd90a 2022-07-09 op 
 208 f36fd90a 2022-07-09 op void
 209 f36fd90a 2022-07-09 op freezero(void *ptr, size_t len)
 210 f36fd90a 2022-07-09 op {
 211 f36fd90a 2022-07-09 op 	if (ptr == NULL)
 212 f36fd90a 2022-07-09 op 		return;
 213 f36fd90a 2022-07-09 op 	memset(ptr, 0, len);
 214 f36fd90a 2022-07-09 op 	free(ptr);
 215 f36fd90a 2022-07-09 op }
 216 f36fd90a 2022-07-09 op #endif /* HAVE_FREEZERO */
 217 f36fd90a 2022-07-09 op #if !HAVE_EXPLICIT_BZERO
 218 f36fd90a 2022-07-09 op /* OPENBSD ORIGINAL: lib/libc/string/explicit_bzero.c */
 219 f36fd90a 2022-07-09 op /*
 220 f36fd90a 2022-07-09 op  * Public domain.
 221 f36fd90a 2022-07-09 op  * Written by Ted Unangst
 222 f36fd90a 2022-07-09 op  */
 223 f36fd90a 2022-07-09 op 
 224 f36fd90a 2022-07-09 op #include <string.h>
 225 f36fd90a 2022-07-09 op 
 226 f36fd90a 2022-07-09 op /*
 227 f36fd90a 2022-07-09 op  * explicit_bzero - don't let the compiler optimize away bzero
 228 f36fd90a 2022-07-09 op  */
 229 f36fd90a 2022-07-09 op 
 230 f36fd90a 2022-07-09 op #if HAVE_MEMSET_S
 231 f36fd90a 2022-07-09 op 
 232 f36fd90a 2022-07-09 op void
 233 f36fd90a 2022-07-09 op explicit_bzero(void *p, size_t n)
 234 f36fd90a 2022-07-09 op {
 235 f36fd90a 2022-07-09 op 	if (n == 0)
 236 f36fd90a 2022-07-09 op 		return;
 237 f36fd90a 2022-07-09 op 	(void)memset_s(p, n, 0, n);
 238 f36fd90a 2022-07-09 op }
 239 f36fd90a 2022-07-09 op 
 240 f36fd90a 2022-07-09 op #else /* HAVE_MEMSET_S */
 241 f36fd90a 2022-07-09 op 
 242 f36fd90a 2022-07-09 op #include <strings.h>
 243 f36fd90a 2022-07-09 op 
 244 f36fd90a 2022-07-09 op /*
 245 f36fd90a 2022-07-09 op  * Indirect memset through a volatile pointer to hopefully avoid
 246 f36fd90a 2022-07-09 op  * dead-store optimisation eliminating the call.
 247 f36fd90a 2022-07-09 op  */
 248 f36fd90a 2022-07-09 op static void (* volatile ssh_memset)(void *, int, size_t) = memset;
 249 f36fd90a 2022-07-09 op 
 250 f36fd90a 2022-07-09 op void
 251 f36fd90a 2022-07-09 op explicit_bzero(void *p, size_t n)
 252 f36fd90a 2022-07-09 op {
 253 f36fd90a 2022-07-09 op 	if (n == 0)
 254 f36fd90a 2022-07-09 op 		return;
 255 f36fd90a 2022-07-09 op 	/*
 256 f36fd90a 2022-07-09 op 	 * clang -fsanitize=memory needs to intercept memset-like functions
 257 f36fd90a 2022-07-09 op 	 * to correctly detect memory initialisation. Make sure one is called
 258 f36fd90a 2022-07-09 op 	 * directly since our indirection trick above sucessfully confuses it.
 259 f36fd90a 2022-07-09 op 	 */
 260 f36fd90a 2022-07-09 op #if defined(__has_feature)
 261 f36fd90a 2022-07-09 op # if __has_feature(memory_sanitizer)
 262 f36fd90a 2022-07-09 op 	memset(p, 0, n);
 263 f36fd90a 2022-07-09 op # endif
 264 f36fd90a 2022-07-09 op #endif
 265 f36fd90a 2022-07-09 op 
 266 f36fd90a 2022-07-09 op 	ssh_memset(p, 0, n);
 267 f36fd90a 2022-07-09 op }
 268 f36fd90a 2022-07-09 op 
 269 f36fd90a 2022-07-09 op #endif /* HAVE_MEMSET_S */
 270 f36fd90a 2022-07-09 op #endif /* !HAVE_EXPLICIT_BZERO */
 271 f36fd90a 2022-07-09 op #if !HAVE_GETPROGNAME
 272 f36fd90a 2022-07-09 op /*
 273 f36fd90a 2022-07-09 op  * Copyright (c) 2016 Nicholas Marriott <nicholas.marriott@gmail.com>
 274 f36fd90a 2022-07-09 op  * Copyright (c) 2017 Kristaps Dzonsons <kristaps@bsd.lv>
 275 f36fd90a 2022-07-09 op  * Copyright (c) 2020 Stephen Gregoratto <dev@sgregoratto.me>
 276 f36fd90a 2022-07-09 op  *
 277 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
 278 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
 279 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
 280 f36fd90a 2022-07-09 op  *
 281 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 282 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 283 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 284 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 285 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF MIND, USE, DATA OR PROFITS, WHETHER
 286 f36fd90a 2022-07-09 op  * IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
 287 f36fd90a 2022-07-09 op  * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 288 f36fd90a 2022-07-09 op  */
 289 f36fd90a 2022-07-09 op 
 290 f36fd90a 2022-07-09 op #include <sys/types.h>
 291 f36fd90a 2022-07-09 op 
 292 f36fd90a 2022-07-09 op #include <errno.h>
 293 f36fd90a 2022-07-09 op 
 294 f36fd90a 2022-07-09 op #if HAVE_GETEXECNAME
 295 f36fd90a 2022-07-09 op #include <stdlib.h>
 296 f36fd90a 2022-07-09 op const char *
 297 f36fd90a 2022-07-09 op getprogname(void)
 298 f36fd90a 2022-07-09 op {
 299 f36fd90a 2022-07-09 op 	return getexecname();
 300 f36fd90a 2022-07-09 op }
 301 f36fd90a 2022-07-09 op #elif HAVE_PROGRAM_INVOCATION_SHORT_NAME
 302 f36fd90a 2022-07-09 op const char *
 303 f36fd90a 2022-07-09 op getprogname(void)
 304 f36fd90a 2022-07-09 op {
 305 f36fd90a 2022-07-09 op 	return (program_invocation_short_name);
 306 f36fd90a 2022-07-09 op }
 307 f36fd90a 2022-07-09 op #elif HAVE___PROGNAME
 308 f36fd90a 2022-07-09 op const char *
 309 f36fd90a 2022-07-09 op getprogname(void)
 310 f36fd90a 2022-07-09 op {
 311 f36fd90a 2022-07-09 op 	extern char	*__progname;
 312 f36fd90a 2022-07-09 op 
 313 f36fd90a 2022-07-09 op 	return (__progname);
 314 f36fd90a 2022-07-09 op }
 315 f36fd90a 2022-07-09 op #else
 316 f36fd90a 2022-07-09 op #warning No getprogname available.
 317 f36fd90a 2022-07-09 op const char *
 318 f36fd90a 2022-07-09 op getprogname(void)
 319 f36fd90a 2022-07-09 op {
 320 f36fd90a 2022-07-09 op 	return ("amused");
 321 f36fd90a 2022-07-09 op }
 322 f36fd90a 2022-07-09 op #endif
 323 f36fd90a 2022-07-09 op #endif /* !HAVE_GETPROGNAME */
 324 82556d5b 2023-09-07 op #if !HAVE_LIB_IMSG
 325 3ac93df9 2023-07-02 op /*	$OpenBSD: imsg-buffer.c,v 1.16 2023/06/19 17:19:50 claudio Exp $	*/
 326 3ac93df9 2023-07-02 op /*	$OpenBSD: imsg.c,v 1.19 2023/06/19 17:19:50 claudio Exp $	*/
 327 f36fd90a 2022-07-09 op 
 328 f36fd90a 2022-07-09 op /*
 329 f36fd90a 2022-07-09 op  * Copyright (c) 2003, 2004 Henning Brauer <henning@openbsd.org>
 330 f36fd90a 2022-07-09 op  *
 331 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
 332 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
 333 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
 334 f36fd90a 2022-07-09 op  *
 335 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 336 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 337 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 338 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 339 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 340 f36fd90a 2022-07-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 341 f36fd90a 2022-07-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 342 f36fd90a 2022-07-09 op  */
 343 f36fd90a 2022-07-09 op 
 344 f36fd90a 2022-07-09 op #include "config.h"
 345 f36fd90a 2022-07-09 op 
 346 f36fd90a 2022-07-09 op #include <sys/types.h>
 347 f36fd90a 2022-07-09 op #include <sys/socket.h>
 348 f36fd90a 2022-07-09 op #include <sys/uio.h>
 349 f36fd90a 2022-07-09 op 
 350 f36fd90a 2022-07-09 op #include <limits.h>
 351 f36fd90a 2022-07-09 op #include <errno.h>
 352 f36fd90a 2022-07-09 op #include <stdlib.h>
 353 f36fd90a 2022-07-09 op #include <string.h>
 354 f36fd90a 2022-07-09 op #include <unistd.h>
 355 f36fd90a 2022-07-09 op 
 356 f36fd90a 2022-07-09 op #include "imsg.h"
 357 f36fd90a 2022-07-09 op 
 358 f36fd90a 2022-07-09 op static int	ibuf_realloc(struct ibuf *, size_t);
 359 f36fd90a 2022-07-09 op static void	ibuf_enqueue(struct msgbuf *, struct ibuf *);
 360 f36fd90a 2022-07-09 op static void	ibuf_dequeue(struct msgbuf *, struct ibuf *);
 361 3ac93df9 2023-07-02 op static void	msgbuf_drain(struct msgbuf *, size_t);
 362 f36fd90a 2022-07-09 op 
 363 f36fd90a 2022-07-09 op struct ibuf *
 364 f36fd90a 2022-07-09 op ibuf_open(size_t len)
 365 f36fd90a 2022-07-09 op {
 366 f36fd90a 2022-07-09 op 	struct ibuf	*buf;
 367 f36fd90a 2022-07-09 op 
 368 3ac93df9 2023-07-02 op 	if (len == 0) {
 369 3ac93df9 2023-07-02 op 		errno = EINVAL;
 370 3ac93df9 2023-07-02 op 		return (NULL);
 371 3ac93df9 2023-07-02 op 	}
 372 f36fd90a 2022-07-09 op 	if ((buf = calloc(1, sizeof(struct ibuf))) == NULL)
 373 f36fd90a 2022-07-09 op 		return (NULL);
 374 3ac93df9 2023-07-02 op 	if ((buf->buf = calloc(len, 1)) == NULL) {
 375 f36fd90a 2022-07-09 op 		free(buf);
 376 f36fd90a 2022-07-09 op 		return (NULL);
 377 f36fd90a 2022-07-09 op 	}
 378 f36fd90a 2022-07-09 op 	buf->size = buf->max = len;
 379 f36fd90a 2022-07-09 op 	buf->fd = -1;
 380 f36fd90a 2022-07-09 op 
 381 f36fd90a 2022-07-09 op 	return (buf);
 382 f36fd90a 2022-07-09 op }
 383 f36fd90a 2022-07-09 op 
 384 f36fd90a 2022-07-09 op struct ibuf *
 385 f36fd90a 2022-07-09 op ibuf_dynamic(size_t len, size_t max)
 386 f36fd90a 2022-07-09 op {
 387 f36fd90a 2022-07-09 op 	struct ibuf	*buf;
 388 f36fd90a 2022-07-09 op 
 389 3ac93df9 2023-07-02 op 	if (max < len) {
 390 3ac93df9 2023-07-02 op 		errno = EINVAL;
 391 f36fd90a 2022-07-09 op 		return (NULL);
 392 3ac93df9 2023-07-02 op 	}
 393 f36fd90a 2022-07-09 op 
 394 3ac93df9 2023-07-02 op 	if ((buf = calloc(1, sizeof(struct ibuf))) == NULL)
 395 f36fd90a 2022-07-09 op 		return (NULL);
 396 3ac93df9 2023-07-02 op 	if (len > 0) {
 397 3ac93df9 2023-07-02 op 		if ((buf->buf = calloc(len, 1)) == NULL) {
 398 3ac93df9 2023-07-02 op 			free(buf);
 399 3ac93df9 2023-07-02 op 			return (NULL);
 400 3ac93df9 2023-07-02 op 		}
 401 3ac93df9 2023-07-02 op 	}
 402 3ac93df9 2023-07-02 op 	buf->size = len;
 403 3ac93df9 2023-07-02 op 	buf->max = max;
 404 3ac93df9 2023-07-02 op 	buf->fd = -1;
 405 f36fd90a 2022-07-09 op 
 406 f36fd90a 2022-07-09 op 	return (buf);
 407 f36fd90a 2022-07-09 op }
 408 f36fd90a 2022-07-09 op 
 409 f36fd90a 2022-07-09 op static int
 410 f36fd90a 2022-07-09 op ibuf_realloc(struct ibuf *buf, size_t len)
 411 f36fd90a 2022-07-09 op {
 412 f36fd90a 2022-07-09 op 	unsigned char	*b;
 413 f36fd90a 2022-07-09 op 
 414 f36fd90a 2022-07-09 op 	/* on static buffers max is eq size and so the following fails */
 415 3ac93df9 2023-07-02 op 	if (len > SIZE_MAX - buf->wpos || buf->wpos + len > buf->max) {
 416 f36fd90a 2022-07-09 op 		errno = ERANGE;
 417 f36fd90a 2022-07-09 op 		return (-1);
 418 f36fd90a 2022-07-09 op 	}
 419 f36fd90a 2022-07-09 op 
 420 f36fd90a 2022-07-09 op 	b = recallocarray(buf->buf, buf->size, buf->wpos + len, 1);
 421 f36fd90a 2022-07-09 op 	if (b == NULL)
 422 f36fd90a 2022-07-09 op 		return (-1);
 423 f36fd90a 2022-07-09 op 	buf->buf = b;
 424 f36fd90a 2022-07-09 op 	buf->size = buf->wpos + len;
 425 f36fd90a 2022-07-09 op 
 426 f36fd90a 2022-07-09 op 	return (0);
 427 f36fd90a 2022-07-09 op }
 428 f36fd90a 2022-07-09 op 
 429 f36fd90a 2022-07-09 op void *
 430 f36fd90a 2022-07-09 op ibuf_reserve(struct ibuf *buf, size_t len)
 431 f36fd90a 2022-07-09 op {
 432 f36fd90a 2022-07-09 op 	void	*b;
 433 f36fd90a 2022-07-09 op 
 434 3ac93df9 2023-07-02 op 	if (len > SIZE_MAX - buf->wpos) {
 435 3ac93df9 2023-07-02 op 		errno = ERANGE;
 436 3ac93df9 2023-07-02 op 		return (NULL);
 437 3ac93df9 2023-07-02 op 	}
 438 3ac93df9 2023-07-02 op 
 439 f36fd90a 2022-07-09 op 	if (buf->wpos + len > buf->size)
 440 f36fd90a 2022-07-09 op 		if (ibuf_realloc(buf, len) == -1)
 441 f36fd90a 2022-07-09 op 			return (NULL);
 442 f36fd90a 2022-07-09 op 
 443 f36fd90a 2022-07-09 op 	b = buf->buf + buf->wpos;
 444 f36fd90a 2022-07-09 op 	buf->wpos += len;
 445 3ac93df9 2023-07-02 op 	memset(b, 0, len);
 446 f36fd90a 2022-07-09 op 	return (b);
 447 3ac93df9 2023-07-02 op }
 448 3ac93df9 2023-07-02 op 
 449 3ac93df9 2023-07-02 op int
 450 3ac93df9 2023-07-02 op ibuf_add(struct ibuf *buf, const void *data, size_t len)
 451 3ac93df9 2023-07-02 op {
 452 3ac93df9 2023-07-02 op 	void *b;
 453 3ac93df9 2023-07-02 op 
 454 3ac93df9 2023-07-02 op 	if ((b = ibuf_reserve(buf, len)) == NULL)
 455 3ac93df9 2023-07-02 op 		return (-1);
 456 3ac93df9 2023-07-02 op 
 457 3ac93df9 2023-07-02 op 	memcpy(b, data, len);
 458 3ac93df9 2023-07-02 op 	return (0);
 459 3ac93df9 2023-07-02 op }
 460 3ac93df9 2023-07-02 op 
 461 3ac93df9 2023-07-02 op int
 462 3ac93df9 2023-07-02 op ibuf_add_buf(struct ibuf *buf, const struct ibuf *from)
 463 3ac93df9 2023-07-02 op {
 464 3ac93df9 2023-07-02 op 	return ibuf_add(buf, from->buf, from->wpos);
 465 3ac93df9 2023-07-02 op }
 466 3ac93df9 2023-07-02 op 
 467 3ac93df9 2023-07-02 op int
 468 3ac93df9 2023-07-02 op ibuf_add_n8(struct ibuf *buf, uint64_t value)
 469 3ac93df9 2023-07-02 op {
 470 3ac93df9 2023-07-02 op 	uint8_t v;
 471 3ac93df9 2023-07-02 op 
 472 3ac93df9 2023-07-02 op 	if (value > UINT8_MAX) {
 473 3ac93df9 2023-07-02 op 		errno = EINVAL;
 474 3ac93df9 2023-07-02 op 		return (-1);
 475 3ac93df9 2023-07-02 op 	}
 476 3ac93df9 2023-07-02 op 	v = value;
 477 3ac93df9 2023-07-02 op 	return ibuf_add(buf, &v, sizeof(v));
 478 f36fd90a 2022-07-09 op }
 479 f36fd90a 2022-07-09 op 
 480 3ac93df9 2023-07-02 op int
 481 3ac93df9 2023-07-02 op ibuf_add_n16(struct ibuf *buf, uint64_t value)
 482 3ac93df9 2023-07-02 op {
 483 3ac93df9 2023-07-02 op 	uint16_t v;
 484 3ac93df9 2023-07-02 op 
 485 3ac93df9 2023-07-02 op 	if (value > UINT16_MAX) {
 486 3ac93df9 2023-07-02 op 		errno = EINVAL;
 487 3ac93df9 2023-07-02 op 		return (-1);
 488 3ac93df9 2023-07-02 op 	}
 489 3ac93df9 2023-07-02 op 	v = htobe16(value);
 490 3ac93df9 2023-07-02 op 	return ibuf_add(buf, &v, sizeof(v));
 491 3ac93df9 2023-07-02 op }
 492 3ac93df9 2023-07-02 op 
 493 3ac93df9 2023-07-02 op int
 494 3ac93df9 2023-07-02 op ibuf_add_n32(struct ibuf *buf, uint64_t value)
 495 3ac93df9 2023-07-02 op {
 496 3ac93df9 2023-07-02 op 	uint32_t v;
 497 3ac93df9 2023-07-02 op 
 498 3ac93df9 2023-07-02 op 	if (value > UINT32_MAX) {
 499 3ac93df9 2023-07-02 op 		errno = EINVAL;
 500 3ac93df9 2023-07-02 op 		return (-1);
 501 3ac93df9 2023-07-02 op 	}
 502 3ac93df9 2023-07-02 op 	v = htobe32(value);
 503 3ac93df9 2023-07-02 op 	return ibuf_add(buf, &v, sizeof(v));
 504 3ac93df9 2023-07-02 op }
 505 3ac93df9 2023-07-02 op 
 506 3ac93df9 2023-07-02 op int
 507 3ac93df9 2023-07-02 op ibuf_add_n64(struct ibuf *buf, uint64_t value)
 508 3ac93df9 2023-07-02 op {
 509 3ac93df9 2023-07-02 op 	value = htobe64(value);
 510 3ac93df9 2023-07-02 op 	return ibuf_add(buf, &value, sizeof(value));
 511 3ac93df9 2023-07-02 op }
 512 3ac93df9 2023-07-02 op 
 513 3ac93df9 2023-07-02 op int
 514 3ac93df9 2023-07-02 op ibuf_add_zero(struct ibuf *buf, size_t len)
 515 3ac93df9 2023-07-02 op {
 516 3ac93df9 2023-07-02 op 	void *b;
 517 3ac93df9 2023-07-02 op 
 518 3ac93df9 2023-07-02 op 	if ((b = ibuf_reserve(buf, len)) == NULL)
 519 3ac93df9 2023-07-02 op 		return (-1);
 520 3ac93df9 2023-07-02 op 	return (0);
 521 3ac93df9 2023-07-02 op }
 522 3ac93df9 2023-07-02 op 
 523 f36fd90a 2022-07-09 op void *
 524 f36fd90a 2022-07-09 op ibuf_seek(struct ibuf *buf, size_t pos, size_t len)
 525 f36fd90a 2022-07-09 op {
 526 f36fd90a 2022-07-09 op 	/* only allowed to seek in already written parts */
 527 3ac93df9 2023-07-02 op 	if (len > SIZE_MAX - pos || pos + len > buf->wpos) {
 528 3ac93df9 2023-07-02 op 		errno = ERANGE;
 529 f36fd90a 2022-07-09 op 		return (NULL);
 530 3ac93df9 2023-07-02 op 	}
 531 f36fd90a 2022-07-09 op 
 532 f36fd90a 2022-07-09 op 	return (buf->buf + pos);
 533 3ac93df9 2023-07-02 op }
 534 3ac93df9 2023-07-02 op 
 535 3ac93df9 2023-07-02 op int
 536 3ac93df9 2023-07-02 op ibuf_set(struct ibuf *buf, size_t pos, const void *data, size_t len)
 537 3ac93df9 2023-07-02 op {
 538 3ac93df9 2023-07-02 op 	void *b;
 539 3ac93df9 2023-07-02 op 
 540 3ac93df9 2023-07-02 op 	if ((b = ibuf_seek(buf, pos, len)) == NULL)
 541 3ac93df9 2023-07-02 op 		return (-1);
 542 3ac93df9 2023-07-02 op 
 543 3ac93df9 2023-07-02 op 	memcpy(b, data, len);
 544 3ac93df9 2023-07-02 op 	return (0);
 545 3ac93df9 2023-07-02 op }
 546 3ac93df9 2023-07-02 op 
 547 3ac93df9 2023-07-02 op int
 548 3ac93df9 2023-07-02 op ibuf_set_n8(struct ibuf *buf, size_t pos, uint64_t value)
 549 3ac93df9 2023-07-02 op {
 550 3ac93df9 2023-07-02 op 	uint8_t v;
 551 3ac93df9 2023-07-02 op 
 552 3ac93df9 2023-07-02 op 	if (value > UINT8_MAX) {
 553 3ac93df9 2023-07-02 op 		errno = EINVAL;
 554 3ac93df9 2023-07-02 op 		return (-1);
 555 3ac93df9 2023-07-02 op 	}
 556 3ac93df9 2023-07-02 op 	v = value;
 557 3ac93df9 2023-07-02 op 	return (ibuf_set(buf, pos, &v, sizeof(v)));
 558 f36fd90a 2022-07-09 op }
 559 f36fd90a 2022-07-09 op 
 560 3ac93df9 2023-07-02 op int
 561 3ac93df9 2023-07-02 op ibuf_set_n16(struct ibuf *buf, size_t pos, uint64_t value)
 562 3ac93df9 2023-07-02 op {
 563 3ac93df9 2023-07-02 op 	uint16_t v;
 564 3ac93df9 2023-07-02 op 
 565 3ac93df9 2023-07-02 op 	if (value > UINT16_MAX) {
 566 3ac93df9 2023-07-02 op 		errno = EINVAL;
 567 3ac93df9 2023-07-02 op 		return (-1);
 568 3ac93df9 2023-07-02 op 	}
 569 3ac93df9 2023-07-02 op 	v = htobe16(value);
 570 3ac93df9 2023-07-02 op 	return (ibuf_set(buf, pos, &v, sizeof(v)));
 571 3ac93df9 2023-07-02 op }
 572 3ac93df9 2023-07-02 op 
 573 3ac93df9 2023-07-02 op int
 574 3ac93df9 2023-07-02 op ibuf_set_n32(struct ibuf *buf, size_t pos, uint64_t value)
 575 3ac93df9 2023-07-02 op {
 576 3ac93df9 2023-07-02 op 	uint32_t v;
 577 3ac93df9 2023-07-02 op 
 578 3ac93df9 2023-07-02 op 	if (value > UINT32_MAX) {
 579 3ac93df9 2023-07-02 op 		errno = EINVAL;
 580 3ac93df9 2023-07-02 op 		return (-1);
 581 3ac93df9 2023-07-02 op 	}
 582 3ac93df9 2023-07-02 op 	v = htobe32(value);
 583 3ac93df9 2023-07-02 op 	return (ibuf_set(buf, pos, &v, sizeof(v)));
 584 3ac93df9 2023-07-02 op }
 585 3ac93df9 2023-07-02 op 
 586 3ac93df9 2023-07-02 op int
 587 3ac93df9 2023-07-02 op ibuf_set_n64(struct ibuf *buf, size_t pos, uint64_t value)
 588 3ac93df9 2023-07-02 op {
 589 3ac93df9 2023-07-02 op 	value = htobe64(value);
 590 3ac93df9 2023-07-02 op 	return (ibuf_set(buf, pos, &value, sizeof(value)));
 591 3ac93df9 2023-07-02 op }
 592 3ac93df9 2023-07-02 op 
 593 3ac93df9 2023-07-02 op void *
 594 3ac93df9 2023-07-02 op ibuf_data(struct ibuf *buf)
 595 3ac93df9 2023-07-02 op {
 596 3ac93df9 2023-07-02 op 	return (buf->buf);
 597 3ac93df9 2023-07-02 op }
 598 3ac93df9 2023-07-02 op 
 599 f36fd90a 2022-07-09 op size_t
 600 f36fd90a 2022-07-09 op ibuf_size(struct ibuf *buf)
 601 f36fd90a 2022-07-09 op {
 602 f36fd90a 2022-07-09 op 	return (buf->wpos);
 603 f36fd90a 2022-07-09 op }
 604 f36fd90a 2022-07-09 op 
 605 f36fd90a 2022-07-09 op size_t
 606 f36fd90a 2022-07-09 op ibuf_left(struct ibuf *buf)
 607 f36fd90a 2022-07-09 op {
 608 f36fd90a 2022-07-09 op 	return (buf->max - buf->wpos);
 609 f36fd90a 2022-07-09 op }
 610 f36fd90a 2022-07-09 op 
 611 f36fd90a 2022-07-09 op void
 612 f36fd90a 2022-07-09 op ibuf_close(struct msgbuf *msgbuf, struct ibuf *buf)
 613 f36fd90a 2022-07-09 op {
 614 f36fd90a 2022-07-09 op 	ibuf_enqueue(msgbuf, buf);
 615 f36fd90a 2022-07-09 op }
 616 f36fd90a 2022-07-09 op 
 617 3ac93df9 2023-07-02 op void
 618 3ac93df9 2023-07-02 op ibuf_free(struct ibuf *buf)
 619 3ac93df9 2023-07-02 op {
 620 3ac93df9 2023-07-02 op 	if (buf == NULL)
 621 3ac93df9 2023-07-02 op 		return;
 622 3ac93df9 2023-07-02 op #ifdef NOTYET
 623 3ac93df9 2023-07-02 op 	if (buf->fd != -1)
 624 3ac93df9 2023-07-02 op 		close(buf->fd);
 625 3ac93df9 2023-07-02 op #endif
 626 3ac93df9 2023-07-02 op 	freezero(buf->buf, buf->size);
 627 3ac93df9 2023-07-02 op 	free(buf);
 628 3ac93df9 2023-07-02 op }
 629 3ac93df9 2023-07-02 op 
 630 f36fd90a 2022-07-09 op int
 631 3ac93df9 2023-07-02 op ibuf_fd_avail(struct ibuf *buf)
 632 3ac93df9 2023-07-02 op {
 633 3ac93df9 2023-07-02 op 	return (buf->fd != -1);
 634 3ac93df9 2023-07-02 op }
 635 3ac93df9 2023-07-02 op 
 636 3ac93df9 2023-07-02 op int
 637 3ac93df9 2023-07-02 op ibuf_fd_get(struct ibuf *buf)
 638 3ac93df9 2023-07-02 op {
 639 3ac93df9 2023-07-02 op 	int fd;
 640 3ac93df9 2023-07-02 op 
 641 3ac93df9 2023-07-02 op 	fd = buf->fd;
 642 3ac93df9 2023-07-02 op #ifdef NOTYET
 643 3ac93df9 2023-07-02 op 	buf->fd = -1;
 644 3ac93df9 2023-07-02 op #endif
 645 3ac93df9 2023-07-02 op 	return (fd);
 646 3ac93df9 2023-07-02 op }
 647 3ac93df9 2023-07-02 op 
 648 3ac93df9 2023-07-02 op void
 649 3ac93df9 2023-07-02 op ibuf_fd_set(struct ibuf *buf, int fd)
 650 3ac93df9 2023-07-02 op {
 651 3ac93df9 2023-07-02 op 	if (buf->fd != -1)
 652 3ac93df9 2023-07-02 op 		close(buf->fd);
 653 3ac93df9 2023-07-02 op 	buf->fd = fd;
 654 3ac93df9 2023-07-02 op }
 655 3ac93df9 2023-07-02 op 
 656 3ac93df9 2023-07-02 op int
 657 f36fd90a 2022-07-09 op ibuf_write(struct msgbuf *msgbuf)
 658 f36fd90a 2022-07-09 op {
 659 f36fd90a 2022-07-09 op 	struct iovec	 iov[IOV_MAX];
 660 f36fd90a 2022-07-09 op 	struct ibuf	*buf;
 661 f36fd90a 2022-07-09 op 	unsigned int	 i = 0;
 662 f36fd90a 2022-07-09 op 	ssize_t	n;
 663 f36fd90a 2022-07-09 op 
 664 f36fd90a 2022-07-09 op 	memset(&iov, 0, sizeof(iov));
 665 f36fd90a 2022-07-09 op 	TAILQ_FOREACH(buf, &msgbuf->bufs, entry) {
 666 f36fd90a 2022-07-09 op 		if (i >= IOV_MAX)
 667 f36fd90a 2022-07-09 op 			break;
 668 f36fd90a 2022-07-09 op 		iov[i].iov_base = buf->buf + buf->rpos;
 669 f36fd90a 2022-07-09 op 		iov[i].iov_len = buf->wpos - buf->rpos;
 670 f36fd90a 2022-07-09 op 		i++;
 671 f36fd90a 2022-07-09 op 	}
 672 f36fd90a 2022-07-09 op 
 673 f36fd90a 2022-07-09 op again:
 674 f36fd90a 2022-07-09 op 	if ((n = writev(msgbuf->fd, iov, i)) == -1) {
 675 f36fd90a 2022-07-09 op 		if (errno == EINTR)
 676 f36fd90a 2022-07-09 op 			goto again;
 677 f36fd90a 2022-07-09 op 		if (errno == ENOBUFS)
 678 f36fd90a 2022-07-09 op 			errno = EAGAIN;
 679 f36fd90a 2022-07-09 op 		return (-1);
 680 f36fd90a 2022-07-09 op 	}
 681 f36fd90a 2022-07-09 op 
 682 f36fd90a 2022-07-09 op 	if (n == 0) {			/* connection closed */
 683 f36fd90a 2022-07-09 op 		errno = 0;
 684 f36fd90a 2022-07-09 op 		return (0);
 685 f36fd90a 2022-07-09 op 	}
 686 f36fd90a 2022-07-09 op 
 687 f36fd90a 2022-07-09 op 	msgbuf_drain(msgbuf, n);
 688 f36fd90a 2022-07-09 op 
 689 f36fd90a 2022-07-09 op 	return (1);
 690 f36fd90a 2022-07-09 op }
 691 f36fd90a 2022-07-09 op 
 692 f36fd90a 2022-07-09 op void
 693 f36fd90a 2022-07-09 op msgbuf_init(struct msgbuf *msgbuf)
 694 f36fd90a 2022-07-09 op {
 695 f36fd90a 2022-07-09 op 	msgbuf->queued = 0;
 696 f36fd90a 2022-07-09 op 	msgbuf->fd = -1;
 697 f36fd90a 2022-07-09 op 	TAILQ_INIT(&msgbuf->bufs);
 698 f36fd90a 2022-07-09 op }
 699 f36fd90a 2022-07-09 op 
 700 3ac93df9 2023-07-02 op static void
 701 f36fd90a 2022-07-09 op msgbuf_drain(struct msgbuf *msgbuf, size_t n)
 702 f36fd90a 2022-07-09 op {
 703 f36fd90a 2022-07-09 op 	struct ibuf	*buf, *next;
 704 f36fd90a 2022-07-09 op 
 705 f36fd90a 2022-07-09 op 	for (buf = TAILQ_FIRST(&msgbuf->bufs); buf != NULL && n > 0;
 706 f36fd90a 2022-07-09 op 	    buf = next) {
 707 f36fd90a 2022-07-09 op 		next = TAILQ_NEXT(buf, entry);
 708 3ac93df9 2023-07-02 op 		if (n >= buf->wpos - buf->rpos) {
 709 f36fd90a 2022-07-09 op 			n -= buf->wpos - buf->rpos;
 710 f36fd90a 2022-07-09 op 			ibuf_dequeue(msgbuf, buf);
 711 f36fd90a 2022-07-09 op 		} else {
 712 f36fd90a 2022-07-09 op 			buf->rpos += n;
 713 f36fd90a 2022-07-09 op 			n = 0;
 714 f36fd90a 2022-07-09 op 		}
 715 f36fd90a 2022-07-09 op 	}
 716 f36fd90a 2022-07-09 op }
 717 f36fd90a 2022-07-09 op 
 718 f36fd90a 2022-07-09 op void
 719 f36fd90a 2022-07-09 op msgbuf_clear(struct msgbuf *msgbuf)
 720 f36fd90a 2022-07-09 op {
 721 f36fd90a 2022-07-09 op 	struct ibuf	*buf;
 722 f36fd90a 2022-07-09 op 
 723 f36fd90a 2022-07-09 op 	while ((buf = TAILQ_FIRST(&msgbuf->bufs)) != NULL)
 724 f36fd90a 2022-07-09 op 		ibuf_dequeue(msgbuf, buf);
 725 f36fd90a 2022-07-09 op }
 726 f36fd90a 2022-07-09 op 
 727 f36fd90a 2022-07-09 op int
 728 f36fd90a 2022-07-09 op msgbuf_write(struct msgbuf *msgbuf)
 729 f36fd90a 2022-07-09 op {
 730 f36fd90a 2022-07-09 op 	struct iovec	 iov[IOV_MAX];
 731 f36fd90a 2022-07-09 op 	struct ibuf	*buf, *buf0 = NULL;
 732 f36fd90a 2022-07-09 op 	unsigned int	 i = 0;
 733 f36fd90a 2022-07-09 op 	ssize_t		 n;
 734 f36fd90a 2022-07-09 op 	struct msghdr	 msg;
 735 f36fd90a 2022-07-09 op 	struct cmsghdr	*cmsg;
 736 f36fd90a 2022-07-09 op 	union {
 737 f36fd90a 2022-07-09 op 		struct cmsghdr	hdr;
 738 f36fd90a 2022-07-09 op 		char		buf[CMSG_SPACE(sizeof(int))];
 739 f36fd90a 2022-07-09 op 	} cmsgbuf;
 740 f36fd90a 2022-07-09 op 
 741 f36fd90a 2022-07-09 op 	memset(&iov, 0, sizeof(iov));
 742 f36fd90a 2022-07-09 op 	memset(&msg, 0, sizeof(msg));
 743 f36fd90a 2022-07-09 op 	memset(&cmsgbuf, 0, sizeof(cmsgbuf));
 744 f36fd90a 2022-07-09 op 	TAILQ_FOREACH(buf, &msgbuf->bufs, entry) {
 745 f36fd90a 2022-07-09 op 		if (i >= IOV_MAX)
 746 f36fd90a 2022-07-09 op 			break;
 747 f36fd90a 2022-07-09 op 		if (i > 0 && buf->fd != -1)
 748 f36fd90a 2022-07-09 op 			break;
 749 f36fd90a 2022-07-09 op 		iov[i].iov_base = buf->buf + buf->rpos;
 750 f36fd90a 2022-07-09 op 		iov[i].iov_len = buf->wpos - buf->rpos;
 751 f36fd90a 2022-07-09 op 		i++;
 752 f36fd90a 2022-07-09 op 		if (buf->fd != -1)
 753 f36fd90a 2022-07-09 op 			buf0 = buf;
 754 f36fd90a 2022-07-09 op 	}
 755 f36fd90a 2022-07-09 op 
 756 f36fd90a 2022-07-09 op 	msg.msg_iov = iov;
 757 f36fd90a 2022-07-09 op 	msg.msg_iovlen = i;
 758 f36fd90a 2022-07-09 op 
 759 f36fd90a 2022-07-09 op 	if (buf0 != NULL) {
 760 f36fd90a 2022-07-09 op 		msg.msg_control = (caddr_t)&cmsgbuf.buf;
 761 f36fd90a 2022-07-09 op 		msg.msg_controllen = sizeof(cmsgbuf.buf);
 762 f36fd90a 2022-07-09 op 		cmsg = CMSG_FIRSTHDR(&msg);
 763 f36fd90a 2022-07-09 op 		cmsg->cmsg_len = CMSG_LEN(sizeof(int));
 764 f36fd90a 2022-07-09 op 		cmsg->cmsg_level = SOL_SOCKET;
 765 f36fd90a 2022-07-09 op 		cmsg->cmsg_type = SCM_RIGHTS;
 766 f36fd90a 2022-07-09 op 		*(int *)CMSG_DATA(cmsg) = buf0->fd;
 767 f36fd90a 2022-07-09 op 	}
 768 f36fd90a 2022-07-09 op 
 769 f36fd90a 2022-07-09 op again:
 770 f36fd90a 2022-07-09 op 	if ((n = sendmsg(msgbuf->fd, &msg, 0)) == -1) {
 771 f36fd90a 2022-07-09 op 		if (errno == EINTR)
 772 f36fd90a 2022-07-09 op 			goto again;
 773 f36fd90a 2022-07-09 op 		if (errno == ENOBUFS)
 774 f36fd90a 2022-07-09 op 			errno = EAGAIN;
 775 f36fd90a 2022-07-09 op 		return (-1);
 776 f36fd90a 2022-07-09 op 	}
 777 f36fd90a 2022-07-09 op 
 778 f36fd90a 2022-07-09 op 	if (n == 0) {			/* connection closed */
 779 f36fd90a 2022-07-09 op 		errno = 0;
 780 f36fd90a 2022-07-09 op 		return (0);
 781 f36fd90a 2022-07-09 op 	}
 782 f36fd90a 2022-07-09 op 
 783 f36fd90a 2022-07-09 op 	/*
 784 f36fd90a 2022-07-09 op 	 * assumption: fd got sent if sendmsg sent anything
 785 f36fd90a 2022-07-09 op 	 * this works because fds are passed one at a time
 786 f36fd90a 2022-07-09 op 	 */
 787 f36fd90a 2022-07-09 op 	if (buf0 != NULL) {
 788 f36fd90a 2022-07-09 op 		close(buf0->fd);
 789 f36fd90a 2022-07-09 op 		buf0->fd = -1;
 790 f36fd90a 2022-07-09 op 	}
 791 f36fd90a 2022-07-09 op 
 792 f36fd90a 2022-07-09 op 	msgbuf_drain(msgbuf, n);
 793 f36fd90a 2022-07-09 op 
 794 f36fd90a 2022-07-09 op 	return (1);
 795 f36fd90a 2022-07-09 op }
 796 f36fd90a 2022-07-09 op 
 797 f36fd90a 2022-07-09 op static void
 798 f36fd90a 2022-07-09 op ibuf_enqueue(struct msgbuf *msgbuf, struct ibuf *buf)
 799 f36fd90a 2022-07-09 op {
 800 f36fd90a 2022-07-09 op 	TAILQ_INSERT_TAIL(&msgbuf->bufs, buf, entry);
 801 f36fd90a 2022-07-09 op 	msgbuf->queued++;
 802 f36fd90a 2022-07-09 op }
 803 f36fd90a 2022-07-09 op 
 804 f36fd90a 2022-07-09 op static void
 805 f36fd90a 2022-07-09 op ibuf_dequeue(struct msgbuf *msgbuf, struct ibuf *buf)
 806 f36fd90a 2022-07-09 op {
 807 f36fd90a 2022-07-09 op 	TAILQ_REMOVE(&msgbuf->bufs, buf, entry);
 808 f36fd90a 2022-07-09 op 
 809 3ac93df9 2023-07-02 op 	if (buf->fd != -1) {
 810 f36fd90a 2022-07-09 op 		close(buf->fd);
 811 3ac93df9 2023-07-02 op 		buf->fd = -1;
 812 3ac93df9 2023-07-02 op 	}
 813 f36fd90a 2022-07-09 op 
 814 f36fd90a 2022-07-09 op 	msgbuf->queued--;
 815 f36fd90a 2022-07-09 op 	ibuf_free(buf);
 816 f36fd90a 2022-07-09 op }
 817 f36fd90a 2022-07-09 op 
 818 f36fd90a 2022-07-09 op /* imsg.c */
 819 f36fd90a 2022-07-09 op 
 820 f36fd90a 2022-07-09 op int	 imsg_fd_overhead = 0;
 821 f36fd90a 2022-07-09 op 
 822 f36fd90a 2022-07-09 op static int	 imsg_get_fd(struct imsgbuf *);
 823 f36fd90a 2022-07-09 op 
 824 f36fd90a 2022-07-09 op void
 825 f36fd90a 2022-07-09 op imsg_init(struct imsgbuf *ibuf, int fd)
 826 f36fd90a 2022-07-09 op {
 827 f36fd90a 2022-07-09 op 	msgbuf_init(&ibuf->w);
 828 f36fd90a 2022-07-09 op 	memset(&ibuf->r, 0, sizeof(ibuf->r));
 829 f36fd90a 2022-07-09 op 	ibuf->fd = fd;
 830 f36fd90a 2022-07-09 op 	ibuf->w.fd = fd;
 831 f36fd90a 2022-07-09 op 	ibuf->pid = getpid();
 832 f36fd90a 2022-07-09 op 	TAILQ_INIT(&ibuf->fds);
 833 f36fd90a 2022-07-09 op }
 834 f36fd90a 2022-07-09 op 
 835 f36fd90a 2022-07-09 op ssize_t
 836 f36fd90a 2022-07-09 op imsg_read(struct imsgbuf *ibuf)
 837 f36fd90a 2022-07-09 op {
 838 f36fd90a 2022-07-09 op 	struct msghdr		 msg;
 839 f36fd90a 2022-07-09 op 	struct cmsghdr		*cmsg;
 840 f36fd90a 2022-07-09 op 	union {
 841 f36fd90a 2022-07-09 op 		struct cmsghdr hdr;
 842 f36fd90a 2022-07-09 op 		char	buf[CMSG_SPACE(sizeof(int) * 1)];
 843 f36fd90a 2022-07-09 op 	} cmsgbuf;
 844 f36fd90a 2022-07-09 op 	struct iovec		 iov;
 845 f36fd90a 2022-07-09 op 	ssize_t			 n = -1;
 846 f36fd90a 2022-07-09 op 	int			 fd;
 847 f36fd90a 2022-07-09 op 	struct imsg_fd		*ifd;
 848 f36fd90a 2022-07-09 op 
 849 f36fd90a 2022-07-09 op 	memset(&msg, 0, sizeof(msg));
 850 f36fd90a 2022-07-09 op 	memset(&cmsgbuf, 0, sizeof(cmsgbuf));
 851 f36fd90a 2022-07-09 op 
 852 f36fd90a 2022-07-09 op 	iov.iov_base = ibuf->r.buf + ibuf->r.wpos;
 853 f36fd90a 2022-07-09 op 	iov.iov_len = sizeof(ibuf->r.buf) - ibuf->r.wpos;
 854 f36fd90a 2022-07-09 op 	msg.msg_iov = &iov;
 855 f36fd90a 2022-07-09 op 	msg.msg_iovlen = 1;
 856 f36fd90a 2022-07-09 op 	msg.msg_control = &cmsgbuf.buf;
 857 f36fd90a 2022-07-09 op 	msg.msg_controllen = sizeof(cmsgbuf.buf);
 858 f36fd90a 2022-07-09 op 
 859 f36fd90a 2022-07-09 op 	if ((ifd = calloc(1, sizeof(struct imsg_fd))) == NULL)
 860 f36fd90a 2022-07-09 op 		return (-1);
 861 f36fd90a 2022-07-09 op 
 862 f36fd90a 2022-07-09 op again:
 863 f36fd90a 2022-07-09 op 	if (getdtablecount() + imsg_fd_overhead +
 864 f36fd90a 2022-07-09 op 	    (int)((CMSG_SPACE(sizeof(int))-CMSG_SPACE(0))/sizeof(int))
 865 f36fd90a 2022-07-09 op 	    >= getdtablesize()) {
 866 f36fd90a 2022-07-09 op 		errno = EAGAIN;
 867 f36fd90a 2022-07-09 op 		free(ifd);
 868 f36fd90a 2022-07-09 op 		return (-1);
 869 f36fd90a 2022-07-09 op 	}
 870 f36fd90a 2022-07-09 op 
 871 f36fd90a 2022-07-09 op 	if ((n = recvmsg(ibuf->fd, &msg, 0)) == -1) {
 872 f36fd90a 2022-07-09 op 		if (errno == EINTR)
 873 f36fd90a 2022-07-09 op 			goto again;
 874 f36fd90a 2022-07-09 op 		goto fail;
 875 f36fd90a 2022-07-09 op 	}
 876 f36fd90a 2022-07-09 op 
 877 f36fd90a 2022-07-09 op 	ibuf->r.wpos += n;
 878 f36fd90a 2022-07-09 op 
 879 f36fd90a 2022-07-09 op 	for (cmsg = CMSG_FIRSTHDR(&msg); cmsg != NULL;
 880 f36fd90a 2022-07-09 op 	    cmsg = CMSG_NXTHDR(&msg, cmsg)) {
 881 f36fd90a 2022-07-09 op 		if (cmsg->cmsg_level == SOL_SOCKET &&
 882 f36fd90a 2022-07-09 op 		    cmsg->cmsg_type == SCM_RIGHTS) {
 883 f36fd90a 2022-07-09 op 			int i;
 884 f36fd90a 2022-07-09 op 			int j;
 885 f36fd90a 2022-07-09 op 
 886 f36fd90a 2022-07-09 op 			/*
 887 f36fd90a 2022-07-09 op 			 * We only accept one file descriptor.  Due to C
 888 f36fd90a 2022-07-09 op 			 * padding rules, our control buffer might contain
 889 f36fd90a 2022-07-09 op 			 * more than one fd, and we must close them.
 890 f36fd90a 2022-07-09 op 			 */
 891 f36fd90a 2022-07-09 op 			j = ((char *)cmsg + cmsg->cmsg_len -
 892 f36fd90a 2022-07-09 op 			    (char *)CMSG_DATA(cmsg)) / sizeof(int);
 893 f36fd90a 2022-07-09 op 			for (i = 0; i < j; i++) {
 894 f36fd90a 2022-07-09 op 				fd = ((int *)CMSG_DATA(cmsg))[i];
 895 f36fd90a 2022-07-09 op 				if (ifd != NULL) {
 896 f36fd90a 2022-07-09 op 					ifd->fd = fd;
 897 f36fd90a 2022-07-09 op 					TAILQ_INSERT_TAIL(&ibuf->fds, ifd,
 898 f36fd90a 2022-07-09 op 					    entry);
 899 f36fd90a 2022-07-09 op 					ifd = NULL;
 900 f36fd90a 2022-07-09 op 				} else
 901 f36fd90a 2022-07-09 op 					close(fd);
 902 f36fd90a 2022-07-09 op 			}
 903 f36fd90a 2022-07-09 op 		}
 904 f36fd90a 2022-07-09 op 		/* we do not handle other ctl data level */
 905 f36fd90a 2022-07-09 op 	}
 906 f36fd90a 2022-07-09 op 
 907 f36fd90a 2022-07-09 op fail:
 908 f36fd90a 2022-07-09 op 	free(ifd);
 909 f36fd90a 2022-07-09 op 	return (n);
 910 f36fd90a 2022-07-09 op }
 911 f36fd90a 2022-07-09 op 
 912 f36fd90a 2022-07-09 op ssize_t
 913 f36fd90a 2022-07-09 op imsg_get(struct imsgbuf *ibuf, struct imsg *imsg)
 914 f36fd90a 2022-07-09 op {
 915 f36fd90a 2022-07-09 op 	size_t			 av, left, datalen;
 916 f36fd90a 2022-07-09 op 
 917 f36fd90a 2022-07-09 op 	av = ibuf->r.wpos;
 918 f36fd90a 2022-07-09 op 
 919 f36fd90a 2022-07-09 op 	if (IMSG_HEADER_SIZE > av)
 920 f36fd90a 2022-07-09 op 		return (0);
 921 f36fd90a 2022-07-09 op 
 922 f36fd90a 2022-07-09 op 	memcpy(&imsg->hdr, ibuf->r.buf, sizeof(imsg->hdr));
 923 f36fd90a 2022-07-09 op 	if (imsg->hdr.len < IMSG_HEADER_SIZE ||
 924 f36fd90a 2022-07-09 op 	    imsg->hdr.len > MAX_IMSGSIZE) {
 925 f36fd90a 2022-07-09 op 		errno = ERANGE;
 926 f36fd90a 2022-07-09 op 		return (-1);
 927 f36fd90a 2022-07-09 op 	}
 928 f36fd90a 2022-07-09 op 	if (imsg->hdr.len > av)
 929 f36fd90a 2022-07-09 op 		return (0);
 930 f36fd90a 2022-07-09 op 	datalen = imsg->hdr.len - IMSG_HEADER_SIZE;
 931 f36fd90a 2022-07-09 op 	ibuf->r.rptr = ibuf->r.buf + IMSG_HEADER_SIZE;
 932 f36fd90a 2022-07-09 op 	if (datalen == 0)
 933 f36fd90a 2022-07-09 op 		imsg->data = NULL;
 934 f36fd90a 2022-07-09 op 	else if ((imsg->data = malloc(datalen)) == NULL)
 935 f36fd90a 2022-07-09 op 		return (-1);
 936 f36fd90a 2022-07-09 op 
 937 f36fd90a 2022-07-09 op 	if (imsg->hdr.flags & IMSGF_HASFD)
 938 f36fd90a 2022-07-09 op 		imsg->fd = imsg_get_fd(ibuf);
 939 f36fd90a 2022-07-09 op 	else
 940 f36fd90a 2022-07-09 op 		imsg->fd = -1;
 941 f36fd90a 2022-07-09 op 
 942 f36fd90a 2022-07-09 op 	if (datalen != 0)
 943 f36fd90a 2022-07-09 op 		memcpy(imsg->data, ibuf->r.rptr, datalen);
 944 f36fd90a 2022-07-09 op 
 945 f36fd90a 2022-07-09 op 	if (imsg->hdr.len < av) {
 946 f36fd90a 2022-07-09 op 		left = av - imsg->hdr.len;
 947 f36fd90a 2022-07-09 op 		memmove(&ibuf->r.buf, ibuf->r.buf + imsg->hdr.len, left);
 948 f36fd90a 2022-07-09 op 		ibuf->r.wpos = left;
 949 f36fd90a 2022-07-09 op 	} else
 950 f36fd90a 2022-07-09 op 		ibuf->r.wpos = 0;
 951 f36fd90a 2022-07-09 op 
 952 f36fd90a 2022-07-09 op 	return (datalen + IMSG_HEADER_SIZE);
 953 f36fd90a 2022-07-09 op }
 954 f36fd90a 2022-07-09 op 
 955 f36fd90a 2022-07-09 op int
 956 f36fd90a 2022-07-09 op imsg_compose(struct imsgbuf *ibuf, uint32_t type, uint32_t peerid, pid_t pid,
 957 f36fd90a 2022-07-09 op     int fd, const void *data, uint16_t datalen)
 958 f36fd90a 2022-07-09 op {
 959 f36fd90a 2022-07-09 op 	struct ibuf	*wbuf;
 960 f36fd90a 2022-07-09 op 
 961 f36fd90a 2022-07-09 op 	if ((wbuf = imsg_create(ibuf, type, peerid, pid, datalen)) == NULL)
 962 f36fd90a 2022-07-09 op 		return (-1);
 963 f36fd90a 2022-07-09 op 
 964 f36fd90a 2022-07-09 op 	if (imsg_add(wbuf, data, datalen) == -1)
 965 f36fd90a 2022-07-09 op 		return (-1);
 966 f36fd90a 2022-07-09 op 
 967 3ac93df9 2023-07-02 op 	ibuf_fd_set(wbuf, fd);
 968 f36fd90a 2022-07-09 op 	imsg_close(ibuf, wbuf);
 969 f36fd90a 2022-07-09 op 
 970 f36fd90a 2022-07-09 op 	return (1);
 971 f36fd90a 2022-07-09 op }
 972 f36fd90a 2022-07-09 op 
 973 f36fd90a 2022-07-09 op int
 974 f36fd90a 2022-07-09 op imsg_composev(struct imsgbuf *ibuf, uint32_t type, uint32_t peerid, pid_t pid,
 975 f36fd90a 2022-07-09 op     int fd, const struct iovec *iov, int iovcnt)
 976 f36fd90a 2022-07-09 op {
 977 f36fd90a 2022-07-09 op 	struct ibuf	*wbuf;
 978 f36fd90a 2022-07-09 op 	int		 i, datalen = 0;
 979 f36fd90a 2022-07-09 op 
 980 f36fd90a 2022-07-09 op 	for (i = 0; i < iovcnt; i++)
 981 f36fd90a 2022-07-09 op 		datalen += iov[i].iov_len;
 982 f36fd90a 2022-07-09 op 
 983 f36fd90a 2022-07-09 op 	if ((wbuf = imsg_create(ibuf, type, peerid, pid, datalen)) == NULL)
 984 f36fd90a 2022-07-09 op 		return (-1);
 985 f36fd90a 2022-07-09 op 
 986 f36fd90a 2022-07-09 op 	for (i = 0; i < iovcnt; i++)
 987 f36fd90a 2022-07-09 op 		if (imsg_add(wbuf, iov[i].iov_base, iov[i].iov_len) == -1)
 988 f36fd90a 2022-07-09 op 			return (-1);
 989 f36fd90a 2022-07-09 op 
 990 3ac93df9 2023-07-02 op 	ibuf_fd_set(wbuf, fd);
 991 f36fd90a 2022-07-09 op 	imsg_close(ibuf, wbuf);
 992 f36fd90a 2022-07-09 op 
 993 f36fd90a 2022-07-09 op 	return (1);
 994 f36fd90a 2022-07-09 op }
 995 f36fd90a 2022-07-09 op 
 996 3ac93df9 2023-07-02 op int
 997 3ac93df9 2023-07-02 op imsg_compose_ibuf(struct imsgbuf *ibuf, uint32_t type, uint32_t peerid,
 998 3ac93df9 2023-07-02 op     pid_t pid, struct ibuf *buf)
 999 3ac93df9 2023-07-02 op {
1000 3ac93df9 2023-07-02 op 	struct ibuf	*wbuf = NULL;
1001 3ac93df9 2023-07-02 op 	struct imsg_hdr	 hdr;
1002 3ac93df9 2023-07-02 op 	int save_errno;
1003 3ac93df9 2023-07-02 op 
1004 3ac93df9 2023-07-02 op 	if (ibuf_size(buf) + IMSG_HEADER_SIZE > MAX_IMSGSIZE) {
1005 3ac93df9 2023-07-02 op 		errno = ERANGE;
1006 3ac93df9 2023-07-02 op 		goto fail;
1007 3ac93df9 2023-07-02 op 	}
1008 3ac93df9 2023-07-02 op 
1009 3ac93df9 2023-07-02 op 	hdr.type = type;
1010 3ac93df9 2023-07-02 op 	hdr.len = ibuf_size(buf) + IMSG_HEADER_SIZE;
1011 3ac93df9 2023-07-02 op 	hdr.flags = 0;
1012 3ac93df9 2023-07-02 op 	hdr.peerid = peerid;
1013 3ac93df9 2023-07-02 op 	if ((hdr.pid = pid) == 0)
1014 3ac93df9 2023-07-02 op 		hdr.pid = ibuf->pid;
1015 3ac93df9 2023-07-02 op 
1016 3ac93df9 2023-07-02 op 	if ((wbuf = ibuf_open(IMSG_HEADER_SIZE)) == NULL)
1017 3ac93df9 2023-07-02 op 		goto fail;
1018 3ac93df9 2023-07-02 op 	if (imsg_add(wbuf, &hdr, sizeof(hdr)) == -1)
1019 3ac93df9 2023-07-02 op 		goto fail;
1020 3ac93df9 2023-07-02 op 
1021 3ac93df9 2023-07-02 op 	ibuf_close(&ibuf->w, wbuf);
1022 3ac93df9 2023-07-02 op 	ibuf_close(&ibuf->w, buf);
1023 3ac93df9 2023-07-02 op 	return (1);
1024 3ac93df9 2023-07-02 op 
1025 3ac93df9 2023-07-02 op  fail:
1026 3ac93df9 2023-07-02 op 	save_errno = errno;
1027 3ac93df9 2023-07-02 op 	ibuf_free(buf);
1028 3ac93df9 2023-07-02 op 	ibuf_free(wbuf);
1029 3ac93df9 2023-07-02 op 	errno = save_errno;
1030 3ac93df9 2023-07-02 op 	return (-1);
1031 3ac93df9 2023-07-02 op }
1032 3ac93df9 2023-07-02 op 
1033 f36fd90a 2022-07-09 op struct ibuf *
1034 f36fd90a 2022-07-09 op imsg_create(struct imsgbuf *ibuf, uint32_t type, uint32_t peerid, pid_t pid,
1035 f36fd90a 2022-07-09 op     uint16_t datalen)
1036 f36fd90a 2022-07-09 op {
1037 f36fd90a 2022-07-09 op 	struct ibuf	*wbuf;
1038 f36fd90a 2022-07-09 op 	struct imsg_hdr	 hdr;
1039 f36fd90a 2022-07-09 op 
1040 f36fd90a 2022-07-09 op 	datalen += IMSG_HEADER_SIZE;
1041 f36fd90a 2022-07-09 op 	if (datalen > MAX_IMSGSIZE) {
1042 f36fd90a 2022-07-09 op 		errno = ERANGE;
1043 f36fd90a 2022-07-09 op 		return (NULL);
1044 f36fd90a 2022-07-09 op 	}
1045 f36fd90a 2022-07-09 op 
1046 f36fd90a 2022-07-09 op 	hdr.type = type;
1047 f36fd90a 2022-07-09 op 	hdr.flags = 0;
1048 f36fd90a 2022-07-09 op 	hdr.peerid = peerid;
1049 f36fd90a 2022-07-09 op 	if ((hdr.pid = pid) == 0)
1050 f36fd90a 2022-07-09 op 		hdr.pid = ibuf->pid;
1051 f36fd90a 2022-07-09 op 	if ((wbuf = ibuf_dynamic(datalen, MAX_IMSGSIZE)) == NULL) {
1052 f36fd90a 2022-07-09 op 		return (NULL);
1053 f36fd90a 2022-07-09 op 	}
1054 f36fd90a 2022-07-09 op 	if (imsg_add(wbuf, &hdr, sizeof(hdr)) == -1)
1055 f36fd90a 2022-07-09 op 		return (NULL);
1056 f36fd90a 2022-07-09 op 
1057 f36fd90a 2022-07-09 op 	return (wbuf);
1058 f36fd90a 2022-07-09 op }
1059 f36fd90a 2022-07-09 op 
1060 f36fd90a 2022-07-09 op int
1061 f36fd90a 2022-07-09 op imsg_add(struct ibuf *msg, const void *data, uint16_t datalen)
1062 f36fd90a 2022-07-09 op {
1063 f36fd90a 2022-07-09 op 	if (datalen)
1064 f36fd90a 2022-07-09 op 		if (ibuf_add(msg, data, datalen) == -1) {
1065 f36fd90a 2022-07-09 op 			ibuf_free(msg);
1066 f36fd90a 2022-07-09 op 			return (-1);
1067 f36fd90a 2022-07-09 op 		}
1068 f36fd90a 2022-07-09 op 	return (datalen);
1069 f36fd90a 2022-07-09 op }
1070 f36fd90a 2022-07-09 op 
1071 f36fd90a 2022-07-09 op void
1072 f36fd90a 2022-07-09 op imsg_close(struct imsgbuf *ibuf, struct ibuf *msg)
1073 f36fd90a 2022-07-09 op {
1074 f36fd90a 2022-07-09 op 	struct imsg_hdr	*hdr;
1075 f36fd90a 2022-07-09 op 
1076 f36fd90a 2022-07-09 op 	hdr = (struct imsg_hdr *)msg->buf;
1077 f36fd90a 2022-07-09 op 
1078 f36fd90a 2022-07-09 op 	hdr->flags &= ~IMSGF_HASFD;
1079 3ac93df9 2023-07-02 op 	if (ibuf_fd_avail(msg))
1080 f36fd90a 2022-07-09 op 		hdr->flags |= IMSGF_HASFD;
1081 3ac93df9 2023-07-02 op 	hdr->len = ibuf_size(msg);
1082 f36fd90a 2022-07-09 op 
1083 f36fd90a 2022-07-09 op 	ibuf_close(&ibuf->w, msg);
1084 f36fd90a 2022-07-09 op }
1085 f36fd90a 2022-07-09 op 
1086 f36fd90a 2022-07-09 op void
1087 f36fd90a 2022-07-09 op imsg_free(struct imsg *imsg)
1088 f36fd90a 2022-07-09 op {
1089 f36fd90a 2022-07-09 op 	freezero(imsg->data, imsg->hdr.len - IMSG_HEADER_SIZE);
1090 f36fd90a 2022-07-09 op }
1091 f36fd90a 2022-07-09 op 
1092 f36fd90a 2022-07-09 op static int
1093 f36fd90a 2022-07-09 op imsg_get_fd(struct imsgbuf *ibuf)
1094 f36fd90a 2022-07-09 op {
1095 f36fd90a 2022-07-09 op 	int		 fd;
1096 f36fd90a 2022-07-09 op 	struct imsg_fd	*ifd;
1097 f36fd90a 2022-07-09 op 
1098 f36fd90a 2022-07-09 op 	if ((ifd = TAILQ_FIRST(&ibuf->fds)) == NULL)
1099 f36fd90a 2022-07-09 op 		return (-1);
1100 f36fd90a 2022-07-09 op 
1101 f36fd90a 2022-07-09 op 	fd = ifd->fd;
1102 f36fd90a 2022-07-09 op 	TAILQ_REMOVE(&ibuf->fds, ifd, entry);
1103 f36fd90a 2022-07-09 op 	free(ifd);
1104 f36fd90a 2022-07-09 op 
1105 f36fd90a 2022-07-09 op 	return (fd);
1106 f36fd90a 2022-07-09 op }
1107 f36fd90a 2022-07-09 op 
1108 f36fd90a 2022-07-09 op int
1109 f36fd90a 2022-07-09 op imsg_flush(struct imsgbuf *ibuf)
1110 f36fd90a 2022-07-09 op {
1111 f36fd90a 2022-07-09 op 	while (ibuf->w.queued)
1112 f36fd90a 2022-07-09 op 		if (msgbuf_write(&ibuf->w) <= 0)
1113 f36fd90a 2022-07-09 op 			return (-1);
1114 f36fd90a 2022-07-09 op 	return (0);
1115 f36fd90a 2022-07-09 op }
1116 f36fd90a 2022-07-09 op 
1117 f36fd90a 2022-07-09 op void
1118 f36fd90a 2022-07-09 op imsg_clear(struct imsgbuf *ibuf)
1119 f36fd90a 2022-07-09 op {
1120 f36fd90a 2022-07-09 op 	int	fd;
1121 f36fd90a 2022-07-09 op 
1122 f36fd90a 2022-07-09 op 	msgbuf_clear(&ibuf->w);
1123 f36fd90a 2022-07-09 op 	while ((fd = imsg_get_fd(ibuf)) != -1)
1124 f36fd90a 2022-07-09 op 		close(fd);
1125 f36fd90a 2022-07-09 op }
1126 82556d5b 2023-09-07 op #endif /* HAVE_LIB_IMSG */
1127 f36fd90a 2022-07-09 op #if !HAVE_MEMMEM
1128 f36fd90a 2022-07-09 op /*-
1129 f36fd90a 2022-07-09 op  * Copyright (c) 2005 Pascal Gloor <pascal.gloor@spale.com>
1130 f36fd90a 2022-07-09 op  *
1131 f36fd90a 2022-07-09 op  * Redistribution and use in source and binary forms, with or without
1132 f36fd90a 2022-07-09 op  * modification, are permitted provided that the following conditions
1133 f36fd90a 2022-07-09 op  * are met:
1134 f36fd90a 2022-07-09 op  * 1. Redistributions of source code must retain the above copyright
1135 f36fd90a 2022-07-09 op  *    notice, this list of conditions and the following disclaimer.
1136 f36fd90a 2022-07-09 op  * 2. Redistributions in binary form must reproduce the above copyright
1137 f36fd90a 2022-07-09 op  *    notice, this list of conditions and the following disclaimer in
1138 f36fd90a 2022-07-09 op  *    the documentation and/or other materials provided with the
1139 f36fd90a 2022-07-09 op  *    distribution.
1140 f36fd90a 2022-07-09 op  * 3. The name of the author may not be used to endorse or promote
1141 f36fd90a 2022-07-09 op  *    products derived from this software without specific prior written
1142 f36fd90a 2022-07-09 op  *    permission.
1143 f36fd90a 2022-07-09 op  *
1144 f36fd90a 2022-07-09 op  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS''
1145 f36fd90a 2022-07-09 op  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
1146 f36fd90a 2022-07-09 op  * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
1147 f36fd90a 2022-07-09 op  * PARTICULAR PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR
1148 f36fd90a 2022-07-09 op  * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
1149 f36fd90a 2022-07-09 op  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
1150 f36fd90a 2022-07-09 op  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
1151 f36fd90a 2022-07-09 op  * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
1152 f36fd90a 2022-07-09 op  * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
1153 f36fd90a 2022-07-09 op  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
1154 f36fd90a 2022-07-09 op  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
1155 f36fd90a 2022-07-09 op  */
1156 f36fd90a 2022-07-09 op /*
1157 f36fd90a 2022-07-09 op  * Find the first occurrence of the byte string s in byte string l.
1158 f36fd90a 2022-07-09 op  */
1159 f36fd90a 2022-07-09 op void *
1160 f36fd90a 2022-07-09 op memmem(const void *l, size_t l_len, const void *s, size_t s_len)
1161 f36fd90a 2022-07-09 op {
1162 f36fd90a 2022-07-09 op 	const char *cur, *last;
1163 f36fd90a 2022-07-09 op 	const char *cl = l;
1164 f36fd90a 2022-07-09 op 	const char *cs = s;
1165 f36fd90a 2022-07-09 op 
1166 f36fd90a 2022-07-09 op 	/* a zero length needle should just return the haystack */
1167 f36fd90a 2022-07-09 op 	if (l_len == 0)
1168 f36fd90a 2022-07-09 op 		return (void *)cl;
1169 f36fd90a 2022-07-09 op 
1170 f36fd90a 2022-07-09 op 	/* "s" must be smaller or equal to "l" */
1171 f36fd90a 2022-07-09 op 	if (l_len < s_len)
1172 f36fd90a 2022-07-09 op 		return NULL;
1173 f36fd90a 2022-07-09 op 
1174 f36fd90a 2022-07-09 op 	/* special case where s_len == 1 */
1175 f36fd90a 2022-07-09 op 	if (s_len == 1)
1176 f36fd90a 2022-07-09 op 		return memchr(l, *cs, l_len);
1177 f36fd90a 2022-07-09 op 
1178 f36fd90a 2022-07-09 op 	/* the last position where its possible to find "s" in "l" */
1179 f36fd90a 2022-07-09 op 	last = cl + l_len - s_len;
1180 f36fd90a 2022-07-09 op 
1181 f36fd90a 2022-07-09 op 	for (cur = cl; cur <= last; cur++)
1182 f36fd90a 2022-07-09 op 		if (cur[0] == cs[0] && memcmp(cur, cs, s_len) == 0)
1183 f36fd90a 2022-07-09 op 			return (void *)cur;
1184 f36fd90a 2022-07-09 op 
1185 f36fd90a 2022-07-09 op 	return NULL;
1186 f36fd90a 2022-07-09 op }
1187 f36fd90a 2022-07-09 op #endif /* !HAVE_MEMMEM */
1188 f36fd90a 2022-07-09 op #if !HAVE_MEMRCHR
1189 f36fd90a 2022-07-09 op /*
1190 f36fd90a 2022-07-09 op  * Copyright (c) 2007 Todd C. Miller <Todd.Miller@courtesan.com>
1191 f36fd90a 2022-07-09 op  *
1192 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
1193 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
1194 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
1195 f36fd90a 2022-07-09 op  *
1196 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
1197 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
1198 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
1199 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
1200 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
1201 f36fd90a 2022-07-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
1202 f36fd90a 2022-07-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1203 f36fd90a 2022-07-09 op  *
1204 f36fd90a 2022-07-09 op  */
1205 f36fd90a 2022-07-09 op 
1206 f36fd90a 2022-07-09 op #include <string.h>
1207 f36fd90a 2022-07-09 op 
1208 f36fd90a 2022-07-09 op /*
1209 f36fd90a 2022-07-09 op  * Reverse memchr()
1210 f36fd90a 2022-07-09 op  * Find the last occurrence of 'c' in the buffer 's' of size 'n'.
1211 f36fd90a 2022-07-09 op  */
1212 f36fd90a 2022-07-09 op void *
1213 f36fd90a 2022-07-09 op memrchr(const void *s, int c, size_t n)
1214 f36fd90a 2022-07-09 op {
1215 f36fd90a 2022-07-09 op     const unsigned char *cp;
1216 f36fd90a 2022-07-09 op 
1217 f36fd90a 2022-07-09 op     if (n != 0) {
1218 f36fd90a 2022-07-09 op         cp = (unsigned char *)s + n;
1219 f36fd90a 2022-07-09 op         do {
1220 f36fd90a 2022-07-09 op             if (*(--cp) == (unsigned char)c)
1221 f36fd90a 2022-07-09 op                 return((void *)cp);
1222 f36fd90a 2022-07-09 op         } while (--n != 0);
1223 f36fd90a 2022-07-09 op     }
1224 f36fd90a 2022-07-09 op     return(NULL);
1225 f36fd90a 2022-07-09 op }
1226 f36fd90a 2022-07-09 op #endif /* !HAVE_MEMRCHR */
1227 f36fd90a 2022-07-09 op #if !HAVE_OPTRESET
1228 f36fd90a 2022-07-09 op /*
1229 f36fd90a 2022-07-09 op  * Copyright (c) 1987, 1993, 1994
1230 f36fd90a 2022-07-09 op  *	The Regents of the University of California.  All rights reserved.
1231 f36fd90a 2022-07-09 op  *
1232 f36fd90a 2022-07-09 op  * Redistribution and use in source and binary forms, with or without
1233 f36fd90a 2022-07-09 op  * modification, are permitted provided that the following conditions
1234 f36fd90a 2022-07-09 op  * are met:
1235 f36fd90a 2022-07-09 op  * 1. Redistributions of source code must retain the above copyright
1236 f36fd90a 2022-07-09 op  *    notice, this list of conditions and the following disclaimer.
1237 f36fd90a 2022-07-09 op  * 2. Redistributions in binary form must reproduce the above copyright
1238 f36fd90a 2022-07-09 op  *    notice, this list of conditions and the following disclaimer in the
1239 f36fd90a 2022-07-09 op  *    documentation and/or other materials provided with the distribution.
1240 f36fd90a 2022-07-09 op  * 3. Neither the name of the University nor the names of its contributors
1241 f36fd90a 2022-07-09 op  *    may be used to endorse or promote products derived from this software
1242 f36fd90a 2022-07-09 op  *    without specific prior written permission.
1243 f36fd90a 2022-07-09 op  *
1244 f36fd90a 2022-07-09 op  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
1245 f36fd90a 2022-07-09 op  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
1246 f36fd90a 2022-07-09 op  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
1247 f36fd90a 2022-07-09 op  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
1248 f36fd90a 2022-07-09 op  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
1249 f36fd90a 2022-07-09 op  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
1250 f36fd90a 2022-07-09 op  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
1251 f36fd90a 2022-07-09 op  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
1252 f36fd90a 2022-07-09 op  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
1253 f36fd90a 2022-07-09 op  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
1254 f36fd90a 2022-07-09 op  * SUCH DAMAGE.
1255 f36fd90a 2022-07-09 op  */
1256 f36fd90a 2022-07-09 op 
1257 f36fd90a 2022-07-09 op /* OPENBSD ORIGINAL: lib/libc/stdlib/getopt.c */
1258 f36fd90a 2022-07-09 op 
1259 f36fd90a 2022-07-09 op #include <stdio.h>
1260 f36fd90a 2022-07-09 op #include <stdlib.h>
1261 f36fd90a 2022-07-09 op #include <string.h>
1262 f36fd90a 2022-07-09 op 
1263 f36fd90a 2022-07-09 op int	BSDopterr = 1,		/* if error message should be printed */
1264 f36fd90a 2022-07-09 op 	BSDoptind = 1,		/* index into parent argv vector */
1265 f36fd90a 2022-07-09 op 	BSDoptopt,		/* character checked for validity */
1266 f36fd90a 2022-07-09 op 	BSDoptreset;		/* reset getopt */
1267 f36fd90a 2022-07-09 op char	*BSDoptarg;		/* argument associated with option */
1268 f36fd90a 2022-07-09 op 
1269 f36fd90a 2022-07-09 op #define	BADCH	(int)'?'
1270 f36fd90a 2022-07-09 op #define	BADARG	(int)':'
1271 f36fd90a 2022-07-09 op #define	EMSG	""
1272 f36fd90a 2022-07-09 op 
1273 f36fd90a 2022-07-09 op /*
1274 f36fd90a 2022-07-09 op  * getopt --
1275 f36fd90a 2022-07-09 op  *	Parse argc/argv argument vector.
1276 f36fd90a 2022-07-09 op  */
1277 f36fd90a 2022-07-09 op int
1278 f36fd90a 2022-07-09 op BSDgetopt(int nargc, char *const *nargv, const char *ostr)
1279 f36fd90a 2022-07-09 op {
1280 f36fd90a 2022-07-09 op 	static const char *place = EMSG;	/* option letter processing */
1281 f36fd90a 2022-07-09 op 	char *oli;				/* option letter list index */
1282 f36fd90a 2022-07-09 op 
1283 f36fd90a 2022-07-09 op 	if (ostr == NULL)
1284 f36fd90a 2022-07-09 op 		return (-1);
1285 f36fd90a 2022-07-09 op 
1286 f36fd90a 2022-07-09 op 	if (BSDoptreset || !*place) {		/* update scanning pointer */
1287 f36fd90a 2022-07-09 op 		BSDoptreset = 0;
1288 f36fd90a 2022-07-09 op 		if (BSDoptind >= nargc || *(place = nargv[BSDoptind]) != '-') {
1289 f36fd90a 2022-07-09 op 			place = EMSG;
1290 f36fd90a 2022-07-09 op 			return (-1);
1291 f36fd90a 2022-07-09 op 		}
1292 f36fd90a 2022-07-09 op 		if (place[1] && *++place == '-') {	/* found "--" */
1293 f36fd90a 2022-07-09 op 			if (place[1])
1294 f36fd90a 2022-07-09 op 				return (BADCH);
1295 f36fd90a 2022-07-09 op 			++BSDoptind;
1296 f36fd90a 2022-07-09 op 			place = EMSG;
1297 f36fd90a 2022-07-09 op 			return (-1);
1298 f36fd90a 2022-07-09 op 		}
1299 f36fd90a 2022-07-09 op 	}					/* option letter okay? */
1300 f36fd90a 2022-07-09 op 	if ((BSDoptopt = (int)*place++) == (int)':' ||
1301 f36fd90a 2022-07-09 op 	    !(oli = strchr(ostr, BSDoptopt))) {
1302 f36fd90a 2022-07-09 op 		/*
1303 f36fd90a 2022-07-09 op 		 * if the user didn't specify '-' as an option,
1304 f36fd90a 2022-07-09 op 		 * assume it means -1.
1305 f36fd90a 2022-07-09 op 		 */
1306 f36fd90a 2022-07-09 op 		if (BSDoptopt == (int)'-')
1307 f36fd90a 2022-07-09 op 			return (-1);
1308 f36fd90a 2022-07-09 op 		if (!*place)
1309 f36fd90a 2022-07-09 op 			++BSDoptind;
1310 f36fd90a 2022-07-09 op 		if (BSDopterr && *ostr != ':')
1311 f36fd90a 2022-07-09 op 			(void)fprintf(stderr,
1312 f36fd90a 2022-07-09 op 			    "%s: unknown option -- %c\n", getprogname(),
1313 f36fd90a 2022-07-09 op 			    BSDoptopt);
1314 f36fd90a 2022-07-09 op 		return (BADCH);
1315 f36fd90a 2022-07-09 op 	}
1316 f36fd90a 2022-07-09 op 	if (*++oli != ':') {			/* don't need argument */
1317 f36fd90a 2022-07-09 op 		BSDoptarg = NULL;
1318 f36fd90a 2022-07-09 op 		if (!*place)
1319 f36fd90a 2022-07-09 op 			++BSDoptind;
1320 f36fd90a 2022-07-09 op 	}
1321 f36fd90a 2022-07-09 op 	else {					/* need an argument */
1322 f36fd90a 2022-07-09 op 		if (*place)			/* no white space */
1323 f36fd90a 2022-07-09 op 			BSDoptarg = (char *)place;
1324 f36fd90a 2022-07-09 op 		else if (nargc <= ++BSDoptind) {	/* no arg */
1325 f36fd90a 2022-07-09 op 			place = EMSG;
1326 f36fd90a 2022-07-09 op 			if (*ostr == ':')
1327 f36fd90a 2022-07-09 op 				return (BADARG);
1328 f36fd90a 2022-07-09 op 			if (BSDopterr)
1329 f36fd90a 2022-07-09 op 				(void)fprintf(stderr,
1330 f36fd90a 2022-07-09 op 				    "%s: option requires an argument -- %c\n",
1331 f36fd90a 2022-07-09 op 				    getprogname(), BSDoptopt);
1332 f36fd90a 2022-07-09 op 			return (BADCH);
1333 f36fd90a 2022-07-09 op 		}
1334 f36fd90a 2022-07-09 op 		else				/* white space */
1335 f36fd90a 2022-07-09 op 			BSDoptarg = nargv[BSDoptind];
1336 f36fd90a 2022-07-09 op 		place = EMSG;
1337 f36fd90a 2022-07-09 op 		++BSDoptind;
1338 f36fd90a 2022-07-09 op 	}
1339 f36fd90a 2022-07-09 op 	return (BSDoptopt);			/* dump back option letter */
1340 f36fd90a 2022-07-09 op }
1341 f36fd90a 2022-07-09 op #endif
1342 f36fd90a 2022-07-09 op #if !HAVE_REALLOCARRAY
1343 f36fd90a 2022-07-09 op /*
1344 f36fd90a 2022-07-09 op  * Copyright (c) 2008 Otto Moerbeek <otto@drijf.net>
1345 f36fd90a 2022-07-09 op  *
1346 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
1347 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
1348 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
1349 f36fd90a 2022-07-09 op  *
1350 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
1351 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
1352 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
1353 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
1354 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
1355 f36fd90a 2022-07-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
1356 f36fd90a 2022-07-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1357 f36fd90a 2022-07-09 op  */
1358 f36fd90a 2022-07-09 op 
1359 f36fd90a 2022-07-09 op #include <sys/types.h>
1360 f36fd90a 2022-07-09 op #include <errno.h>
1361 f36fd90a 2022-07-09 op #include <stdint.h>
1362 f36fd90a 2022-07-09 op #include <stdlib.h>
1363 f36fd90a 2022-07-09 op 
1364 f36fd90a 2022-07-09 op /*
1365 f36fd90a 2022-07-09 op  * This is sqrt(SIZE_MAX+1), as s1*s2 <= SIZE_MAX
1366 f36fd90a 2022-07-09 op  * if both s1 < MUL_NO_OVERFLOW and s2 < MUL_NO_OVERFLOW
1367 f36fd90a 2022-07-09 op  */
1368 f36fd90a 2022-07-09 op #define MUL_NO_OVERFLOW	((size_t)1 << (sizeof(size_t) * 4))
1369 f36fd90a 2022-07-09 op 
1370 f36fd90a 2022-07-09 op void *
1371 f36fd90a 2022-07-09 op reallocarray(void *optr, size_t nmemb, size_t size)
1372 f36fd90a 2022-07-09 op {
1373 f36fd90a 2022-07-09 op 	if ((nmemb >= MUL_NO_OVERFLOW || size >= MUL_NO_OVERFLOW) &&
1374 f36fd90a 2022-07-09 op 	    nmemb > 0 && SIZE_MAX / nmemb < size) {
1375 f36fd90a 2022-07-09 op 		errno = ENOMEM;
1376 f36fd90a 2022-07-09 op 		return NULL;
1377 f36fd90a 2022-07-09 op 	}
1378 f36fd90a 2022-07-09 op 	return realloc(optr, size * nmemb);
1379 f36fd90a 2022-07-09 op }
1380 f36fd90a 2022-07-09 op #endif /* !HAVE_REALLOCARRAY */
1381 f36fd90a 2022-07-09 op #if !HAVE_RECALLOCARRAY
1382 f36fd90a 2022-07-09 op /*
1383 f36fd90a 2022-07-09 op  * Copyright (c) 2008, 2017 Otto Moerbeek <otto@drijf.net>
1384 f36fd90a 2022-07-09 op  *
1385 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
1386 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
1387 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
1388 f36fd90a 2022-07-09 op  *
1389 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
1390 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
1391 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
1392 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
1393 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
1394 f36fd90a 2022-07-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
1395 f36fd90a 2022-07-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1396 f36fd90a 2022-07-09 op  */
1397 f36fd90a 2022-07-09 op 
1398 f36fd90a 2022-07-09 op /* OPENBSD ORIGINAL: lib/libc/stdlib/recallocarray.c */
1399 f36fd90a 2022-07-09 op 
1400 f36fd90a 2022-07-09 op #include <errno.h>
1401 f36fd90a 2022-07-09 op #include <stdlib.h>
1402 f36fd90a 2022-07-09 op #include <stdint.h>
1403 f36fd90a 2022-07-09 op #include <string.h>
1404 f36fd90a 2022-07-09 op #include <unistd.h>
1405 f36fd90a 2022-07-09 op 
1406 f36fd90a 2022-07-09 op /*
1407 f36fd90a 2022-07-09 op  * This is sqrt(SIZE_MAX+1), as s1*s2 <= SIZE_MAX
1408 f36fd90a 2022-07-09 op  * if both s1 < MUL_NO_OVERFLOW and s2 < MUL_NO_OVERFLOW
1409 f36fd90a 2022-07-09 op  */
1410 f36fd90a 2022-07-09 op #define MUL_NO_OVERFLOW ((size_t)1 << (sizeof(size_t) * 4))
1411 f36fd90a 2022-07-09 op 
1412 f36fd90a 2022-07-09 op void *
1413 f36fd90a 2022-07-09 op recallocarray(void *ptr, size_t oldnmemb, size_t newnmemb, size_t size)
1414 f36fd90a 2022-07-09 op {
1415 f36fd90a 2022-07-09 op 	size_t oldsize, newsize;
1416 f36fd90a 2022-07-09 op 	void *newptr;
1417 f36fd90a 2022-07-09 op 
1418 f36fd90a 2022-07-09 op 	if (ptr == NULL)
1419 f36fd90a 2022-07-09 op 		return calloc(newnmemb, size);
1420 f36fd90a 2022-07-09 op 
1421 f36fd90a 2022-07-09 op 	if ((newnmemb >= MUL_NO_OVERFLOW || size >= MUL_NO_OVERFLOW) &&
1422 f36fd90a 2022-07-09 op 	    newnmemb > 0 && SIZE_MAX / newnmemb < size) {
1423 f36fd90a 2022-07-09 op 		errno = ENOMEM;
1424 f36fd90a 2022-07-09 op 		return NULL;
1425 f36fd90a 2022-07-09 op 	}
1426 f36fd90a 2022-07-09 op 	newsize = newnmemb * size;
1427 f36fd90a 2022-07-09 op 
1428 f36fd90a 2022-07-09 op 	if ((oldnmemb >= MUL_NO_OVERFLOW || size >= MUL_NO_OVERFLOW) &&
1429 f36fd90a 2022-07-09 op 	    oldnmemb > 0 && SIZE_MAX / oldnmemb < size) {
1430 f36fd90a 2022-07-09 op 		errno = EINVAL;
1431 f36fd90a 2022-07-09 op 		return NULL;
1432 f36fd90a 2022-07-09 op 	}
1433 f36fd90a 2022-07-09 op 	oldsize = oldnmemb * size;
1434 f36fd90a 2022-07-09 op 	
1435 f36fd90a 2022-07-09 op 	/*
1436 f36fd90a 2022-07-09 op 	 * Don't bother too much if we're shrinking just a bit,
1437 f36fd90a 2022-07-09 op 	 * we do not shrink for series of small steps, oh well.
1438 f36fd90a 2022-07-09 op 	 */
1439 f36fd90a 2022-07-09 op 	if (newsize <= oldsize) {
1440 f36fd90a 2022-07-09 op 		size_t d = oldsize - newsize;
1441 f36fd90a 2022-07-09 op 
1442 f36fd90a 2022-07-09 op 		if (d < oldsize / 2 && d < (size_t)getpagesize()) {
1443 f36fd90a 2022-07-09 op 			memset((char *)ptr + newsize, 0, d);
1444 f36fd90a 2022-07-09 op 			return ptr;
1445 f36fd90a 2022-07-09 op 		}
1446 f36fd90a 2022-07-09 op 	}
1447 f36fd90a 2022-07-09 op 
1448 f36fd90a 2022-07-09 op 	newptr = malloc(newsize);
1449 f36fd90a 2022-07-09 op 	if (newptr == NULL)
1450 f36fd90a 2022-07-09 op 		return NULL;
1451 f36fd90a 2022-07-09 op 
1452 f36fd90a 2022-07-09 op 	if (newsize > oldsize) {
1453 f36fd90a 2022-07-09 op 		memcpy(newptr, ptr, oldsize);
1454 f36fd90a 2022-07-09 op 		memset((char *)newptr + oldsize, 0, newsize - oldsize);
1455 f36fd90a 2022-07-09 op 	} else
1456 f36fd90a 2022-07-09 op 		memcpy(newptr, ptr, newsize);
1457 f36fd90a 2022-07-09 op 
1458 f36fd90a 2022-07-09 op 	explicit_bzero(ptr, oldsize);
1459 f36fd90a 2022-07-09 op 	free(ptr);
1460 f36fd90a 2022-07-09 op 
1461 f36fd90a 2022-07-09 op 	return newptr;
1462 f36fd90a 2022-07-09 op }
1463 f36fd90a 2022-07-09 op #endif /* !HAVE_RECALLOCARRAY */
1464 f36fd90a 2022-07-09 op #if !HAVE_SETPROCTITLE
1465 f36fd90a 2022-07-09 op /*
1466 f36fd90a 2022-07-09 op  * Copyright (c) 2016 Nicholas Marriott <nicholas.marriott@gmail.com>
1467 f36fd90a 2022-07-09 op  *
1468 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
1469 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
1470 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
1471 f36fd90a 2022-07-09 op  *
1472 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
1473 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
1474 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
1475 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
1476 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF MIND, USE, DATA OR PROFITS, WHETHER
1477 f36fd90a 2022-07-09 op  * IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
1478 f36fd90a 2022-07-09 op  * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1479 f36fd90a 2022-07-09 op  */
1480 f36fd90a 2022-07-09 op 
1481 f36fd90a 2022-07-09 op # if HAVE_PR_SET_NAME
1482 f36fd90a 2022-07-09 op #include <sys/types.h>
1483 f36fd90a 2022-07-09 op #include <stdarg.h>
1484 f36fd90a 2022-07-09 op #include <stdio.h>
1485 f36fd90a 2022-07-09 op #include <string.h>
1486 f36fd90a 2022-07-09 op #include <sys/prctl.h>
1487 f36fd90a 2022-07-09 op void
1488 f36fd90a 2022-07-09 op setproctitle(const char *fmt, ...)
1489 f36fd90a 2022-07-09 op {
1490 f36fd90a 2022-07-09 op 	char	title[16], name[16], *cp;
1491 f36fd90a 2022-07-09 op 	va_list	ap;
1492 f36fd90a 2022-07-09 op 	int	used;
1493 f36fd90a 2022-07-09 op 
1494 f36fd90a 2022-07-09 op 	va_start(ap, fmt);
1495 f36fd90a 2022-07-09 op 	vsnprintf(title, sizeof(title), fmt, ap);
1496 f36fd90a 2022-07-09 op 	va_end(ap);
1497 f36fd90a 2022-07-09 op 
1498 f36fd90a 2022-07-09 op 	used = snprintf(name, sizeof(name), "%s: %s", getprogname(), title);
1499 f36fd90a 2022-07-09 op 	if (used >= (int)sizeof(name)) {
1500 f36fd90a 2022-07-09 op 		cp = strrchr(name, ' ');
1501 f36fd90a 2022-07-09 op 		if (cp != NULL)
1502 f36fd90a 2022-07-09 op 			*cp = '\0';
1503 f36fd90a 2022-07-09 op 	}
1504 f36fd90a 2022-07-09 op 	prctl(PR_SET_NAME, name);
1505 f36fd90a 2022-07-09 op }
1506 f36fd90a 2022-07-09 op # else
1507 f36fd90a 2022-07-09 op void
1508 f36fd90a 2022-07-09 op setproctitle(const char *fmt, ...)
1509 f36fd90a 2022-07-09 op {
1510 f36fd90a 2022-07-09 op 	return;
1511 f36fd90a 2022-07-09 op }
1512 f36fd90a 2022-07-09 op # endif
1513 f36fd90a 2022-07-09 op #endif /* !HAVE_SETPROCTITLE */
1514 f36fd90a 2022-07-09 op #if !HAVE_STRLCAT
1515 f36fd90a 2022-07-09 op /*
1516 f36fd90a 2022-07-09 op  * Copyright (c) 1998 Todd C. Miller <Todd.Miller@courtesan.com>
1517 f36fd90a 2022-07-09 op  *
1518 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
1519 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
1520 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
1521 f36fd90a 2022-07-09 op  *
1522 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
1523 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
1524 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
1525 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
1526 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
1527 f36fd90a 2022-07-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
1528 f36fd90a 2022-07-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1529 f36fd90a 2022-07-09 op  */
1530 f36fd90a 2022-07-09 op 
1531 f36fd90a 2022-07-09 op #include <sys/types.h>
1532 f36fd90a 2022-07-09 op #include <string.h>
1533 f36fd90a 2022-07-09 op 
1534 f36fd90a 2022-07-09 op /*
1535 f36fd90a 2022-07-09 op  * Appends src to string dst of size siz (unlike strncat, siz is the
1536 f36fd90a 2022-07-09 op  * full size of dst, not space left).  At most siz-1 characters
1537 f36fd90a 2022-07-09 op  * will be copied.  Always NUL terminates (unless siz <= strlen(dst)).
1538 f36fd90a 2022-07-09 op  * Returns strlen(src) + MIN(siz, strlen(initial dst)).
1539 f36fd90a 2022-07-09 op  * If retval >= siz, truncation occurred.
1540 f36fd90a 2022-07-09 op  */
1541 f36fd90a 2022-07-09 op size_t
1542 f36fd90a 2022-07-09 op strlcat(char *dst, const char *src, size_t siz)
1543 f36fd90a 2022-07-09 op {
1544 f36fd90a 2022-07-09 op 	char *d = dst;
1545 f36fd90a 2022-07-09 op 	const char *s = src;
1546 f36fd90a 2022-07-09 op 	size_t n = siz;
1547 f36fd90a 2022-07-09 op 	size_t dlen;
1548 f36fd90a 2022-07-09 op 
1549 f36fd90a 2022-07-09 op 	/* Find the end of dst and adjust bytes left but don't go past end */
1550 f36fd90a 2022-07-09 op 	while (n-- != 0 && *d != '\0')
1551 f36fd90a 2022-07-09 op 		d++;
1552 f36fd90a 2022-07-09 op 	dlen = d - dst;
1553 f36fd90a 2022-07-09 op 	n = siz - dlen;
1554 f36fd90a 2022-07-09 op 
1555 f36fd90a 2022-07-09 op 	if (n == 0)
1556 f36fd90a 2022-07-09 op 		return(dlen + strlen(s));
1557 f36fd90a 2022-07-09 op 	while (*s != '\0') {
1558 f36fd90a 2022-07-09 op 		if (n != 1) {
1559 f36fd90a 2022-07-09 op 			*d++ = *s;
1560 f36fd90a 2022-07-09 op 			n--;
1561 f36fd90a 2022-07-09 op 		}
1562 f36fd90a 2022-07-09 op 		s++;
1563 f36fd90a 2022-07-09 op 	}
1564 f36fd90a 2022-07-09 op 	*d = '\0';
1565 f36fd90a 2022-07-09 op 
1566 f36fd90a 2022-07-09 op 	return(dlen + (s - src));	/* count does not include NUL */
1567 f36fd90a 2022-07-09 op }
1568 f36fd90a 2022-07-09 op #endif /* !HAVE_STRLCAT */
1569 f36fd90a 2022-07-09 op #if !HAVE_STRLCPY
1570 f36fd90a 2022-07-09 op /*
1571 f36fd90a 2022-07-09 op  * Copyright (c) 1998 Todd C. Miller <Todd.Miller@courtesan.com>
1572 f36fd90a 2022-07-09 op  *
1573 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
1574 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
1575 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
1576 f36fd90a 2022-07-09 op  *
1577 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
1578 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
1579 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
1580 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
1581 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
1582 f36fd90a 2022-07-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
1583 f36fd90a 2022-07-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1584 f36fd90a 2022-07-09 op  */
1585 f36fd90a 2022-07-09 op 
1586 f36fd90a 2022-07-09 op #include <sys/types.h>
1587 f36fd90a 2022-07-09 op #include <string.h>
1588 f36fd90a 2022-07-09 op 
1589 f36fd90a 2022-07-09 op /*
1590 f36fd90a 2022-07-09 op  * Copy src to string dst of size siz.  At most siz-1 characters
1591 f36fd90a 2022-07-09 op  * will be copied.  Always NUL terminates (unless siz == 0).
1592 f36fd90a 2022-07-09 op  * Returns strlen(src); if retval >= siz, truncation occurred.
1593 f36fd90a 2022-07-09 op  */
1594 f36fd90a 2022-07-09 op size_t
1595 f36fd90a 2022-07-09 op strlcpy(char *dst, const char *src, size_t siz)
1596 f36fd90a 2022-07-09 op {
1597 f36fd90a 2022-07-09 op 	char *d = dst;
1598 f36fd90a 2022-07-09 op 	const char *s = src;
1599 f36fd90a 2022-07-09 op 	size_t n = siz;
1600 f36fd90a 2022-07-09 op 
1601 f36fd90a 2022-07-09 op 	/* Copy as many bytes as will fit */
1602 f36fd90a 2022-07-09 op 	if (n != 0) {
1603 f36fd90a 2022-07-09 op 		while (--n != 0) {
1604 f36fd90a 2022-07-09 op 			if ((*d++ = *s++) == '\0')
1605 f36fd90a 2022-07-09 op 				break;
1606 f36fd90a 2022-07-09 op 		}
1607 f36fd90a 2022-07-09 op 	}
1608 f36fd90a 2022-07-09 op 
1609 f36fd90a 2022-07-09 op 	/* Not enough room in dst, add NUL and traverse rest of src */
1610 f36fd90a 2022-07-09 op 	if (n == 0) {
1611 f36fd90a 2022-07-09 op 		if (siz != 0)
1612 f36fd90a 2022-07-09 op 			*d = '\0';		/* NUL-terminate dst */
1613 f36fd90a 2022-07-09 op 		while (*s++)
1614 f36fd90a 2022-07-09 op 			;
1615 f36fd90a 2022-07-09 op 	}
1616 f36fd90a 2022-07-09 op 
1617 f36fd90a 2022-07-09 op 	return(s - src - 1);	/* count does not include NUL */
1618 f36fd90a 2022-07-09 op }
1619 f36fd90a 2022-07-09 op #endif /* !HAVE_STRLCPY */
1620 f36fd90a 2022-07-09 op #if !HAVE_STRNDUP
1621 f36fd90a 2022-07-09 op /*	$OpenBSD$	*/
1622 f36fd90a 2022-07-09 op /*
1623 f36fd90a 2022-07-09 op  * Copyright (c) 2010 Todd C. Miller <Todd.Miller@courtesan.com>
1624 f36fd90a 2022-07-09 op  *
1625 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
1626 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
1627 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
1628 f36fd90a 2022-07-09 op  *
1629 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
1630 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
1631 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
1632 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
1633 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
1634 f36fd90a 2022-07-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
1635 f36fd90a 2022-07-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1636 f36fd90a 2022-07-09 op  */
1637 f36fd90a 2022-07-09 op 
1638 f36fd90a 2022-07-09 op #include <sys/types.h>
1639 f36fd90a 2022-07-09 op 
1640 f36fd90a 2022-07-09 op #include <stddef.h>
1641 f36fd90a 2022-07-09 op #include <stdlib.h>
1642 f36fd90a 2022-07-09 op #include <string.h>
1643 f36fd90a 2022-07-09 op 
1644 f36fd90a 2022-07-09 op char *
1645 f36fd90a 2022-07-09 op strndup(const char *str, size_t maxlen)
1646 f36fd90a 2022-07-09 op {
1647 f36fd90a 2022-07-09 op 	char *copy;
1648 f36fd90a 2022-07-09 op 	size_t len;
1649 f36fd90a 2022-07-09 op 
1650 f36fd90a 2022-07-09 op 	len = strnlen(str, maxlen);
1651 f36fd90a 2022-07-09 op 	copy = malloc(len + 1);
1652 f36fd90a 2022-07-09 op 	if (copy != NULL) {
1653 f36fd90a 2022-07-09 op 		(void)memcpy(copy, str, len);
1654 f36fd90a 2022-07-09 op 		copy[len] = '\0';
1655 f36fd90a 2022-07-09 op 	}
1656 f36fd90a 2022-07-09 op 
1657 f36fd90a 2022-07-09 op 	return copy;
1658 f36fd90a 2022-07-09 op }
1659 f36fd90a 2022-07-09 op #endif /* !HAVE_STRNDUP */
1660 f36fd90a 2022-07-09 op #if !HAVE_STRNLEN
1661 f36fd90a 2022-07-09 op /*	$OpenBSD$	*/
1662 f36fd90a 2022-07-09 op 
1663 f36fd90a 2022-07-09 op /*
1664 f36fd90a 2022-07-09 op  * Copyright (c) 2010 Todd C. Miller <Todd.Miller@courtesan.com>
1665 f36fd90a 2022-07-09 op  *
1666 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
1667 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
1668 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
1669 f36fd90a 2022-07-09 op  *
1670 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
1671 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
1672 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
1673 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
1674 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
1675 f36fd90a 2022-07-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
1676 f36fd90a 2022-07-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1677 f36fd90a 2022-07-09 op  */
1678 f36fd90a 2022-07-09 op 
1679 f36fd90a 2022-07-09 op #include <sys/types.h>
1680 f36fd90a 2022-07-09 op #include <string.h>
1681 f36fd90a 2022-07-09 op 
1682 f36fd90a 2022-07-09 op size_t
1683 f36fd90a 2022-07-09 op strnlen(const char *str, size_t maxlen)
1684 f36fd90a 2022-07-09 op {
1685 f36fd90a 2022-07-09 op 	const char *cp;
1686 f36fd90a 2022-07-09 op 
1687 f36fd90a 2022-07-09 op 	for (cp = str; maxlen != 0 && *cp != '\0'; cp++, maxlen--)
1688 f36fd90a 2022-07-09 op 		;
1689 f36fd90a 2022-07-09 op 
1690 f36fd90a 2022-07-09 op 	return (size_t)(cp - str);
1691 f36fd90a 2022-07-09 op }
1692 f36fd90a 2022-07-09 op #endif /* !HAVE_STRNLEN */
1693 f36fd90a 2022-07-09 op #if !HAVE_STRTONUM
1694 f36fd90a 2022-07-09 op /*
1695 f36fd90a 2022-07-09 op  * Copyright (c) 2004 Ted Unangst and Todd Miller
1696 f36fd90a 2022-07-09 op  * All rights reserved.
1697 f36fd90a 2022-07-09 op  *
1698 f36fd90a 2022-07-09 op  * Permission to use, copy, modify, and distribute this software for any
1699 f36fd90a 2022-07-09 op  * purpose with or without fee is hereby granted, provided that the above
1700 f36fd90a 2022-07-09 op  * copyright notice and this permission notice appear in all copies.
1701 f36fd90a 2022-07-09 op  *
1702 f36fd90a 2022-07-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
1703 f36fd90a 2022-07-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
1704 f36fd90a 2022-07-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
1705 f36fd90a 2022-07-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
1706 f36fd90a 2022-07-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
1707 f36fd90a 2022-07-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
1708 f36fd90a 2022-07-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1709 f36fd90a 2022-07-09 op  */
1710 f36fd90a 2022-07-09 op 
1711 f36fd90a 2022-07-09 op #include <errno.h>
1712 f36fd90a 2022-07-09 op #include <limits.h>
1713 f36fd90a 2022-07-09 op #include <stdlib.h>
1714 f36fd90a 2022-07-09 op 
1715 f36fd90a 2022-07-09 op #define	INVALID		1
1716 f36fd90a 2022-07-09 op #define	TOOSMALL	2
1717 f36fd90a 2022-07-09 op #define	TOOLARGE	3
1718 f36fd90a 2022-07-09 op 
1719 f36fd90a 2022-07-09 op long long
1720 f36fd90a 2022-07-09 op strtonum(const char *numstr, long long minval, long long maxval,
1721 f36fd90a 2022-07-09 op     const char **errstrp)
1722 f36fd90a 2022-07-09 op {
1723 f36fd90a 2022-07-09 op 	long long ll = 0;
1724 f36fd90a 2022-07-09 op 	int error = 0;
1725 f36fd90a 2022-07-09 op 	char *ep;
1726 f36fd90a 2022-07-09 op 	struct errval {
1727 f36fd90a 2022-07-09 op 		const char *errstr;
1728 f36fd90a 2022-07-09 op 		int err;
1729 f36fd90a 2022-07-09 op 	} ev[4] = {
1730 f36fd90a 2022-07-09 op 		{ NULL,		0 },
1731 f36fd90a 2022-07-09 op 		{ "invalid",	EINVAL },
1732 f36fd90a 2022-07-09 op 		{ "too small",	ERANGE },
1733 f36fd90a 2022-07-09 op 		{ "too large",	ERANGE },
1734 f36fd90a 2022-07-09 op 	};
1735 f36fd90a 2022-07-09 op 
1736 f36fd90a 2022-07-09 op 	ev[0].err = errno;
1737 f36fd90a 2022-07-09 op 	errno = 0;
1738 f36fd90a 2022-07-09 op 	if (minval > maxval) {
1739 f36fd90a 2022-07-09 op 		error = INVALID;
1740 f36fd90a 2022-07-09 op 	} else {
1741 f36fd90a 2022-07-09 op 		ll = strtoll(numstr, &ep, 10);
1742 f36fd90a 2022-07-09 op 		if (numstr == ep || *ep != '\0')
1743 f36fd90a 2022-07-09 op 			error = INVALID;
1744 f36fd90a 2022-07-09 op 		else if ((ll == LLONG_MIN && errno == ERANGE) || ll < minval)
1745 f36fd90a 2022-07-09 op 			error = TOOSMALL;
1746 f36fd90a 2022-07-09 op 		else if ((ll == LLONG_MAX && errno == ERANGE) || ll > maxval)
1747 f36fd90a 2022-07-09 op 			error = TOOLARGE;
1748 f36fd90a 2022-07-09 op 	}
1749 f36fd90a 2022-07-09 op 	if (errstrp != NULL)
1750 f36fd90a 2022-07-09 op 		*errstrp = ev[error].errstr;
1751 f36fd90a 2022-07-09 op 	errno = ev[error].err;
1752 f36fd90a 2022-07-09 op 	if (error)
1753 f36fd90a 2022-07-09 op 		ll = 0;
1754 f36fd90a 2022-07-09 op 
1755 f36fd90a 2022-07-09 op 	return (ll);
1756 f36fd90a 2022-07-09 op }
1757 f36fd90a 2022-07-09 op #endif /* !HAVE_STRTONUM */
1758 31e12e67 2023-09-07 op #if !HAVE_TIMESPECSUB
1759 31e12e67 2023-09-07 op #include <sys/time.h>
1760 31e12e67 2023-09-07 op void
1761 31e12e67 2023-09-07 op timespecsub(struct timespec *a, struct timespec *b, struct timespec *ret)
1762 31e12e67 2023-09-07 op {
1763 31e12e67 2023-09-07 op 	ret->tv_sec = a->tv_sec - b->tv_sec;
1764 31e12e67 2023-09-07 op 	ret->tv_nsec = a->tv_nsec - b->tv_nsec;
1765 31e12e67 2023-09-07 op 	if (ret->tv_nsec < 0) {
1766 31e12e67 2023-09-07 op 		ret->tv_sec--;
1767 31e12e67 2023-09-07 op 		ret->tv_nsec += 1000000000L;
1768 31e12e67 2023-09-07 op 	}
1769 31e12e67 2023-09-07 op }
1770 31e12e67 2023-09-07 op #endif /* !HAVE_TIMESPECSUB */