Loading...
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 | /* main.c: AFS client file system * * Copyright (C) 2002 Red Hat, Inc. All Rights Reserved. * Written by David Howells (dhowells@redhat.com) * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License * as published by the Free Software Foundation; either version * 2 of the License, or (at your option) any later version. */ #include <linux/module.h> #include <linux/init.h> #include <linux/sched.h> #include <linux/completion.h> #include <rxrpc/rxrpc.h> #include <rxrpc/transport.h> #include <rxrpc/call.h> #include <rxrpc/peer.h> #include "cell.h" #include "server.h" #include "fsclient.h" #include "cmservice.h" #include "kafstimod.h" #include "kafsasyncd.h" #include "internal.h" struct rxrpc_transport *afs_transport; static int afs_init(void); static void afs_exit(void); static int afs_adding_peer(struct rxrpc_peer *peer); static void afs_discarding_peer(struct rxrpc_peer *peer); module_init(afs_init); module_exit(afs_exit); MODULE_DESCRIPTION("AFS Client File System"); MODULE_AUTHOR("Red Hat, Inc."); MODULE_LICENSE("GPL"); static struct rxrpc_peer_ops afs_peer_ops = { .adding = afs_adding_peer, .discarding = afs_discarding_peer, }; struct list_head afs_cb_hash_tbl[AFS_CB_HASH_COUNT]; spinlock_t afs_cb_hash_lock = SPIN_LOCK_UNLOCKED; /*****************************************************************************/ /* * initialise the AFS client FS module */ static int afs_init(void) { int loop, ret; printk(KERN_INFO "kAFS: Red Hat AFS client v0.1 registering.\n"); /* initialise the callback hash table */ spin_lock_init(&afs_cb_hash_lock); for (loop=AFS_CB_HASH_COUNT-1; loop>=0; loop--) INIT_LIST_HEAD(&afs_cb_hash_tbl[loop]); /* register the /proc stuff */ ret = afs_proc_init(); if (ret<0) return ret; /* initialise the cell DB */ ret = afs_cell_init(); if (ret<0) goto error; /* start the timeout daemon */ ret = afs_kafstimod_start(); if (ret<0) goto error; /* start the async operation daemon */ ret = afs_kafsasyncd_start(); if (ret<0) goto error_kafstimod; /* create the RxRPC transport */ ret = rxrpc_create_transport(7001,&afs_transport); if (ret<0) goto error_kafsasyncd; afs_transport->peer_ops = &afs_peer_ops; /* register the filesystems */ ret = afs_fs_init(); if (ret<0) goto error_transport; return ret; error_transport: rxrpc_put_transport(afs_transport); error_kafsasyncd: afs_kafsasyncd_stop(); error_kafstimod: afs_kafstimod_stop(); error: afs_cell_purge(); afs_proc_cleanup(); printk(KERN_ERR "kAFS: failed to register: %d\n",ret); return ret; } /* end afs_init() */ /*****************************************************************************/ /* * clean up on module removal */ static void __exit afs_exit(void) { printk(KERN_INFO "kAFS: Red Hat AFS client v0.1 unregistering.\n"); afs_fs_exit(); rxrpc_put_transport(afs_transport); afs_kafstimod_stop(); afs_kafsasyncd_stop(); afs_cell_purge(); afs_proc_cleanup(); } /* end afs_exit() */ /*****************************************************************************/ /* * notification that new peer record is being added * - called from krxsecd * - return an error to induce an abort * - mustn't sleep (caller holds an rwlock) */ static int afs_adding_peer(struct rxrpc_peer *peer) { afs_server_t *server; int ret; _debug("kAFS: Adding new peer %08x\n",ntohl(peer->addr.s_addr)); /* determine which server the peer resides in (if any) */ ret = afs_server_find_by_peer(peer,&server); if (ret<0) return ret; /* none that we recognise, so abort */ _debug("Server %p{u=%d}\n",server,atomic_read(&server->usage)); _debug("Cell %p{u=%d}\n",server->cell,atomic_read(&server->cell->usage)); /* cross-point the structs under a global lock */ spin_lock(&afs_server_peer_lock); peer->user = server; server->peer = peer; spin_unlock(&afs_server_peer_lock); afs_put_server(server); return 0; } /* end afs_adding_peer() */ /*****************************************************************************/ /* * notification that a peer record is being discarded * - called from krxiod or krxsecd */ static void afs_discarding_peer(struct rxrpc_peer *peer) { afs_server_t *server; _enter("%p",peer); _debug("Discarding peer %08x (rtt=%lu.%lumS)\n", ntohl(peer->addr.s_addr), (long)(peer->rtt/1000), (long)(peer->rtt%1000)); /* uncross-point the structs under a global lock */ spin_lock(&afs_server_peer_lock); server = peer->user; if (server) { peer->user = NULL; server->peer = NULL; //_debug("Server %p{u=%d}\n",server,atomic_read(&server->usage)); //_debug("Cell %p{u=%d}\n",server->cell,atomic_read(&server->cell->usage)); } spin_unlock(&afs_server_peer_lock); _leave(""); } /* end afs_discarding_peer() */ |