1 /* AFS Cache Manager Service
3 * Copyright (C) 2002 Red Hat, Inc. All Rights Reserved.
4 * Written by David Howells (dhowells@redhat.com)
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.
12 #include <linux/module.h>
13 #include <linux/init.h>
14 #include <linux/slab.h>
15 #include <linux/sched.h>
21 struct workqueue_struct
*afs_cm_workqueue
;
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
*);
36 * CB.CallBack operation type
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
,
46 * CB.InitCallBackState operation type
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
,
56 * CB.InitCallBackState3 operation type
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
,
66 * CB.Probe operation type
68 static const struct afs_call_type afs_SRXCBProbe
= {
70 .deliver
= afs_deliver_cb_probe
,
71 .abort_to_error
= afs_abort_to_error
,
72 .destructor
= afs_cm_destructor
,
76 * CB.ProbeUuid operation type
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
,
86 * CB.TellMeAboutYourself operation type
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
,
96 * route an incoming cache manager call
97 * - return T if supported, F if not
99 bool afs_cm_incoming_call(struct afs_call
*call
)
101 u32 operation_id
= ntohl(call
->operation_ID
);
103 _enter("{CB.OP %u}", operation_id
);
105 switch (operation_id
) {
107 call
->type
= &afs_SRXCBCallBack
;
109 case CBInitCallBackState
:
110 call
->type
= &afs_SRXCBInitCallBackState
;
112 case CBInitCallBackState3
:
113 call
->type
= &afs_SRXCBInitCallBackState3
;
116 call
->type
= &afs_SRXCBProbe
;
119 call
->type
= &afs_SRXCBProbeUuid
;
121 case CBTellMeAboutYourself
:
122 call
->type
= &afs_SRXCBTellMeAboutYourself
;
130 * clean up a cache manager call
132 static void afs_cm_destructor(struct afs_call
*call
)
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().
140 if (call
->unmarshall
== 6) {
141 ASSERT(call
->server
&& call
->count
&& call
->request
);
142 afs_break_callbacks(call
->server
, call
->count
, call
->request
);
145 afs_put_server(call
->server
);
152 * allow the fileserver to see if the cache manager is still alive
154 static void SRXAFSCB_CallBack(struct work_struct
*work
)
156 struct afs_call
*call
= container_of(work
, struct afs_call
, work
);
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
165 afs_send_empty_reply(call
);
167 afs_break_callbacks(call
->server
, call
->count
, call
->request
);
172 * deliver request data to a CB.CallBack call
174 static int afs_deliver_cb_callback(struct afs_call
*call
, struct sk_buff
*skb
,
177 struct afs_callback
*cb
;
178 struct afs_server
*server
;
184 _enter("{%u},{%u},%d", call
->unmarshall
, skb
->len
, last
);
186 switch (call
->unmarshall
) {
191 /* extract the FID array and its count in two steps */
193 _debug("extract FID count");
194 ret
= afs_extract_data(call
, skb
, last
, &call
->tmp
, 4);
197 case -EAGAIN
: return 0;
201 call
->count
= ntohl(call
->tmp
);
202 _debug("FID count: %u", call
->count
);
203 if (call
->count
> AFSCBMAX
)
206 call
->buffer
= kmalloc(call
->count
* 3 * 4, GFP_KERNEL
);
213 _debug("extract FID array");
214 ret
= afs_extract_data(call
, skb
, last
, call
->buffer
,
215 call
->count
* 3 * 4);
218 case -EAGAIN
: return 0;
222 _debug("unmarshall FID array");
223 call
->request
= kcalloc(call
->count
,
224 sizeof(struct afs_callback
),
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
;
241 /* extract the callback array and its count in two steps */
243 _debug("extract CB count");
244 ret
= afs_extract_data(call
, skb
, last
, &call
->tmp
, 4);
247 case -EAGAIN
: return 0;
251 tmp
= ntohl(call
->tmp
);
252 _debug("CB count: %u", tmp
);
253 if (tmp
!= call
->count
&& tmp
!= 0)
261 _debug("extract CB array");
262 ret
= afs_extract_data(call
, skb
, last
, call
->request
,
263 call
->count
* 3 * 4);
266 case -EAGAIN
: return 0;
270 _debug("unmarshall CB array");
273 for (loop
= call
->count
; loop
> 0; loop
--, cb
++) {
274 cb
->version
= ntohl(*bp
++);
275 cb
->expiry
= ntohl(*bp
++);
276 cb
->type
= ntohl(*bp
++);
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.
292 * If the step number changes, then afs_cm_destructor() must be
303 call
->state
= AFS_CALL_REPLYING
;
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
);
311 call
->server
= server
;
313 INIT_WORK(&call
->work
, SRXAFSCB_CallBack
);
314 queue_work(afs_wq
, &call
->work
);
319 * allow the fileserver to request callback state (re-)initialisation
321 static void SRXAFSCB_InitCallBackState(struct work_struct
*work
)
323 struct afs_call
*call
= container_of(work
, struct afs_call
, work
);
325 _enter("{%p}", call
->server
);
327 afs_init_callback_state(call
->server
);
328 afs_send_empty_reply(call
);
333 * deliver request data to a CB.InitCallBackState call
335 static int afs_deliver_cb_init_call_back_state(struct afs_call
*call
,
339 struct afs_server
*server
;
342 _enter(",{%u},%d", skb
->len
, last
);
349 /* no unmarshalling required */
350 call
->state
= AFS_CALL_REPLYING
;
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
);
358 call
->server
= server
;
360 INIT_WORK(&call
->work
, SRXAFSCB_InitCallBackState
);
361 queue_work(afs_wq
, &call
->work
);
366 * deliver request data to a CB.InitCallBackState3 call
368 static int afs_deliver_cb_init_call_back_state3(struct afs_call
*call
,
372 struct afs_server
*server
;
375 _enter(",{%u},%d", skb
->len
, last
);
380 /* no unmarshalling required */
381 call
->state
= AFS_CALL_REPLYING
;
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
);
389 call
->server
= server
;
391 INIT_WORK(&call
->work
, SRXAFSCB_InitCallBackState
);
392 queue_work(afs_wq
, &call
->work
);
397 * allow the fileserver to see if the cache manager is still alive
399 static void SRXAFSCB_Probe(struct work_struct
*work
)
401 struct afs_call
*call
= container_of(work
, struct afs_call
, work
);
404 afs_send_empty_reply(call
);
409 * deliver request data to a CB.Probe call
411 static int afs_deliver_cb_probe(struct afs_call
*call
, struct sk_buff
*skb
,
414 _enter(",{%u},%d", skb
->len
, last
);
421 /* no unmarshalling required */
422 call
->state
= AFS_CALL_REPLYING
;
424 INIT_WORK(&call
->work
, SRXAFSCB_Probe
);
425 queue_work(afs_wq
, &call
->work
);
430 * allow the fileserver to quickly find out if the fileserver has been rebooted
432 static void SRXAFSCB_ProbeUuid(struct work_struct
*work
)
434 struct afs_call
*call
= container_of(work
, struct afs_call
, work
);
435 struct afs_uuid
*r
= call
->request
;
444 if (memcmp(r
, &afs_uuid
, sizeof(afs_uuid
)) == 0)
445 reply
.match
= htonl(0);
447 reply
.match
= htonl(1);
449 afs_send_simple_reply(call
, &reply
, sizeof(reply
));
454 * deliver request data to a CB.ProbeUuid call
456 static int afs_deliver_cb_probe_uuid(struct afs_call
*call
, struct sk_buff
*skb
,
464 _enter("{%u},{%u},%d", call
->unmarshall
, skb
->len
, last
);
471 switch (call
->unmarshall
) {
474 call
->buffer
= kmalloc(11 * sizeof(__be32
), GFP_KERNEL
);
480 _debug("extract UUID");
481 ret
= afs_extract_data(call
, skb
, last
, call
->buffer
,
482 11 * sizeof(__be32
));
485 case -EAGAIN
: return 0;
489 _debug("unmarshall UUID");
490 call
->request
= kmalloc(sizeof(struct afs_uuid
), GFP_KERNEL
);
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]);
502 for (loop
= 0; loop
< 6; loop
++)
503 r
->node
[loop
] = ntohl(b
[loop
+ 5]);
518 call
->state
= AFS_CALL_REPLYING
;
520 INIT_WORK(&call
->work
, SRXAFSCB_ProbeUuid
);
521 queue_work(afs_wq
, &call
->work
);
526 * allow the fileserver to ask about the cache manager's capabilities
528 static void SRXAFSCB_TellMeAboutYourself(struct work_struct
*work
)
530 struct afs_interface
*ifs
;
531 struct afs_call
*call
= container_of(work
, struct afs_call
, work
);
535 struct /* InterfaceAddr */ {
542 struct /* Capabilities */ {
551 ifs
= kcalloc(32, sizeof(*ifs
), GFP_KERNEL
);
553 nifs
= afs_get_ipv4_interfaces(ifs
, 32, false);
561 memset(&reply
, 0, sizeof(reply
));
562 reply
.ia
.nifs
= htonl(nifs
);
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
]);
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
);
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
));
589 * deliver request data to a CB.TellMeAboutYourself call
591 static int afs_deliver_cb_tell_me_about_yourself(struct afs_call
*call
,
592 struct sk_buff
*skb
, bool last
)
594 _enter(",{%u},%d", skb
->len
, last
);
601 /* no unmarshalling required */
602 call
->state
= AFS_CALL_REPLYING
;
604 INIT_WORK(&call
->work
, SRXAFSCB_TellMeAboutYourself
);
605 queue_work(afs_wq
, &call
->work
);