op public repos

Blame

Date:: Sun May 22 18:53:05 2022 UTC
Message:: allow Twrite with size bigger than ~16K Until now I've been using a single imsg to handle each messages and the imsg framework has a limit of around 16K for message. For almost all requests, this is fine. Except for Twrite and Tread. This is an attempt to make Twrite handle bigger buffers. The listener process just looks at how big a request is and split it up in multiple messages and the client process tries to remember the fid, position and missing data to continue the write. This means that a single Twrite can be split up in multiple write(2)s.
Actions:: History | Blob | Raw File
   1 fb1a36c0 2022-01-09 op /*
   2 1e84c7b7 2022-01-10 op  * Copyright (c) 2021, 2022 Omar Polo <op@omarpolo.com>
   3 fb1a36c0 2022-01-09 op  *
   4 fb1a36c0 2022-01-09 op  * Permission to use, copy, modify, and distribute this software for any
   5 fb1a36c0 2022-01-09 op  * purpose with or without fee is hereby granted, provided that the above
   6 fb1a36c0 2022-01-09 op  * copyright notice and this permission notice appear in all copies.
   7 fb1a36c0 2022-01-09 op  *
   8 fb1a36c0 2022-01-09 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
   9 fb1a36c0 2022-01-09 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
  10 fb1a36c0 2022-01-09 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
  11 fb1a36c0 2022-01-09 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  12 fb1a36c0 2022-01-09 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  13 fb1a36c0 2022-01-09 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
  14 fb1a36c0 2022-01-09 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  15 fb1a36c0 2022-01-09 op  */
  16 fb1a36c0 2022-01-09 op 
  17 bbcba3ed 2022-01-10 op #include "compat.h"
  18 bbcba3ed 2022-01-10 op 
  19 fb1a36c0 2022-01-09 op #include <sys/stat.h>
  20 fb1a36c0 2022-01-09 op #include <sys/types.h>
  21 fb1a36c0 2022-01-09 op #include <sys/uio.h>
  22 fb1a36c0 2022-01-09 op 
  23 fb1a36c0 2022-01-09 op #include <dirent.h>
  24 fb1a36c0 2022-01-09 op #include <endian.h>
  25 fb1a36c0 2022-01-09 op #include <errno.h>
  26 fb1a36c0 2022-01-09 op #include <fcntl.h>
  27 755d75bf 2022-01-17 op #include <inttypes.h>
  28 755d75bf 2022-01-17 op #include <libgen.h>
  29 fb1a36c0 2022-01-09 op #include <pwd.h>
  30 fb1a36c0 2022-01-09 op #include <signal.h>
  31 fb1a36c0 2022-01-09 op #include <stdint.h>
  32 755d75bf 2022-01-17 op #include <stdio.h>
  33 fb1a36c0 2022-01-09 op #include <stdlib.h>
  34 fb1a36c0 2022-01-09 op #include <string.h>
  35 fb1a36c0 2022-01-09 op #include <syslog.h>
  36 fb1a36c0 2022-01-09 op #include <unistd.h>
  37 fb1a36c0 2022-01-09 op 
  38 fb1a36c0 2022-01-09 op #include "client.h"
  39 fb1a36c0 2022-01-09 op #include "kami.h"
  40 fb1a36c0 2022-01-09 op #include "kamid.h"
  41 fb1a36c0 2022-01-09 op #include "log.h"
  42 fb1a36c0 2022-01-09 op #include "sandbox.h"
  43 fb1a36c0 2022-01-09 op #include "utils.h"
  44 fb1a36c0 2022-01-09 op 
  45 fb1a36c0 2022-01-09 op /*
  46 6be59daa 2022-05-22 op  * The minimum value allowed for the msize.
  47 6be59daa 2022-05-22 op  */
  48 6be59daa 2022-05-22 op #define MIN_MSIZE 256
  49 fb1a36c0 2022-01-09 op 
  50 fb1a36c0 2022-01-09 op #define DEBUG_PACKETS 0
  51 fb1a36c0 2022-01-09 op 
  52 fb1a36c0 2022-01-09 op /* straight outta /src/usr.bin/ssh/scp.c */
  53 fb1a36c0 2022-01-09 op #define TYPE_OVERFLOW(type, val) \
  54 fb1a36c0 2022-01-09 op 	((sizeof(type) == 4 && (val) > INT32_MAX) || \
  55 fb1a36c0 2022-01-09 op 	 (sizeof(type) == 8 && (val) > INT64_MAX) || \
  56 fb1a36c0 2022-01-09 op 	 (sizeof(type) != 4 && sizeof(type) != 8))
  57 fb1a36c0 2022-01-09 op 
  58 fb1a36c0 2022-01-09 op STAILQ_HEAD(dirhead, dir) dirs;
  59 fb1a36c0 2022-01-09 op struct dir {
  60 fb1a36c0 2022-01-09 op 	int			 refcount;
  61 fb1a36c0 2022-01-09 op 	int			 fd;
  62 fb1a36c0 2022-01-09 op 	STAILQ_ENTRY(dir)	 entries;
  63 fb1a36c0 2022-01-09 op };
  64 fb1a36c0 2022-01-09 op 
  65 fb1a36c0 2022-01-09 op STAILQ_HEAD(fidhead, fid) fids;
  66 fb1a36c0 2022-01-09 op struct fid {
  67 fb1a36c0 2022-01-09 op 	uint32_t		 fid;
  68 fb1a36c0 2022-01-09 op 
  69 46e4e74b 2022-01-17 op 	char			 fname[NAME_MAX];
  70 fb1a36c0 2022-01-09 op 
  71 fb1a36c0 2022-01-09 op 	/*
  72 fb1a36c0 2022-01-09 op 	 * the flags passed to open(2).  O_CLOEXEC means ORCLOSE, that
  73 fb1a36c0 2022-01-09 op 	 * is to unlink the file upon Tclunk.
  74 fb1a36c0 2022-01-09 op 	 */
  75 fb1a36c0 2022-01-09 op 	int			 iomode;
  76 fb1a36c0 2022-01-09 op 
  77 fb1a36c0 2022-01-09 op 	/*
  78 fb1a36c0 2022-01-09 op 	 * if fd is not -1 this fid was opened, fd represents its
  79 fb1a36c0 2022-01-09 op 	 * file descriptor and iomode the flags passed to open(2).
  80 fb1a36c0 2022-01-09 op 	 */
  81 fb1a36c0 2022-01-09 op 	int			 fd;
  82 fb1a36c0 2022-01-09 op 	DIR			*d;
  83 fb1a36c0 2022-01-09 op 	struct evbuffer		*evb;
  84 fb1a36c0 2022-01-09 op 
  85 fb1a36c0 2022-01-09 op 	/*
  86 fb1a36c0 2022-01-09 op 	 * expected offset for Tread against a directory.
  87 fb1a36c0 2022-01-09 op 	 */
  88 fb1a36c0 2022-01-09 op 	uint64_t		 offset;
  89 fb1a36c0 2022-01-09 op 
  90 fb1a36c0 2022-01-09 op 	struct qid		 qid;
  91 fb1a36c0 2022-01-09 op 	struct dir		*dir;
  92 fb1a36c0 2022-01-09 op 	STAILQ_ENTRY(fid)	 entries;
  93 fb1a36c0 2022-01-09 op };
  94 fb1a36c0 2022-01-09 op 
  95 fb1a36c0 2022-01-09 op static struct imsgev	*iev_listener;
  96 fb1a36c0 2022-01-09 op static struct evbuffer	*evb;
  97 fb1a36c0 2022-01-09 op static uint32_t		 peerid;
  98 fb1a36c0 2022-01-09 op 
  99 fb1a36c0 2022-01-09 op static int		 handshaked;
 100 fb1a36c0 2022-01-09 op uint32_t		 msize;
 101 fb1a36c0 2022-01-09 op 
 102 fb1a36c0 2022-01-09 op static __dead void	client_shutdown(void);
 103 fb1a36c0 2022-01-09 op static void		client_sig_handler(int, short, void *);
 104 fb1a36c0 2022-01-09 op static void		client_dispatch_listener(int, short, void *);
 105 fb1a36c0 2022-01-09 op static void		client_privdrop(const char *, const char *);
 106 fb1a36c0 2022-01-09 op 
 107 5c69b561 2022-01-29 op static int		client_send_listenerp(int, uint32_t, const void *, uint16_t);
 108 fb1a36c0 2022-01-09 op static int		client_send_listener(int, const void *, uint16_t);
 109 fb1a36c0 2022-01-09 op 
 110 fb1a36c0 2022-01-09 op static void		 qid_update_from_sb(struct qid *, struct stat *);
 111 fb1a36c0 2022-01-09 op 
 112 fb1a36c0 2022-01-09 op static struct dir	*new_dir(int);
 113 fb1a36c0 2022-01-09 op static struct dir	*dir_incref(struct dir *);
 114 fb1a36c0 2022-01-09 op static void		 dir_decref(struct dir *);
 115 fb1a36c0 2022-01-09 op 
 116 fb1a36c0 2022-01-09 op static struct fid	*new_fid(struct dir *, uint32_t, const char *, struct qid *);
 117 fb1a36c0 2022-01-09 op static struct fid	*fid_by_id(uint32_t);
 118 fb1a36c0 2022-01-09 op static void		 free_fid(struct fid *);
 119 fb1a36c0 2022-01-09 op 
 120 fb1a36c0 2022-01-09 op static void		parse_message(const uint8_t *, size_t,
 121 fb1a36c0 2022-01-09 op 			    struct np_msg_header *, uint8_t **);
 122 fb1a36c0 2022-01-09 op 
 123 fb1a36c0 2022-01-09 op static void		np_write16(struct evbuffer *, uint16_t);
 124 fb1a36c0 2022-01-09 op static void		np_write32(struct evbuffer *, uint32_t);
 125 fb1a36c0 2022-01-09 op static void		np_write64(struct evbuffer *, uint64_t);
 126 fb1a36c0 2022-01-09 op static void		np_header(uint32_t, uint8_t, uint16_t);
 127 fb1a36c0 2022-01-09 op static void		np_string(struct evbuffer *, uint16_t, const char *);
 128 fb1a36c0 2022-01-09 op static void		np_qid(struct evbuffer *, struct qid *);
 129 fb1a36c0 2022-01-09 op static void		do_send(void);
 130 fb1a36c0 2022-01-09 op 
 131 fb1a36c0 2022-01-09 op static void		np_version(uint16_t, uint32_t, const char *);
 132 fb1a36c0 2022-01-09 op static void		np_attach(uint16_t, struct qid *);
 133 fb1a36c0 2022-01-09 op static void		np_clunk(uint16_t);
 134 fb1a36c0 2022-01-09 op static void		np_flush(uint16_t);
 135 fb1a36c0 2022-01-09 op static void		np_walk(uint16_t, int, struct qid *);
 136 fb1a36c0 2022-01-09 op static void		np_open(uint16_t, struct qid *, uint32_t);
 137 fb1a36c0 2022-01-09 op static void		np_create(uint16_t, struct qid *, uint32_t);
 138 fb1a36c0 2022-01-09 op static void		np_read(uint16_t, uint32_t, void *);
 139 fb1a36c0 2022-01-09 op static void		np_write(uint16_t, uint32_t);
 140 70540bb5 2022-02-02 op static void		np_stat(uint16_t, uint16_t, void *);
 141 755d75bf 2022-01-17 op static void		np_wstat(uint16_t);
 142 fb1a36c0 2022-01-09 op static void		np_remove(uint16_t);
 143 fb1a36c0 2022-01-09 op static void		np_error(uint16_t, const char *);
 144 fb1a36c0 2022-01-09 op static void		np_errno(uint16_t);
 145 fb1a36c0 2022-01-09 op 
 146 fb1a36c0 2022-01-09 op static int	np_read8(const char *, const char *, uint8_t *,
 147 fb1a36c0 2022-01-09 op 		    const uint8_t **, size_t *);
 148 fb1a36c0 2022-01-09 op static int	np_read16(const char *, const char *, uint16_t *,
 149 fb1a36c0 2022-01-09 op 		    const uint8_t **, size_t *);
 150 fb1a36c0 2022-01-09 op static int	np_read32(const char *, const char *, uint32_t *,
 151 fb1a36c0 2022-01-09 op 		    const uint8_t **, size_t *);
 152 fb1a36c0 2022-01-09 op static int	np_read64(const char *, const char *, uint64_t *,
 153 fb1a36c0 2022-01-09 op 		    const uint8_t **, size_t *);
 154 fb1a36c0 2022-01-09 op 
 155 fb1a36c0 2022-01-09 op #define READSTRERR	-1
 156 fb1a36c0 2022-01-09 op #define READSTRTRUNC	-2
 157 fb1a36c0 2022-01-09 op static int	np_readstr(const char *, const char *, char *, size_t,
 158 fb1a36c0 2022-01-09 op 		    const uint8_t **, size_t *);
 159 fb1a36c0 2022-01-09 op 
 160 755d75bf 2022-01-17 op static int	np_readst(const char *, const char *, struct np_stat *,
 161 755d75bf 2022-01-17 op 		    char *, size_t, const uint8_t **, size_t *);
 162 755d75bf 2022-01-17 op 
 163 fb1a36c0 2022-01-09 op #define NPREAD8(f, dst, src, len)  np_read8(__func__, f, dst, src, len)
 164 fb1a36c0 2022-01-09 op #define NPREAD16(f, dst, src, len) np_read16(__func__, f, dst, src, len)
 165 fb1a36c0 2022-01-09 op #define NPREAD32(f, dst, src, len) np_read32(__func__, f, dst, src, len)
 166 fb1a36c0 2022-01-09 op #define NPREAD64(f, dst, src, len) np_read64(__func__, f, dst, src, len)
 167 fb1a36c0 2022-01-09 op 
 168 fb1a36c0 2022-01-09 op #define NPREADSTR(f, b, bl, src, len) np_readstr(__func__, f, b, bl, src, len)
 169 fb1a36c0 2022-01-09 op 
 170 755d75bf 2022-01-17 op #define NPREADST(f, dst, n, nl, src, len) np_readst(__func__, f, dst, n, nl, src, len)
 171 755d75bf 2022-01-17 op 
 172 fb1a36c0 2022-01-09 op static void	tversion(struct np_msg_header *, const uint8_t *, size_t);
 173 fb1a36c0 2022-01-09 op static void	tattach(struct np_msg_header *, const uint8_t *, size_t);
 174 fb1a36c0 2022-01-09 op static void	tclunk(struct np_msg_header *, const uint8_t *, size_t);
 175 fb1a36c0 2022-01-09 op static void	tflush(struct np_msg_header *, const uint8_t *, size_t);
 176 fb1a36c0 2022-01-09 op static void	twalk(struct np_msg_header *, const uint8_t *, size_t);
 177 fb1a36c0 2022-01-09 op static void	topen(struct np_msg_header *, const uint8_t *, size_t);
 178 fb1a36c0 2022-01-09 op static void	tcreate(struct np_msg_header *, const uint8_t *, size_t);
 179 fb1a36c0 2022-01-09 op static void	tread(struct np_msg_header *, const uint8_t *, size_t);
 180 8b0a5062 2022-05-22 op static void	twrite(struct np_msg_header *, const uint8_t *, size_t, struct fid **, off_t *, size_t *, int *);
 181 8b0a5062 2022-05-22 op static void	twrite_cont(struct fid *, off_t *, size_t *, int *, uint16_t, const uint8_t *, size_t);
 182 fb1a36c0 2022-01-09 op static void	tstat(struct np_msg_header *, const uint8_t *, size_t);
 183 755d75bf 2022-01-17 op static void	twstat(struct np_msg_header *, const uint8_t *, size_t);
 184 fb1a36c0 2022-01-09 op static void	tremove(struct np_msg_header *, const uint8_t *, size_t);
 185 8b0a5062 2022-05-22 op static void	handle_message(struct imsg *, size_t, int);
 186 fb1a36c0 2022-01-09 op 
 187 fb1a36c0 2022-01-09 op __dead void
 188 fb1a36c0 2022-01-09 op client(int debug, int verbose)
 189 fb1a36c0 2022-01-09 op {
 190 fb1a36c0 2022-01-09 op 	struct event	ev_sigint, ev_sigterm;
 191 fb1a36c0 2022-01-09 op 
 192 fb1a36c0 2022-01-09 op 	log_init(debug, LOG_DAEMON);
 193 fb1a36c0 2022-01-09 op 	log_setverbose(verbose);
 194 fb1a36c0 2022-01-09 op 
 195 fb1a36c0 2022-01-09 op 	setproctitle("client");
 196 fb1a36c0 2022-01-09 op 	log_procinit("client");
 197 fb1a36c0 2022-01-09 op 
 198 fb1a36c0 2022-01-09 op 	log_debug("warming up");
 199 fb1a36c0 2022-01-09 op 
 200 fb1a36c0 2022-01-09 op 	event_init();
 201 fb1a36c0 2022-01-09 op 
 202 fb1a36c0 2022-01-09 op 	/* Setup signal handlers */
 203 fb1a36c0 2022-01-09 op 	signal_set(&ev_sigint, SIGINT, client_sig_handler, NULL);
 204 fb1a36c0 2022-01-09 op 	signal_set(&ev_sigterm, SIGTERM, client_sig_handler, NULL);
 205 fb1a36c0 2022-01-09 op 
 206 fb1a36c0 2022-01-09 op 	signal_add(&ev_sigint, NULL);
 207 fb1a36c0 2022-01-09 op 	signal_add(&ev_sigterm, NULL);
 208 fb1a36c0 2022-01-09 op 
 209 fb1a36c0 2022-01-09 op 	signal(SIGPIPE, SIG_IGN);
 210 fb1a36c0 2022-01-09 op 	signal(SIGHUP, SIG_IGN);
 211 fb1a36c0 2022-01-09 op 
 212 fb1a36c0 2022-01-09 op 	/* Setup pipe and event handler to the listener process */
 213 fb1a36c0 2022-01-09 op 	if ((iev_listener = malloc(sizeof(*iev_listener))) == NULL)
 214 fb1a36c0 2022-01-09 op 		fatal(NULL);
 215 fb1a36c0 2022-01-09 op 
 216 fb1a36c0 2022-01-09 op 	imsg_init(&iev_listener->ibuf, 3);
 217 fb1a36c0 2022-01-09 op 	iev_listener->handler = client_dispatch_listener;
 218 fb1a36c0 2022-01-09 op 
 219 fb1a36c0 2022-01-09 op 	/* Setup event handlers. */
 220 fb1a36c0 2022-01-09 op 	iev_listener->events = EV_READ;
 221 fb1a36c0 2022-01-09 op 	event_set(&iev_listener->ev, iev_listener->ibuf.fd,
 222 fb1a36c0 2022-01-09 op 	    iev_listener->events, iev_listener->handler, iev_listener);
 223 fb1a36c0 2022-01-09 op 	event_add(&iev_listener->ev, NULL);
 224 fb1a36c0 2022-01-09 op 
 225 fb1a36c0 2022-01-09 op 	event_dispatch();
 226 fb1a36c0 2022-01-09 op 	client_shutdown();
 227 fb1a36c0 2022-01-09 op }
 228 fb1a36c0 2022-01-09 op 
 229 fb1a36c0 2022-01-09 op static __dead void
 230 fb1a36c0 2022-01-09 op client_shutdown(void)
 231 fb1a36c0 2022-01-09 op {
 232 fb1a36c0 2022-01-09 op 	if (evb != NULL)
 233 fb1a36c0 2022-01-09 op 		evbuffer_free(evb);
 234 fb1a36c0 2022-01-09 op 
 235 fb1a36c0 2022-01-09 op 	msgbuf_clear(&iev_listener->ibuf.w);
 236 fb1a36c0 2022-01-09 op 	close(iev_listener->ibuf.fd);
 237 fb1a36c0 2022-01-09 op 
 238 fb1a36c0 2022-01-09 op         free(iev_listener);
 239 fb1a36c0 2022-01-09 op 
 240 fb1a36c0 2022-01-09 op 	log_debug("client exiting");
 241 fb1a36c0 2022-01-09 op 	exit(0);
 242 fb1a36c0 2022-01-09 op }
 243 fb1a36c0 2022-01-09 op 
 244 fb1a36c0 2022-01-09 op static void
 245 fb1a36c0 2022-01-09 op client_sig_handler(int sig, short event, void *d)
 246 fb1a36c0 2022-01-09 op {
 247 fb1a36c0 2022-01-09 op 	/*
 248 fb1a36c0 2022-01-09 op 	 * Normal signal handler rules don't apply because libevent
 249 fb1a36c0 2022-01-09 op 	 * decouples for us.
 250 fb1a36c0 2022-01-09 op 	 */
 251 fb1a36c0 2022-01-09 op 
 252 fb1a36c0 2022-01-09 op 	switch (sig) {
 253 fb1a36c0 2022-01-09 op 	case SIGINT:
 254 fb1a36c0 2022-01-09 op 	case SIGTERM:
 255 fb1a36c0 2022-01-09 op 		client_shutdown();
 256 fb1a36c0 2022-01-09 op 	default:
 257 fb1a36c0 2022-01-09 op 		fatalx("unexpected signal %d", sig);
 258 fb1a36c0 2022-01-09 op 	}
 259 fb1a36c0 2022-01-09 op }
 260 fb1a36c0 2022-01-09 op 
 261 fb1a36c0 2022-01-09 op static void
 262 fb1a36c0 2022-01-09 op client_dispatch_listener(int fd, short event, void *d)
 263 fb1a36c0 2022-01-09 op {
 264 1e84c7b7 2022-01-10 op 	static int		 auth = 0;
 265 1e84c7b7 2022-01-10 op 	struct kd_auth_proc	 rauth;
 266 5c69b561 2022-01-29 op 	struct kd_debug_info	 debug;
 267 5c69b561 2022-01-29 op 	struct fid		*f;
 268 fb1a36c0 2022-01-09 op 	struct imsg		 imsg;
 269 fb1a36c0 2022-01-09 op 	struct imsgev		*iev = d;
 270 fb1a36c0 2022-01-09 op 	struct imsgbuf		*ibuf;
 271 fb1a36c0 2022-01-09 op 	ssize_t			 n;
 272 fb1a36c0 2022-01-09 op 	int			 shut = 0;
 273 fb1a36c0 2022-01-09 op 
 274 fb1a36c0 2022-01-09 op 	ibuf = &iev->ibuf;
 275 fb1a36c0 2022-01-09 op 
 276 fb1a36c0 2022-01-09 op 	if (event & EV_READ) {
 277 fb1a36c0 2022-01-09 op 		if ((n = imsg_read(ibuf)) == -1 && errno != EAGAIN)
 278 fb1a36c0 2022-01-09 op 			fatal("imsg_read error");
 279 fb1a36c0 2022-01-09 op 		if (n == 0)	/* Connection closed */
 280 fb1a36c0 2022-01-09 op 			shut = 1;
 281 fb1a36c0 2022-01-09 op 	}
 282 fb1a36c0 2022-01-09 op 	if (event & EV_WRITE) {
 283 fb1a36c0 2022-01-09 op 		if ((n = msgbuf_write(&ibuf->w)) == -1 && errno != EAGAIN)
 284 fb1a36c0 2022-01-09 op 			fatal("msgbuf_write");
 285 fb1a36c0 2022-01-09 op 		if (n == 0)	/* Connection closed */
 286 fb1a36c0 2022-01-09 op 			shut = 1;
 287 fb1a36c0 2022-01-09 op 	}
 288 fb1a36c0 2022-01-09 op 
 289 fb1a36c0 2022-01-09 op 	for (;;) {
 290 fb1a36c0 2022-01-09 op 		if ((n = imsg_get(ibuf, &imsg)) == -1)
 291 fb1a36c0 2022-01-09 op 			fatal("%s: imsg_get error", __func__);
 292 fb1a36c0 2022-01-09 op 		if (n == 0)	/* No more messages. */
 293 fb1a36c0 2022-01-09 op 			break;
 294 fb1a36c0 2022-01-09 op 
 295 fb1a36c0 2022-01-09 op 		switch (imsg.hdr.type) {
 296 982f38dc 2022-01-23 op 		case IMSG_CTL_LOG_VERBOSE:
 297 982f38dc 2022-01-23 op 			if (IMSG_DATA_SIZE(imsg) != sizeof(verbose))
 298 982f38dc 2022-01-23 op 				fatalx("%s: IMSG_CTL_LOG_VERBOSE wrong size",
 299 982f38dc 2022-01-23 op 				    __func__);
 300 982f38dc 2022-01-23 op 			memcpy(&verbose, imsg.data, sizeof(verbose));
 301 982f38dc 2022-01-23 op 			log_setverbose(verbose);
 302 982f38dc 2022-01-23 op 			break;
 303 5c69b561 2022-01-29 op 		case IMSG_CTL_DEBUG:
 304 5c69b561 2022-01-29 op 			STAILQ_FOREACH(f, &fids, entries) {
 305 5c69b561 2022-01-29 op 				memset(&debug, 0, sizeof(debug));
 306 5c69b561 2022-01-29 op 				debug.fid = f->fid;
 307 5c69b561 2022-01-29 op 				strlcpy(debug.path, f->fname,
 308 5c69b561 2022-01-29 op 				    sizeof(debug.path));
 309 5c69b561 2022-01-29 op 				client_send_listenerp(IMSG_CTL_DEBUG_BACK,
 310 5c69b561 2022-01-29 op 				    imsg.hdr.peerid, &debug, sizeof(debug));
 311 5c69b561 2022-01-29 op 			}
 312 5c69b561 2022-01-29 op 			client_send_listenerp(IMSG_CTL_DEBUG_END,
 313 5c69b561 2022-01-29 op 			    imsg.hdr.peerid, NULL, 0);
 314 5c69b561 2022-01-29 op 			break;
 315 fb1a36c0 2022-01-09 op 		case IMSG_AUTH:
 316 fb1a36c0 2022-01-09 op 			peerid = imsg.hdr.peerid;
 317 fb1a36c0 2022-01-09 op 			if (auth)
 318 fb1a36c0 2022-01-09 op 				fatalx("%s: IMSG_AUTH already done", __func__);
 319 1e84c7b7 2022-01-10 op 			auth = 1;
 320 1e84c7b7 2022-01-10 op 
 321 1e84c7b7 2022-01-10 op 			if (IMSG_DATA_SIZE(imsg) != sizeof(rauth))
 322 1e84c7b7 2022-01-10 op 				fatalx("mismatching size for IMSG_AUTH");
 323 1e84c7b7 2022-01-10 op 			memcpy(&rauth, imsg.data, sizeof(rauth));
 324 1e84c7b7 2022-01-10 op 			if (rauth.uname[sizeof(rauth.uname)-1] != '\0' ||
 325 1e84c7b7 2022-01-10 op 			    rauth.dir[sizeof(rauth.dir)-1] != '\0')
 326 1e84c7b7 2022-01-10 op 				fatalx("IMSG_AUTH strings not NUL-terminated");
 327 1e84c7b7 2022-01-10 op 
 328 1e84c7b7 2022-01-10 op 			client_privdrop(rauth.uname, rauth.dir);
 329 1e84c7b7 2022-01-10 op 			explicit_bzero(&rauth, sizeof(rauth));
 330 fb1a36c0 2022-01-09 op 			break;
 331 fb1a36c0 2022-01-09 op 		case IMSG_BUF:
 332 8b0a5062 2022-05-22 op 		case IMSG_BUF_CONT:
 333 fb1a36c0 2022-01-09 op 			if (!auth)
 334 fb1a36c0 2022-01-09 op 				fatalx("%s: can't handle messages before"
 335 fb1a36c0 2022-01-09 op 				    " doing the auth", __func__);
 336 8b0a5062 2022-05-22 op 			handle_message(&imsg, IMSG_DATA_SIZE(imsg),
 337 8b0a5062 2022-05-22 op 			    imsg.hdr.type == IMSG_BUF_CONT);
 338 fb1a36c0 2022-01-09 op 			break;
 339 fb1a36c0 2022-01-09 op 		case IMSG_CONN_GONE:
 340 fb1a36c0 2022-01-09 op 			log_debug("closing");
 341 fb1a36c0 2022-01-09 op 			shut = 1;
 342 fb1a36c0 2022-01-09 op 			break;
 343 fb1a36c0 2022-01-09 op 		default:
 344 fb1a36c0 2022-01-09 op 			log_debug("%s: unexpected imsg %d",
 345 fb1a36c0 2022-01-09 op 			    __func__, imsg.hdr.type);
 346 fb1a36c0 2022-01-09 op 			break;
 347 fb1a36c0 2022-01-09 op 		}
 348 fb1a36c0 2022-01-09 op 		imsg_free(&imsg);
 349 fb1a36c0 2022-01-09 op 	}
 350 fb1a36c0 2022-01-09 op 
 351 fb1a36c0 2022-01-09 op 	if (!shut)
 352 fb1a36c0 2022-01-09 op 		imsg_event_add(iev);
 353 fb1a36c0 2022-01-09 op 	else {
 354 fb1a36c0 2022-01-09 op 		/* This pipe is dead.  Remove its event handler. */
 355 fb1a36c0 2022-01-09 op 		event_del(&iev->ev);
 356 fb1a36c0 2022-01-09 op 		log_debug("pipe closed, shutting down...");
 357 fb1a36c0 2022-01-09 op 		event_loopexit(NULL);
 358 fb1a36c0 2022-01-09 op 	}
 359 fb1a36c0 2022-01-09 op }
 360 fb1a36c0 2022-01-09 op 
 361 fb1a36c0 2022-01-09 op static void
 362 fb1a36c0 2022-01-09 op client_privdrop(const char *username, const char *dir)
 363 fb1a36c0 2022-01-09 op {
 364 fb1a36c0 2022-01-09 op 	struct passwd *pw;
 365 fb1a36c0 2022-01-09 op 
 366 fb1a36c0 2022-01-09 op 	setproctitle("client %s", username);
 367 fb1a36c0 2022-01-09 op 
 368 fb1a36c0 2022-01-09 op 	if ((pw = getpwnam(username)) == NULL)
 369 fb1a36c0 2022-01-09 op 		fatalx("getpwnam(%s) failed", username);
 370 fb1a36c0 2022-01-09 op 
 371 fb1a36c0 2022-01-09 op 	if (chroot(dir) == -1)
 372 fb1a36c0 2022-01-09 op 		fatal("chroot");
 373 fb1a36c0 2022-01-09 op 	if (chdir("/") == -1)
 374 fb1a36c0 2022-01-09 op 		fatal("chdir(\"/\")");
 375 fb1a36c0 2022-01-09 op 
 376 fb1a36c0 2022-01-09 op 	if (setgroups(1, &pw->pw_gid) ||
 377 fb1a36c0 2022-01-09 op 	    setresgid(pw->pw_gid, pw->pw_gid, pw->pw_gid) ||
 378 fb1a36c0 2022-01-09 op 	    setresuid(pw->pw_uid, pw->pw_uid, pw->pw_uid))
 379 fb1a36c0 2022-01-09 op 		fatal("can't drop privileges");
 380 fb1a36c0 2022-01-09 op 
 381 fb1a36c0 2022-01-09 op 	sandbox_client();
 382 fb1a36c0 2022-01-09 op 	log_debug("client ready; user=%s dir=%s", username, dir);
 383 fb1a36c0 2022-01-09 op 
 384 fb1a36c0 2022-01-09 op 	if ((evb = evbuffer_new()) == NULL)
 385 fb1a36c0 2022-01-09 op 		fatal("evbuffer_new");
 386 fb1a36c0 2022-01-09 op }
 387 fb1a36c0 2022-01-09 op 
 388 fb1a36c0 2022-01-09 op static int
 389 5c69b561 2022-01-29 op client_send_listenerp(int type, uint32_t peerid, const void *data, uint16_t len)
 390 fb1a36c0 2022-01-09 op {
 391 fb1a36c0 2022-01-09 op 	int ret;
 392 fb1a36c0 2022-01-09 op 
 393 fb1a36c0 2022-01-09 op 	if ((ret = imsg_compose(&iev_listener->ibuf, type, peerid, 0, -1,
 394 fb1a36c0 2022-01-09 op 	    data, len)) != -1)
 395 fb1a36c0 2022-01-09 op 		imsg_event_add(iev_listener);
 396 fb1a36c0 2022-01-09 op 
 397 fb1a36c0 2022-01-09 op 	return ret;
 398 fb1a36c0 2022-01-09 op }
 399 fb1a36c0 2022-01-09 op 
 400 5c69b561 2022-01-29 op static int
 401 5c69b561 2022-01-29 op client_send_listener(int type, const void *data, uint16_t len)
 402 5c69b561 2022-01-29 op {
 403 865dd323 2022-01-29 op 	return client_send_listenerp(type, peerid, data, len);
 404 5c69b561 2022-01-29 op }
 405 5c69b561 2022-01-29 op 
 406 fb1a36c0 2022-01-09 op /* set qid fields from sb */
 407 fb1a36c0 2022-01-09 op static void
 408 fb1a36c0 2022-01-09 op qid_update_from_sb(struct qid *qid, struct stat *sb)
 409 fb1a36c0 2022-01-09 op {
 410 fb1a36c0 2022-01-09 op 	qid->path = sb->st_ino;
 411 fb1a36c0 2022-01-09 op 
 412 fb1a36c0 2022-01-09 op 	/*
 413 fb1a36c0 2022-01-09 op 	 * Theoretically (and hopefully!) this should be a 64 bit
 414 fb1a36c0 2022-01-09 op 	 * number.  Unfortunately, 9P uses 32 bit timestamps.
 415 fb1a36c0 2022-01-09 op 	 */
 416 fb1a36c0 2022-01-09 op 	qid->vers = sb->st_mtim.tv_sec;
 417 fb1a36c0 2022-01-09 op 
 418 fb1a36c0 2022-01-09 op 	if (S_ISREG(sb->st_mode))
 419 fb1a36c0 2022-01-09 op 		qid->type = QTFILE;
 420 fb1a36c0 2022-01-09 op 	else if (S_ISDIR(sb->st_mode))
 421 fb1a36c0 2022-01-09 op 		qid->type = QTDIR;
 422 fb1a36c0 2022-01-09 op 	else if (S_ISLNK(sb->st_mode))
 423 fb1a36c0 2022-01-09 op 		qid->type = QTSYMLINK;
 424 fb1a36c0 2022-01-09 op }
 425 fb1a36c0 2022-01-09 op 
 426 fb1a36c0 2022-01-09 op /* creates a qid given a fd */
 427 fb1a36c0 2022-01-09 op static struct dir *
 428 fb1a36c0 2022-01-09 op new_dir(int fd)
 429 fb1a36c0 2022-01-09 op {
 430 fb1a36c0 2022-01-09 op 	struct dir	*dir;
 431 fb1a36c0 2022-01-09 op 
 432 fb1a36c0 2022-01-09 op 	if ((dir = calloc(1, sizeof(*dir))) == NULL)
 433 fb1a36c0 2022-01-09 op 		return NULL;
 434 fb1a36c0 2022-01-09 op 
 435 fb1a36c0 2022-01-09 op 	dir->fd = fd;
 436 fb1a36c0 2022-01-09 op 	STAILQ_INSERT_HEAD(&dirs, dir, entries);
 437 fb1a36c0 2022-01-09 op 	return dir;
 438 fb1a36c0 2022-01-09 op }
 439 fb1a36c0 2022-01-09 op 
 440 fb1a36c0 2022-01-09 op static struct dir *
 441 fb1a36c0 2022-01-09 op dir_incref(struct dir *dir)
 442 fb1a36c0 2022-01-09 op {
 443 fb1a36c0 2022-01-09 op 	dir->refcount++;
 444 fb1a36c0 2022-01-09 op 	return dir;
 445 fb1a36c0 2022-01-09 op }
 446 fb1a36c0 2022-01-09 op 
 447 fb1a36c0 2022-01-09 op static void
 448 fb1a36c0 2022-01-09 op dir_decref(struct dir *dir)
 449 fb1a36c0 2022-01-09 op {
 450 fb1a36c0 2022-01-09 op 	if (--dir->refcount > 0)
 451 fb1a36c0 2022-01-09 op 		return;
 452 fb1a36c0 2022-01-09 op 
 453 fb1a36c0 2022-01-09 op 	STAILQ_REMOVE(&dirs, dir, dir, entries);
 454 fb1a36c0 2022-01-09 op 
 455 fb1a36c0 2022-01-09 op 	close(dir->fd);
 456 fb1a36c0 2022-01-09 op 	free(dir);
 457 fb1a36c0 2022-01-09 op }
 458 fb1a36c0 2022-01-09 op 
 459 fb1a36c0 2022-01-09 op static struct fid *
 460 fb1a36c0 2022-01-09 op new_fid(struct dir *dir, uint32_t fid, const char *path, struct qid *qid)
 461 fb1a36c0 2022-01-09 op {
 462 fb1a36c0 2022-01-09 op 	struct fid	*f;
 463 fb1a36c0 2022-01-09 op 	struct qid	 q;
 464 fb1a36c0 2022-01-09 op 	struct stat	sb;
 465 fb1a36c0 2022-01-09 op 
 466 fb1a36c0 2022-01-09 op 	if (qid == NULL) {
 467 fb1a36c0 2022-01-09 op 		if (fstatat(dir->fd, path, &sb, 0)) {
 468 fb1a36c0 2022-01-09 op 			log_warn("fstatat(%s)", path);
 469 fb1a36c0 2022-01-09 op 			return NULL;
 470 fb1a36c0 2022-01-09 op 		}
 471 fb1a36c0 2022-01-09 op 		qid_update_from_sb(&q, &sb);
 472 fb1a36c0 2022-01-09 op 		qid = &q;
 473 fb1a36c0 2022-01-09 op 	}
 474 fb1a36c0 2022-01-09 op 
 475 fb1a36c0 2022-01-09 op 	if ((f = calloc(1, sizeof(*f))) == NULL)
 476 fb1a36c0 2022-01-09 op 		return NULL;
 477 fb1a36c0 2022-01-09 op 
 478 fb1a36c0 2022-01-09 op 	f->dir = dir_incref(dir);
 479 fb1a36c0 2022-01-09 op 	f->fid = fid;
 480 fb1a36c0 2022-01-09 op 	f->fd = -1;
 481 fb1a36c0 2022-01-09 op 
 482 543fc013 2022-01-17 op 	strlcpy(f->fname, path, sizeof(f->fname));
 483 fb1a36c0 2022-01-09 op 
 484 fb1a36c0 2022-01-09 op 	memcpy(&f->qid, qid, sizeof(f->qid));
 485 fb1a36c0 2022-01-09 op 
 486 fb1a36c0 2022-01-09 op 	STAILQ_INSERT_HEAD(&fids, f, entries);
 487 fb1a36c0 2022-01-09 op 
 488 fb1a36c0 2022-01-09 op 	return f;
 489 fb1a36c0 2022-01-09 op }
 490 fb1a36c0 2022-01-09 op 
 491 fb1a36c0 2022-01-09 op static struct fid *
 492 fb1a36c0 2022-01-09 op fid_by_id(uint32_t fid)
 493 fb1a36c0 2022-01-09 op {
 494 fb1a36c0 2022-01-09 op 	struct fid	*f;
 495 fb1a36c0 2022-01-09 op 
 496 fb1a36c0 2022-01-09 op 	STAILQ_FOREACH(f, &fids, entries) {
 497 fb1a36c0 2022-01-09 op 		if (f->fid == fid)
 498 fb1a36c0 2022-01-09 op 			return f;
 499 fb1a36c0 2022-01-09 op 	}
 500 fb1a36c0 2022-01-09 op 
 501 fb1a36c0 2022-01-09 op 	return NULL;
 502 fb1a36c0 2022-01-09 op }
 503 fb1a36c0 2022-01-09 op 
 504 fb1a36c0 2022-01-09 op static void
 505 fb1a36c0 2022-01-09 op free_fid(struct fid *f)
 506 fb1a36c0 2022-01-09 op {
 507 fb1a36c0 2022-01-09 op 	int r;
 508 fb1a36c0 2022-01-09 op 
 509 fb1a36c0 2022-01-09 op 	if (f->fd != -1) {
 510 fb1a36c0 2022-01-09 op 		if (f->d != NULL)
 511 fb1a36c0 2022-01-09 op 			r = closedir(f->d);
 512 fb1a36c0 2022-01-09 op 		else
 513 fb1a36c0 2022-01-09 op 			r = close(f->fd);
 514 fb1a36c0 2022-01-09 op 
 515 fb1a36c0 2022-01-09 op 		if (r == -1)
 516 fb1a36c0 2022-01-09 op 			fatal("can't close fid %d", f->fid);
 517 fb1a36c0 2022-01-09 op 
 518 fb1a36c0 2022-01-09 op 		if (f->evb != NULL)
 519 fb1a36c0 2022-01-09 op 			evbuffer_free(f->evb);
 520 fb1a36c0 2022-01-09 op 
 521 fb1a36c0 2022-01-09 op 		/* try to honour ORCLOSE if requested */
 522 fb1a36c0 2022-01-09 op 		if (f->iomode & O_CLOEXEC)
 523 543fc013 2022-01-17 op 			unlinkat(f->dir->fd, f->fname, 0);
 524 fb1a36c0 2022-01-09 op 	}
 525 fb1a36c0 2022-01-09 op 
 526 fb1a36c0 2022-01-09 op 	dir_decref(f->dir);
 527 fb1a36c0 2022-01-09 op 
 528 fb1a36c0 2022-01-09 op 	STAILQ_REMOVE(&fids, f, fid, entries);
 529 fb1a36c0 2022-01-09 op 	free(f);
 530 fb1a36c0 2022-01-09 op }
 531 fb1a36c0 2022-01-09 op 
 532 fb1a36c0 2022-01-09 op static void
 533 fb1a36c0 2022-01-09 op parse_message(const uint8_t *data, size_t len, struct np_msg_header *hdr,
 534 fb1a36c0 2022-01-09 op     uint8_t **cnt)
 535 fb1a36c0 2022-01-09 op {
 536 fb1a36c0 2022-01-09 op 	size_t olen = len;
 537 fb1a36c0 2022-01-09 op 
 538 fb1a36c0 2022-01-09 op 	if (!NPREAD32("len", &hdr->len, &data, &len) ||
 539 fb1a36c0 2022-01-09 op 	    !NPREAD8("type", &hdr->type, &data, &len) ||
 540 fb1a36c0 2022-01-09 op 	    !NPREAD16("tag", &hdr->tag, &data, &len))
 541 fb1a36c0 2022-01-09 op 		goto err;
 542 fb1a36c0 2022-01-09 op 
 543 fb1a36c0 2022-01-09 op 	if (olen != hdr->len)
 544 fb1a36c0 2022-01-09 op 		goto err;
 545 fb1a36c0 2022-01-09 op 
 546 fb1a36c0 2022-01-09 op 	if (hdr->type < Tversion ||
 547 fb1a36c0 2022-01-09 op 	    hdr->type >= Tmax    ||
 548 fb1a36c0 2022-01-09 op 	    hdr->type == Terror  ||
 549 fb1a36c0 2022-01-09 op 	    (hdr->type & 0x1) != 0) /* cannot recv a R* */
 550 fb1a36c0 2022-01-09 op 		goto err;
 551 fb1a36c0 2022-01-09 op 
 552 fb1a36c0 2022-01-09 op 	hdr->tag = le32toh(hdr->tag);
 553 fb1a36c0 2022-01-09 op 
 554 fb1a36c0 2022-01-09 op 	*cnt = (uint8_t *)data;
 555 fb1a36c0 2022-01-09 op 	return;
 556 fb1a36c0 2022-01-09 op 
 557 fb1a36c0 2022-01-09 op err:
 558 fb1a36c0 2022-01-09 op 	/* TODO: send a proper message to terminate the connection. */
 559 fb1a36c0 2022-01-09 op 	fatalx("got invalid message");
 560 fb1a36c0 2022-01-09 op }
 561 fb1a36c0 2022-01-09 op 
 562 fb1a36c0 2022-01-09 op static void
 563 fb1a36c0 2022-01-09 op np_write16(struct evbuffer *e, uint16_t x)
 564 fb1a36c0 2022-01-09 op {
 565 fb1a36c0 2022-01-09 op 	x = htole16(x);
 566 fb1a36c0 2022-01-09 op 	evbuffer_add(e, &x, sizeof(x));
 567 fb1a36c0 2022-01-09 op }
 568 fb1a36c0 2022-01-09 op 
 569 fb1a36c0 2022-01-09 op static void
 570 fb1a36c0 2022-01-09 op np_write32(struct evbuffer *e, uint32_t x)
 571 fb1a36c0 2022-01-09 op {
 572 fb1a36c0 2022-01-09 op 	x = htole32(x);
 573 fb1a36c0 2022-01-09 op 	evbuffer_add(e, &x, sizeof(x));
 574 fb1a36c0 2022-01-09 op }
 575 fb1a36c0 2022-01-09 op 
 576 fb1a36c0 2022-01-09 op static void
 577 fb1a36c0 2022-01-09 op np_write64(struct evbuffer *e, uint64_t x)
 578 fb1a36c0 2022-01-09 op {
 579 fb1a36c0 2022-01-09 op 	x = htole64(x);
 580 fb1a36c0 2022-01-09 op 	evbuffer_add(e, &x, sizeof(x));
 581 fb1a36c0 2022-01-09 op }
 582 fb1a36c0 2022-01-09 op 
 583 fb1a36c0 2022-01-09 op static void
 584 fb1a36c0 2022-01-09 op np_writebuf(struct evbuffer *e, size_t len, void *data)
 585 fb1a36c0 2022-01-09 op {
 586 fb1a36c0 2022-01-09 op 	evbuffer_add(e, data, len);
 587 fb1a36c0 2022-01-09 op }
 588 fb1a36c0 2022-01-09 op 
 589 fb1a36c0 2022-01-09 op static void
 590 fb1a36c0 2022-01-09 op np_header(uint32_t len, uint8_t type, uint16_t tag)
 591 fb1a36c0 2022-01-09 op {
 592 fb1a36c0 2022-01-09 op 	len += HEADERSIZE;
 593 fb1a36c0 2022-01-09 op 
 594 fb1a36c0 2022-01-09 op 	len = htole32(len);
 595 fb1a36c0 2022-01-09 op 	tag = htole16(tag);
 596 fb1a36c0 2022-01-09 op 
 597 fb1a36c0 2022-01-09 op 	evbuffer_add(evb, &len, sizeof(len));
 598 fb1a36c0 2022-01-09 op 	evbuffer_add(evb, &type, sizeof(type));
 599 fb1a36c0 2022-01-09 op 	evbuffer_add(evb, &tag, sizeof(tag));
 600 fb1a36c0 2022-01-09 op }
 601 fb1a36c0 2022-01-09 op 
 602 fb1a36c0 2022-01-09 op static void
 603 fb1a36c0 2022-01-09 op np_string(struct evbuffer *e, uint16_t len, const char *str)
 604 fb1a36c0 2022-01-09 op {
 605 fb1a36c0 2022-01-09 op 	uint16_t l = len;
 606 fb1a36c0 2022-01-09 op 
 607 fb1a36c0 2022-01-09 op 	len = htole16(len);
 608 fb1a36c0 2022-01-09 op 	evbuffer_add(e, &len, sizeof(len));
 609 fb1a36c0 2022-01-09 op 	evbuffer_add(e, str, l);
 610 fb1a36c0 2022-01-09 op }
 611 fb1a36c0 2022-01-09 op 
 612 fb1a36c0 2022-01-09 op static void
 613 fb1a36c0 2022-01-09 op np_qid(struct evbuffer *e, struct qid *qid)
 614 fb1a36c0 2022-01-09 op {
 615 fb1a36c0 2022-01-09 op 	uint64_t	path;
 616 fb1a36c0 2022-01-09 op 	uint32_t	vers;
 617 fb1a36c0 2022-01-09 op 
 618 fb1a36c0 2022-01-09 op 	path = htole64(qid->path);
 619 fb1a36c0 2022-01-09 op 	vers = htole32(qid->vers);
 620 fb1a36c0 2022-01-09 op 
 621 fb1a36c0 2022-01-09 op 	evbuffer_add(e, &qid->type, sizeof(qid->type));
 622 fb1a36c0 2022-01-09 op 	evbuffer_add(e, &vers, sizeof(vers));
 623 fb1a36c0 2022-01-09 op 	evbuffer_add(e, &path, sizeof(path));
 624 fb1a36c0 2022-01-09 op }
 625 fb1a36c0 2022-01-09 op 
 626 fb1a36c0 2022-01-09 op static void
 627 fb1a36c0 2022-01-09 op do_send(void)
 628 fb1a36c0 2022-01-09 op {
 629 fb1a36c0 2022-01-09 op 	size_t	 len;
 630 fb1a36c0 2022-01-09 op 	void	*data;
 631 fb1a36c0 2022-01-09 op 
 632 fb1a36c0 2022-01-09 op 	len = EVBUFFER_LENGTH(evb);
 633 fb1a36c0 2022-01-09 op 	data = EVBUFFER_DATA(evb);
 634 fb1a36c0 2022-01-09 op 
 635 fb1a36c0 2022-01-09 op #if DEBUG_PACKETS
 636 fb1a36c0 2022-01-09 op 	hexdump("outgoing packet", data, len);
 637 fb1a36c0 2022-01-09 op #endif
 638 fb1a36c0 2022-01-09 op 	client_send_listener(IMSG_BUF, data, len);
 639 fb1a36c0 2022-01-09 op 	evbuffer_drain(evb, len);
 640 fb1a36c0 2022-01-09 op }
 641 fb1a36c0 2022-01-09 op 
 642 fb1a36c0 2022-01-09 op static void
 643 fb1a36c0 2022-01-09 op np_version(uint16_t tag, uint32_t msize, const char *version)
 644 fb1a36c0 2022-01-09 op {
 645 fb1a36c0 2022-01-09 op 	uint16_t l;
 646 fb1a36c0 2022-01-09 op 
 647 fb1a36c0 2022-01-09 op 	l = strlen(version);
 648 fb1a36c0 2022-01-09 op 
 649 fb1a36c0 2022-01-09 op 	msize = htole32(msize);
 650 fb1a36c0 2022-01-09 op 
 651 fb1a36c0 2022-01-09 op 	np_header(sizeof(msize) + sizeof(l) + l, Rversion, tag);
 652 fb1a36c0 2022-01-09 op 	evbuffer_add(evb, &msize, sizeof(msize));
 653 fb1a36c0 2022-01-09 op 	np_string(evb, l, version);
 654 fb1a36c0 2022-01-09 op 	do_send();
 655 fb1a36c0 2022-01-09 op }
 656 fb1a36c0 2022-01-09 op 
 657 fb1a36c0 2022-01-09 op static void
 658 fb1a36c0 2022-01-09 op np_attach(uint16_t tag, struct qid *qid)
 659 fb1a36c0 2022-01-09 op {
 660 fb1a36c0 2022-01-09 op 	np_header(QIDSIZE, Rattach, tag);
 661 fb1a36c0 2022-01-09 op 	np_qid(evb, qid);
 662 fb1a36c0 2022-01-09 op 	do_send();
 663 fb1a36c0 2022-01-09 op }
 664 fb1a36c0 2022-01-09 op 
 665 fb1a36c0 2022-01-09 op static void
 666 fb1a36c0 2022-01-09 op np_clunk(uint16_t tag)
 667 fb1a36c0 2022-01-09 op {
 668 fb1a36c0 2022-01-09 op 	np_header(0, Rclunk, tag);
 669 fb1a36c0 2022-01-09 op 	do_send();
 670 fb1a36c0 2022-01-09 op }
 671 fb1a36c0 2022-01-09 op 
 672 fb1a36c0 2022-01-09 op static void
 673 fb1a36c0 2022-01-09 op np_flush(uint16_t tag)
 674 fb1a36c0 2022-01-09 op {
 675 fb1a36c0 2022-01-09 op 	np_header(0, Rflush, tag);
 676 fb1a36c0 2022-01-09 op 	do_send();
 677 fb1a36c0 2022-01-09 op }
 678 fb1a36c0 2022-01-09 op 
 679 fb1a36c0 2022-01-09 op static void
 680 fb1a36c0 2022-01-09 op np_walk(uint16_t tag, int nwqid, struct qid *wqid)
 681 fb1a36c0 2022-01-09 op {
 682 fb1a36c0 2022-01-09 op 	int i;
 683 fb1a36c0 2022-01-09 op 
 684 fb1a36c0 2022-01-09 op 	/* two bytes for the counter */
 685 fb1a36c0 2022-01-09 op 	np_header(2 + QIDSIZE * nwqid, Rwalk, tag);
 686 fb1a36c0 2022-01-09 op 	np_write16(evb, nwqid);
 687 fb1a36c0 2022-01-09 op 	for (i = 0; i < nwqid; ++i)
 688 fb1a36c0 2022-01-09 op 		np_qid(evb, wqid + i);
 689 fb1a36c0 2022-01-09 op 
 690 fb1a36c0 2022-01-09 op 	do_send();
 691 fb1a36c0 2022-01-09 op }
 692 fb1a36c0 2022-01-09 op 
 693 fb1a36c0 2022-01-09 op static void
 694 fb1a36c0 2022-01-09 op np_open(uint16_t tag, struct qid *qid, uint32_t iounit)
 695 fb1a36c0 2022-01-09 op {
 696 fb1a36c0 2022-01-09 op 	np_header(QIDSIZE + sizeof(iounit), Ropen, tag);
 697 fb1a36c0 2022-01-09 op 	np_qid(evb, qid);
 698 fb1a36c0 2022-01-09 op 	np_write32(evb, iounit);
 699 fb1a36c0 2022-01-09 op 	do_send();
 700 fb1a36c0 2022-01-09 op }
 701 fb1a36c0 2022-01-09 op 
 702 fb1a36c0 2022-01-09 op static void
 703 fb1a36c0 2022-01-09 op np_create(uint16_t tag, struct qid *qid, uint32_t iounit)
 704 fb1a36c0 2022-01-09 op {
 705 fb1a36c0 2022-01-09 op 	np_header(QIDSIZE + sizeof(iounit), Rcreate, tag);
 706 fb1a36c0 2022-01-09 op 	np_qid(evb, qid);
 707 fb1a36c0 2022-01-09 op 	np_write32(evb, iounit);
 708 fb1a36c0 2022-01-09 op 	do_send();
 709 fb1a36c0 2022-01-09 op }
 710 fb1a36c0 2022-01-09 op 
 711 fb1a36c0 2022-01-09 op static void
 712 fb1a36c0 2022-01-09 op np_read(uint16_t tag, uint32_t count, void *data)
 713 fb1a36c0 2022-01-09 op {
 714 fb1a36c0 2022-01-09 op 	if (sizeof(count) + count + HEADERSIZE >= msize) {
 715 fb1a36c0 2022-01-09 op 		np_error(tag, "Rread would overflow");
 716 fb1a36c0 2022-01-09 op 		return;
 717 fb1a36c0 2022-01-09 op 	}
 718 fb1a36c0 2022-01-09 op 
 719 fb1a36c0 2022-01-09 op 	np_header(sizeof(count) + count, Rread, tag);
 720 fb1a36c0 2022-01-09 op 	np_write32(evb, count);
 721 fb1a36c0 2022-01-09 op 	np_writebuf(evb, count, data);
 722 fb1a36c0 2022-01-09 op 	do_send();
 723 fb1a36c0 2022-01-09 op }
 724 fb1a36c0 2022-01-09 op 
 725 fb1a36c0 2022-01-09 op static void
 726 fb1a36c0 2022-01-09 op np_write(uint16_t tag, uint32_t count)
 727 fb1a36c0 2022-01-09 op {
 728 fb1a36c0 2022-01-09 op 	np_header(sizeof(count), Rwrite, tag);
 729 fb1a36c0 2022-01-09 op 	np_write32(evb, count);
 730 fb1a36c0 2022-01-09 op 	do_send();
 731 fb1a36c0 2022-01-09 op }
 732 fb1a36c0 2022-01-09 op 
 733 fb1a36c0 2022-01-09 op static void
 734 70540bb5 2022-02-02 op np_stat(uint16_t tag, uint16_t count, void *data)
 735 fb1a36c0 2022-01-09 op {
 736 fb1a36c0 2022-01-09 op 	if (sizeof(count) + count + HEADERSIZE >= msize) {
 737 fb1a36c0 2022-01-09 op 		np_error(tag, "Rstat would overflow");
 738 fb1a36c0 2022-01-09 op 		return;
 739 fb1a36c0 2022-01-09 op 	}
 740 fb1a36c0 2022-01-09 op 
 741 70540bb5 2022-02-02 op 	np_header(sizeof(count) + count, Rstat, tag);
 742 70540bb5 2022-02-02 op 	np_write16(evb, count);
 743 fb1a36c0 2022-01-09 op 	np_writebuf(evb, count, data);
 744 755d75bf 2022-01-17 op 	do_send();
 745 755d75bf 2022-01-17 op }
 746 755d75bf 2022-01-17 op 
 747 755d75bf 2022-01-17 op static void
 748 755d75bf 2022-01-17 op np_wstat(uint16_t tag)
 749 755d75bf 2022-01-17 op {
 750 755d75bf 2022-01-17 op 	np_header(0, Rwstat, tag);
 751 fb1a36c0 2022-01-09 op 	do_send();
 752 fb1a36c0 2022-01-09 op }
 753 fb1a36c0 2022-01-09 op 
 754 fb1a36c0 2022-01-09 op static void
 755 fb1a36c0 2022-01-09 op np_remove(uint16_t tag)
 756 fb1a36c0 2022-01-09 op {
 757 fb1a36c0 2022-01-09 op 	np_header(0, Rremove, tag);
 758 fb1a36c0 2022-01-09 op 	do_send();
 759 fb1a36c0 2022-01-09 op }
 760 fb1a36c0 2022-01-09 op 
 761 fb1a36c0 2022-01-09 op static void
 762 fb1a36c0 2022-01-09 op np_error(uint16_t tag, const char *errstr)
 763 fb1a36c0 2022-01-09 op {
 764 fb1a36c0 2022-01-09 op 	uint16_t l;
 765 fb1a36c0 2022-01-09 op 
 766 fb1a36c0 2022-01-09 op 	l = strlen(errstr);
 767 fb1a36c0 2022-01-09 op 
 768 fb1a36c0 2022-01-09 op 	np_header(sizeof(l) + l, Rerror, tag);
 769 fb1a36c0 2022-01-09 op 	np_string(evb, l, errstr);
 770 fb1a36c0 2022-01-09 op 	do_send();
 771 fb1a36c0 2022-01-09 op }
 772 fb1a36c0 2022-01-09 op 
 773 fb1a36c0 2022-01-09 op static void
 774 fb1a36c0 2022-01-09 op np_errno(uint16_t tag)
 775 fb1a36c0 2022-01-09 op {
 776 fb1a36c0 2022-01-09 op 	int saved_errno;
 777 fb1a36c0 2022-01-09 op 	char buf[NL_TEXTMAX] = {0};
 778 fb1a36c0 2022-01-09 op 
 779 fb1a36c0 2022-01-09 op 	saved_errno = errno;
 780 fb1a36c0 2022-01-09 op 
 781 fb1a36c0 2022-01-09 op 	strerror_r(errno, buf, sizeof(buf));
 782 fb1a36c0 2022-01-09 op 	np_error(tag, buf);
 783 fb1a36c0 2022-01-09 op 
 784 fb1a36c0 2022-01-09 op 	errno = saved_errno;
 785 fb1a36c0 2022-01-09 op }
 786 fb1a36c0 2022-01-09 op 
 787 fb1a36c0 2022-01-09 op static int
 788 fb1a36c0 2022-01-09 op np_read8(const char *t, const char *f, uint8_t *dst, const uint8_t **src,
 789 fb1a36c0 2022-01-09 op     size_t *len)
 790 fb1a36c0 2022-01-09 op {
 791 fb1a36c0 2022-01-09 op 	if (*len < sizeof(*dst)) {
 792 fb1a36c0 2022-01-09 op 		log_warnx("%s: wanted %zu bytes for the %s field but only "
 793 fb1a36c0 2022-01-09 op 		    "%zu are available.", t, sizeof(*dst), f, *len);
 794 ae6f257a 2022-01-19 op 		return 0;
 795 fb1a36c0 2022-01-09 op 	}
 796 fb1a36c0 2022-01-09 op 
 797 fb1a36c0 2022-01-09 op 	memcpy(dst, *src, sizeof(*dst));
 798 fb1a36c0 2022-01-09 op 	*src += sizeof(*dst);
 799 fb1a36c0 2022-01-09 op 	*len -= sizeof(*dst);
 800 fb1a36c0 2022-01-09 op 
 801 fb1a36c0 2022-01-09 op 	return 1;
 802 fb1a36c0 2022-01-09 op }
 803 fb1a36c0 2022-01-09 op 
 804 fb1a36c0 2022-01-09 op static int
 805 fb1a36c0 2022-01-09 op np_read16(const char *t, const char *f, uint16_t *dst, const uint8_t **src,
 806 fb1a36c0 2022-01-09 op     size_t *len)
 807 fb1a36c0 2022-01-09 op {
 808 fb1a36c0 2022-01-09 op 	if (*len < sizeof(*dst)) {
 809 fb1a36c0 2022-01-09 op 		log_warnx("%s: wanted %zu bytes for the %s field but only "
 810 fb1a36c0 2022-01-09 op 		    "%zu are available.", t, sizeof(*dst), f, *len);
 811 ae6f257a 2022-01-19 op 		return 0;
 812 fb1a36c0 2022-01-09 op 	}
 813 fb1a36c0 2022-01-09 op 
 814 fb1a36c0 2022-01-09 op 	memcpy(dst, *src, sizeof(*dst));
 815 fb1a36c0 2022-01-09 op 	*src += sizeof(*dst);
 816 fb1a36c0 2022-01-09 op 	*len -= sizeof(*dst);
 817 fb1a36c0 2022-01-09 op 	*dst = le16toh(*dst);
 818 fb1a36c0 2022-01-09 op 
 819 fb1a36c0 2022-01-09 op 	return 1;
 820 fb1a36c0 2022-01-09 op }
 821 fb1a36c0 2022-01-09 op 
 822 fb1a36c0 2022-01-09 op static int
 823 fb1a36c0 2022-01-09 op np_read32(const char *t, const char *f, uint32_t *dst, const uint8_t **src,
 824 fb1a36c0 2022-01-09 op     size_t *len)
 825 fb1a36c0 2022-01-09 op {
 826 fb1a36c0 2022-01-09 op 	if (*len < sizeof(*dst)) {
 827 fb1a36c0 2022-01-09 op 		log_warnx("%s: wanted %zu bytes for the %s field but only "
 828 fb1a36c0 2022-01-09 op 		    "%zu are available.", t, sizeof(*dst), f, *len);
 829 ae6f257a 2022-01-19 op 		return 0;
 830 fb1a36c0 2022-01-09 op 	}
 831 fb1a36c0 2022-01-09 op 
 832 fb1a36c0 2022-01-09 op 	memcpy(dst, *src, sizeof(*dst));
 833 fb1a36c0 2022-01-09 op 	*src += sizeof(*dst);
 834 fb1a36c0 2022-01-09 op 	*len -= sizeof(*dst);
 835 fb1a36c0 2022-01-09 op 	*dst = le32toh(*dst);
 836 fb1a36c0 2022-01-09 op 
 837 fb1a36c0 2022-01-09 op 	return 1;
 838 fb1a36c0 2022-01-09 op }
 839 fb1a36c0 2022-01-09 op 
 840 fb1a36c0 2022-01-09 op static int
 841 fb1a36c0 2022-01-09 op np_read64(const char *t, const char *f, uint64_t *dst, const uint8_t **src,
 842 fb1a36c0 2022-01-09 op     size_t *len)
 843 fb1a36c0 2022-01-09 op {
 844 fb1a36c0 2022-01-09 op 	if (*len < sizeof(*dst)) {
 845 fb1a36c0 2022-01-09 op 		log_warnx("%s: wanted %zu bytes for the %s field but only "
 846 fb1a36c0 2022-01-09 op 		    "%zu are available.", t, sizeof(*dst), f, *len);
 847 ae6f257a 2022-01-19 op 		return 0;
 848 fb1a36c0 2022-01-09 op 	}
 849 fb1a36c0 2022-01-09 op 
 850 fb1a36c0 2022-01-09 op 	memcpy(dst, *src, sizeof(*dst));
 851 fb1a36c0 2022-01-09 op 	*src += sizeof(*dst);
 852 fb1a36c0 2022-01-09 op 	*len -= sizeof(*dst);
 853 fb1a36c0 2022-01-09 op 	*dst = le64toh(*dst);
 854 fb1a36c0 2022-01-09 op 
 855 fb1a36c0 2022-01-09 op 	return 1;
 856 fb1a36c0 2022-01-09 op }
 857 fb1a36c0 2022-01-09 op 
 858 fb1a36c0 2022-01-09 op static int
 859 fb1a36c0 2022-01-09 op np_readstr(const char *t, const char *f, char *res, size_t reslen,
 860 fb1a36c0 2022-01-09 op     const uint8_t **src, size_t *len)
 861 fb1a36c0 2022-01-09 op {
 862 fb1a36c0 2022-01-09 op 	uint16_t	sl;
 863 fb1a36c0 2022-01-09 op 	char		buf[32];
 864 fb1a36c0 2022-01-09 op 
 865 fb1a36c0 2022-01-09 op 	strlcpy(buf, f, sizeof(buf));
 866 fb1a36c0 2022-01-09 op 	strlcat(buf, "-len", sizeof(buf));
 867 fb1a36c0 2022-01-09 op 
 868 fb1a36c0 2022-01-09 op 	if (!np_read16(t, buf, &sl, src, len))
 869 fb1a36c0 2022-01-09 op 		return READSTRERR;
 870 fb1a36c0 2022-01-09 op 
 871 fb1a36c0 2022-01-09 op 	if (*len < sl) {
 872 fb1a36c0 2022-01-09 op 		log_warnx("%s: wanted %d bytes for the %s field but only "
 873 fb1a36c0 2022-01-09 op 		    "%zu are available.", t, sl, f, *len);
 874 fb1a36c0 2022-01-09 op 		return READSTRERR;
 875 fb1a36c0 2022-01-09 op 	}
 876 fb1a36c0 2022-01-09 op 
 877 fb1a36c0 2022-01-09 op 	if (*len > reslen-1)
 878 fb1a36c0 2022-01-09 op 		return READSTRTRUNC;
 879 fb1a36c0 2022-01-09 op 
 880 fb1a36c0 2022-01-09 op 	memcpy(res, *src, sl);
 881 fb1a36c0 2022-01-09 op 	res[sl] = '\0';
 882 fb1a36c0 2022-01-09 op 	*src += sl;
 883 fb1a36c0 2022-01-09 op 	*len -= sl;
 884 fb1a36c0 2022-01-09 op 
 885 fb1a36c0 2022-01-09 op 	return 0;
 886 755d75bf 2022-01-17 op }
 887 755d75bf 2022-01-17 op 
 888 755d75bf 2022-01-17 op static int
 889 755d75bf 2022-01-17 op np_readst(const char *t, const char *f, struct np_stat *st,
 890 755d75bf 2022-01-17 op     char *name, size_t namelen, const uint8_t **src, size_t *len)
 891 755d75bf 2022-01-17 op {
 892 755d75bf 2022-01-17 op 	memset(st, 0, sizeof(*st));
 893 755d75bf 2022-01-17 op 
 894 4e7aba8f 2022-02-02 op 	/* len is sent twice! */
 895 4e7aba8f 2022-02-02 op 	if (!np_read16(t, "stat len", &st->size, src, len) ||
 896 4e7aba8f 2022-02-02 op 	    !np_read16(t, "stat.size", &st->size, src, len) ||
 897 9029ac6f 2022-01-19 op 	    !np_read16(t, "stat.type", &st->type, src, len) ||
 898 755d75bf 2022-01-17 op 	    !np_read32(t, "stat.dev", &st->dev, src, len) ||
 899 755d75bf 2022-01-17 op 	    !np_read64(t, "stat.qid.path", &st->qid.path, src, len) ||
 900 755d75bf 2022-01-17 op 	    !np_read32(t, "stat.qid.vers", &st->qid.vers, src, len) ||
 901 755d75bf 2022-01-17 op 	    !np_read8(t, "stat.qid.type", &st->qid.type, src, len) ||
 902 755d75bf 2022-01-17 op 	    !np_read32(t, "stat.mode", &st->mode, src, len) ||
 903 755d75bf 2022-01-17 op 	    !np_read32(t, "stat.atime", &st->atime, src, len) ||
 904 755d75bf 2022-01-17 op 	    !np_read32(t, "stat.mtime", &st->mtime, src, len) ||
 905 755d75bf 2022-01-17 op 	    !np_read64(t, "stat.length", &st->length, src, len))
 906 755d75bf 2022-01-17 op 		return READSTRERR;
 907 755d75bf 2022-01-17 op 
 908 755d75bf 2022-01-17 op 	/*
 909 755d75bf 2022-01-17 op 	 * ignore everything but the name, we don't support
 910 755d75bf 2022-01-17 op 	 * changing those fields anyway
 911 755d75bf 2022-01-17 op 	 */
 912 755d75bf 2022-01-17 op 	st->name = name;
 913 755d75bf 2022-01-17 op 	return np_readstr(t, "stat.name", name, namelen, src, len);
 914 fb1a36c0 2022-01-09 op }
 915 fb1a36c0 2022-01-09 op 
 916 fb1a36c0 2022-01-09 op static void
 917 fb1a36c0 2022-01-09 op tversion(struct np_msg_header *hdr, const uint8_t *data, size_t len)
 918 fb1a36c0 2022-01-09 op {
 919 fb1a36c0 2022-01-09 op 	char *dot, version[32];
 920 fb1a36c0 2022-01-09 op 
 921 fb1a36c0 2022-01-09 op 	if (handshaked)
 922 fb1a36c0 2022-01-09 op 		goto err;
 923 fb1a36c0 2022-01-09 op 
 924 fb1a36c0 2022-01-09 op 	/* msize[4] version[s] */
 925 fb1a36c0 2022-01-09 op 	if (!NPREAD32("msize", &msize, &data, &len))
 926 fb1a36c0 2022-01-09 op 		goto err;
 927 fb1a36c0 2022-01-09 op 
 928 fb1a36c0 2022-01-09 op 	switch (NPREADSTR("version", version, sizeof(version), &data, &len)) {
 929 fb1a36c0 2022-01-09 op 	case READSTRERR:
 930 fb1a36c0 2022-01-09 op 		goto err;
 931 fb1a36c0 2022-01-09 op 	case READSTRTRUNC:
 932 fb1a36c0 2022-01-09 op 		log_warnx("9P version string too long, truncated");
 933 6be59daa 2022-05-22 op 		np_version(hdr->tag, MSIZE9P, "unknown");
 934 6be59daa 2022-05-22 op 		return;
 935 fb1a36c0 2022-01-09 op 	}
 936 fb1a36c0 2022-01-09 op 
 937 bcdb46a7 2022-01-19 op 	if (len != 0)
 938 bcdb46a7 2022-01-19 op 		goto err;
 939 bcdb46a7 2022-01-19 op 
 940 fb1a36c0 2022-01-09 op 	if ((dot = strchr(version, '.')) != NULL)
 941 fb1a36c0 2022-01-09 op 		*dot = '\0';
 942 fb1a36c0 2022-01-09 op 
 943 6be59daa 2022-05-22 op 	if (strcmp(version, VERSION9P) != 0) {
 944 6be59daa 2022-05-22 op 		log_warnx("unknown 9P version \"%s\"; want "VERSION9P,
 945 6be59daa 2022-05-22 op 		    version);
 946 6be59daa 2022-05-22 op 		np_version(hdr->tag, MSIZE9P, "unknown");
 947 6be59daa 2022-05-22 op 		return;
 948 6be59daa 2022-05-22 op 	}
 949 6be59daa 2022-05-22 op 
 950 6be59daa 2022-05-22 op 	if (msize < MIN_MSIZE) {
 951 6be59daa 2022-05-22 op 		log_warnx("msize too small: %"PRIu32"; want %d at least",
 952 6be59daa 2022-05-22 op 		    msize, MIN_MSIZE);
 953 6be59daa 2022-05-22 op 		np_version(hdr->tag, MSIZE9P, "unknown");
 954 6be59daa 2022-05-22 op 		return;
 955 6be59daa 2022-05-22 op 	}
 956 fb1a36c0 2022-01-09 op 
 957 fb1a36c0 2022-01-09 op 	/* version matched */
 958 fb1a36c0 2022-01-09 op 	handshaked = 1;
 959 8b0a5062 2022-05-22 op 	msize = MIN(msize, MSIZE9P);
 960 fb1a36c0 2022-01-09 op 	client_send_listener(IMSG_MSIZE, &msize, sizeof(msize));
 961 fb1a36c0 2022-01-09 op 	np_version(hdr->tag, msize, VERSION9P);
 962 fb1a36c0 2022-01-09 op 	return;
 963 fb1a36c0 2022-01-09 op 
 964 fb1a36c0 2022-01-09 op err:
 965 fb1a36c0 2022-01-09 op 	client_send_listener(IMSG_CLOSE, NULL, 0);
 966 fb1a36c0 2022-01-09 op 	client_shutdown();
 967 fb1a36c0 2022-01-09 op }
 968 fb1a36c0 2022-01-09 op 
 969 fb1a36c0 2022-01-09 op static void
 970 fb1a36c0 2022-01-09 op tattach(struct np_msg_header *hdr, const uint8_t *data, size_t len)
 971 fb1a36c0 2022-01-09 op {
 972 fb1a36c0 2022-01-09 op 	struct dir	*dir;
 973 fb1a36c0 2022-01-09 op 	struct fid	*f;
 974 fb1a36c0 2022-01-09 op 	uint32_t	 fid, afid;
 975 fb1a36c0 2022-01-09 op 	int		 fd;
 976 fb1a36c0 2022-01-09 op 	char		 aname[PATH_MAX];
 977 fb1a36c0 2022-01-09 op 
 978 fb1a36c0 2022-01-09 op 	/* fid[4] afid[4] uname[s] aname[s] */
 979 fb1a36c0 2022-01-09 op 
 980 fb1a36c0 2022-01-09 op 	if (!NPREAD32("fid", &fid, &data, &len) ||
 981 fb1a36c0 2022-01-09 op 	    !NPREAD32("afid", &afid, &data, &len))
 982 fb1a36c0 2022-01-09 op 		goto err;
 983 fb1a36c0 2022-01-09 op 
 984 fb1a36c0 2022-01-09 op 	/* read the uname but don't actually use it */
 985 fb1a36c0 2022-01-09 op 	switch (NPREADSTR("uname", aname, sizeof(aname), &data, &len)) {
 986 fb1a36c0 2022-01-09 op 	case READSTRERR:
 987 fb1a36c0 2022-01-09 op 		goto err;
 988 fb1a36c0 2022-01-09 op 	case READSTRTRUNC:
 989 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "name too long");
 990 fb1a36c0 2022-01-09 op 		return;
 991 fb1a36c0 2022-01-09 op 	}
 992 fb1a36c0 2022-01-09 op 
 993 fb1a36c0 2022-01-09 op 	switch (NPREADSTR("aname", aname, sizeof(aname), &data, &len)) {
 994 fb1a36c0 2022-01-09 op 	case READSTRERR:
 995 fb1a36c0 2022-01-09 op 		goto err;
 996 fb1a36c0 2022-01-09 op 	case READSTRTRUNC:
 997 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "name too long");
 998 fb1a36c0 2022-01-09 op 		return;
 999 fb1a36c0 2022-01-09 op 	}
