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 fb1a36c0 2022-01-09 op  * Copyright (c) 2021 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 fb1a36c0 2022-01-09 op #ifndef KAMID_H
 18 fb1a36c0 2022-01-09 op #define KAMID_H
 19 fb1a36c0 2022-01-09 op 
 20 fb1a36c0 2022-01-09 op #include <limits.h>
 21 fb1a36c0 2022-01-09 op #include <stdint.h>
 22 fb1a36c0 2022-01-09 op #include <tls.h>
 23 fb1a36c0 2022-01-09 op 
 24 fb1a36c0 2022-01-09 op /* TODO: make these customizable */
 25 fb1a36c0 2022-01-09 op #define KD_CONF_FILE		"/etc/kamid.conf"
 26 fb1a36c0 2022-01-09 op #define KD_USER			"_kamid"
 27 fb1a36c0 2022-01-09 op #define KD_SOCKET		"/var/run/kamid.sock"
 28 fb1a36c0 2022-01-09 op 
 29 fb1a36c0 2022-01-09 op #define IMSG_DATA_SIZE(imsg)	((imsg).hdr.len - IMSG_HEADER_SIZE)
 30 fb1a36c0 2022-01-09 op 
 31 fb1a36c0 2022-01-09 op enum imsg_type {
 32 fb1a36c0 2022-01-09 op 	IMSG_NONE,
 33 fb1a36c0 2022-01-09 op 	IMSG_CTL_LOG_VERBOSE,
 34 fb1a36c0 2022-01-09 op 	IMSG_CTL_RELOAD,
 35 5c69b561 2022-01-29 op 	IMSG_CTL_DEBUG,
 36 5c69b561 2022-01-29 op 	IMSG_CTL_DEBUG_BACK,	/* kd_debug_info */
 37 5c69b561 2022-01-29 op 	IMSG_CTL_DEBUG_END,
 38 fb1a36c0 2022-01-09 op 	IMSG_STARTUP,
 39 fb1a36c0 2022-01-09 op 	IMSG_RECONF_CONF,
 40 fb1a36c0 2022-01-09 op 	IMSG_RECONF_PKI,
 41 fb1a36c0 2022-01-09 op 	IMSG_RECONF_PKI_CERT,
 42 fb1a36c0 2022-01-09 op 	IMSG_RECONF_PKI_KEY,
 43 fb1a36c0 2022-01-09 op 	IMSG_RECONF_LISTEN,
 44 fb1a36c0 2022-01-09 op 	IMSG_RECONF_END,
 45 1e84c7b7 2022-01-10 op 	IMSG_AUTH,		/* kd_auth_proc */
 46 1e84c7b7 2022-01-10 op 	IMSG_AUTH_TLS,		/* kd_auth_req */
 47 fb1a36c0 2022-01-09 op 	IMSG_CONN_GONE,
 48 fb1a36c0 2022-01-09 op 	IMSG_BUF,
 49 8b0a5062 2022-05-22 op 	IMSG_BUF_CONT,
 50 fb1a36c0 2022-01-09 op 	IMSG_MSIZE,
 51 fb1a36c0 2022-01-09 op 	IMSG_CLOSE,
 52 fb1a36c0 2022-01-09 op };
 53 fb1a36c0 2022-01-09 op 
 54 fb1a36c0 2022-01-09 op struct kd_options_conf {
 55 fb1a36c0 2022-01-09 op 	/* ... */
 56 fb1a36c0 2022-01-09 op };
 57 fb1a36c0 2022-01-09 op 
 58 35c6cd0e 2022-01-10 op struct table;
 59 fb1a36c0 2022-01-09 op 
 60 fb1a36c0 2022-01-09 op #define L_NONE	0x0
 61 fb1a36c0 2022-01-09 op #define L_TLS	0x1
 62 fb1a36c0 2022-01-09 op struct kd_listen_conf {
 63 fb1a36c0 2022-01-09 op 	STAILQ_ENTRY(kd_listen_conf)	 entry;
 64 fb1a36c0 2022-01-09 op 	uint32_t			 id;
 65 fb1a36c0 2022-01-09 op 	uint32_t			 flags;
 66 fb1a36c0 2022-01-09 op 	int				 fd;
 67 fb1a36c0 2022-01-09 op 	char				 iface[LINE_MAX];
 68 fb1a36c0 2022-01-09 op 	uint16_t			 port;
 69 fb1a36c0 2022-01-09 op 
 70 fb1a36c0 2022-01-09 op 	/* certificate hash => (virtual) user */
 71 fb1a36c0 2022-01-09 op 	struct table			*auth_table;
 72 fb1a36c0 2022-01-09 op 
 73 fb1a36c0 2022-01-09 op 	/* virtual user => local user */
 74 fb1a36c0 2022-01-09 op 	struct table			*virtual_table;
 75 fb1a36c0 2022-01-09 op 
 76 fb1a36c0 2022-01-09 op 	/* (virtual) user => export directory */
 77 fb1a36c0 2022-01-09 op 	struct table			*userdata_table;
 78 fb1a36c0 2022-01-09 op 
 79 fb1a36c0 2022-01-09 op 	char				 pki[LINE_MAX];
 80 fb1a36c0 2022-01-09 op 	struct event			 ev;
 81 fb1a36c0 2022-01-09 op 	struct tls			*ctx;
 82 fb1a36c0 2022-01-09 op };
 83 fb1a36c0 2022-01-09 op 
 84 fb1a36c0 2022-01-09 op struct kd_pki_conf {
 85 fb1a36c0 2022-01-09 op 	STAILQ_ENTRY(kd_pki_conf)	 entry;
 86 fb1a36c0 2022-01-09 op 	char				 name[LINE_MAX];
 87 fb1a36c0 2022-01-09 op 	uint8_t				*cert;
 88 fb1a36c0 2022-01-09 op 	size_t				 certlen;
 89 fb1a36c0 2022-01-09 op 	uint8_t				*key;
 90 fb1a36c0 2022-01-09 op 	size_t				 keylen;
 91 fb1a36c0 2022-01-09 op 	struct tls_config		*tlsconf;
 92 fb1a36c0 2022-01-09 op };
 93 fb1a36c0 2022-01-09 op 
 94 fb1a36c0 2022-01-09 op struct kd_tables_conf {
 95 fb1a36c0 2022-01-09 op 	STAILQ_ENTRY(kd_tables_conf)	 entry;
 96 fb1a36c0 2022-01-09 op 	struct table			*table;
 97 fb1a36c0 2022-01-09 op };
 98 fb1a36c0 2022-01-09 op 
 99 fb1a36c0 2022-01-09 op struct kd_conf {
100 fb1a36c0 2022-01-09 op 	struct kd_options_conf					 kd_options;
101 fb1a36c0 2022-01-09 op 	STAILQ_HEAD(kd_pki_conf_head, kd_pki_conf)		 pki_head;
102 fb1a36c0 2022-01-09 op 	STAILQ_HEAD(kd_tables_conf_head, kd_tables_conf)	 table_head;
103 fb1a36c0 2022-01-09 op 	STAILQ_HEAD(kd_listen_conf_head, kd_listen_conf)	 listen_head;
104 fb1a36c0 2022-01-09 op };
105 fb1a36c0 2022-01-09 op 
106 fb1a36c0 2022-01-09 op struct kd_auth_req {
107 fb1a36c0 2022-01-09 op 	uint32_t	listen_id;
108 fb1a36c0 2022-01-09 op 	char		hash[128+1];
109 fb1a36c0 2022-01-09 op };
110 fb1a36c0 2022-01-09 op 
111 1e84c7b7 2022-01-10 op struct kd_auth_proc {
112 1e84c7b7 2022-01-10 op 	char		uname[LOGIN_NAME_MAX];
113 1e84c7b7 2022-01-10 op 	char		dir[PATH_MAX];
114 1e84c7b7 2022-01-10 op };
115 1e84c7b7 2022-01-10 op 
116 5c69b561 2022-01-29 op struct kd_debug_info {
117 5c69b561 2022-01-29 op 	uint32_t	client_id;
118 5c69b561 2022-01-29 op 	uint32_t	fid;
119 5c69b561 2022-01-29 op 	char		path[NAME_MAX];
120 5c69b561 2022-01-29 op };
121 5c69b561 2022-01-29 op 
122 fb1a36c0 2022-01-09 op /* kamid.c */
123 fb1a36c0 2022-01-09 op extern int verbose;
124 a80d2bca 2022-01-23 op int	main_reload(void);
125 fb1a36c0 2022-01-09 op int	main_imsg_compose_listener(int, int, uint32_t, const void *, uint16_t);
126 fb1a36c0 2022-01-09 op void	merge_config(struct kd_conf *, struct kd_conf *);
127 fb1a36c0 2022-01-09 op 
128 fb1a36c0 2022-01-09 op struct kd_conf	*config_new_empty(void);
129 fb1a36c0 2022-01-09 op void		 config_clear(struct kd_conf *);
130 fb1a36c0 2022-01-09 op 
131 fb1a36c0 2022-01-09 op /* parse.y */
132 fb1a36c0 2022-01-09 op struct kd_conf	*parse_config(const char *);
133 fb1a36c0 2022-01-09 op int		 cmdline_symset(char *);
134 d5207cf4 2022-01-28 op void		 clear_config(struct kd_conf *);
135 fb1a36c0 2022-01-09 op 
136 fb1a36c0 2022-01-09 op #endif