linux/fs/afs/cmservice.c
<<
>>
Prefs
   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
  21struct workqueue_struct *afs_cm_workqueue;
  22#endif  /*  0  */
  23
  24static int afs_deliver_cb_init_call_back_state(struct afs_call *,
  25                                               struct sk_buff *, bool);
  26static int afs_deliver_cb_init_call_back_state3(struct afs_call *,
  27                                                struct sk_buff *, bool);
  28static int afs_deliver_cb_probe(struct afs_call *, struct sk_buff *, bool);
  29static int afs_deliver_cb_callback(struct afs_call *, struct sk_buff *, bool);
  30static int afs_deliver_cb_probe_uuid(struct afs_call *, struct sk_buff *, bool);
  31static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *,
  32                                                 struct sk_buff *, bool);
  33static void afs_cm_destructor(struct afs_call *);
  34
  35/*
  36 * CB.CallBack operation type
  37 */
  38static 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 */
  48static 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 */
  58static 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 */
  68static 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 */
  78static 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 */
  88static 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 */
  99bool 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 CBTellMeAboutYourself:
 119                call->type = &afs_SRXCBTellMeAboutYourself;
 120                return true;
 121        default:
 122                return false;
 123        }
 124}
 125
 126/*
 127 * clean up a cache manager call
 128 */
 129static void afs_cm_destructor(struct afs_call *call)
 130{
 131        _enter("");
 132
 133        afs_put_server(call->server);
 134        call->server = NULL;
 135        kfree(call->buffer);
 136        call->buffer = NULL;
 137}
 138
 139/*
 140 * allow the fileserver to see if the cache manager is still alive
 141 */
 142static void SRXAFSCB_CallBack(struct work_struct *work)
 143{
 144        struct afs_call *call = container_of(work, struct afs_call, work);
 145
 146        _enter("");
 147
 148        /* be sure to send the reply *before* attempting to spam the AFS server
 149         * with FSFetchStatus requests on the vnodes with broken callbacks lest
 150         * the AFS server get into a vicious cycle of trying to break further
 151         * callbacks because it hadn't received completion of the CBCallBack op
 152         * yet */
 153        afs_send_empty_reply(call);
 154
 155        afs_break_callbacks(call->server, call->count, call->request);
 156        _leave("");
 157}
 158
 159/*
 160 * deliver request data to a CB.CallBack call
 161 */
 162static int afs_deliver_cb_callback(struct afs_call *call, struct sk_buff *skb,
 163                                   bool last)
 164{
 165        struct afs_callback *cb;
 166        struct afs_server *server;
 167        struct in_addr addr;
 168        __be32 *bp;
 169        u32 tmp;
 170        int ret, loop;
 171
 172        _enter("{%u},{%u},%d", call->unmarshall, skb->len, last);
 173
 174        switch (call->unmarshall) {
 175        case 0:
 176                call->offset = 0;
 177                call->unmarshall++;
 178
 179                /* extract the FID array and its count in two steps */
 180        case 1:
 181                _debug("extract FID count");
 182                ret = afs_extract_data(call, skb, last, &call->tmp, 4);
 183                switch (ret) {
 184                case 0:         break;
 185                case -EAGAIN:   return 0;
 186                default:        return ret;
 187                }
 188
 189                call->count = ntohl(call->tmp);
 190                _debug("FID count: %u", call->count);
 191                if (call->count > AFSCBMAX)
 192                        return -EBADMSG;
 193
 194                call->buffer = kmalloc(call->count * 3 * 4, GFP_KERNEL);
 195                if (!call->buffer)
 196                        return -ENOMEM;
 197                call->offset = 0;
 198                call->unmarshall++;
 199
 200        case 2:
 201                _debug("extract FID array");
 202                ret = afs_extract_data(call, skb, last, call->buffer,
 203                                       call->count * 3 * 4);
 204                switch (ret) {
 205                case 0:         break;
 206                case -EAGAIN:   return 0;
 207                default:        return ret;
 208                }
 209
 210                _debug("unmarshall FID array");
 211                call->request = kcalloc(call->count,
 212                                        sizeof(struct afs_callback),
 213                                        GFP_KERNEL);
 214                if (!call->request)
 215                        return -ENOMEM;
 216
 217                cb = call->request;
 218                bp = call->buffer;
 219                for (loop = call->count; loop > 0; loop--, cb++) {
 220                        cb->fid.vid     = ntohl(*bp++);
 221                        cb->fid.vnode   = ntohl(*bp++);
 222                        cb->fid.unique  = ntohl(*bp++);
 223                        cb->type        = AFSCM_CB_UNTYPED;
 224                }
 225
 226                call->offset = 0;
 227                call->unmarshall++;
 228
 229                /* extract the callback array and its count in two steps */
 230        case 3:
 231                _debug("extract CB count");
 232                ret = afs_extract_data(call, skb, last, &call->tmp, 4);
 233                switch (ret) {
 234                case 0:         break;
 235                case -EAGAIN:   return 0;
 236                default:        return ret;
 237                }
 238
 239                tmp = ntohl(call->tmp);
 240                _debug("CB count: %u", tmp);
 241                if (tmp != call->count && tmp != 0)
 242                        return -EBADMSG;
 243                call->offset = 0;
 244                call->unmarshall++;
 245                if (tmp == 0)
 246                        goto empty_cb_array;
 247
 248        case 4:
 249                _debug("extract CB array");
 250                ret = afs_extract_data(call, skb, last, call->request,
 251                                       call->count * 3 * 4);
 252                switch (ret) {
 253                case 0:         break;
 254                case -EAGAIN:   return 0;
 255                default:        return ret;
 256                }
 257
 258                _debug("unmarshall CB array");
 259                cb = call->request;
 260                bp = call->buffer;
 261                for (loop = call->count; loop > 0; loop--, cb++) {
 262                        cb->version     = ntohl(*bp++);
 263                        cb->expiry      = ntohl(*bp++);
 264                        cb->type        = ntohl(*bp++);
 265                }
 266
 267        empty_cb_array:
 268                call->offset = 0;
 269                call->unmarshall++;
 270
 271        case 5:
 272                _debug("trailer");
 273                if (skb->len != 0)
 274                        return -EBADMSG;
 275                break;
 276        }
 277
 278        if (!last)
 279                return 0;
 280
 281        call->state = AFS_CALL_REPLYING;
 282
 283        /* we'll need the file server record as that tells us which set of
 284         * vnodes to operate upon */
 285        memcpy(&addr, &ip_hdr(skb)->saddr, 4);
 286        server = afs_find_server(&addr);
 287        if (!server)
 288                return -ENOTCONN;
 289        call->server = server;
 290
 291        INIT_WORK(&call->work, SRXAFSCB_CallBack);
 292        queue_work(afs_wq, &call->work);
 293        return 0;
 294}
 295
 296/*
 297 * allow the fileserver to request callback state (re-)initialisation
 298 */
 299static void SRXAFSCB_InitCallBackState(struct work_struct *work)
 300{
 301        struct afs_call *call = container_of(work, struct afs_call, work);
 302
 303        _enter("{%p}", call->server);
 304
 305        afs_init_callback_state(call->server);
 306        afs_send_empty_reply(call);
 307        _leave("");
 308}
 309
 310/*
 311 * deliver request data to a CB.InitCallBackState call
 312 */
 313static int afs_deliver_cb_init_call_back_state(struct afs_call *call,
 314                                               struct sk_buff *skb,
 315                                               bool last)
 316{
 317        struct afs_server *server;
 318        struct in_addr addr;
 319
 320        _enter(",{%u},%d", skb->len, last);
 321
 322        if (skb->len > 0)
 323                return -EBADMSG;
 324        if (!last)
 325                return 0;
 326
 327        /* no unmarshalling required */
 328        call->state = AFS_CALL_REPLYING;
 329
 330        /* we'll need the file server record as that tells us which set of
 331         * vnodes to operate upon */
 332        memcpy(&addr, &ip_hdr(skb)->saddr, 4);
 333        server = afs_find_server(&addr);
 334        if (!server)
 335                return -ENOTCONN;
 336        call->server = server;
 337
 338        INIT_WORK(&call->work, SRXAFSCB_InitCallBackState);
 339        queue_work(afs_wq, &call->work);
 340        return 0;
 341}
 342
 343/*
 344 * deliver request data to a CB.InitCallBackState3 call
 345 */
 346static int afs_deliver_cb_init_call_back_state3(struct afs_call *call,
 347                                                struct sk_buff *skb,
 348                                                bool last)
 349{
 350        struct afs_server *server;
 351        struct in_addr addr;
 352
 353        _enter(",{%u},%d", skb->len, last);
 354
 355        if (!last)
 356                return 0;
 357
 358        /* no unmarshalling required */
 359        call->state = AFS_CALL_REPLYING;
 360
 361        /* we'll need the file server record as that tells us which set of
 362         * vnodes to operate upon */
 363        memcpy(&addr, &ip_hdr(skb)->saddr, 4);
 364        server = afs_find_server(&addr);
 365        if (!server)
 366                return -ENOTCONN;
 367        call->server = server;
 368
 369        INIT_WORK(&call->work, SRXAFSCB_InitCallBackState);
 370        queue_work(afs_wq, &call->work);
 371        return 0;
 372}
 373
 374/*
 375 * allow the fileserver to see if the cache manager is still alive
 376 */
 377static void SRXAFSCB_Probe(struct work_struct *work)
 378{
 379        struct afs_call *call = container_of(work, struct afs_call, work);
 380
 381        _enter("");
 382        afs_send_empty_reply(call);
 383        _leave("");
 384}
 385
 386/*
 387 * deliver request data to a CB.Probe call
 388 */
 389static int afs_deliver_cb_probe(struct afs_call *call, struct sk_buff *skb,
 390                                bool last)
 391{
 392        _enter(",{%u},%d", skb->len, last);
 393
 394        if (skb->len > 0)
 395                return -EBADMSG;
 396        if (!last)
 397                return 0;
 398
 399        /* no unmarshalling required */
 400        call->state = AFS_CALL_REPLYING;
 401
 402        INIT_WORK(&call->work, SRXAFSCB_Probe);
 403        queue_work(afs_wq, &call->work);
 404        return 0;
 405}
 406
 407/*
 408 * allow the fileserver to quickly find out if the fileserver has been rebooted
 409 */
 410static void SRXAFSCB_ProbeUuid(struct work_struct *work)
 411{
 412        struct afs_call *call = container_of(work, struct afs_call, work);
 413        struct afs_uuid *r = call->request;
 414
 415        struct {
 416                __be32  match;
 417        } reply;
 418
 419        _enter("");
 420
 421
 422        if (memcmp(r, &afs_uuid, sizeof(afs_uuid)) == 0)
 423                reply.match = htonl(0);
 424        else
 425                reply.match = htonl(1);
 426
 427        afs_send_simple_reply(call, &reply, sizeof(reply));
 428        _leave("");
 429}
 430
 431/*
 432 * deliver request data to a CB.ProbeUuid call
 433 */
 434static int afs_deliver_cb_probe_uuid(struct afs_call *call, struct sk_buff *skb,
 435                                     bool last)
 436{
 437        struct afs_uuid *r;
 438        unsigned loop;
 439        __be32 *b;
 440        int ret;
 441
 442        _enter("{%u},{%u},%d", call->unmarshall, skb->len, last);
 443
 444        if (skb->len > 0)
 445                return -EBADMSG;
 446        if (!last)
 447                return 0;
 448
 449        switch (call->unmarshall) {
 450        case 0:
 451                call->offset = 0;
 452                call->buffer = kmalloc(11 * sizeof(__be32), GFP_KERNEL);
 453                if (!call->buffer)
 454                        return -ENOMEM;
 455                call->unmarshall++;
 456
 457        case 1:
 458                _debug("extract UUID");
 459                ret = afs_extract_data(call, skb, last, call->buffer,
 460                                       11 * sizeof(__be32));
 461                switch (ret) {
 462                case 0:         break;
 463                case -EAGAIN:   return 0;
 464                default:        return ret;
 465                }
 466
 467                _debug("unmarshall UUID");
 468                call->request = kmalloc(sizeof(struct afs_uuid), GFP_KERNEL);
 469                if (!call->request)
 470                        return -ENOMEM;
 471
 472                b = call->buffer;
 473                r = call->request;
 474                r->time_low                     = ntohl(b[0]);
 475                r->time_mid                     = ntohl(b[1]);
 476                r->time_hi_and_version          = ntohl(b[2]);
 477                r->clock_seq_hi_and_reserved    = ntohl(b[3]);
 478                r->clock_seq_low                = ntohl(b[4]);
 479
 480                for (loop = 0; loop < 6; loop++)
 481                        r->node[loop] = ntohl(b[loop + 5]);
 482
 483                call->offset = 0;
 484                call->unmarshall++;
 485
 486        case 2:
 487                _debug("trailer");
 488                if (skb->len != 0)
 489                        return -EBADMSG;
 490                break;
 491        }
 492
 493        if (!last)
 494                return 0;
 495
 496        call->state = AFS_CALL_REPLYING;
 497
 498        INIT_WORK(&call->work, SRXAFSCB_ProbeUuid);
 499        queue_work(afs_wq, &call->work);
 500        return 0;
 501}
 502
 503/*
 504 * allow the fileserver to ask about the cache manager's capabilities
 505 */
 506static void SRXAFSCB_TellMeAboutYourself(struct work_struct *work)
 507{
 508        struct afs_interface *ifs;
 509        struct afs_call *call = container_of(work, struct afs_call, work);
 510        int loop, nifs;
 511
 512        struct {
 513                struct /* InterfaceAddr */ {
 514                        __be32 nifs;
 515                        __be32 uuid[11];
 516                        __be32 ifaddr[32];
 517                        __be32 netmask[32];
 518                        __be32 mtu[32];
 519                } ia;
 520                struct /* Capabilities */ {
 521                        __be32 capcount;
 522                        __be32 caps[1];
 523                } cap;
 524        } reply;
 525
 526        _enter("");
 527
 528        nifs = 0;
 529        ifs = kcalloc(32, sizeof(*ifs), GFP_KERNEL);
 530        if (ifs) {
 531                nifs = afs_get_ipv4_interfaces(ifs, 32, false);
 532                if (nifs < 0) {
 533                        kfree(ifs);
 534                        ifs = NULL;
 535                        nifs = 0;
 536                }
 537        }
 538
 539        memset(&reply, 0, sizeof(reply));
 540        reply.ia.nifs = htonl(nifs);
 541
 542        reply.ia.uuid[0] = htonl(afs_uuid.time_low);
 543        reply.ia.uuid[1] = htonl(afs_uuid.time_mid);
 544        reply.ia.uuid[2] = htonl(afs_uuid.time_hi_and_version);
 545        reply.ia.uuid[3] = htonl((s8) afs_uuid.clock_seq_hi_and_reserved);
 546        reply.ia.uuid[4] = htonl((s8) afs_uuid.clock_seq_low);
 547        for (loop = 0; loop < 6; loop++)
 548                reply.ia.uuid[loop + 5] = htonl((s8) afs_uuid.node[loop]);
 549
 550        if (ifs) {
 551                for (loop = 0; loop < nifs; loop++) {
 552                        reply.ia.ifaddr[loop] = ifs[loop].address.s_addr;
 553                        reply.ia.netmask[loop] = ifs[loop].netmask.s_addr;
 554                        reply.ia.mtu[loop] = htonl(ifs[loop].mtu);
 555                }
 556                kfree(ifs);
 557        }
 558
 559        reply.cap.capcount = htonl(1);
 560        reply.cap.caps[0] = htonl(AFS_CAP_ERROR_TRANSLATION);
 561        afs_send_simple_reply(call, &reply, sizeof(reply));
 562
 563        _leave("");
 564}
 565
 566/*
 567 * deliver request data to a CB.TellMeAboutYourself call
 568 */
 569static int afs_deliver_cb_tell_me_about_yourself(struct afs_call *call,
 570                                                 struct sk_buff *skb, bool last)
 571{
 572        _enter(",{%u},%d", skb->len, last);
 573
 574        if (skb->len > 0)
 575                return -EBADMSG;
 576        if (!last)
 577                return 0;
 578
 579        /* no unmarshalling required */
 580        call->state = AFS_CALL_REPLYING;
 581
 582        INIT_WORK(&call->work, SRXAFSCB_TellMeAboutYourself);
 583        queue_work(afs_wq, &call->work);
 584        return 0;
 585}
 586
lxr.linux.no kindly hosted by Redpill Linpro AS, provider of Linux consulting and operations services since 1995.