1000 fb1a36c0 2022-01-09 op 
1001 73df5ca2 2022-02-02 op 	if (*aname == '\0')
1002 73df5ca2 2022-02-02 op 		strlcpy(aname, "/", sizeof(aname));
1003 73df5ca2 2022-02-02 op 
1004 bcdb46a7 2022-01-19 op 	if (len != 0)
1005 bcdb46a7 2022-01-19 op 		goto err;
1006 bcdb46a7 2022-01-19 op 
1007 fb1a36c0 2022-01-09 op 	if (fid_by_id(fid) != NULL || afid != NOFID) {
1008 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid fid or afid");
1009 fb1a36c0 2022-01-09 op 		return;
1010 fb1a36c0 2022-01-09 op 	}
1011 fb1a36c0 2022-01-09 op 
1012 fb1a36c0 2022-01-09 op 	if ((fd = open(aname, O_RDONLY|O_DIRECTORY)) == -1)
1013 fb1a36c0 2022-01-09 op 		goto fail;
1014 fb1a36c0 2022-01-09 op 
1015 fb1a36c0 2022-01-09 op 	if ((dir = new_dir(fd)) == NULL)
1016 fb1a36c0 2022-01-09 op 		goto fail;
1017 fb1a36c0 2022-01-09 op 
1018 fb1a36c0 2022-01-09 op 	log_debug("attached %s to %d", aname, fid);
1019 fb1a36c0 2022-01-09 op 
1020 fb1a36c0 2022-01-09 op 	if ((f = new_fid(dir, fid, aname, NULL)) == NULL) {
1021 fb1a36c0 2022-01-09 op 		dir_decref(dir);
1022 fb1a36c0 2022-01-09 op 		goto fail;
1023 fb1a36c0 2022-01-09 op 	}
1024 fb1a36c0 2022-01-09 op 
1025 fb1a36c0 2022-01-09 op 	np_attach(hdr->tag, &f->qid);
1026 fb1a36c0 2022-01-09 op 	return;
1027 fb1a36c0 2022-01-09 op 
1028 fb1a36c0 2022-01-09 op fail:
1029 fb1a36c0 2022-01-09 op 	np_errno(hdr->tag);
1030 fb1a36c0 2022-01-09 op 	log_warn("failed to attach %s", aname);
1031 fb1a36c0 2022-01-09 op 	return;
1032 fb1a36c0 2022-01-09 op 
1033 fb1a36c0 2022-01-09 op err:
1034 fb1a36c0 2022-01-09 op 	client_send_listener(IMSG_CLOSE, NULL, 0);
1035 fb1a36c0 2022-01-09 op 	client_shutdown();
1036 fb1a36c0 2022-01-09 op }
1037 fb1a36c0 2022-01-09 op 
1038 fb1a36c0 2022-01-09 op static void
1039 fb1a36c0 2022-01-09 op tclunk(struct np_msg_header *hdr, const uint8_t *data, size_t len)
1040 fb1a36c0 2022-01-09 op {
1041 fb1a36c0 2022-01-09 op 	struct fid	*f;
1042 fb1a36c0 2022-01-09 op 	uint32_t	 fid;
1043 fb1a36c0 2022-01-09 op 
1044 fb1a36c0 2022-01-09 op 	/* fid[4] */
1045 bcdb46a7 2022-01-19 op 	if (!NPREAD32("fid", &fid, &data, &len) ||
1046 bcdb46a7 2022-01-19 op 	    len != 0) {
1047 fb1a36c0 2022-01-09 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1048 fb1a36c0 2022-01-09 op 		client_shutdown();
1049 fb1a36c0 2022-01-09 op 		return;
1050 fb1a36c0 2022-01-09 op 	}
1051 fb1a36c0 2022-01-09 op 
1052 fb1a36c0 2022-01-09 op 	if ((f = fid_by_id(fid)) == NULL) {
1053 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid fid");
1054 fb1a36c0 2022-01-09 op 		return;
1055 fb1a36c0 2022-01-09 op 	}
1056 fb1a36c0 2022-01-09 op 
1057 fb1a36c0 2022-01-09 op 	free_fid(f);
1058 fb1a36c0 2022-01-09 op 	np_clunk(hdr->tag);
1059 fb1a36c0 2022-01-09 op }
1060 fb1a36c0 2022-01-09 op 
1061 fb1a36c0 2022-01-09 op static void
1062 fb1a36c0 2022-01-09 op tflush(struct np_msg_header *hdr, const uint8_t *data, size_t len)
1063 fb1a36c0 2022-01-09 op {
1064 fb1a36c0 2022-01-09 op 	uint16_t	oldtag;
1065 fb1a36c0 2022-01-09 op 
1066 fb1a36c0 2022-01-09 op 	/*
1067 fb1a36c0 2022-01-09 op 	 * We're doing only synchronous I/O.  Tflush is implemented
1068 fb1a36c0 2022-01-09 op 	 * only because it's illegal to reply with a Rerror.
1069 fb1a36c0 2022-01-09 op 	 */
1070 fb1a36c0 2022-01-09 op 
1071 fb1a36c0 2022-01-09 op 	/* oldtag[2] */
1072 fb1a36c0 2022-01-09 op 	if (len != sizeof(oldtag)) {
1073 fb1a36c0 2022-01-09 op 		log_warnx("Tflush with the wrong size: got %zu want %zu",
1074 fb1a36c0 2022-01-09 op 		    len, sizeof(oldtag));
1075 fb1a36c0 2022-01-09 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1076 fb1a36c0 2022-01-09 op 		client_shutdown();
1077 fb1a36c0 2022-01-09 op 		return;
1078 fb1a36c0 2022-01-09 op 	}
1079 fb1a36c0 2022-01-09 op 
1080 fb1a36c0 2022-01-09 op 	np_flush(hdr->tag);
1081 fb1a36c0 2022-01-09 op }
1082 fb1a36c0 2022-01-09 op 
1083 fb1a36c0 2022-01-09 op static void
1084 fb1a36c0 2022-01-09 op twalk(struct np_msg_header *hdr, const uint8_t *data, size_t len)
1085 fb1a36c0 2022-01-09 op {
1086 fb1a36c0 2022-01-09 op 	struct stat	 sb;
1087 fb1a36c0 2022-01-09 op 	struct dir	*dir;
1088 fb1a36c0 2022-01-09 op 	struct qid	 wqid[MAXWELEM] = {0};
1089 fb1a36c0 2022-01-09 op 	struct fid	*f, *nf;
1090 fb1a36c0 2022-01-09 op 	uint32_t	 fid, newfid;
1091 fb1a36c0 2022-01-09 op 	uint16_t	 nwname;
1092 fb1a36c0 2022-01-09 op 	int		 fd, oldfd, no, nwqid = 0;
1093 fb1a36c0 2022-01-09 op 	char		 wnam[PATH_MAX];
1094 fb1a36c0 2022-01-09 op 
1095 fb1a36c0 2022-01-09 op 	if (!NPREAD32("fid", &fid, &data, &len)       ||
1096 fb1a36c0 2022-01-09 op 	    !NPREAD32("newfid", &newfid, &data, &len) ||
1097 fb1a36c0 2022-01-09 op 	    !NPREAD16("nwname", &nwname, &data, &len))
1098 fb1a36c0 2022-01-09 op 		goto err;
1099 fb1a36c0 2022-01-09 op 
1100 fb1a36c0 2022-01-09 op 	if (nwname > MAXWELEM) {
1101 fb1a36c0 2022-01-09 op 		log_warnx("Twalk: more than %d path elements: %d",
1102 fb1a36c0 2022-01-09 op 		    MAXWELEM, nwname);
1103 fb1a36c0 2022-01-09 op 		goto err;
1104 fb1a36c0 2022-01-09 op 	}
1105 fb1a36c0 2022-01-09 op 
1106 fb1a36c0 2022-01-09 op 	if ((f = fid_by_id(fid)) == NULL) {
1107 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid fid");
1108 fb1a36c0 2022-01-09 op 		return;
1109 fb1a36c0 2022-01-09 op 	}
1110 fb1a36c0 2022-01-09 op 
1111 fb1a36c0 2022-01-09 op 	if (f->fd != -1) {
1112 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "fid already opened for I/O");
1113 fb1a36c0 2022-01-09 op 		return;
1114 fb1a36c0 2022-01-09 op 	}
1115 fb1a36c0 2022-01-09 op 
1116 fb1a36c0 2022-01-09 op 	if (fid == newfid)
1117 fb1a36c0 2022-01-09 op 		nf = f;
1118 fb1a36c0 2022-01-09 op 	else if ((nf = fid_by_id(newfid)) != NULL) {
1119 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "newfid already in use");
1120 fb1a36c0 2022-01-09 op 		return;
1121 fb1a36c0 2022-01-09 op 	} else
1122 fb1a36c0 2022-01-09 op 		nf = NULL;
1123 fb1a36c0 2022-01-09 op 
1124 fb1a36c0 2022-01-09 op 	/* special case: fid duplication */
1125 fb1a36c0 2022-01-09 op 	if (nwname == 0) {
1126 fb1a36c0 2022-01-09 op 		/*
1127 fb1a36c0 2022-01-09 op 		 * TODO: should we forbid fids duplication when fid ==
1128 fb1a36c0 2022-01-09 op 		 * newfid?
1129 fb1a36c0 2022-01-09 op 		 */
1130 fb1a36c0 2022-01-09 op 		if (nf == NULL &&
1131 543fc013 2022-01-17 op 		    (nf = new_fid(f->dir, newfid, f->fname, &f->qid)) == NULL)
1132 fb1a36c0 2022-01-09 op 			fatal("new_fid duplication");
1133 fb1a36c0 2022-01-09 op 
1134 fb1a36c0 2022-01-09 op 		np_walk(hdr->tag, 0, NULL);
1135 fb1a36c0 2022-01-09 op 		return;
1136 fb1a36c0 2022-01-09 op 	}
1137 fb1a36c0 2022-01-09 op 
1138 fb1a36c0 2022-01-09 op 	if (!(f->qid.type & QTDIR)) {
1139 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "fid doesn't represent a directory");
1140 fb1a36c0 2022-01-09 op 		return;
1141 fb1a36c0 2022-01-09 op 	}
1142 fb1a36c0 2022-01-09 op 
1143 fb1a36c0 2022-01-09 op 	oldfd = f->dir->fd;
1144 fb1a36c0 2022-01-09 op 
1145 fb1a36c0 2022-01-09 op 	for (nwqid = 0; nwqid < nwname; nwqid++) {
1146 fb1a36c0 2022-01-09 op 		switch (NPREADSTR("wname", wnam, sizeof(wnam), &data, &len)) {
1147 fb1a36c0 2022-01-09 op 		case READSTRERR:
1148 fb1a36c0 2022-01-09 op 			goto err;
1149 fb1a36c0 2022-01-09 op 		case READSTRTRUNC:
1150 fb1a36c0 2022-01-09 op 			np_error(hdr->tag, "wname too long");
1151 fb1a36c0 2022-01-09 op 			return;
1152 fb1a36c0 2022-01-09 op 		}
1153 fb1a36c0 2022-01-09 op 
1154 fb1a36c0 2022-01-09 op 		if (*wnam == '\0' ||
1155 fb1a36c0 2022-01-09 op 		    strchr(wnam, '/') != NULL ||
1156 fb1a36c0 2022-01-09 op 		    !strcmp(wnam, ".")) {
1157 fb1a36c0 2022-01-09 op 			errno = EINVAL;
1158 fb1a36c0 2022-01-09 op 			goto cantopen;
1159 fb1a36c0 2022-01-09 op 		}
1160 fb1a36c0 2022-01-09 op 
1161 fb1a36c0 2022-01-09 op 		if ((fd = openat(oldfd, wnam, O_RDONLY|O_DIRECTORY)) == -1 &&
1162 fb1a36c0 2022-01-09 op 		    errno != ENOTDIR)
1163 fb1a36c0 2022-01-09 op 			goto cantopen;
1164 fb1a36c0 2022-01-09 op 
1165 fb1a36c0 2022-01-09 op 		if ((fd == -1 && fstatat(oldfd, wnam, &sb, 0) == -1) ||
1166 fb1a36c0 2022-01-09 op 		    (fd != -1 && fstat(fd, &sb) == -1))
1167 fb1a36c0 2022-01-09 op 			goto cantopen;
1168 fb1a36c0 2022-01-09 op 
1169 fb1a36c0 2022-01-09 op 		qid_update_from_sb(&wqid[nwqid], &sb);
1170 fb1a36c0 2022-01-09 op 
1171 fb1a36c0 2022-01-09 op 		/* reached a file but we still have other components */
1172 fb1a36c0 2022-01-09 op 		if (fd == -1 && nwqid+1 < nwname)
1173 fb1a36c0 2022-01-09 op 			goto cantopen;
1174 fb1a36c0 2022-01-09 op 
1175 fb1a36c0 2022-01-09 op 		/* reached the end and found a file */
1176 fb1a36c0 2022-01-09 op 		if (fd == -1 && nwqid+1 == nwname)
1177 fb1a36c0 2022-01-09 op 			continue;
1178 fb1a36c0 2022-01-09 op 
1179 fb1a36c0 2022-01-09 op 		if (oldfd != f->dir->fd)
1180 fb1a36c0 2022-01-09 op 			close(oldfd);
1181 fb1a36c0 2022-01-09 op 		oldfd = fd;
1182 fb1a36c0 2022-01-09 op 	}
1183 fb1a36c0 2022-01-09 op 
1184 bcdb46a7 2022-01-19 op 	if (len != 0)
1185 bcdb46a7 2022-01-19 op 		goto err;
1186 bcdb46a7 2022-01-19 op 
1187 fb1a36c0 2022-01-09 op 	/*
1188 fb1a36c0 2022-01-09 op 	 * If fd is -1 we've reached a file, otherwise we've just
1189 fb1a36c0 2022-01-09 op 	 * reached another directory.  We must pay attention to what
1190 fb1a36c0 2022-01-09 op 	 * file descriptor we use to create the dir, because if we've
1191 fb1a36c0 2022-01-09 op 	 * reached a file and oldfd is f->dir->fd then we *must* share
1192 fb1a36c0 2022-01-09 op 	 * the same dir (it was a walk of one path from a directory to a
1193 fb1a36c0 2022-01-09 op 	 * file, otherwise fun is bound to happen as soon as the client
1194 fb1a36c0 2022-01-09 op      	 * closes the fid for the directory but keeps the one for the
1195 fb1a36c0 2022-01-09 op 	 * file.
1196 fb1a36c0 2022-01-09 op 	 */
1197 fb1a36c0 2022-01-09 op 	if (fd == -1 && oldfd == f->dir->fd)
1198 fb1a36c0 2022-01-09 op 		dir = f->dir;
1199 fb1a36c0 2022-01-09 op 	else if (fd == -1)
1200 fb1a36c0 2022-01-09 op 		dir = new_dir(oldfd);
1201 fb1a36c0 2022-01-09 op 	else
1202 fb1a36c0 2022-01-09 op 		dir = new_dir(fd);
1203 fb1a36c0 2022-01-09 op 
1204 fb1a36c0 2022-01-09 op 	if (dir == NULL)
1205 fb1a36c0 2022-01-09 op 		fatal("new_dir");
1206 fb1a36c0 2022-01-09 op 
1207 fb1a36c0 2022-01-09 op 	if (nf == NULL) {
1208 fb1a36c0 2022-01-09 op 		if ((nf = new_fid(dir, newfid, wnam, &wqid[nwqid-1])) == NULL)
1209 fb1a36c0 2022-01-09 op 			fatal("new fid");
1210 fb1a36c0 2022-01-09 op 	} else {
1211 fb1a36c0 2022-01-09 op 		/* update the dir */
1212 fb1a36c0 2022-01-09 op 		dir_decref(nf->dir);
1213 fb1a36c0 2022-01-09 op 		nf->dir = dir_incref(dir);
1214 fb1a36c0 2022-01-09 op 	}
1215 fb1a36c0 2022-01-09 op 
1216 fb1a36c0 2022-01-09 op 	np_walk(hdr->tag, nwqid, wqid);
1217 fb1a36c0 2022-01-09 op 	return;
1218 fb1a36c0 2022-01-09 op 
1219 fb1a36c0 2022-01-09 op cantopen:
1220 fb1a36c0 2022-01-09 op 	if (oldfd != f->dir->fd)
1221 fb1a36c0 2022-01-09 op 		close(oldfd);
1222 fb1a36c0 2022-01-09 op 	no = errno;
1223 fb1a36c0 2022-01-09 op 	if (nwqid == 0)
1224 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, strerror(no));
1225 fb1a36c0 2022-01-09 op 	else
1226 fb1a36c0 2022-01-09 op 		np_walk(hdr->tag, nwqid, wqid);
1227 fb1a36c0 2022-01-09 op 	return;
1228 fb1a36c0 2022-01-09 op 
1229 fb1a36c0 2022-01-09 op err:
1230 fb1a36c0 2022-01-09 op 	client_send_listener(IMSG_CLOSE, NULL, 0);
1231 fb1a36c0 2022-01-09 op 	client_shutdown();
1232 fb1a36c0 2022-01-09 op }
1233 fb1a36c0 2022-01-09 op 
1234 fb1a36c0 2022-01-09 op static inline int
1235 fb1a36c0 2022-01-09 op npmode_to_unix(uint8_t mode, int *flags)
1236 fb1a36c0 2022-01-09 op {
1237 fb1a36c0 2022-01-09 op 	switch (mode & 0x0F) {
1238 fb1a36c0 2022-01-09 op 	case KOREAD:
1239 fb1a36c0 2022-01-09 op 		*flags = O_RDONLY;
1240 fb1a36c0 2022-01-09 op 		break;
1241 fb1a36c0 2022-01-09 op 	case KOWRITE:
1242 fb1a36c0 2022-01-09 op 		*flags = O_WRONLY;
1243 fb1a36c0 2022-01-09 op 		break;
1244 fb1a36c0 2022-01-09 op 	case KORDWR:
1245 fb1a36c0 2022-01-09 op 		*flags = O_RDWR;
1246 fb1a36c0 2022-01-09 op 		break;
1247 fb1a36c0 2022-01-09 op 	case KOEXEC:
1248 fb1a36c0 2022-01-09 op 		log_warnx("tried to open something with KOEXEC");
1249 fb1a36c0 2022-01-09 op 		/* fallthrough */
1250 fb1a36c0 2022-01-09 op 	default:
1251 fb1a36c0 2022-01-09 op 		return -1;
1252 fb1a36c0 2022-01-09 op 	}
1253 fb1a36c0 2022-01-09 op 
1254 fb1a36c0 2022-01-09 op 	if (mode & KOTRUNC)
1255 fb1a36c0 2022-01-09 op 		*flags |= O_TRUNC;
1256 fb1a36c0 2022-01-09 op 	if (mode & KORCLOSE)
1257 fb1a36c0 2022-01-09 op 		*flags |= O_CLOEXEC;
1258 fb1a36c0 2022-01-09 op 
1259 fb1a36c0 2022-01-09 op 	return 0;
1260 fb1a36c0 2022-01-09 op }
1261 fb1a36c0 2022-01-09 op 
1262 fb1a36c0 2022-01-09 op static void
1263 fb1a36c0 2022-01-09 op topen(struct np_msg_header *hdr, const uint8_t *data, size_t len)
1264 fb1a36c0 2022-01-09 op {
1265 fb1a36c0 2022-01-09 op 	struct stat	 sb;
1266 fb1a36c0 2022-01-09 op 	struct qid	 qid;
1267 fb1a36c0 2022-01-09 op 	struct fid	*f;
1268 fb1a36c0 2022-01-09 op 	uint32_t	 fid;
1269 fb1a36c0 2022-01-09 op 	uint8_t		 mode;
1270 fb1a36c0 2022-01-09 op 	const char	*path;
1271 fb1a36c0 2022-01-09 op 
1272 fb1a36c0 2022-01-09 op 	/* fid[4] mode[1] */
1273 fb1a36c0 2022-01-09 op 	if (!NPREAD32("fid", &fid, &data, &len) ||
1274 bcdb46a7 2022-01-19 op 	    !NPREAD8("mode", &mode, &data, &len) ||
1275 bcdb46a7 2022-01-19 op 	    len != 0) {
1276 fb1a36c0 2022-01-09 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1277 fb1a36c0 2022-01-09 op 		client_shutdown();
1278 fb1a36c0 2022-01-09 op 		return;
1279 fb1a36c0 2022-01-09 op 	}
1280 fb1a36c0 2022-01-09 op 
1281 fb1a36c0 2022-01-09 op 	if ((f = fid_by_id(fid)) == NULL || f->fd != -1) {
1282 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid fid");
1283 fb1a36c0 2022-01-09 op 		return;
1284 fb1a36c0 2022-01-09 op 	}
1285 fb1a36c0 2022-01-09 op 
1286 fb1a36c0 2022-01-09 op 	if (npmode_to_unix(mode, &f->iomode) == -1) {
1287 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid mode");
1288 fb1a36c0 2022-01-09 op 		return;
1289 fb1a36c0 2022-01-09 op 	}
1290 fb1a36c0 2022-01-09 op 
1291 543fc013 2022-01-17 op 	path = f->fname;
1292 fb1a36c0 2022-01-09 op 	if (f->qid.type & QTDIR)
1293 fb1a36c0 2022-01-09 op 		path = ".";
1294 fb1a36c0 2022-01-09 op 
1295 fb1a36c0 2022-01-09 op 	if ((f->fd = openat(f->dir->fd, path, f->iomode)) == -1) {
1296 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, strerror(errno));
1297 fb1a36c0 2022-01-09 op 		return;
1298 fb1a36c0 2022-01-09 op 	}
1299 fb1a36c0 2022-01-09 op 
1300 fb1a36c0 2022-01-09 op 	if (fstat(f->fd, &sb) == -1)
1301 fb1a36c0 2022-01-09 op 		fatal("fstat");
1302 fb1a36c0 2022-01-09 op 
1303 fb1a36c0 2022-01-09 op 	if (S_ISDIR(sb.st_mode)) {
1304 fb1a36c0 2022-01-09 op 		if ((f->d = fdopendir(f->fd)) == NULL) {
1305 fb1a36c0 2022-01-09 op 			np_errno(hdr->tag);
1306 fb1a36c0 2022-01-09 op 			close(f->fd);
1307 fb1a36c0 2022-01-09 op 			f->fd = -1;
1308 fb1a36c0 2022-01-09 op 			return;
1309 fb1a36c0 2022-01-09 op 		}
1310 fb1a36c0 2022-01-09 op 
1311 fb1a36c0 2022-01-09 op 		if ((f->evb = evbuffer_new()) == NULL) {
1312 fb1a36c0 2022-01-09 op 			np_errno(hdr->tag);
1313 fb1a36c0 2022-01-09 op 			closedir(f->d);
1314 fb1a36c0 2022-01-09 op 			f->d = NULL;
1315 fb1a36c0 2022-01-09 op 			f->fd = -1;
1316 fb1a36c0 2022-01-09 op 		}
1317 fb1a36c0 2022-01-09 op 	}
1318 fb1a36c0 2022-01-09 op 
1319 fb1a36c0 2022-01-09 op 	f->offset = 0;
1320 fb1a36c0 2022-01-09 op 
1321 fb1a36c0 2022-01-09 op 	qid_update_from_sb(&qid, &sb);
1322 fb1a36c0 2022-01-09 op 	np_open(hdr->tag, &qid, sb.st_blksize);
1323 fb1a36c0 2022-01-09 op }
1324 fb1a36c0 2022-01-09 op 
1325 fb1a36c0 2022-01-09 op static void
1326 fb1a36c0 2022-01-09 op tcreate(struct np_msg_header *hdr, const uint8_t *data, size_t len)
1327 fb1a36c0 2022-01-09 op {
1328 fb1a36c0 2022-01-09 op 	struct stat	 sb;
1329 fb1a36c0 2022-01-09 op 	struct qid	 qid;
1330 fb1a36c0 2022-01-09 op 	struct fid	*f;
1331 fb1a36c0 2022-01-09 op 	uint32_t	 fid, perm;
1332 fb1a36c0 2022-01-09 op 	uint8_t		 mode;
1333 fb1a36c0 2022-01-09 op 	char		 name[PATH_MAX];
1334 fb1a36c0 2022-01-09 op 
1335 fb1a36c0 2022-01-09 op 	/* fid[4] name[s] perm[4] mode[1] */
1336 fb1a36c0 2022-01-09 op 	if (!NPREAD32("fid", &fid, &data, &len))
1337 fb1a36c0 2022-01-09 op 		goto err;
1338 fb1a36c0 2022-01-09 op 	switch (NPREADSTR("name", name, sizeof(name), &data, &len)) {
1339 fb1a36c0 2022-01-09 op 	case READSTRERR:
1340 fb1a36c0 2022-01-09 op 		goto err;
1341 fb1a36c0 2022-01-09 op 	case READSTRTRUNC:
1342 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "name too long");
1343 fb1a36c0 2022-01-09 op 		return;
1344 fb1a36c0 2022-01-09 op 	}
1345 fb1a36c0 2022-01-09 op 	if (!NPREAD32("perm", &perm, &data, &len) ||
1346 bcdb46a7 2022-01-19 op 	    !NPREAD8("mode", &mode, &data, &len) ||
1347 bcdb46a7 2022-01-19 op 	    len != 0)
1348 fb1a36c0 2022-01-09 op 		goto err;
1349 fb1a36c0 2022-01-09 op 
1350 fb1a36c0 2022-01-09 op 	if (!strcmp(name, ".") || !strcmp(name, "..") ||
1351 fb1a36c0 2022-01-09 op 	    strchr(name, '/') != NULL) {
1352 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid name");
1353 fb1a36c0 2022-01-09 op 		return;
1354 fb1a36c0 2022-01-09 op 	}
1355 fb1a36c0 2022-01-09 op 
1356 fb1a36c0 2022-01-09 op 	if ((f = fid_by_id(fid)) == NULL || f->fd != -1) {
1357 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid fid");
1358 fb1a36c0 2022-01-09 op 		return;
1359 fb1a36c0 2022-01-09 op 	}
1360 fb1a36c0 2022-01-09 op 
1361 fb1a36c0 2022-01-09 op 	if (!(f->qid.type & QTDIR)) {
1362 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "fid doesn't identify a directory");
1363 fb1a36c0 2022-01-09 op 		return;
1364 fb1a36c0 2022-01-09 op 	}
1365 fb1a36c0 2022-01-09 op 
1366 fb1a36c0 2022-01-09 op 	if (npmode_to_unix(mode, &f->iomode) == -1) {
1367 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid mode");
1368 fb1a36c0 2022-01-09 op 		return;
1369 fb1a36c0 2022-01-09 op 	}
1370 fb1a36c0 2022-01-09 op 
1371 fb1a36c0 2022-01-09 op 	if (f->iomode & O_RDONLY) {
1372 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "can't create a read-only file");
1373 fb1a36c0 2022-01-09 op 		return;
1374 fb1a36c0 2022-01-09 op 	}
1375 fb1a36c0 2022-01-09 op 
1376 fb1a36c0 2022-01-09 op 	/* TODO: parse the mode */
1377 fb1a36c0 2022-01-09 op 
1378 fb1a36c0 2022-01-09 op 	if (perm & 0x80000000) {
1379 fb1a36c0 2022-01-09 op 		/* create a directory */
1380 fb1a36c0 2022-01-09 op 		f->fd = mkdirat(f->dir->fd, name, 0755);
1381 fb1a36c0 2022-01-09 op 	} else {
1382 fb1a36c0 2022-01-09 op 		/* create a file */
1383 fb1a36c0 2022-01-09 op 		f->fd = openat(f->dir->fd, name, f->iomode | O_CREAT | O_TRUNC,
1384 fb1a36c0 2022-01-09 op 		    0644);
1385 fb1a36c0 2022-01-09 op 	}
1386 fb1a36c0 2022-01-09 op 
1387 fb1a36c0 2022-01-09 op 	if (f->fd == -1) {
1388 fb1a36c0 2022-01-09 op 		np_errno(hdr->tag);
1389 fb1a36c0 2022-01-09 op 		return;
1390 fb1a36c0 2022-01-09 op 	}
1391 fb1a36c0 2022-01-09 op 
1392 fb1a36c0 2022-01-09 op 	if (fstat(f->fd, &sb) == -1)
1393 fb1a36c0 2022-01-09 op 		fatal("fstat");
1394 fb1a36c0 2022-01-09 op 
1395 fb1a36c0 2022-01-09 op 	if (S_ISDIR(sb.st_mode)) {
1396 fb1a36c0 2022-01-09 op 		if ((f->d = fdopendir(f->fd)) == NULL) {
1397 fb1a36c0 2022-01-09 op 			np_errno(hdr->tag);
1398 fb1a36c0 2022-01-09 op 			close(f->fd);
1399 fb1a36c0 2022-01-09 op 			f->fd = -1;
1400 fb1a36c0 2022-01-09 op 			return;
1401 fb1a36c0 2022-01-09 op 		}
1402 fb1a36c0 2022-01-09 op 
1403 fb1a36c0 2022-01-09 op 		if ((f->evb = evbuffer_new()) == NULL) {
1404 fb1a36c0 2022-01-09 op 			np_errno(hdr->tag);
1405 fb1a36c0 2022-01-09 op 			closedir(f->d);
1406 fb1a36c0 2022-01-09 op 			f->d = NULL;
1407 fb1a36c0 2022-01-09 op 			f->fd = -1;
1408 fb1a36c0 2022-01-09 op 		}
1409 fb1a36c0 2022-01-09 op 	}
1410 fb1a36c0 2022-01-09 op 
1411 fb1a36c0 2022-01-09 op 	f->offset = 0;
1412 fb1a36c0 2022-01-09 op 
1413 fb1a36c0 2022-01-09 op 	qid_update_from_sb(&qid, &sb);
1414 fb1a36c0 2022-01-09 op 	np_create(hdr->tag, &qid, sb.st_blksize);
1415 fb1a36c0 2022-01-09 op 
1416 fb1a36c0 2022-01-09 op 	return;
1417 fb1a36c0 2022-01-09 op 
1418 fb1a36c0 2022-01-09 op err:
1419 fb1a36c0 2022-01-09 op 	client_send_listener(IMSG_CLOSE, NULL, 0);
1420 fb1a36c0 2022-01-09 op 	client_shutdown();
1421 fb1a36c0 2022-01-09 op }
1422 fb1a36c0 2022-01-09 op 
1423 91f48e25 2022-02-02 op static inline int
1424 fb1a36c0 2022-01-09 op serialize_stat(const char *fname, struct stat *sb, struct evbuffer *evb)
1425 fb1a36c0 2022-01-09 op {
1426 fb1a36c0 2022-01-09 op 	struct qid	 qid;
1427 fb1a36c0 2022-01-09 op 	const char	*uid, *gid, *muid;
1428 fb1a36c0 2022-01-09 op 	size_t		 tot;
1429 bee0a9e3 2022-02-02 op 	uint32_t	 mode;
1430 fb1a36c0 2022-01-09 op 	uint16_t	 namlen, uidlen, gidlen, ulen;
1431 fb1a36c0 2022-01-09 op 
1432 fb1a36c0 2022-01-09 op 	qid_update_from_sb(&qid, sb);
1433 fb1a36c0 2022-01-09 op 
1434 fb1a36c0 2022-01-09 op 	/* TODO: fill these fields */
1435 fb1a36c0 2022-01-09 op 	uid = "";
1436 fb1a36c0 2022-01-09 op 	gid = "";
1437 fb1a36c0 2022-01-09 op 	muid = "";
1438 fb1a36c0 2022-01-09 op 
1439 fb1a36c0 2022-01-09 op 	namlen = strlen(fname);
1440 fb1a36c0 2022-01-09 op 	uidlen = strlen(uid);
1441 fb1a36c0 2022-01-09 op 	gidlen = strlen(gid);
1442 fb1a36c0 2022-01-09 op 	ulen = strlen(muid);
1443 fb1a36c0 2022-01-09 op 
1444 fb1a36c0 2022-01-09 op 	tot = NPSTATSIZ(namlen, uidlen, gidlen, ulen);
1445 91f48e25 2022-02-02 op 	if (tot > UINT16_MAX) {
1446 fb1a36c0 2022-01-09 op 		log_warnx("stat info for dir entry %s would overflow",
1447 fb1a36c0 2022-01-09 op 		    fname);
1448 91f48e25 2022-02-02 op 		return -1;
1449 fb1a36c0 2022-01-09 op 	}
1450 bee0a9e3 2022-02-02 op 
1451 bee0a9e3 2022-02-02 op 	mode = sb->st_mode & 0xFFFF;
1452 bee0a9e3 2022-02-02 op 	if (qid.type & QTDIR)
1453 bee0a9e3 2022-02-02 op 		mode |= 0x80000000;
1454 fb1a36c0 2022-01-09 op 
1455 fb1a36c0 2022-01-09 op 	np_write16(evb, tot);			/*	size[2]		*/
1456 fb1a36c0 2022-01-09 op 	np_write16(evb, sb->st_rdev);		/*	type[2]		*/
1457 fb1a36c0 2022-01-09 op 	np_write32(evb, sb->st_dev);		/*	dev[4]		*/
1458 fb1a36c0 2022-01-09 op 	np_qid(evb, &qid);			/*	qid[13]		*/
1459 bee0a9e3 2022-02-02 op 	np_write32(evb, mode);			/*	mode[4]		*/
1460 fb1a36c0 2022-01-09 op 	np_write32(evb, sb->st_atim.tv_sec);	/*	atime[4]	*/
1461 fb1a36c0 2022-01-09 op 	np_write32(evb, sb->st_mtim.tv_sec);	/*	mtime[4]	*/
1462 68a7ef68 2022-01-16 op 
1463 68a7ef68 2022-01-16 op 	/* special case: directories have size 0 */
1464 68a7ef68 2022-01-16 op 	if (qid.type & QTDIR)
1465 68a7ef68 2022-01-16 op 		np_write64(evb, 0);
1466 68a7ef68 2022-01-16 op 	else
1467 68a7ef68 2022-01-16 op 		np_write64(evb, sb->st_size);	/*	length[8]	*/
1468 68a7ef68 2022-01-16 op 
1469 fb1a36c0 2022-01-09 op 	np_string(evb, namlen, fname);		/*	name[s]		*/
1470 fb1a36c0 2022-01-09 op 	np_string(evb, uidlen, uid);		/*	uid[s]		*/
1471 fb1a36c0 2022-01-09 op 	np_string(evb, gidlen, gid);		/*	gid[s]		*/
1472 fb1a36c0 2022-01-09 op 	np_string(evb, ulen, muid);		/*	muid[s]		*/
1473 91f48e25 2022-02-02 op 
1474 91f48e25 2022-02-02 op 	return 0;
1475 fb1a36c0 2022-01-09 op }
1476 fb1a36c0 2022-01-09 op 
1477 fb1a36c0 2022-01-09 op static void
1478 fb1a36c0 2022-01-09 op tread(struct np_msg_header *hdr, const uint8_t *data, size_t len)
1479 fb1a36c0 2022-01-09 op {
1480 fb1a36c0 2022-01-09 op 	struct fid	*f;
1481 fb1a36c0 2022-01-09 op 	ssize_t		 r;
1482 fb1a36c0 2022-01-09 op 	size_t		 howmuch;
1483 fb1a36c0 2022-01-09 op 	uint64_t	 off;
1484 fb1a36c0 2022-01-09 op 	uint32_t	 fid, count;
1485 fb1a36c0 2022-01-09 op 	char		 buf[2048];
1486 fb1a36c0 2022-01-09 op 
1487 fb1a36c0 2022-01-09 op 	/* fid[4] offset[8] count[4] */
1488 fb1a36c0 2022-01-09 op 	if (!NPREAD32("fid", &fid, &data, &len) ||
1489 fb1a36c0 2022-01-09 op 	    !NPREAD64("offset", &off, &data, &len) ||
1490 bcdb46a7 2022-01-19 op 	    !NPREAD32("count", &count, &data, &len) ||
1491 bcdb46a7 2022-01-19 op 	    len != 0) {
1492 fb1a36c0 2022-01-09 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1493 fb1a36c0 2022-01-09 op 		client_shutdown();
1494 fb1a36c0 2022-01-09 op 		return;
1495 fb1a36c0 2022-01-09 op 	}
1496 fb1a36c0 2022-01-09 op 
1497 fb1a36c0 2022-01-09 op 	if ((f = fid_by_id(fid)) == NULL || f->fd == -1) {
1498 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid fid");
1499 fb1a36c0 2022-01-09 op 		return;
1500 fb1a36c0 2022-01-09 op 	}
1501 fb1a36c0 2022-01-09 op 
1502 fb1a36c0 2022-01-09 op 	if (TYPE_OVERFLOW(off_t, off)) {
1503 fb1a36c0 2022-01-09 op 		log_warnx("unexpected off_t size");
1504 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid offset");
1505 fb1a36c0 2022-01-09 op 		return;
1506 fb1a36c0 2022-01-09 op 	}
1507 fb1a36c0 2022-01-09 op 
1508 fb1a36c0 2022-01-09 op 	if (f->d == NULL) {
1509 fb1a36c0 2022-01-09 op 		/* read a file */
1510 fb1a36c0 2022-01-09 op 		howmuch = MIN(sizeof(buf), count);
1511 fb1a36c0 2022-01-09 op 		r = pread(f->fd, buf, howmuch, (off_t)off);
1512 fb1a36c0 2022-01-09 op 		if (r == -1)
1513 fb1a36c0 2022-01-09 op 			np_errno(hdr->tag);
1514 fb1a36c0 2022-01-09 op 		else
1515 fb1a36c0 2022-01-09 op 			np_read(hdr->tag, r, buf);
1516 fb1a36c0 2022-01-09 op 	} else {
1517 fb1a36c0 2022-01-09 op 		if (off == 0 && f->offset != 0) {
1518 fb1a36c0 2022-01-09 op 			rewinddir(f->d);
1519 fb1a36c0 2022-01-09 op 			f->offset = 0;
1520 fb1a36c0 2022-01-09 op 			evbuffer_drain(f->evb, EVBUFFER_LENGTH(f->evb));
1521 fb1a36c0 2022-01-09 op 		}
1522 fb1a36c0 2022-01-09 op 
1523 fb1a36c0 2022-01-09 op 		if (off != f->offset) {
1524 fb1a36c0 2022-01-09 op 			np_error(hdr->tag, "can't seek in directories");
1525 fb1a36c0 2022-01-09 op 			return;
1526 fb1a36c0 2022-01-09 op 		}
1527 fb1a36c0 2022-01-09 op 
1528 fb1a36c0 2022-01-09 op 		while (EVBUFFER_LENGTH(f->evb) < count) {
1529 fb1a36c0 2022-01-09 op 			struct dirent *d;
1530 fb1a36c0 2022-01-09 op 			struct stat sb;
1531 fb1a36c0 2022-01-09 op 
1532 fb1a36c0 2022-01-09 op 			if ((d = readdir(f->d)) == NULL)
1533 fb1a36c0 2022-01-09 op 				break;
1534 ff6f19b1 2022-02-02 op 			if (!strcmp(d->d_name, ".") || !strcmp(d->d_name, ".."))
1535 ff6f19b1 2022-02-02 op 				continue;
1536 fb1a36c0 2022-01-09 op 			if (fstatat(f->fd, d->d_name, &sb, 0) == -1) {
1537 fb1a36c0 2022-01-09 op 				warn("fstatat");
1538 fb1a36c0 2022-01-09 op 				continue;
1539 fb1a36c0 2022-01-09 op 			}
1540 fb1a36c0 2022-01-09 op 			serialize_stat(d->d_name, &sb, f->evb);
1541 fb1a36c0 2022-01-09 op 		}
1542 fb1a36c0 2022-01-09 op 
1543 fb1a36c0 2022-01-09 op 		count = MIN(count, EVBUFFER_LENGTH(f->evb));
1544 fb1a36c0 2022-01-09 op 		np_read(hdr->tag, count, EVBUFFER_DATA(f->evb));
1545 fb1a36c0 2022-01-09 op 		evbuffer_drain(f->evb, count);
1546 fb1a36c0 2022-01-09 op 
1547 fb1a36c0 2022-01-09 op 		f->offset += count;
1548 fb1a36c0 2022-01-09 op 	}
1549 fb1a36c0 2022-01-09 op }
1550 fb1a36c0 2022-01-09 op 
1551 fb1a36c0 2022-01-09 op static void
1552 8b0a5062 2022-05-22 op twrite(struct np_msg_header *hdr, const uint8_t *data, size_t len,
1553 8b0a5062 2022-05-22 op     struct fid **writefid, off_t *writepos, size_t *writeleft, int *writeskip)
1554 fb1a36c0 2022-01-09 op {
1555 fb1a36c0 2022-01-09 op 	struct fid	*f;
1556 fb1a36c0 2022-01-09 op 	ssize_t		 r;
1557 fb1a36c0 2022-01-09 op 	uint64_t	 off;
1558 fb1a36c0 2022-01-09 op 	uint32_t	 fid, count;
1559 fb1a36c0 2022-01-09 op 
1560 fb1a36c0 2022-01-09 op 	/* fid[4] offset[8] count[4] data[count] */
1561 fb1a36c0 2022-01-09 op 	if (!NPREAD32("fid", &fid, &data, &len) ||
1562 fb1a36c0 2022-01-09 op 	    !NPREAD64("off", &off, &data, &len) ||
1563 fb1a36c0 2022-01-09 op 	    !NPREAD32("count", &count, &data, &len) ||
1564 8b0a5062 2022-05-22 op 	    count < len) {
1565 fb1a36c0 2022-01-09 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1566 fb1a36c0 2022-01-09 op 		client_shutdown();
1567 fb1a36c0 2022-01-09 op 		return;
1568 fb1a36c0 2022-01-09 op 	}
1569 fb1a36c0 2022-01-09 op 
1570 fb1a36c0 2022-01-09 op 	if ((f = fid_by_id(fid)) == NULL || f->fd == -1) {
1571 8b0a5062 2022-05-22 op 		*writeskip = 1;
1572 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid fid");
1573 fb1a36c0 2022-01-09 op 		return;
1574 fb1a36c0 2022-01-09 op 	}
1575 fb1a36c0 2022-01-09 op 
1576 fb1a36c0 2022-01-09 op 	if (!(f->iomode & O_WRONLY) &&
1577 fb1a36c0 2022-01-09 op 	    !(f->iomode & O_RDWR)) {
1578 8b0a5062 2022-05-22 op 		*writeskip = 1;
1579 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "fid not opened for writing");
1580 fb1a36c0 2022-01-09 op 		return;
1581 fb1a36c0 2022-01-09 op 	}
1582 fb1a36c0 2022-01-09 op 
1583 fb1a36c0 2022-01-09 op 	if (TYPE_OVERFLOW(off_t, off)) {
1584 8b0a5062 2022-05-22 op 		*writeskip = 1;
1585 fb1a36c0 2022-01-09 op 		log_warnx("unexpected off_t size");
1586 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid offset");
1587 fb1a36c0 2022-01-09 op 		return;
1588 fb1a36c0 2022-01-09 op 	}
1589 fb1a36c0 2022-01-09 op 
1590 8b0a5062 2022-05-22 op 	if ((r = pwrite(f->fd, data, len, off)) == -1) {
1591 8b0a5062 2022-05-22 op 		*writeskip = 1;
1592 8b0a5062 2022-05-22 op 		np_errno(hdr->tag);
1593 8b0a5062 2022-05-22 op 	} else if (count == len)
1594 fb1a36c0 2022-01-09 op 		np_write(hdr->tag, r);
1595 8b0a5062 2022-05-22 op 
1596 8b0a5062 2022-05-22 op 	/* account for a continuated write */
1597 8b0a5062 2022-05-22 op 	if (count > len) {
1598 8b0a5062 2022-05-22 op 		*writefid = f;
1599 8b0a5062 2022-05-22 op 		*writepos = off + len;
1600 8b0a5062 2022-05-22 op 		*writeleft = count - len;
1601 8b0a5062 2022-05-22 op 		*writeskip = 0;
1602 8b0a5062 2022-05-22 op 	}
1603 fb1a36c0 2022-01-09 op }
1604 fb1a36c0 2022-01-09 op 
1605 fb1a36c0 2022-01-09 op static void
1606 8b0a5062 2022-05-22 op twrite_cont(struct fid *f, off_t *writepos, size_t *writeleft, int *writeskip,
1607 8b0a5062 2022-05-22 op     uint16_t tag, const uint8_t *data, size_t len)
1608 8b0a5062 2022-05-22 op {
1609 8b0a5062 2022-05-22 op 	ssize_t r;
1610 8b0a5062 2022-05-22 op 
1611 8b0a5062 2022-05-22 op 	if (len > *writeleft) {
1612 8b0a5062 2022-05-22 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1613 8b0a5062 2022-05-22 op 		client_shutdown();
1614 8b0a5062 2022-05-22 op 		return;
1615 8b0a5062 2022-05-22 op 	}
1616 8b0a5062 2022-05-22 op 
1617 8b0a5062 2022-05-22 op 	if ((r = pwrite(f->fd, data, len, *writepos)) == -1) {
1618 8b0a5062 2022-05-22 op 		*writeskip = 1;
1619 8b0a5062 2022-05-22 op 		np_errno(tag);
1620 8b0a5062 2022-05-22 op 		return;
1621 8b0a5062 2022-05-22 op 	}
1622 8b0a5062 2022-05-22 op 
1623 8b0a5062 2022-05-22 op 	*writeleft -= len;
1624 8b0a5062 2022-05-22 op 	*writepos += len;
1625 8b0a5062 2022-05-22 op 
1626 8b0a5062 2022-05-22 op 	if (*writeleft == 0)
1627 8b0a5062 2022-05-22 op 		np_write(tag, r);
1628 8b0a5062 2022-05-22 op }
1629 8b0a5062 2022-05-22 op 
1630 8b0a5062 2022-05-22 op static void
1631 fb1a36c0 2022-01-09 op tstat(struct np_msg_header *hdr, const uint8_t *data, size_t len)
1632 fb1a36c0 2022-01-09 op {
1633 fb1a36c0 2022-01-09 op 	struct evbuffer	*evb;
1634 fb1a36c0 2022-01-09 op 	struct stat	 sb;
1635 fb1a36c0 2022-01-09 op 	struct fid	*f;
1636 fb1a36c0 2022-01-09 op 	int		 r;
1637 fb1a36c0 2022-01-09 op 	uint32_t	 fid;
1638 fb1a36c0 2022-01-09 op 
1639 fb1a36c0 2022-01-09 op 	/* fid[4] */
1640 bcdb46a7 2022-01-19 op 	if (!NPREAD32("fid", &fid, &data, &len) ||
1641 bcdb46a7 2022-01-19 op 	    len != 0) {
1642 fb1a36c0 2022-01-09 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1643 fb1a36c0 2022-01-09 op 		client_shutdown();
1644 fb1a36c0 2022-01-09 op 		return;
1645 fb1a36c0 2022-01-09 op 	}
1646 fb1a36c0 2022-01-09 op 
1647 fb1a36c0 2022-01-09 op 	/*
1648 fb1a36c0 2022-01-09 op 	 * plan9' stat(9P) is not clear on whether the stat is allowed
1649 fb1a36c0 2022-01-09 op 	 * on opened fids or not.  We're allowing stat regardless of the
1650 fb1a36c0 2022-01-09 op 	 * status of the fid.
1651 fb1a36c0 2022-01-09 op 	 */
1652 fb1a36c0 2022-01-09 op 
1653 fb1a36c0 2022-01-09 op 	if ((f = fid_by_id(fid)) == NULL) {
1654 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid fid");
1655 fb1a36c0 2022-01-09 op 		return;
1656 fb1a36c0 2022-01-09 op 	}
1657 fb1a36c0 2022-01-09 op 
1658 fb1a36c0 2022-01-09 op 	if ((evb = evbuffer_new()) == NULL)
1659 fb1a36c0 2022-01-09 op 		fatal("evbuffer_new");
1660 fb1a36c0 2022-01-09 op 
1661 fb1a36c0 2022-01-09 op 	if (f->fd != -1)
1662 fb1a36c0 2022-01-09 op 		r = fstat(f->fd, &sb);
1663 fb1a36c0 2022-01-09 op 	else if (f->qid.type & QTDIR)
1664 fb1a36c0 2022-01-09 op 		r = fstat(f->dir->fd, &sb);
1665 fb1a36c0 2022-01-09 op 	else
1666 543fc013 2022-01-17 op 		r = fstatat(f->dir->fd, f->fname, &sb, 0);
1667 fb1a36c0 2022-01-09 op 
1668 fb1a36c0 2022-01-09 op 	if (r == -1) {
1669 fb1a36c0 2022-01-09 op 		np_errno(hdr->tag);
1670 fb1a36c0 2022-01-09 op 		evbuffer_free(evb);
1671 fb1a36c0 2022-01-09 op 		return;
1672 fb1a36c0 2022-01-09 op 	}
1673 fb1a36c0 2022-01-09 op 
1674 91f48e25 2022-02-02 op 	if (serialize_stat(f->fname, &sb, evb) == -1)
1675 91f48e25 2022-02-02 op 		np_error(hdr->tag, "stat would overflow");
1676 91f48e25 2022-02-02 op 	else
1677 91f48e25 2022-02-02 op 		np_stat(hdr->tag, EVBUFFER_LENGTH(evb), EVBUFFER_DATA(evb));
1678 fb1a36c0 2022-01-09 op 	evbuffer_free(evb);
1679 755d75bf 2022-01-17 op }
1680 755d75bf 2022-01-17 op 
1681 755d75bf 2022-01-17 op static void
1682 755d75bf 2022-01-17 op twstat(struct np_msg_header *hdr, const uint8_t *data, size_t len)
1683 755d75bf 2022-01-17 op {
1684 755d75bf 2022-01-17 op 	struct timespec	 times[2];
1685 755d75bf 2022-01-17 op 	struct np_stat	 st;
1686 755d75bf 2022-01-17 op 	struct fid	*f;
1687 755d75bf 2022-01-17 op 	int		 r;
1688 755d75bf 2022-01-17 op 	uint32_t	 fid;
1689 755d75bf 2022-01-17 op 	char		 name[PATH_MAX];
1690 755d75bf 2022-01-17 op 
1691 755d75bf 2022-01-17 op 	/* fid[4] stat[n] */
1692 755d75bf 2022-01-17 op 	if (!NPREAD32("fid", &fid, &data, &len))
1693 755d75bf 2022-01-17 op 		goto err;
1694 755d75bf 2022-01-17 op 
1695 755d75bf 2022-01-17 op 	switch (NPREADST("stat", &st, name, sizeof(name), &data, &len)) {
1696 755d75bf 2022-01-17 op 	case READSTRERR:
1697 755d75bf 2022-01-17 op 		goto err;
1698 755d75bf 2022-01-17 op 	case READSTRTRUNC:
1699 755d75bf 2022-01-17 op 		log_warnx("wstat new name would overflow");
1700 755d75bf 2022-01-17 op 		np_error(hdr->tag, "new name too long");
1701 755d75bf 2022-01-17 op 		return;
1702 755d75bf 2022-01-17 op 	}
1703 755d75bf 2022-01-17 op 
1704 f4ad0146 2022-01-19 op 	/*
1705 f4ad0146 2022-01-19 op 	 * We skip the reading of some fields voluntarily because we
1706 f4ad0146 2022-01-19 op 	 * don't support chown, so len will always be > 0!
1707 f4ad0146 2022-01-19 op 	 */
1708 f4ad0146 2022-01-19 op #ifdef notyet
1709 bcdb46a7 2022-01-19 op 	if (len != 0)
1710 bcdb46a7 2022-01-19 op 		goto err;
1711 f4ad0146 2022-01-19 op #endif
1712 bcdb46a7 2022-01-19 op 
1713 755d75bf 2022-01-17 op 	if ((f = fid_by_id(fid)) == NULL) {
1714 755d75bf 2022-01-17 op 		np_error(hdr->tag, "invalid fid");
1715 755d75bf 2022-01-17 op 		return;
1716 755d75bf 2022-01-17 op 	}
1717 755d75bf 2022-01-17 op 
1718 755d75bf 2022-01-17 op 	/*
1719 755d75bf 2022-01-17 op 	 * 9P wants these edits to be done in an atomic fashion,
1720 755d75bf 2022-01-17 op 	 * something that I don't think it's possible on UNIX without
1721 755d75bf 2022-01-17 op 	 * some special kernel help.  Changing atime or mtime,
1722 755d75bf 2022-01-17 op 	 * permissions, or rename the file are different syscalls.
1723 755d75bf 2022-01-17 op 	 *
1724 755d75bf 2022-01-17 op 	 * Also, silently ignore stuff we can't/don't want to modify.
1725 755d75bf 2022-01-17 op 	 */
1726 755d75bf 2022-01-17 op 
1727 755d75bf 2022-01-17 op 	/* change the permissions */
1728 755d75bf 2022-01-17 op 	if (st.mode != (uint32_t)-1) {
1729 b7c2d377 2022-02-13 op 		mode_t m = st.mode & 0x7FF; /* silently truncate higer bits */
1730 755d75bf 2022-01-17 op 		if (f->fd != -1)
1731 755d75bf 2022-01-17 op 			r = fchmod(f->fd, m);
1732 755d75bf 2022-01-17 op 		else
1733 543fc013 2022-01-17 op 			r = fchmodat(f->dir->fd, f->fname, m, 0);
1734 755d75bf 2022-01-17 op 
1735 755d75bf 2022-01-17 op 		if (r == -1) {
1736 755d75bf 2022-01-17 op 			np_errno(hdr->tag);
1737 755d75bf 2022-01-17 op 			return;
1738 755d75bf 2022-01-17 op 		}
1739 755d75bf 2022-01-17 op 	}
1740 755d75bf 2022-01-17 op 
1741 755d75bf 2022-01-17 op 	/* change the atime/mtime of the fid, opened or not */
1742 755d75bf 2022-01-17 op 	if (st.atime != (uint32_t)-1 || st.mtime != (uint32_t)-1) {
1743 755d75bf 2022-01-17 op 		times[0].tv_nsec = UTIME_OMIT;
1744 755d75bf 2022-01-17 op 		times[1].tv_nsec = UTIME_OMIT;
1745 755d75bf 2022-01-17 op 
1746 755d75bf 2022-01-17 op 		if (st.atime != (uint32_t)-1) {
1747 755d75bf 2022-01-17 op 			times[0].tv_sec = st.atime;
1748 755d75bf 2022-01-17 op 			times[0].tv_nsec = 0;
1749 755d75bf 2022-01-17 op 		}
1750 755d75bf 2022-01-17 op 		if (st.mtime != (uint32_t)-1) {
1751 755d75bf 2022-01-17 op 			times[1].tv_sec = st.mtime;
1752 755d75bf 2022-01-17 op 			times[1].tv_nsec = 0;
1753 755d75bf 2022-01-17 op 		}
1754 755d75bf 2022-01-17 op 
1755 755d75bf 2022-01-17 op 		if (f->fd != -1)
1756 755d75bf 2022-01-17 op 			r = futimens(f->fd, times);
1757 755d75bf 2022-01-17 op 		else
1758 543fc013 2022-01-17 op 			r = utimensat(f->dir->fd, f->fname, times, 0);
1759 755d75bf 2022-01-17 op 
1760 755d75bf 2022-01-17 op 		if (r == -1) {
1761 755d75bf 2022-01-17 op 			np_errno(hdr->tag);
1762 755d75bf 2022-01-17 op 			return;
1763 755d75bf 2022-01-17 op 		}
1764 755d75bf 2022-01-17 op 	}
1765 755d75bf 2022-01-17 op 
1766 755d75bf 2022-01-17 op 	/* truncate */
1767 755d75bf 2022-01-17 op 	if (st.length != (uint64_t)-1) {
1768 755d75bf 2022-01-17 op 		if (f->fd == -1) {
1769 755d75bf 2022-01-17 op 			np_error(hdr->tag, "can't truncate a non-opened fid");
1770 755d75bf 2022-01-17 op 			return;
1771 755d75bf 2022-01-17 op 		}
1772 755d75bf 2022-01-17 op 
1773 755d75bf 2022-01-17 op 		if (f->qid.type & QTDIR && st.length != 0) {
1774 755d75bf 2022-01-17 op 			np_error(hdr->tag, "can't truncate directories");
1775 755d75bf 2022-01-17 op 			return;
1776 755d75bf 2022-01-17 op 		}
1777 755d75bf 2022-01-17 op 
1778 755d75bf 2022-01-17 op 		if (TYPE_OVERFLOW(off_t, st.length)) {
1779 755d75bf 2022-01-17 op 			log_warnx("truncate request overflows off_t: %"PRIu64,
1780 755d75bf 2022-01-17 op 			    st.length);
1781 755d75bf 2022-01-17 op 			np_error(hdr->tag, "length overflows");
1782 755d75bf 2022-01-17 op 			return;
1783 755d75bf 2022-01-17 op 		}
1784 755d75bf 2022-01-17 op 
1785 6d3d71a9 2022-01-19 op 		if (f->qid.type == 0 &&
1786 755d75bf 2022-01-17 op 		    ftruncate(f->fd, st.length) == -1) {
1787 755d75bf 2022-01-17 op 			np_errno(hdr->tag);
1788 755d75bf 2022-01-17 op 			return;
1789 755d75bf 2022-01-17 op 		}
1790 755d75bf 2022-01-17 op 	}
1791 755d75bf 2022-01-17 op 
1792 755d75bf 2022-01-17 op 	/* rename (change the name entry) */
1793 755d75bf 2022-01-17 op 	if (*st.name != '\0') {
1794 755d75bf 2022-01-17 op 		struct stat sb;
1795 755d75bf 2022-01-17 op 		const char *newname;
1796 755d75bf 2022-01-17 op 
1797 755d75bf 2022-01-17 op 		/*
1798 755d75bf 2022-01-17 op 		 * XXX: 9P requires that we disallow changing the name
1799 755d75bf 2022-01-17 op 		 * to that of an existing file.  We can't do that
1800 755d75bf 2022-01-17 op 		 * atomically (rename is happy about stealing names)
1801 755d75bf 2022-01-17 op 		 * so this is just a best effort.
1802 755d75bf 2022-01-17 op 		 */
1803 755d75bf 2022-01-17 op 		if (fstatat(f->dir->fd, st.name, &sb, 0) == -1 &&
1804 755d75bf 2022-01-17 op 		    errno != ENOENT) {
1805 755d75bf 2022-01-17 op 			np_error(hdr->tag, "target file exists");
1806 755d75bf 2022-01-17 op 			return;
1807 755d75bf 2022-01-17 op 		}
1808 755d75bf 2022-01-17 op 
1809 543fc013 2022-01-17 op 		r = renameat(f->dir->fd, f->fname, f->dir->fd, st.name);
1810 755d75bf 2022-01-17 op 		if (r == -1) {
1811 755d75bf 2022-01-17 op 			np_errno(hdr->tag);
1812 755d75bf 2022-01-17 op 			return;
1813 755d75bf 2022-01-17 op 		}
1814 755d75bf 2022-01-17 op 
1815 755d75bf 2022-01-17 op 		/* fix the fid so it points to the new file */
1816 755d75bf 2022-01-17 op 
1817 755d75bf 2022-01-17 op 		if ((newname = strchr(st.name, '/')) != NULL)
1818 755d75bf 2022-01-17 op 			newname++; /* skip / */
1819 755d75bf 2022-01-17 op 		else
1820 755d75bf 2022-01-17 op 			newname = st.name;
1821 543fc013 2022-01-17 op 		strlcpy(f->fname, newname, sizeof(f->fname));
1822 755d75bf 2022-01-17 op 
1823 755d75bf 2022-01-17 op 		if (strchr(st.name, '/') != NULL) {
1824 755d75bf 2022-01-17 op 			struct dir *dir;
1825 755d75bf 2022-01-17 op 			char *dname;
1826 755d75bf 2022-01-17 op 			int fd;
1827 755d75bf 2022-01-17 op 
1828 755d75bf 2022-01-17 op 			dname = dirname(st.name);
1829 755d75bf 2022-01-17 op 			fd = openat(f->dir->fd, dname, O_RDONLY|O_DIRECTORY);
1830 755d75bf 2022-01-17 op 			if (fd == -1) {
1831 755d75bf 2022-01-17 op 				np_errno(hdr->tag);
1832 755d75bf 2022-01-17 op 				free_fid(f);
1833 755d75bf 2022-01-17 op 				return;
1834 755d75bf 2022-01-17 op 			}
1835 755d75bf 2022-01-17 op 
1836 755d75bf 2022-01-17 op 			if ((dir = new_dir(fd)) == NULL) {
1837 755d75bf 2022-01-17 op 				np_errno(hdr->tag);
1838 755d75bf 2022-01-17 op 				free_fid(f);
1839 755d75bf 2022-01-17 op 				return;
1840 755d75bf 2022-01-17 op 			}
1841 755d75bf 2022-01-17 op 
1842 755d75bf 2022-01-17 op 			dir_decref(f->dir);
1843 755d75bf 2022-01-17 op 			f->dir = dir_incref(dir);
1844 755d75bf 2022-01-17 op 		}
1845 755d75bf 2022-01-17 op 	}
1846 755d75bf 2022-01-17 op 
1847 755d75bf 2022-01-17 op 	np_wstat(hdr->tag);
1848 755d75bf 2022-01-17 op 	return;
1849 755d75bf 2022-01-17 op 
1850 755d75bf 2022-01-17 op err:
1851 755d75bf 2022-01-17 op 	client_send_listener(IMSG_CLOSE, NULL, 0);
1852 755d75bf 2022-01-17 op 	client_shutdown();
1853 fb1a36c0 2022-01-09 op }
1854 fb1a36c0 2022-01-09 op 
1855 fb1a36c0 2022-01-09 op static void
1856 fb1a36c0 2022-01-09 op tremove(struct np_msg_header *hdr, const uint8_t *data, size_t len)
1857 fb1a36c0 2022-01-09 op {
1858 fb1a36c0 2022-01-09 op 	struct fid	*f;
1859 fb1a36c0 2022-01-09 op 	uint32_t	 fid;
1860 fb1a36c0 2022-01-09 op 	int		 r;
1861 fb1a36c0 2022-01-09 op 	char		 dirpath[PATH_MAX + 3];
1862 fb1a36c0 2022-01-09 op 
1863 fb1a36c0 2022-01-09 op 	/* fid[4] */
1864 bcdb46a7 2022-01-19 op 	if (!NPREAD32("fid", &fid, &data, &len) ||
1865 bcdb46a7 2022-01-19 op 	    len != 0) {
1866 fb1a36c0 2022-01-09 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1867 fb1a36c0 2022-01-09 op 		client_shutdown();
1868 fb1a36c0 2022-01-09 op 		return;
1869 fb1a36c0 2022-01-09 op 	}
1870 fb1a36c0 2022-01-09 op 
1871 fb1a36c0 2022-01-09 op 	if ((f = fid_by_id(fid)) == NULL) {
1872 fb1a36c0 2022-01-09 op 		np_error(hdr->tag, "invalid fid");
1873 fb1a36c0 2022-01-09 op 		return;
1874 fb1a36c0 2022-01-09 op 	}
1875 fb1a36c0 2022-01-09 op 
1876 fb1a36c0 2022-01-09 op 	if (f->qid.type & QTDIR) { /* directory */
1877 fb1a36c0 2022-01-09 op 		strlcpy(dirpath, "../", sizeof(dirpath));
1878 543fc013 2022-01-17 op 		strlcat(dirpath, f->fname, sizeof(dirpath));
1879 fb1a36c0 2022-01-09 op 		r = unlinkat(f->dir->fd, dirpath, AT_REMOVEDIR);
1880 fb1a36c0 2022-01-09 op 	} else /* file */
1881 543fc013 2022-01-17 op 		r = unlinkat(f->dir->fd, f->fname, 0);
1882 fb1a36c0 2022-01-09 op 
1883 fb1a36c0 2022-01-09 op 	if (r == -1)
1884 fb1a36c0 2022-01-09 op 		np_errno(hdr->tag);
1885 fb1a36c0 2022-01-09 op 	else
1886 fb1a36c0 2022-01-09 op 		np_remove(hdr->tag);
1887 fb1a36c0 2022-01-09 op 
1888 fb1a36c0 2022-01-09 op 	free_fid(f);
1889 fb1a36c0 2022-01-09 op }
1890 fb1a36c0 2022-01-09 op 
1891 fb1a36c0 2022-01-09 op static void
1892 8b0a5062 2022-05-22 op handle_message(struct imsg *imsg, size_t len, int cont)
1893 fb1a36c0 2022-01-09 op {
1894 8b0a5062 2022-05-22 op 	static struct fid *writefid;
1895 8b0a5062 2022-05-22 op 	static off_t writepos;
1896 8b0a5062 2022-05-22 op 	static size_t writeleft;
1897 8b0a5062 2022-05-22 op 	static int writeskip;
1898 8b0a5062 2022-05-22 op 	static uint16_t writetag;
1899 fb1a36c0 2022-01-09 op 	struct msg {
1900 fb1a36c0 2022-01-09 op 		uint8_t	 type;
1901 fb1a36c0 2022-01-09 op 		void	(*fn)(struct np_msg_header *, const uint8_t *, size_t);
1902 fb1a36c0 2022-01-09 op 	} msgs[] = {
1903 fb1a36c0 2022-01-09 op 		{Tversion,	tversion},
1904 fb1a36c0 2022-01-09 op 		{Tattach,	tattach},
1905 fb1a36c0 2022-01-09 op 		{Tclunk,	tclunk},
1906 fb1a36c0 2022-01-09 op 		{Tflush,	tflush},
1907 fb1a36c0 2022-01-09 op 		{Twalk,		twalk},
1908 fb1a36c0 2022-01-09 op 		{Topen,		topen},
1909 fb1a36c0 2022-01-09 op 		{Tcreate,	tcreate},
1910 fb1a36c0 2022-01-09 op 		{Tread,		tread},
1911 8b0a5062 2022-05-22 op 		/* {Twrite,	twrite}, */
1912 fb1a36c0 2022-01-09 op 		{Tstat,		tstat},
1913 755d75bf 2022-01-17 op 		{Twstat,	twstat},
1914 fb1a36c0 2022-01-09 op 		{Tremove,	tremove},
1915 fb1a36c0 2022-01-09 op 	};
1916 fb1a36c0 2022-01-09 op 	struct np_msg_header	 hdr;
1917 fb1a36c0 2022-01-09 op 	size_t			 i;
1918 fb1a36c0 2022-01-09 op 	uint8_t			*data;
1919 fb1a36c0 2022-01-09 op 
1920 fb1a36c0 2022-01-09 op #if DEBUG_PACKETS
1921 fb1a36c0 2022-01-09 op 	hexdump("incoming packet", imsg->data, len);
1922 fb1a36c0 2022-01-09 op #endif
1923 fb1a36c0 2022-01-09 op 
1924 8b0a5062 2022-05-22 op 	/*
1925 8b0a5062 2022-05-22 op 	 * Twrite is special and can be "continued" to allow writing
1926 8b0a5062 2022-05-22 op 	 * more than what the imsg framework would allow us to.
1927 8b0a5062 2022-05-22 op 	 */
1928 8b0a5062 2022-05-22 op 	if (writeleft > 0 && !cont) {
1929 8b0a5062 2022-05-22 op 		log_warnx("received a non continuation message when still "
1930 8b0a5062 2022-05-22 op 		    "missed %zu bytes to write", writeleft);
1931 8b0a5062 2022-05-22 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1932 8b0a5062 2022-05-22 op 		client_shutdown();
1933 8b0a5062 2022-05-22 op 		return;
1934 8b0a5062 2022-05-22 op 	}
1935 8b0a5062 2022-05-22 op 
1936 8b0a5062 2022-05-22 op 	if (cont) {
1937 8b0a5062 2022-05-22 op 		if (writeskip)
1938 8b0a5062 2022-05-22 op 			return;
1939 8b0a5062 2022-05-22 op 
1940 8b0a5062 2022-05-22 op 		if (writefid == NULL) {
1941 8b0a5062 2022-05-22 op 			log_warnx("received a continuation message without "
1942 8b0a5062 2022-05-22 op 			    "seeing a Twrite");
1943 8b0a5062 2022-05-22 op 			client_send_listener(IMSG_CLOSE, NULL, 0);
1944 8b0a5062 2022-05-22 op 			client_shutdown();
1945 8b0a5062 2022-05-22 op 			return;
1946 8b0a5062 2022-05-22 op 		}
1947 8b0a5062 2022-05-22 op 
1948 8b0a5062 2022-05-22 op 		log_warnx("continuing...");
1949 8b0a5062 2022-05-22 op 		twrite_cont(writefid, &writepos, &writeleft, &writeskip,
1950 8b0a5062 2022-05-22 op 		    writetag, imsg->data, len);
1951 8b0a5062 2022-05-22 op 		return;
1952 8b0a5062 2022-05-22 op 	}
1953 8b0a5062 2022-05-22 op 
1954 8b0a5062 2022-05-22 op 	writefid = NULL;
1955 8b0a5062 2022-05-22 op 	writepos = -1;
1956 8b0a5062 2022-05-22 op 	writeleft = 0;
1957 8b0a5062 2022-05-22 op 	writeskip = 0;
1958 8b0a5062 2022-05-22 op 
1959 fb1a36c0 2022-01-09 op 	parse_message(imsg->data, len, &hdr, &data);
1960 fb1a36c0 2022-01-09 op 	len -= HEADERSIZE;
1961 fb1a36c0 2022-01-09 op 
1962 fb1a36c0 2022-01-09 op 	log_debug("got request: len=%d type=%d[%s] tag=%d",
1963 fb1a36c0 2022-01-09 op 	    hdr.len, hdr.type, pp_msg_type(hdr.type), hdr.tag);
1964 fb1a36c0 2022-01-09 op 
1965 fb1a36c0 2022-01-09 op 	if (!handshaked && hdr.type != Tversion) {
1966 fb1a36c0 2022-01-09 op 		client_send_listener(IMSG_CLOSE, NULL, 0);
1967 fb1a36c0 2022-01-09 op 		client_shutdown();
1968 fb1a36c0 2022-01-09 op 		return;
1969 fb1a36c0 2022-01-09 op 	}
1970 fb1a36c0 2022-01-09 op 
1971 8b0a5062 2022-05-22 op 	if (hdr.type == Twrite) {
1972 8b0a5062 2022-05-22 op 		writetag = hdr.tag;
1973 8b0a5062 2022-05-22 op 		twrite(&hdr, data, len, &writefid, &writepos, &writeleft,
1974 8b0a5062 2022-05-22 op 		    &writeskip);
1975 8b0a5062 2022-05-22 op 		return;
1976 8b0a5062 2022-05-22 op 	}
1977 8b0a5062 2022-05-22 op 
1978 fb1a36c0 2022-01-09 op 	for (i = 0; i < sizeof(msgs)/sizeof(msgs[0]); ++i) {
1979 fb1a36c0 2022-01-09 op 		if (msgs[i].type != hdr.type)
1980 fb1a36c0 2022-01-09 op 			continue;
1981 fb1a36c0 2022-01-09 op 
1982 fb1a36c0 2022-01-09 op 		msgs[i].fn(&hdr, data, len);
1983 fb1a36c0 2022-01-09 op 		return;
1984 fb1a36c0 2022-01-09 op 	}
1985 fb1a36c0 2022-01-09 op 
1986 fb1a36c0 2022-01-09 op 	np_error(hdr.tag, "Not supported.");
1987 fb1a36c0 2022-01-09 op }