Blame


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 #include <endian.h>
18 fb1a36c0 2022-01-09 op #include <event.h>
19 fb1a36c0 2022-01-09 op #include <inttypes.h>
20 fb1a36c0 2022-01-09 op #include <string.h>
21 fb1a36c0 2022-01-09 op
22 fb1a36c0 2022-01-09 op #include "9pclib.h"
23 fb1a36c0 2022-01-09 op #include "kami.h"
24 fb1a36c0 2022-01-09 op #include "log.h"
25 fb1a36c0 2022-01-09 op #include "utils.h"
26 fb1a36c0 2022-01-09 op
27 fb1a36c0 2022-01-09 op uint16_t iota_tag;
28 fb1a36c0 2022-01-09 op
29 fb1a36c0 2022-01-09 op struct evbuffer *evb;
30 fb1a36c0 2022-01-09 op
31 fb1a36c0 2022-01-09 op void
32 fb1a36c0 2022-01-09 op write_hdr(uint32_t len, uint8_t type, uint16_t tag)
33 fb1a36c0 2022-01-09 op {
34 fb1a36c0 2022-01-09 op len += HEADERSIZE;
35 fb1a36c0 2022-01-09 op
36 fb1a36c0 2022-01-09 op log_debug("enqueuing a packet; len=%"PRIu32" type=%d[%s] tag=%d",
37 fb1a36c0 2022-01-09 op len, type, pp_msg_type(type), tag);
38 fb1a36c0 2022-01-09 op
39 fb1a36c0 2022-01-09 op len = htole32(len);
40 fb1a36c0 2022-01-09 op /* type is one byte, no endiannes issues */
41 fb1a36c0 2022-01-09 op tag = htole16(tag);
42 fb1a36c0 2022-01-09 op
43 fb1a36c0 2022-01-09 op evbuffer_add(evb, &len, sizeof(len));
44 fb1a36c0 2022-01-09 op evbuffer_add(evb, &type, sizeof(type));
45 fb1a36c0 2022-01-09 op evbuffer_add(evb, &tag, sizeof(tag));
46 fb1a36c0 2022-01-09 op }
47 fb1a36c0 2022-01-09 op
48 fb1a36c0 2022-01-09 op void
49 fb1a36c0 2022-01-09 op write_hdr_auto(uint32_t len, uint8_t type)
50 fb1a36c0 2022-01-09 op {
51 fb1a36c0 2022-01-09 op if (++iota_tag == NOTAG)
52 fb1a36c0 2022-01-09 op ++iota_tag;
53 fb1a36c0 2022-01-09 op write_hdr(len, type, iota_tag);
54 fb1a36c0 2022-01-09 op }
55 fb1a36c0 2022-01-09 op
56 fb1a36c0 2022-01-09 op void
57 fb1a36c0 2022-01-09 op write_str(uint16_t len, const char *str)
58 fb1a36c0 2022-01-09 op {
59 fb1a36c0 2022-01-09 op uint16_t l = len;
60 fb1a36c0 2022-01-09 op
61 fb1a36c0 2022-01-09 op len = htole16(len);
62 fb1a36c0 2022-01-09 op evbuffer_add(evb, &len, sizeof(len));
63 fb1a36c0 2022-01-09 op evbuffer_add(evb, str, l);
64 fb1a36c0 2022-01-09 op }
65 fb1a36c0 2022-01-09 op
66 fb1a36c0 2022-01-09 op void
67 fb1a36c0 2022-01-09 op write_str_auto(const char *str)
68 fb1a36c0 2022-01-09 op {
69 fb1a36c0 2022-01-09 op write_str(strlen(str), str);
70 fb1a36c0 2022-01-09 op }
71 fb1a36c0 2022-01-09 op
72 fb1a36c0 2022-01-09 op void
73 fb1a36c0 2022-01-09 op write_buf(const void *d, uint32_t len)
74 fb1a36c0 2022-01-09 op {
75 fb1a36c0 2022-01-09 op write_32(len);
76 fb1a36c0 2022-01-09 op evbuffer_add(evb, d, len);
77 fb1a36c0 2022-01-09 op }
78 fb1a36c0 2022-01-09 op
79 fb1a36c0 2022-01-09 op void
80 fb1a36c0 2022-01-09 op write_64(uint64_t x)
81 fb1a36c0 2022-01-09 op {
82 fb1a36c0 2022-01-09 op x = htole64(x);
83 fb1a36c0 2022-01-09 op evbuffer_add(evb, &x, sizeof(x));
84 fb1a36c0 2022-01-09 op }
85 fb1a36c0 2022-01-09 op
86 fb1a36c0 2022-01-09 op void
87 fb1a36c0 2022-01-09 op write_32(uint32_t fid)
88 fb1a36c0 2022-01-09 op {
89 fb1a36c0 2022-01-09 op fid = htole32(fid);
90 fb1a36c0 2022-01-09 op evbuffer_add(evb, &fid, sizeof(fid));
91 fb1a36c0 2022-01-09 op }
92 fb1a36c0 2022-01-09 op
93 fb1a36c0 2022-01-09 op void
94 fb1a36c0 2022-01-09 op write_16(uint16_t tag)
95 fb1a36c0 2022-01-09 op {
96 fb1a36c0 2022-01-09 op tag = htole16(tag);
97 fb1a36c0 2022-01-09 op evbuffer_add(evb, &tag, sizeof(tag));
98 fb1a36c0 2022-01-09 op }
99 fb1a36c0 2022-01-09 op
100 fb1a36c0 2022-01-09 op void
101 fb1a36c0 2022-01-09 op write_8(uint8_t x)
102 fb1a36c0 2022-01-09 op {
103 fb1a36c0 2022-01-09 op evbuffer_add(evb, &x, sizeof(x));
104 fb1a36c0 2022-01-09 op }
105 fb1a36c0 2022-01-09 op
106 fb1a36c0 2022-01-09 op
107 fb1a36c0 2022-01-09 op
108 fb1a36c0 2022-01-09 op void
109 fb1a36c0 2022-01-09 op tversion(const char *v, uint32_t msize)
110 fb1a36c0 2022-01-09 op {
111 fb1a36c0 2022-01-09 op uint32_t len;
112 fb1a36c0 2022-01-09 op uint16_t sl;
113 fb1a36c0 2022-01-09 op
114 fb1a36c0 2022-01-09 op sl = strlen(v);
115 fb1a36c0 2022-01-09 op
116 fb1a36c0 2022-01-09 op /* msize[4] version[s] */
117 fb1a36c0 2022-01-09 op len = sizeof(msize) + sizeof(sl) + sl;
118 fb1a36c0 2022-01-09 op write_hdr(len, Tversion, NOTAG);
119 fb1a36c0 2022-01-09 op write_32(msize);
120 fb1a36c0 2022-01-09 op write_str(sl, v);
121 fb1a36c0 2022-01-09 op }
122 fb1a36c0 2022-01-09 op
123 fb1a36c0 2022-01-09 op void
124 fb1a36c0 2022-01-09 op tattach(uint32_t fid, uint32_t afid, const char *uname, const char *aname)
125 fb1a36c0 2022-01-09 op {
126 fb1a36c0 2022-01-09 op uint32_t len;
127 fb1a36c0 2022-01-09 op uint16_t ul, al;
128 fb1a36c0 2022-01-09 op
129 fb1a36c0 2022-01-09 op ul = strlen(uname);
130 fb1a36c0 2022-01-09 op al = strlen(aname);
131 fb1a36c0 2022-01-09 op
132 fb1a36c0 2022-01-09 op /* fid[4] afid[4] uname[s] aname[s] */
133 fb1a36c0 2022-01-09 op len = sizeof(fid) + sizeof(afid) + sizeof(ul) + ul
134 fb1a36c0 2022-01-09 op + sizeof(al) + al;
135 fb1a36c0 2022-01-09 op write_hdr_auto(len, Tattach);
136 fb1a36c0 2022-01-09 op write_fid(fid);
137 fb1a36c0 2022-01-09 op write_fid(afid);
138 fb1a36c0 2022-01-09 op write_str(ul, uname);
139 fb1a36c0 2022-01-09 op write_str(al, aname);
140 fb1a36c0 2022-01-09 op }
141 fb1a36c0 2022-01-09 op
142 fb1a36c0 2022-01-09 op void
143 fb1a36c0 2022-01-09 op tclunk(uint32_t fid)
144 fb1a36c0 2022-01-09 op {
145 fb1a36c0 2022-01-09 op uint32_t len;
146 fb1a36c0 2022-01-09 op
147 fb1a36c0 2022-01-09 op /* fid[4] */
148 fb1a36c0 2022-01-09 op len = sizeof(fid);
149 fb1a36c0 2022-01-09 op write_hdr_auto(len, Tclunk);
150 fb1a36c0 2022-01-09 op write_fid(fid);
151 fb1a36c0 2022-01-09 op }
152 fb1a36c0 2022-01-09 op
153 fb1a36c0 2022-01-09 op void
154 fb1a36c0 2022-01-09 op tflush(uint16_t oldtag)
155 fb1a36c0 2022-01-09 op {
156 fb1a36c0 2022-01-09 op uint32_t len;
157 fb1a36c0 2022-01-09 op
158 fb1a36c0 2022-01-09 op /* oldtag[2] */
159 fb1a36c0 2022-01-09 op len = sizeof(oldtag);
160 fb1a36c0 2022-01-09 op write_hdr_auto(len, Tflush);
161 fb1a36c0 2022-01-09 op write_tag(oldtag);
162 fb1a36c0 2022-01-09 op }
163 fb1a36c0 2022-01-09 op
164 fb1a36c0 2022-01-09 op void
165 fb1a36c0 2022-01-09 op twalk(uint32_t fid, uint32_t newfid, const char **wnames, size_t nwname)
166 fb1a36c0 2022-01-09 op {
167 fb1a36c0 2022-01-09 op size_t i;
168 fb1a36c0 2022-01-09 op uint32_t len;
169 fb1a36c0 2022-01-09 op
170 fb1a36c0 2022-01-09 op /* fid[4] newfid[4] nwname[2] nwname*(wname[s]) */
171 fb1a36c0 2022-01-09 op len = sizeof(fid) + sizeof(newfid) + 2;
172 fb1a36c0 2022-01-09 op for (i = 0; i < nwname; ++i)
173 fb1a36c0 2022-01-09 op len += 2 + strlen(wnames[i]);
174 fb1a36c0 2022-01-09 op
175 fb1a36c0 2022-01-09 op write_hdr_auto(len, Twalk);
176 fb1a36c0 2022-01-09 op write_fid(fid);
177 fb1a36c0 2022-01-09 op write_fid(newfid);
178 fb1a36c0 2022-01-09 op write_16(nwname);
179 fb1a36c0 2022-01-09 op for (i = 0; i < nwname; ++i)
180 fb1a36c0 2022-01-09 op write_str_auto(wnames[i]);
181 fb1a36c0 2022-01-09 op }
182 fb1a36c0 2022-01-09 op
183 fb1a36c0 2022-01-09 op void
184 fb1a36c0 2022-01-09 op topen(uint32_t fid, uint8_t mode)
185 fb1a36c0 2022-01-09 op {
186 fb1a36c0 2022-01-09 op uint32_t len;
187 fb1a36c0 2022-01-09 op
188 fb1a36c0 2022-01-09 op /* fid[4] mode[1] */
189 fb1a36c0 2022-01-09 op len = sizeof(fid) + sizeof(mode);
190 fb1a36c0 2022-01-09 op write_hdr_auto(len, Topen);
191 fb1a36c0 2022-01-09 op write_fid(fid);
192 fb1a36c0 2022-01-09 op write_8(mode);
193 fb1a36c0 2022-01-09 op }
194 fb1a36c0 2022-01-09 op
195 fb1a36c0 2022-01-09 op void
196 fb1a36c0 2022-01-09 op tcreate(uint32_t fid, const char *name, uint32_t perm, uint8_t mode)
197 fb1a36c0 2022-01-09 op {
198 fb1a36c0 2022-01-09 op uint32_t len;
199 fb1a36c0 2022-01-09 op uint16_t nl;
200 fb1a36c0 2022-01-09 op
201 fb1a36c0 2022-01-09 op /* fid[4] name[s] perm[4] mode[1] */
202 fb1a36c0 2022-01-09 op nl = strlen(name);
203 fb1a36c0 2022-01-09 op len = sizeof(fid) + sizeof(nl) + nl + sizeof(perm) + sizeof(mode);
204 fb1a36c0 2022-01-09 op write_hdr_auto(len, Tcreate);
205 fb1a36c0 2022-01-09 op write_fid(fid);
206 fb1a36c0 2022-01-09 op write_str(nl, name);
207 fb1a36c0 2022-01-09 op write_32(perm);
208 fb1a36c0 2022-01-09 op write_8(mode);
209 fb1a36c0 2022-01-09 op }
210 fb1a36c0 2022-01-09 op
211 fb1a36c0 2022-01-09 op void
212 fb1a36c0 2022-01-09 op tread(uint32_t fid, uint64_t off, uint32_t count)
213 fb1a36c0 2022-01-09 op {
214 fb1a36c0 2022-01-09 op uint32_t len;
215 fb1a36c0 2022-01-09 op
216 fb1a36c0 2022-01-09 op /* fid[4] off[8] count[4] */
217 fb1a36c0 2022-01-09 op len = sizeof(fid) + sizeof(off) + sizeof(count);
218 fb1a36c0 2022-01-09 op write_hdr_auto(len, Tread);
219 fb1a36c0 2022-01-09 op write_fid(fid);
220 fb1a36c0 2022-01-09 op write_off(off);
221 fb1a36c0 2022-01-09 op write_32(count);
222 fb1a36c0 2022-01-09 op }
223 fb1a36c0 2022-01-09 op
224 fb1a36c0 2022-01-09 op void
225 fb1a36c0 2022-01-09 op twrite(uint32_t fid, uint64_t off, const void *data, uint32_t count)
226 fb1a36c0 2022-01-09 op {
227 fb1a36c0 2022-01-09 op uint32_t len;
228 fb1a36c0 2022-01-09 op
229 fb1a36c0 2022-01-09 op /* fid[4] off[8] count[4] data[count] */
230 fb1a36c0 2022-01-09 op len = sizeof(fid) + sizeof(off) + sizeof(count) + count;
231 fb1a36c0 2022-01-09 op write_hdr_auto(len, Twrite);
232 fb1a36c0 2022-01-09 op write_fid(fid);
233 fb1a36c0 2022-01-09 op write_off(off);
234 fb1a36c0 2022-01-09 op write_buf(data, count);
235 fb1a36c0 2022-01-09 op }
236 fb1a36c0 2022-01-09 op
237 fb1a36c0 2022-01-09 op void
238 fb1a36c0 2022-01-09 op tstat(uint32_t fid)
239 fb1a36c0 2022-01-09 op {
240 fb1a36c0 2022-01-09 op /* fid[4] */
241 fb1a36c0 2022-01-09 op write_hdr_auto(sizeof(fid), Tstat);
242 fb1a36c0 2022-01-09 op write_fid(fid);
243 fb1a36c0 2022-01-09 op }
244 fb1a36c0 2022-01-09 op
245 fb1a36c0 2022-01-09 op void
246 fb1a36c0 2022-01-09 op tremove(uint32_t fid)
247 fb1a36c0 2022-01-09 op {
248 fb1a36c0 2022-01-09 op /* fid[4] */
249 fb1a36c0 2022-01-09 op write_hdr_auto(sizeof(fid), Tremove);
250 fb1a36c0 2022-01-09 op write_fid(fid);
251 fb1a36c0 2022-01-09 op }