1 /* AFS Cache Manager Service
2 *
3 * Copyright (C) 2002 Red Hat, Inc. All Rights Reserved.
4 * Written by David Howells (dhowells@redhat.com)
5 *
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public License
8 * as published by the Free Software Foundation; either version
9 * 2 of the License, or (at your option) any later version.
10 */
11
12 #include <linux/module.h>
13 #include <linux/init.h>
14 #include <linux/slab.h>
15 #include <linux/sched.h>
16 #include <linux/ip.h>
17 #include "internal.h"
18 #include "afs_cm.h"
19
20 #if 0
21 struct workqueue_struct *afs_cm_workqueue;
22 #endif /* 0 */
23
24 static int afs_deliver_cb_init_call_back_state(struct afs_call *,
25 struct sk_buff *, bool);
26 static int afs_deliver_cb_init_call_back_state3(struct afs_call *,
27 struct sk_buff *, bool);
28 static int afs_deliver_cb_probe(struct afs_call *, struct sk_buff *, bool);
29 static int afs_deliver_cb_callback(struct afs_call *, struct sk_buff *, bool);
30 static int afs_deliver_cb_probe_uuid(struct afs_call *, struct sk_buff *, bool);
31 static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *,
32 struct sk_buff *, bool);
33 static void afs_cm_destructor(struct afs_call *);
34
35 /*
36 * CB.CallBack operation type
37 */
38 static const struct afs_call_type afs_SRXCBCallBack = {
39 .name = "CB.CallBack",
40 .deliver = afs_deliver_cb_callback,
41 .abort_to_error = afs_abort_to_error,
42 .destructor = afs_cm_destructor,
43 };
44
45 /*
46 * CB.InitCallBackState operation type
47 */
48 static const struct afs_call_type afs_SRXCBInitCallBackState = {
49 .name = "CB.InitCallBackState",
50 .deliver = afs_deliver_cb_init_call_back_state,
51 .abort_to_error = afs_abort_to_error,
52 .destructor = afs_cm_destructor,
53 };
54
55 /*
56 * CB.InitCallBackState3 operation type
57 */
58 static const struct afs_call_type afs_SRXCBInitCallBackState3 = {
59 .name = "CB.InitCallBackState3",
60 .deliver = afs_deliver_cb_init_call_back_state3,
61 .abort_to_error = afs_abort_to_error,
62 .destructor = afs_cm_destructor,
63 };
64
65 /*
66 * CB.Probe operation type
67 */
68 static const struct afs_call_type afs_SRXCBProbe = {
69 .name = "CB.Probe",
70 .deliver = afs_deliver_cb_probe,
71 .abort_to_error = afs_abort_to_error,
72 .destructor = afs_cm_destructor,
73 };
74
75 /*
76 * CB.ProbeUuid operation type
77 */
78 static const struct afs_call_type afs_SRXCBProbeUuid = {
79 .name = "CB.ProbeUuid",
80 .deliver = afs_deliver_cb_probe_uuid,
81 .abort_to_error = afs_abort_to_error,
82 .destructor = afs_cm_destructor,
83 };
84
85 /*
86 * CB.TellMeAboutYourself operation type
87 */
88 static const struct afs_call_type afs_SRXCBTellMeAboutYourself = {
89 .name = "CB.TellMeAboutYourself",
90 .deliver = afs_deliver_cb_tell_me_about_yourself,
91 .abort_to_error = afs_abort_to_error,
92 .destructor = afs_cm_destructor,
93 };
94
95 /*
96 * route an incoming cache manager call
97 * - return T if supported, F if not
98 */
afs_cm_incoming_call(struct afs_call * call)99 bool afs_cm_incoming_call(struct afs_call *call)
100 {
101 u32 operation_id = ntohl(call->operation_ID);
102
103 _enter("{CB.OP %u}", operation_id);
104
105 switch (operation_id) {
106 case CBCallBack:
107 call->type = &afs_SRXCBCallBack;
108 return true;
109 case CBInitCallBackState:
110 call->type = &afs_SRXCBInitCallBackState;
111 return true;
112 case CBInitCallBackState3:
113 call->type = &afs_SRXCBInitCallBackState3;
114 return true;
115 case CBProbe:
116 call->type = &afs_SRXCBProbe;
117 return true;
118 case CBProbeUuid:
119 call->type = &afs_SRXCBProbeUuid;
120 return true;
121 case CBTellMeAboutYourself:
122 call->type = &afs_SRXCBTellMeAboutYourself;
123 return true;
124 default:
125 return false;
126 }
127 }
128
129 /*
130 * clean up a cache manager call
131 */
afs_cm_destructor(struct afs_call * call)132 static void afs_cm_destructor(struct afs_call *call)
133 {
134 _enter("");
135
136 /* Break the callbacks here so that we do it after the final ACK is
137 * received. The step number here must match the final number in
138 * afs_deliver_cb_callback().
139 */
140 if (call->unmarshall == 6) {
141 ASSERT(call->server && call->count && call->request);
142 afs_break_callbacks(call->server, call->count, call->request);
143 }
144
145 afs_put_server(call->server);
146 call->server = NULL;
147 kfree(call->buffer);
148 call->buffer = NULL;
149 }
150
151 /*
152 * allow the fileserver to see if the cache manager is still alive
153 */
SRXAFSCB_CallBack(struct work_struct * work)154 static void SRXAFSCB_CallBack(struct work_struct *work)
155 {
156 struct afs_call *call = container_of(work, struct afs_call, work);
157
158 _enter("");
159
160 /* be sure to send the reply *before* attempting to spam the AFS server
161 * with FSFetchStatus requests on the vnodes with broken callbacks lest
162 * the AFS server get into a vicious cycle of trying to break further
163 * callbacks because it hadn't received completion of the CBCallBack op
164 * yet */
165 afs_send_empty_reply(call);
166
167 afs_break_callbacks(call->server, call->count, call->request);
168 _leave("");
169 }
170
171 /*
172 * deliver request data to a CB.CallBack call
173 */
afs_deliver_cb_callback(struct afs_call * call,struct sk_buff * skb,bool last)174 static int afs_deliver_cb_callback(struct afs_call *call, struct sk_buff *skb,
175 bool last)
176 {
177 struct afs_callback *cb;
178 struct afs_server *server;
179 struct in_addr addr;
180 __be32 *bp;
181 u32 tmp;
182 int ret, loop;
183
184 _enter("{%u},{%u},%d", call->unmarshall, skb->len, last);
185
186 switch (call->unmarshall) {
187 case 0:
188 call->offset = 0;
189 call->unmarshall++;
190
191 /* extract the FID array and its count in two steps */
192 case 1:
193 _debug("extract FID count");
194 ret = afs_extract_data(call, skb, last, &call->tmp, 4);
195 switch (ret) {
196 case 0: break;
197 case -EAGAIN: return 0;
198 default: return ret;
199 }
200
201 call->count = ntohl(call->tmp);
202 _debug("FID count: %u", call->count);
203 if (call->count > AFSCBMAX)
204 return -EBADMSG;
205
206 call->buffer = kmalloc(call->count * 3 * 4, GFP_KERNEL);
207 if (!call->buffer)
208 return -ENOMEM;
209 call->offset = 0;
210 call->unmarshall++;
211
212 case 2:
213 _debug("extract FID array");
214 ret = afs_extract_data(call, skb, last, call->buffer,
215 call->count * 3 * 4);
216 switch (ret) {
217 case 0: break;
218 case -EAGAIN: return 0;
219 default: return ret;
220 }
221
222 _debug("unmarshall FID array");
223 call->request = kcalloc(call->count,
224 sizeof(struct afs_callback),
225 GFP_KERNEL);
226 if (!call->request)
227 return -ENOMEM;
228
229 cb = call->request;
230 bp = call->buffer;
231 for (loop = call->count; loop > 0; loop--, cb++) {
232 cb->fid.vid = ntohl(*bp++);
233 cb->fid.vnode = ntohl(*bp++);
234 cb->fid.unique = ntohl(*bp++);
235 cb->type = AFSCM_CB_UNTYPED;
236 }
237
238 call->offset = 0;
239 call->unmarshall++;
240
241 /* extract the callback array and its count in two steps */
242 case 3:
243 _debug("extract CB count");
244 ret = afs_extract_data(call, skb, last, &call->tmp, 4);
245 switch (ret) {
246 case 0: break;
247 case -EAGAIN: return 0;
248 default: return ret;
249 }
250
251 tmp = ntohl(call->tmp);
252 _debug("CB count: %u", tmp);
253 if (tmp != call->count && tmp != 0)
254 return -EBADMSG;
255 call->offset = 0;
256 call->unmarshall++;
257 if (tmp == 0)
258 goto empty_cb_array;
259
260 case 4:
261 _debug("extract CB array");
262 ret = afs_extract_data(call, skb, last, call->request,
263 call->count * 3 * 4);
264 switch (ret) {
265 case 0: break;
266 case -EAGAIN: return 0;
267 default: return ret;
268 }
269
270 _debug("unmarshall CB array");
271 cb = call->request;
272 bp = call->buffer;
273 for (loop = call->count; loop > 0; loop--, cb++) {
274 cb->version = ntohl(*bp++);
275 cb->expiry = ntohl(*bp++);
276 cb->type = ntohl(*bp++);
277 }
278
279 empty_cb_array:
280 call->offset = 0;
281 call->unmarshall++;
282
283 case 5:
284 _debug("trailer");
285 if (skb->len != 0)
286 return -EBADMSG;
287
288 /* Record that the message was unmarshalled successfully so
289 * that the call destructor can know do the callback breaking
290 * work, even if the final ACK isn't received.
291 *
292 * If the step number changes, then afs_cm_destructor() must be
293 * updated also.
294 */
295 call->unmarshall++;
296 case 6:
297 break;
298 }
299
300 if (!last)
301 return 0;
302
303 call->state = AFS_CALL_REPLYING;
304
305 /* we'll need the file server record as that tells us which set of
306 * vnodes to operate upon */
307 memcpy(&addr, &ip_hdr(skb)->saddr, 4);
308 server = afs_find_server(&addr);
309 if (!server)
310 return -ENOTCONN;
311 call->server = server;
312
313 INIT_WORK(&call->work, SRXAFSCB_CallBack);
314 queue_work(afs_wq, &call->work);
315 return 0;
316 }
317
318 /*
319 * allow the fileserver to request callback state (re-)initialisation
320 */
SRXAFSCB_InitCallBackState(struct work_struct * work)321 static void SRXAFSCB_InitCallBackState(struct work_struct *work)
322 {
323 struct afs_call *call = container_of(work, struct afs_call, work);
324
325 _enter("{%p}", call->server);
326
327 afs_init_callback_state(call->server);
328 afs_send_empty_reply(call);
329 _leave("");
330 }
331
332 /*
333 * deliver request data to a CB.InitCallBackState call
334 */
afs_deliver_cb_init_call_back_state(struct afs_call * call,struct sk_buff * skb,bool last)335 static int afs_deliver_cb_init_call_back_state(struct afs_call *call,
336 struct sk_buff *skb,
337 bool last)
338 {
339 struct afs_server *server;
340 struct in_addr addr;
341
342 _enter(",{%u},%d", skb->len, last);
343
344 if (skb->len > 0)
345 return -EBADMSG;
346 if (!last)
347 return 0;
348
349 /* no unmarshalling required */
350 call->state = AFS_CALL_REPLYING;
351
352 /* we'll need the file server record as that tells us which set of
353 * vnodes to operate upon */
354 memcpy(&addr, &ip_hdr(skb)->saddr, 4);
355 server = afs_find_server(&addr);
356 if (!server)
357 return -ENOTCONN;
358 call->server = server;
359
360 INIT_WORK(&call->work, SRXAFSCB_InitCallBackState);
361 queue_work(afs_wq, &call->work);
362 return 0;
363 }
364
365 /*
366 * deliver request data to a CB.InitCallBackState3 call
367 */
afs_deliver_cb_init_call_back_state3(struct afs_call * call,struct sk_buff * skb,bool last)368 static int afs_deliver_cb_init_call_back_state3(struct afs_call *call,
369 struct sk_buff *skb,
370 bool last)
371 {
372 struct afs_server *server;
373 struct in_addr addr;
374
375 _enter(",{%u},%d", skb->len, last);
376
377 if (!last)
378 return 0;
379
380 /* no unmarshalling required */
381 call->state = AFS_CALL_REPLYING;
382
383 /* we'll need the file server record as that tells us which set of
384 * vnodes to operate upon */
385 memcpy(&addr, &ip_hdr(skb)->saddr, 4);
386 server = afs_find_server(&addr);
387 if (!server)
388 return -ENOTCONN;
389 call->server = server;
390
391 INIT_WORK(&call->work, SRXAFSCB_InitCallBackState);
392 queue_work(afs_wq, &call->work);
393 return 0;
394 }
395
396 /*
397 * allow the fileserver to see if the cache manager is still alive
398 */
SRXAFSCB_Probe(struct work_struct * work)399 static void SRXAFSCB_Probe(struct work_struct *work)
400 {
401 struct afs_call *call = container_of(work, struct afs_call, work);
402
403 _enter("");
404 afs_send_empty_reply(call);
405 _leave("");
406 }
407
408 /*
409 * deliver request data to a CB.Probe call
410 */
afs_deliver_cb_probe(struct afs_call * call,struct sk_buff * skb,bool last)411 static int afs_deliver_cb_probe(struct afs_call *call, struct sk_buff *skb,
412 bool last)
413 {
414 _enter(",{%u},%d", skb->len, last);
415
416 if (skb->len > 0)
417 return -EBADMSG;
418 if (!last)
419 return 0;
420
421 /* no unmarshalling required */
422 call->state = AFS_CALL_REPLYING;
423
424 INIT_WORK(&call->work, SRXAFSCB_Probe);
425 queue_work(afs_wq, &call->work);
426 return 0;
427 }
428
429 /*
430 * allow the fileserver to quickly find out if the fileserver has been rebooted
431 */
SRXAFSCB_ProbeUuid(struct work_struct * work)432 static void SRXAFSCB_ProbeUuid(struct work_struct *work)
433 {
434 struct afs_call *call = container_of(work, struct afs_call, work);
435 struct afs_uuid *r = call->request;
436
437 struct {
438 __be32 match;
439 } reply;
440
441 _enter("");
442
443
444 if (memcmp(r, &afs_uuid, sizeof(afs_uuid)) == 0)
445 reply.match = htonl(0);
446 else
447 reply.match = htonl(1);
448
449 afs_send_simple_reply(call, &reply, sizeof(reply));
450 _leave("");
451 }
452
453 /*
454 * deliver request data to a CB.ProbeUuid call
455 */
afs_deliver_cb_probe_uuid(struct afs_call * call,struct sk_buff * skb,bool last)456 static int afs_deliver_cb_probe_uuid(struct afs_call *call, struct sk_buff *skb,
457 bool last)
458 {
459 struct afs_uuid *r;
460 unsigned loop;
461 __be32 *b;
462 int ret;
463
464 _enter("{%u},{%u},%d", call->unmarshall, skb->len, last);
465
466 if (skb->len > 0)
467 return -EBADMSG;
468 if (!last)
469 return 0;
470
471 switch (call->unmarshall) {
472 case 0:
473 call->offset = 0;
474 call->buffer = kmalloc(11 * sizeof(__be32), GFP_KERNEL);
475 if (!call->buffer)
476 return -ENOMEM;
477 call->unmarshall++;
478
479 case 1:
480 _debug("extract UUID");
481 ret = afs_extract_data(call, skb, last, call->buffer,
482 11 * sizeof(__be32));
483 switch (ret) {
484 case 0: break;
485 case -EAGAIN: return 0;
486 default: return ret;
487 }
488
489 _debug("unmarshall UUID");
490 call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL);
491 if (!call->request)
492 return -ENOMEM;
493
494 b = call->buffer;
495 r = call->request;
496 r->time_low = ntohl(b[0]);
497 r->time_mid = ntohl(b[1]);
498 r->time_hi_and_version = ntohl(b[2]);
499 r->clock_seq_hi_and_reserved = ntohl(b[3]);
500 r->clock_seq_low = ntohl(b[4]);
501
502 for (loop = 0; loop < 6; loop++)
503 r->node[loop] = ntohl(b[loop + 5]);
504
505 call->offset = 0;
506 call->unmarshall++;
507
508 case 2:
509 _debug("trailer");
510 if (skb->len != 0)
511 return -EBADMSG;
512 break;
513 }
514
515 if (!last)
516 return 0;
517
518 call->state = AFS_CALL_REPLYING;
519
520 INIT_WORK(&call->work, SRXAFSCB_ProbeUuid);
521 queue_work(afs_wq, &call->work);
522 return 0;
523 }
524
525 /*
526 * allow the fileserver to ask about the cache manager's capabilities
527 */
SRXAFSCB_TellMeAboutYourself(struct work_struct * work)528 static void SRXAFSCB_TellMeAboutYourself(struct work_struct *work)
529 {
530 struct afs_interface *ifs;
531 struct afs_call *call = container_of(work, struct afs_call, work);
532 int loop, nifs;
533
534 struct {
535 struct /* InterfaceAddr */ {
536 __be32 nifs;
537 __be32 uuid[11];
538 __be32 ifaddr[32];
539 __be32 netmask[32];
540 __be32 mtu[32];
541 } ia;
542 struct /* Capabilities */ {
543 __be32 capcount;
544 __be32 caps[1];
545 } cap;
546 } reply;
547
548 _enter("");
549
550 nifs = 0;
551 ifs = kcalloc(32, sizeof(*ifs), GFP_KERNEL);
552 if (ifs) {
553 nifs = afs_get_ipv4_interfaces(ifs, 32, false);
554 if (nifs < 0) {
555 kfree(ifs);
556 ifs = NULL;
557 nifs = 0;
558 }
559 }
560
561 memset(&reply, 0, sizeof(reply));
562 reply.ia.nifs = htonl(nifs);
563
564 reply.ia.uuid[0] = htonl(afs_uuid.time_low);
565 reply.ia.uuid[1] = htonl(afs_uuid.time_mid);
566 reply.ia.uuid[2] = htonl(afs_uuid.time_hi_and_version);
567 reply.ia.uuid[3] = htonl((s8) afs_uuid.clock_seq_hi_and_reserved);
568 reply.ia.uuid[4] = htonl((s8) afs_uuid.clock_seq_low);
569 for (loop = 0; loop < 6; loop++)
570 reply.ia.uuid[loop + 5] = htonl((s8) afs_uuid.node[loop]);
571
572 if (ifs) {
573 for (loop = 0; loop < nifs; loop++) {
574 reply.ia.ifaddr[loop] = ifs[loop].address.s_addr;
575 reply.ia.netmask[loop] = ifs[loop].netmask.s_addr;
576 reply.ia.mtu[loop] = htonl(ifs[loop].mtu);
577 }
578 kfree(ifs);
579 }
580
581 reply.cap.capcount = htonl(1);
582 reply.cap.caps[0] = htonl(AFS_CAP_ERROR_TRANSLATION);
583 afs_send_simple_reply(call, &reply, sizeof(reply));
584
585 _leave("");
586 }
587
588 /*
589 * deliver request data to a CB.TellMeAboutYourself call
590 */
afs_deliver_cb_tell_me_about_yourself(struct afs_call * call,struct sk_buff * skb,bool last)591 static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *call,
592 struct sk_buff *skb, bool last)
593 {
594 _enter(",{%u},%d", skb->len, last);
595
596 if (skb->len > 0)
597 return -EBADMSG;
598 if (!last)
599 return 0;
600
601 /* no unmarshalling required */
602 call->state = AFS_CALL_REPLYING;
603
604 INIT_WORK(&call->work, SRXAFSCB_TellMeAboutYourself);
605 queue_work(afs_wq, &call->work);
606 return 0;
607 }
608