Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 1 | |
| 2 | #include <linux/ceph/ceph_debug.h> |
| 3 | #include <linux/backing-dev.h> |
| 4 | #include <linux/ctype.h> |
| 5 | #include <linux/fs.h> |
| 6 | #include <linux/inet.h> |
| 7 | #include <linux/in6.h> |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 8 | #include <linux/key.h> |
Tommi Virtanen | 4b2a58a | 2011-03-28 14:59:38 -0700 | [diff] [blame] | 9 | #include <keys/ceph-type.h> |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 10 | #include <linux/module.h> |
| 11 | #include <linux/mount.h> |
Ilya Dryomov | 757856d | 2015-06-25 17:47:45 +0300 | [diff] [blame] | 12 | #include <linux/nsproxy.h> |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 13 | #include <linux/parser.h> |
| 14 | #include <linux/sched.h> |
| 15 | #include <linux/seq_file.h> |
| 16 | #include <linux/slab.h> |
| 17 | #include <linux/statfs.h> |
| 18 | #include <linux/string.h> |
Ilya Dryomov | eeb0bed | 2014-01-09 20:08:21 +0200 | [diff] [blame] | 19 | #include <linux/vmalloc.h> |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 20 | |
| 21 | |
Sage Weil | 1fe60e5 | 2012-07-30 16:23:22 -0700 | [diff] [blame] | 22 | #include <linux/ceph/ceph_features.h> |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 23 | #include <linux/ceph/libceph.h> |
| 24 | #include <linux/ceph/debugfs.h> |
| 25 | #include <linux/ceph/decode.h> |
| 26 | #include <linux/ceph/mon_client.h> |
| 27 | #include <linux/ceph/auth.h> |
Tommi Virtanen | 8323c3a | 2011-03-25 16:32:57 -0700 | [diff] [blame] | 28 | #include "crypto.h" |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 29 | |
| 30 | |
Alex Elder | 72fe25e | 2013-01-30 11:13:33 -0600 | [diff] [blame] | 31 | /* |
| 32 | * Module compatibility interface. For now it doesn't do anything, |
| 33 | * but its existence signals a certain level of functionality. |
| 34 | * |
| 35 | * The data buffer is used to pass information both to and from |
| 36 | * libceph. The return value indicates whether libceph determines |
| 37 | * it is compatible with the caller (from another kernel module), |
| 38 | * given the provided data. |
| 39 | * |
| 40 | * The data pointer can be null. |
| 41 | */ |
| 42 | bool libceph_compatible(void *data) |
| 43 | { |
Alex Elder | 1e32d34 | 2013-01-30 11:13:33 -0600 | [diff] [blame] | 44 | return true; |
Alex Elder | 72fe25e | 2013-01-30 11:13:33 -0600 | [diff] [blame] | 45 | } |
| 46 | EXPORT_SYMBOL(libceph_compatible); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 47 | |
Ilya Dryomov | d6a3408 | 2017-03-03 18:16:07 +0100 | [diff] [blame] | 48 | static int param_get_supported_features(char *buffer, |
| 49 | const struct kernel_param *kp) |
| 50 | { |
| 51 | return sprintf(buffer, "0x%llx", CEPH_FEATURES_SUPPORTED_DEFAULT); |
| 52 | } |
| 53 | static const struct kernel_param_ops param_ops_supported_features = { |
| 54 | .get = param_get_supported_features, |
| 55 | }; |
| 56 | module_param_cb(supported_features, ¶m_ops_supported_features, NULL, |
Joe Perches | d644406 | 2018-03-23 15:54:38 -0700 | [diff] [blame] | 57 | 0444); |
Ilya Dryomov | d6a3408 | 2017-03-03 18:16:07 +0100 | [diff] [blame] | 58 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 59 | const char *ceph_msg_type_name(int type) |
| 60 | { |
| 61 | switch (type) { |
| 62 | case CEPH_MSG_SHUTDOWN: return "shutdown"; |
| 63 | case CEPH_MSG_PING: return "ping"; |
| 64 | case CEPH_MSG_AUTH: return "auth"; |
| 65 | case CEPH_MSG_AUTH_REPLY: return "auth_reply"; |
| 66 | case CEPH_MSG_MON_MAP: return "mon_map"; |
| 67 | case CEPH_MSG_MON_GET_MAP: return "mon_get_map"; |
| 68 | case CEPH_MSG_MON_SUBSCRIBE: return "mon_subscribe"; |
| 69 | case CEPH_MSG_MON_SUBSCRIBE_ACK: return "mon_subscribe_ack"; |
| 70 | case CEPH_MSG_STATFS: return "statfs"; |
| 71 | case CEPH_MSG_STATFS_REPLY: return "statfs_reply"; |
Ilya Dryomov | 513a824 | 2014-05-13 11:19:26 +0400 | [diff] [blame] | 72 | case CEPH_MSG_MON_GET_VERSION: return "mon_get_version"; |
| 73 | case CEPH_MSG_MON_GET_VERSION_REPLY: return "mon_get_version_reply"; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 74 | case CEPH_MSG_MDS_MAP: return "mds_map"; |
Chengguang Xu | f2f8787 | 2018-02-22 15:47:05 +0800 | [diff] [blame] | 75 | case CEPH_MSG_FS_MAP_USER: return "fs_map_user"; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 76 | case CEPH_MSG_CLIENT_SESSION: return "client_session"; |
| 77 | case CEPH_MSG_CLIENT_RECONNECT: return "client_reconnect"; |
| 78 | case CEPH_MSG_CLIENT_REQUEST: return "client_request"; |
| 79 | case CEPH_MSG_CLIENT_REQUEST_FORWARD: return "client_request_forward"; |
| 80 | case CEPH_MSG_CLIENT_REPLY: return "client_reply"; |
| 81 | case CEPH_MSG_CLIENT_CAPS: return "client_caps"; |
| 82 | case CEPH_MSG_CLIENT_CAPRELEASE: return "client_cap_release"; |
Luis Henriques | fb18a57 | 2018-01-05 10:47:18 +0000 | [diff] [blame] | 83 | case CEPH_MSG_CLIENT_QUOTA: return "client_quota"; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 84 | case CEPH_MSG_CLIENT_SNAP: return "client_snap"; |
| 85 | case CEPH_MSG_CLIENT_LEASE: return "client_lease"; |
Chengguang Xu | f2f8787 | 2018-02-22 15:47:05 +0800 | [diff] [blame] | 86 | case CEPH_MSG_POOLOP_REPLY: return "poolop_reply"; |
| 87 | case CEPH_MSG_POOLOP: return "poolop"; |
| 88 | case CEPH_MSG_MON_COMMAND: return "mon_command"; |
| 89 | case CEPH_MSG_MON_COMMAND_ACK: return "mon_command_ack"; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 90 | case CEPH_MSG_OSD_MAP: return "osd_map"; |
| 91 | case CEPH_MSG_OSD_OP: return "osd_op"; |
| 92 | case CEPH_MSG_OSD_OPREPLY: return "osd_opreply"; |
Yehuda Sadeh | a40c4f1 | 2011-03-21 15:07:16 -0700 | [diff] [blame] | 93 | case CEPH_MSG_WATCH_NOTIFY: return "watch_notify"; |
Ilya Dryomov | a02a946 | 2017-06-19 12:18:05 +0200 | [diff] [blame] | 94 | case CEPH_MSG_OSD_BACKOFF: return "osd_backoff"; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 95 | default: return "unknown"; |
| 96 | } |
| 97 | } |
| 98 | EXPORT_SYMBOL(ceph_msg_type_name); |
| 99 | |
| 100 | /* |
| 101 | * Initially learn our fsid, or verify an fsid matches. |
| 102 | */ |
| 103 | int ceph_check_fsid(struct ceph_client *client, struct ceph_fsid *fsid) |
| 104 | { |
| 105 | if (client->have_fsid) { |
| 106 | if (ceph_fsid_compare(&client->fsid, fsid)) { |
| 107 | pr_err("bad fsid, had %pU got %pU", |
| 108 | &client->fsid, fsid); |
| 109 | return -1; |
| 110 | } |
| 111 | } else { |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 112 | memcpy(&client->fsid, fsid, sizeof(*fsid)); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 113 | } |
| 114 | return 0; |
| 115 | } |
| 116 | EXPORT_SYMBOL(ceph_check_fsid); |
| 117 | |
| 118 | static int strcmp_null(const char *s1, const char *s2) |
| 119 | { |
| 120 | if (!s1 && !s2) |
| 121 | return 0; |
| 122 | if (s1 && !s2) |
| 123 | return -1; |
| 124 | if (!s1 && s2) |
| 125 | return 1; |
| 126 | return strcmp(s1, s2); |
| 127 | } |
| 128 | |
| 129 | int ceph_compare_options(struct ceph_options *new_opt, |
| 130 | struct ceph_client *client) |
| 131 | { |
| 132 | struct ceph_options *opt1 = new_opt; |
| 133 | struct ceph_options *opt2 = client->options; |
| 134 | int ofs = offsetof(struct ceph_options, mon_addr); |
| 135 | int i; |
| 136 | int ret; |
| 137 | |
Ilya Dryomov | 757856d | 2015-06-25 17:47:45 +0300 | [diff] [blame] | 138 | /* |
| 139 | * Don't bother comparing options if network namespaces don't |
| 140 | * match. |
| 141 | */ |
| 142 | if (!net_eq(current->nsproxy->net_ns, read_pnet(&client->msgr.net))) |
| 143 | return -1; |
| 144 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 145 | ret = memcmp(opt1, opt2, ofs); |
| 146 | if (ret) |
| 147 | return ret; |
| 148 | |
| 149 | ret = strcmp_null(opt1->name, opt2->name); |
| 150 | if (ret) |
| 151 | return ret; |
| 152 | |
Tommi Virtanen | 8323c3a | 2011-03-25 16:32:57 -0700 | [diff] [blame] | 153 | if (opt1->key && !opt2->key) |
| 154 | return -1; |
| 155 | if (!opt1->key && opt2->key) |
| 156 | return 1; |
| 157 | if (opt1->key && opt2->key) { |
| 158 | if (opt1->key->type != opt2->key->type) |
| 159 | return -1; |
| 160 | if (opt1->key->created.tv_sec != opt2->key->created.tv_sec) |
| 161 | return -1; |
| 162 | if (opt1->key->created.tv_nsec != opt2->key->created.tv_nsec) |
| 163 | return -1; |
| 164 | if (opt1->key->len != opt2->key->len) |
| 165 | return -1; |
| 166 | if (opt1->key->key && !opt2->key->key) |
| 167 | return -1; |
| 168 | if (!opt1->key->key && opt2->key->key) |
| 169 | return 1; |
| 170 | if (opt1->key->key && opt2->key->key) { |
| 171 | ret = memcmp(opt1->key->key, opt2->key->key, opt1->key->len); |
| 172 | if (ret) |
| 173 | return ret; |
| 174 | } |
| 175 | } |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 176 | |
| 177 | /* any matching mon ip implies a match */ |
| 178 | for (i = 0; i < opt1->num_mon; i++) { |
| 179 | if (ceph_monmap_contains(client->monc.monmap, |
| 180 | &opt1->mon_addr[i])) |
| 181 | return 0; |
| 182 | } |
| 183 | return -1; |
| 184 | } |
| 185 | EXPORT_SYMBOL(ceph_compare_options); |
| 186 | |
Ilya Dryomov | eeb0bed | 2014-01-09 20:08:21 +0200 | [diff] [blame] | 187 | void *ceph_kvmalloc(size_t size, gfp_t flags) |
| 188 | { |
| 189 | if (size <= (PAGE_SIZE << PAGE_ALLOC_COSTLY_ORDER)) { |
| 190 | void *ptr = kmalloc(size, flags | __GFP_NOWARN); |
| 191 | if (ptr) |
| 192 | return ptr; |
| 193 | } |
| 194 | |
Michal Hocko | 19809c2 | 2017-05-08 15:57:44 -0700 | [diff] [blame] | 195 | return __vmalloc(size, flags, PAGE_KERNEL); |
Ilya Dryomov | eeb0bed | 2014-01-09 20:08:21 +0200 | [diff] [blame] | 196 | } |
| 197 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 198 | |
| 199 | static int parse_fsid(const char *str, struct ceph_fsid *fsid) |
| 200 | { |
| 201 | int i = 0; |
| 202 | char tmp[3]; |
| 203 | int err = -EINVAL; |
| 204 | int d; |
| 205 | |
| 206 | dout("parse_fsid '%s'\n", str); |
| 207 | tmp[2] = 0; |
| 208 | while (*str && i < 16) { |
| 209 | if (ispunct(*str)) { |
| 210 | str++; |
| 211 | continue; |
| 212 | } |
| 213 | if (!isxdigit(str[0]) || !isxdigit(str[1])) |
| 214 | break; |
| 215 | tmp[0] = str[0]; |
| 216 | tmp[1] = str[1]; |
| 217 | if (sscanf(tmp, "%x", &d) < 1) |
| 218 | break; |
| 219 | fsid->fsid[i] = d & 0xff; |
| 220 | i++; |
| 221 | str += 2; |
| 222 | } |
| 223 | |
| 224 | if (i == 16) |
| 225 | err = 0; |
Chengguang Xu | 4c069a5 | 2018-01-30 16:29:17 +0800 | [diff] [blame] | 226 | dout("parse_fsid ret %d got fsid %pU\n", err, fsid); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 227 | return err; |
| 228 | } |
| 229 | |
| 230 | /* |
| 231 | * ceph options |
| 232 | */ |
| 233 | enum { |
| 234 | Opt_osdtimeout, |
| 235 | Opt_osdkeepalivetimeout, |
| 236 | Opt_mount_timeout, |
| 237 | Opt_osd_idle_ttl, |
Ilya Dryomov | 7cc5e38 | 2017-02-12 17:11:07 +0100 | [diff] [blame] | 238 | Opt_osd_request_timeout, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 239 | Opt_last_int, |
| 240 | /* int args above */ |
| 241 | Opt_fsid, |
| 242 | Opt_name, |
| 243 | Opt_secret, |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 244 | Opt_key, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 245 | Opt_ip, |
| 246 | Opt_last_string, |
| 247 | /* string args above */ |
Alex Elder | cffaba1 | 2012-02-15 07:43:54 -0600 | [diff] [blame] | 248 | Opt_share, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 249 | Opt_noshare, |
Alex Elder | cffaba1 | 2012-02-15 07:43:54 -0600 | [diff] [blame] | 250 | Opt_crc, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 251 | Opt_nocrc, |
Yan, Zheng | a3fc980 | 2014-11-11 16:30:55 +0800 | [diff] [blame] | 252 | Opt_cephx_require_signatures, |
| 253 | Opt_nocephx_require_signatures, |
Ilya Dryomov | a51983e | 2015-10-28 23:52:06 +0100 | [diff] [blame] | 254 | Opt_cephx_sign_messages, |
| 255 | Opt_nocephx_sign_messages, |
Chaitanya Huilgol | ba988f8 | 2015-01-23 16:41:25 +0530 | [diff] [blame] | 256 | Opt_tcp_nodelay, |
| 257 | Opt_notcp_nodelay, |
Dongsheng Yang | 02b2f54 | 2018-12-18 04:31:48 -0500 | [diff] [blame] | 258 | Opt_abort_on_full, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 259 | }; |
| 260 | |
| 261 | static match_table_t opt_tokens = { |
| 262 | {Opt_osdtimeout, "osdtimeout=%d"}, |
| 263 | {Opt_osdkeepalivetimeout, "osdkeepalive=%d"}, |
| 264 | {Opt_mount_timeout, "mount_timeout=%d"}, |
| 265 | {Opt_osd_idle_ttl, "osd_idle_ttl=%d"}, |
Ilya Dryomov | 7cc5e38 | 2017-02-12 17:11:07 +0100 | [diff] [blame] | 266 | {Opt_osd_request_timeout, "osd_request_timeout=%d"}, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 267 | /* int args above */ |
| 268 | {Opt_fsid, "fsid=%s"}, |
| 269 | {Opt_name, "name=%s"}, |
| 270 | {Opt_secret, "secret=%s"}, |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 271 | {Opt_key, "key=%s"}, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 272 | {Opt_ip, "ip=%s"}, |
| 273 | /* string args above */ |
Alex Elder | cffaba1 | 2012-02-15 07:43:54 -0600 | [diff] [blame] | 274 | {Opt_share, "share"}, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 275 | {Opt_noshare, "noshare"}, |
Alex Elder | cffaba1 | 2012-02-15 07:43:54 -0600 | [diff] [blame] | 276 | {Opt_crc, "crc"}, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 277 | {Opt_nocrc, "nocrc"}, |
Yan, Zheng | a3fc980 | 2014-11-11 16:30:55 +0800 | [diff] [blame] | 278 | {Opt_cephx_require_signatures, "cephx_require_signatures"}, |
| 279 | {Opt_nocephx_require_signatures, "nocephx_require_signatures"}, |
Ilya Dryomov | a51983e | 2015-10-28 23:52:06 +0100 | [diff] [blame] | 280 | {Opt_cephx_sign_messages, "cephx_sign_messages"}, |
| 281 | {Opt_nocephx_sign_messages, "nocephx_sign_messages"}, |
Chaitanya Huilgol | ba988f8 | 2015-01-23 16:41:25 +0530 | [diff] [blame] | 282 | {Opt_tcp_nodelay, "tcp_nodelay"}, |
| 283 | {Opt_notcp_nodelay, "notcp_nodelay"}, |
Dongsheng Yang | 02b2f54 | 2018-12-18 04:31:48 -0500 | [diff] [blame] | 284 | {Opt_abort_on_full, "abort_on_full"}, |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 285 | {-1, NULL} |
| 286 | }; |
| 287 | |
| 288 | void ceph_destroy_options(struct ceph_options *opt) |
| 289 | { |
| 290 | dout("destroy_options %p\n", opt); |
| 291 | kfree(opt->name); |
Tommi Virtanen | 8323c3a | 2011-03-25 16:32:57 -0700 | [diff] [blame] | 292 | if (opt->key) { |
| 293 | ceph_crypto_key_destroy(opt->key); |
| 294 | kfree(opt->key); |
| 295 | } |
Noah Watkins | 1cad789 | 2011-09-12 14:51:53 -0700 | [diff] [blame] | 296 | kfree(opt->mon_addr); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 297 | kfree(opt); |
| 298 | } |
| 299 | EXPORT_SYMBOL(ceph_destroy_options); |
| 300 | |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 301 | /* get secret from key store */ |
| 302 | static int get_secret(struct ceph_crypto_key *dst, const char *name) { |
| 303 | struct key *ukey; |
| 304 | int key_err; |
| 305 | int err = 0; |
Tommi Virtanen | 4b2a58a | 2011-03-28 14:59:38 -0700 | [diff] [blame] | 306 | struct ceph_crypto_key *ckey; |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 307 | |
Tommi Virtanen | 4b2a58a | 2011-03-28 14:59:38 -0700 | [diff] [blame] | 308 | ukey = request_key(&key_type_ceph, name, NULL); |
YueHaibing | bad8721 | 2018-08-07 21:02:34 +0800 | [diff] [blame] | 309 | if (IS_ERR(ukey)) { |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 310 | /* request_key errors don't map nicely to mount(2) |
| 311 | errors; don't even try, but still printk */ |
| 312 | key_err = PTR_ERR(ukey); |
| 313 | switch (key_err) { |
| 314 | case -ENOKEY: |
Joe Perches | b9a6789 | 2014-09-09 21:17:29 -0700 | [diff] [blame] | 315 | pr_warn("ceph: Mount failed due to key not found: %s\n", |
| 316 | name); |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 317 | break; |
| 318 | case -EKEYEXPIRED: |
Joe Perches | b9a6789 | 2014-09-09 21:17:29 -0700 | [diff] [blame] | 319 | pr_warn("ceph: Mount failed due to expired key: %s\n", |
| 320 | name); |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 321 | break; |
| 322 | case -EKEYREVOKED: |
Joe Perches | b9a6789 | 2014-09-09 21:17:29 -0700 | [diff] [blame] | 323 | pr_warn("ceph: Mount failed due to revoked key: %s\n", |
| 324 | name); |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 325 | break; |
| 326 | default: |
Joe Perches | b9a6789 | 2014-09-09 21:17:29 -0700 | [diff] [blame] | 327 | pr_warn("ceph: Mount failed due to unknown key error %d: %s\n", |
| 328 | key_err, name); |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 329 | } |
| 330 | err = -EPERM; |
| 331 | goto out; |
| 332 | } |
| 333 | |
David Howells | 146aa8b | 2015-10-21 14:04:48 +0100 | [diff] [blame] | 334 | ckey = ukey->payload.data[0]; |
Tommi Virtanen | 4b2a58a | 2011-03-28 14:59:38 -0700 | [diff] [blame] | 335 | err = ceph_crypto_key_clone(dst, ckey); |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 336 | if (err) |
| 337 | goto out_key; |
| 338 | /* pass through, err is 0 */ |
| 339 | |
| 340 | out_key: |
| 341 | key_put(ukey); |
| 342 | out: |
| 343 | return err; |
| 344 | } |
| 345 | |
Alex Elder | ee57741 | 2012-01-24 10:08:36 -0600 | [diff] [blame] | 346 | struct ceph_options * |
| 347 | ceph_parse_options(char *options, const char *dev_name, |
| 348 | const char *dev_name_end, |
| 349 | int (*parse_extra_token)(char *c, void *private), |
| 350 | void *private) |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 351 | { |
| 352 | struct ceph_options *opt; |
| 353 | const char *c; |
| 354 | int err = -ENOMEM; |
| 355 | substring_t argstr[MAX_OPT_ARGS]; |
| 356 | |
| 357 | opt = kzalloc(sizeof(*opt), GFP_KERNEL); |
| 358 | if (!opt) |
Alex Elder | ee57741 | 2012-01-24 10:08:36 -0600 | [diff] [blame] | 359 | return ERR_PTR(-ENOMEM); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 360 | opt->mon_addr = kcalloc(CEPH_MAX_MON, sizeof(*opt->mon_addr), |
| 361 | GFP_KERNEL); |
| 362 | if (!opt->mon_addr) |
| 363 | goto out; |
| 364 | |
| 365 | dout("parse_options %p options '%s' dev_name '%s'\n", opt, options, |
| 366 | dev_name); |
| 367 | |
| 368 | /* start with defaults */ |
| 369 | opt->flags = CEPH_OPT_DEFAULT; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 370 | opt->osd_keepalive_timeout = CEPH_OSD_KEEPALIVE_DEFAULT; |
Ilya Dryomov | a319bf5 | 2015-05-15 12:02:17 +0300 | [diff] [blame] | 371 | opt->mount_timeout = CEPH_MOUNT_TIMEOUT_DEFAULT; |
| 372 | opt->osd_idle_ttl = CEPH_OSD_IDLE_TTL_DEFAULT; |
Ilya Dryomov | 7cc5e38 | 2017-02-12 17:11:07 +0100 | [diff] [blame] | 373 | opt->osd_request_timeout = CEPH_OSD_REQUEST_TIMEOUT_DEFAULT; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 374 | |
| 375 | /* get mon ip(s) */ |
| 376 | /* ip1[:port1][,ip2[:port2]...] */ |
| 377 | err = ceph_parse_ips(dev_name, dev_name_end, opt->mon_addr, |
| 378 | CEPH_MAX_MON, &opt->num_mon); |
| 379 | if (err < 0) |
| 380 | goto out; |
| 381 | |
| 382 | /* parse mount options */ |
| 383 | while ((c = strsep(&options, ",")) != NULL) { |
Chengguang Xu | 17173c8 | 2018-06-27 21:05:08 +0800 | [diff] [blame] | 384 | int token, intval; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 385 | if (!*c) |
| 386 | continue; |
| 387 | err = -EINVAL; |
| 388 | token = match_token((char *)c, opt_tokens, argstr); |
Yehuda Sadeh | 010e3b4 | 2010-09-30 11:58:31 -0700 | [diff] [blame] | 389 | if (token < 0 && parse_extra_token) { |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 390 | /* extra? */ |
| 391 | err = parse_extra_token((char *)c, private); |
| 392 | if (err < 0) { |
| 393 | pr_err("bad option at '%s'\n", c); |
| 394 | goto out; |
| 395 | } |
| 396 | continue; |
| 397 | } |
| 398 | if (token < Opt_last_int) { |
Chengguang Xu | 17173c8 | 2018-06-27 21:05:08 +0800 | [diff] [blame] | 399 | err = match_int(&argstr[0], &intval); |
| 400 | if (err < 0) { |
Ilya Dryomov | 2f56b6b | 2018-06-27 16:38:13 +0200 | [diff] [blame] | 401 | pr_err("bad option arg (not int) at '%s'\n", c); |
Chengguang Xu | 17173c8 | 2018-06-27 21:05:08 +0800 | [diff] [blame] | 402 | goto out; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 403 | } |
| 404 | dout("got int token %d val %d\n", token, intval); |
| 405 | } else if (token > Opt_last_int && token < Opt_last_string) { |
| 406 | dout("got string token %d val %s\n", token, |
| 407 | argstr[0].from); |
| 408 | } else { |
| 409 | dout("got token %d\n", token); |
| 410 | } |
| 411 | switch (token) { |
| 412 | case Opt_ip: |
| 413 | err = ceph_parse_ips(argstr[0].from, |
| 414 | argstr[0].to, |
| 415 | &opt->my_addr, |
| 416 | 1, NULL); |
| 417 | if (err < 0) |
| 418 | goto out; |
| 419 | opt->flags |= CEPH_OPT_MYIP; |
| 420 | break; |
| 421 | |
| 422 | case Opt_fsid: |
| 423 | err = parse_fsid(argstr[0].from, &opt->fsid); |
| 424 | if (err == 0) |
| 425 | opt->flags |= CEPH_OPT_FSID; |
| 426 | break; |
| 427 | case Opt_name: |
Chengguang Xu | 937441f | 2018-02-06 08:25:55 +0800 | [diff] [blame] | 428 | kfree(opt->name); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 429 | opt->name = kstrndup(argstr[0].from, |
| 430 | argstr[0].to-argstr[0].from, |
| 431 | GFP_KERNEL); |
Chengguang Xu | affff07 | 2018-01-26 14:54:43 +0800 | [diff] [blame] | 432 | if (!opt->name) { |
| 433 | err = -ENOMEM; |
| 434 | goto out; |
| 435 | } |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 436 | break; |
| 437 | case Opt_secret: |
Chengguang Xu | 937441f | 2018-02-06 08:25:55 +0800 | [diff] [blame] | 438 | ceph_crypto_key_destroy(opt->key); |
| 439 | kfree(opt->key); |
| 440 | |
Tommi Virtanen | 8323c3a | 2011-03-25 16:32:57 -0700 | [diff] [blame] | 441 | opt->key = kzalloc(sizeof(*opt->key), GFP_KERNEL); |
| 442 | if (!opt->key) { |
| 443 | err = -ENOMEM; |
| 444 | goto out; |
| 445 | } |
| 446 | err = ceph_crypto_key_unarmor(opt->key, argstr[0].from); |
| 447 | if (err < 0) |
| 448 | goto out; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 449 | break; |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 450 | case Opt_key: |
Chengguang Xu | 937441f | 2018-02-06 08:25:55 +0800 | [diff] [blame] | 451 | ceph_crypto_key_destroy(opt->key); |
| 452 | kfree(opt->key); |
| 453 | |
Tommi Virtanen | e2c3d29 | 2011-03-25 16:40:48 -0700 | [diff] [blame] | 454 | opt->key = kzalloc(sizeof(*opt->key), GFP_KERNEL); |
| 455 | if (!opt->key) { |
| 456 | err = -ENOMEM; |
| 457 | goto out; |
| 458 | } |
| 459 | err = get_secret(opt->key, argstr[0].from); |
| 460 | if (err < 0) |
| 461 | goto out; |
| 462 | break; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 463 | |
| 464 | /* misc */ |
| 465 | case Opt_osdtimeout: |
Joe Perches | b9a6789 | 2014-09-09 21:17:29 -0700 | [diff] [blame] | 466 | pr_warn("ignoring deprecated osdtimeout option\n"); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 467 | break; |
| 468 | case Opt_osdkeepalivetimeout: |
Ilya Dryomov | a319bf5 | 2015-05-15 12:02:17 +0300 | [diff] [blame] | 469 | /* 0 isn't well defined right now, reject it */ |
| 470 | if (intval < 1 || intval > INT_MAX / 1000) { |
| 471 | pr_err("osdkeepalive out of range\n"); |
| 472 | err = -EINVAL; |
| 473 | goto out; |
| 474 | } |
| 475 | opt->osd_keepalive_timeout = |
| 476 | msecs_to_jiffies(intval * 1000); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 477 | break; |
| 478 | case Opt_osd_idle_ttl: |
Ilya Dryomov | a319bf5 | 2015-05-15 12:02:17 +0300 | [diff] [blame] | 479 | /* 0 isn't well defined right now, reject it */ |
| 480 | if (intval < 1 || intval > INT_MAX / 1000) { |
| 481 | pr_err("osd_idle_ttl out of range\n"); |
| 482 | err = -EINVAL; |
| 483 | goto out; |
| 484 | } |
| 485 | opt->osd_idle_ttl = msecs_to_jiffies(intval * 1000); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 486 | break; |
| 487 | case Opt_mount_timeout: |
Ilya Dryomov | a319bf5 | 2015-05-15 12:02:17 +0300 | [diff] [blame] | 488 | /* 0 is "wait forever" (i.e. infinite timeout) */ |
| 489 | if (intval < 0 || intval > INT_MAX / 1000) { |
| 490 | pr_err("mount_timeout out of range\n"); |
| 491 | err = -EINVAL; |
| 492 | goto out; |
| 493 | } |
| 494 | opt->mount_timeout = msecs_to_jiffies(intval * 1000); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 495 | break; |
Ilya Dryomov | 7cc5e38 | 2017-02-12 17:11:07 +0100 | [diff] [blame] | 496 | case Opt_osd_request_timeout: |
| 497 | /* 0 is "wait forever" (i.e. infinite timeout) */ |
| 498 | if (intval < 0 || intval > INT_MAX / 1000) { |
| 499 | pr_err("osd_request_timeout out of range\n"); |
| 500 | err = -EINVAL; |
| 501 | goto out; |
| 502 | } |
| 503 | opt->osd_request_timeout = msecs_to_jiffies(intval * 1000); |
| 504 | break; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 505 | |
Alex Elder | cffaba1 | 2012-02-15 07:43:54 -0600 | [diff] [blame] | 506 | case Opt_share: |
| 507 | opt->flags &= ~CEPH_OPT_NOSHARE; |
| 508 | break; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 509 | case Opt_noshare: |
| 510 | opt->flags |= CEPH_OPT_NOSHARE; |
| 511 | break; |
| 512 | |
Alex Elder | cffaba1 | 2012-02-15 07:43:54 -0600 | [diff] [blame] | 513 | case Opt_crc: |
| 514 | opt->flags &= ~CEPH_OPT_NOCRC; |
| 515 | break; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 516 | case Opt_nocrc: |
| 517 | opt->flags |= CEPH_OPT_NOCRC; |
| 518 | break; |
Chaitanya Huilgol | ba988f8 | 2015-01-23 16:41:25 +0530 | [diff] [blame] | 519 | |
Yan, Zheng | a3fc980 | 2014-11-11 16:30:55 +0800 | [diff] [blame] | 520 | case Opt_cephx_require_signatures: |
| 521 | opt->flags &= ~CEPH_OPT_NOMSGAUTH; |
| 522 | break; |
| 523 | case Opt_nocephx_require_signatures: |
| 524 | opt->flags |= CEPH_OPT_NOMSGAUTH; |
| 525 | break; |
Ilya Dryomov | a51983e | 2015-10-28 23:52:06 +0100 | [diff] [blame] | 526 | case Opt_cephx_sign_messages: |
| 527 | opt->flags &= ~CEPH_OPT_NOMSGSIGN; |
| 528 | break; |
| 529 | case Opt_nocephx_sign_messages: |
| 530 | opt->flags |= CEPH_OPT_NOMSGSIGN; |
| 531 | break; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 532 | |
Chaitanya Huilgol | ba988f8 | 2015-01-23 16:41:25 +0530 | [diff] [blame] | 533 | case Opt_tcp_nodelay: |
| 534 | opt->flags |= CEPH_OPT_TCP_NODELAY; |
| 535 | break; |
| 536 | case Opt_notcp_nodelay: |
| 537 | opt->flags &= ~CEPH_OPT_TCP_NODELAY; |
| 538 | break; |
| 539 | |
Dongsheng Yang | 02b2f54 | 2018-12-18 04:31:48 -0500 | [diff] [blame] | 540 | case Opt_abort_on_full: |
| 541 | opt->flags |= CEPH_OPT_ABORT_ON_FULL; |
| 542 | break; |
| 543 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 544 | default: |
| 545 | BUG_ON(token); |
| 546 | } |
| 547 | } |
| 548 | |
| 549 | /* success */ |
Alex Elder | ee57741 | 2012-01-24 10:08:36 -0600 | [diff] [blame] | 550 | return opt; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 551 | |
| 552 | out: |
| 553 | ceph_destroy_options(opt); |
Alex Elder | ee57741 | 2012-01-24 10:08:36 -0600 | [diff] [blame] | 554 | return ERR_PTR(err); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 555 | } |
| 556 | EXPORT_SYMBOL(ceph_parse_options); |
| 557 | |
Dongsheng Yang | 02b2f54 | 2018-12-18 04:31:48 -0500 | [diff] [blame] | 558 | int ceph_print_client_options(struct seq_file *m, struct ceph_client *client, |
| 559 | bool show_all) |
Ilya Dryomov | ff40f9a | 2015-03-25 21:02:16 +0300 | [diff] [blame] | 560 | { |
| 561 | struct ceph_options *opt = client->options; |
| 562 | size_t pos = m->count; |
| 563 | |
Kees Cook | a068acf | 2015-09-04 15:44:57 -0700 | [diff] [blame] | 564 | if (opt->name) { |
| 565 | seq_puts(m, "name="); |
| 566 | seq_escape(m, opt->name, ", \t\n\\"); |
| 567 | seq_putc(m, ','); |
| 568 | } |
Ilya Dryomov | ff40f9a | 2015-03-25 21:02:16 +0300 | [diff] [blame] | 569 | if (opt->key) |
| 570 | seq_puts(m, "secret=<hidden>,"); |
| 571 | |
| 572 | if (opt->flags & CEPH_OPT_FSID) |
| 573 | seq_printf(m, "fsid=%pU,", &opt->fsid); |
| 574 | if (opt->flags & CEPH_OPT_NOSHARE) |
| 575 | seq_puts(m, "noshare,"); |
| 576 | if (opt->flags & CEPH_OPT_NOCRC) |
| 577 | seq_puts(m, "nocrc,"); |
| 578 | if (opt->flags & CEPH_OPT_NOMSGAUTH) |
| 579 | seq_puts(m, "nocephx_require_signatures,"); |
Ilya Dryomov | a51983e | 2015-10-28 23:52:06 +0100 | [diff] [blame] | 580 | if (opt->flags & CEPH_OPT_NOMSGSIGN) |
| 581 | seq_puts(m, "nocephx_sign_messages,"); |
Ilya Dryomov | ff40f9a | 2015-03-25 21:02:16 +0300 | [diff] [blame] | 582 | if ((opt->flags & CEPH_OPT_TCP_NODELAY) == 0) |
| 583 | seq_puts(m, "notcp_nodelay,"); |
Dongsheng Yang | 02b2f54 | 2018-12-18 04:31:48 -0500 | [diff] [blame] | 584 | if (show_all && (opt->flags & CEPH_OPT_ABORT_ON_FULL)) |
| 585 | seq_puts(m, "abort_on_full,"); |
Ilya Dryomov | ff40f9a | 2015-03-25 21:02:16 +0300 | [diff] [blame] | 586 | |
| 587 | if (opt->mount_timeout != CEPH_MOUNT_TIMEOUT_DEFAULT) |
Ilya Dryomov | a319bf5 | 2015-05-15 12:02:17 +0300 | [diff] [blame] | 588 | seq_printf(m, "mount_timeout=%d,", |
| 589 | jiffies_to_msecs(opt->mount_timeout) / 1000); |
Ilya Dryomov | ff40f9a | 2015-03-25 21:02:16 +0300 | [diff] [blame] | 590 | if (opt->osd_idle_ttl != CEPH_OSD_IDLE_TTL_DEFAULT) |
Ilya Dryomov | a319bf5 | 2015-05-15 12:02:17 +0300 | [diff] [blame] | 591 | seq_printf(m, "osd_idle_ttl=%d,", |
| 592 | jiffies_to_msecs(opt->osd_idle_ttl) / 1000); |
Ilya Dryomov | ff40f9a | 2015-03-25 21:02:16 +0300 | [diff] [blame] | 593 | if (opt->osd_keepalive_timeout != CEPH_OSD_KEEPALIVE_DEFAULT) |
| 594 | seq_printf(m, "osdkeepalivetimeout=%d,", |
Ilya Dryomov | a319bf5 | 2015-05-15 12:02:17 +0300 | [diff] [blame] | 595 | jiffies_to_msecs(opt->osd_keepalive_timeout) / 1000); |
Ilya Dryomov | 7cc5e38 | 2017-02-12 17:11:07 +0100 | [diff] [blame] | 596 | if (opt->osd_request_timeout != CEPH_OSD_REQUEST_TIMEOUT_DEFAULT) |
| 597 | seq_printf(m, "osd_request_timeout=%d,", |
| 598 | jiffies_to_msecs(opt->osd_request_timeout) / 1000); |
Ilya Dryomov | ff40f9a | 2015-03-25 21:02:16 +0300 | [diff] [blame] | 599 | |
| 600 | /* drop redundant comma */ |
| 601 | if (m->count != pos) |
| 602 | m->count--; |
| 603 | |
| 604 | return 0; |
| 605 | } |
| 606 | EXPORT_SYMBOL(ceph_print_client_options); |
| 607 | |
Ilya Dryomov | 005a07bf | 2016-08-18 18:38:43 +0200 | [diff] [blame] | 608 | struct ceph_entity_addr *ceph_client_addr(struct ceph_client *client) |
| 609 | { |
| 610 | return &client->msgr.inst.addr; |
| 611 | } |
| 612 | EXPORT_SYMBOL(ceph_client_addr); |
| 613 | |
Ilya Dryomov | 033268a | 2016-08-12 14:59:58 +0200 | [diff] [blame] | 614 | u64 ceph_client_gid(struct ceph_client *client) |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 615 | { |
| 616 | return client->monc.auth->global_id; |
| 617 | } |
Ilya Dryomov | 033268a | 2016-08-12 14:59:58 +0200 | [diff] [blame] | 618 | EXPORT_SYMBOL(ceph_client_gid); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 619 | |
| 620 | /* |
| 621 | * create a fresh client instance |
| 622 | */ |
Ilya Dryomov | 74da4a0f | 2017-03-03 18:16:07 +0100 | [diff] [blame] | 623 | struct ceph_client *ceph_create_client(struct ceph_options *opt, void *private) |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 624 | { |
| 625 | struct ceph_client *client; |
Sage Weil | 6ab00d4 | 2011-08-09 09:41:59 -0700 | [diff] [blame] | 626 | struct ceph_entity_addr *myaddr = NULL; |
Jason A. Donenfeld | ae5b806a | 2017-06-07 22:44:54 -0400 | [diff] [blame] | 627 | int err; |
| 628 | |
| 629 | err = wait_for_random_bytes(); |
| 630 | if (err < 0) |
| 631 | return ERR_PTR(err); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 632 | |
| 633 | client = kzalloc(sizeof(*client), GFP_KERNEL); |
| 634 | if (client == NULL) |
| 635 | return ERR_PTR(-ENOMEM); |
| 636 | |
| 637 | client->private = private; |
| 638 | client->options = opt; |
| 639 | |
| 640 | mutex_init(&client->mount_mutex); |
| 641 | init_waitqueue_head(&client->auth_wq); |
| 642 | client->auth_err = 0; |
| 643 | |
| 644 | client->extra_mon_dispatch = NULL; |
Ilya Dryomov | 74da4a0f | 2017-03-03 18:16:07 +0100 | [diff] [blame] | 645 | client->supported_features = CEPH_FEATURES_SUPPORTED_DEFAULT; |
| 646 | client->required_features = CEPH_FEATURES_REQUIRED_DEFAULT; |
| 647 | |
| 648 | if (!ceph_test_opt(client, NOMSGAUTH)) |
| 649 | client->required_features |= CEPH_FEATURE_MSG_AUTH; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 650 | |
Sage Weil | 6ab00d4 | 2011-08-09 09:41:59 -0700 | [diff] [blame] | 651 | /* msgr */ |
| 652 | if (ceph_test_opt(client, MYIP)) |
| 653 | myaddr = &client->options->my_addr; |
Chaitanya Huilgol | ba988f8 | 2015-01-23 16:41:25 +0530 | [diff] [blame] | 654 | |
Ilya Dryomov | 859bff5 | 2015-10-28 23:50:58 +0100 | [diff] [blame] | 655 | ceph_messenger_init(&client->msgr, myaddr); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 656 | |
| 657 | /* subsystems */ |
| 658 | err = ceph_monc_init(&client->monc, client); |
| 659 | if (err < 0) |
Alex Elder | 15d9882 | 2012-05-26 23:26:43 -0500 | [diff] [blame] | 660 | goto fail; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 661 | err = ceph_osdc_init(&client->osdc, client); |
| 662 | if (err < 0) |
| 663 | goto fail_monc; |
| 664 | |
| 665 | return client; |
| 666 | |
| 667 | fail_monc: |
| 668 | ceph_monc_stop(&client->monc); |
| 669 | fail: |
Ilya Dryomov | 757856d | 2015-06-25 17:47:45 +0300 | [diff] [blame] | 670 | ceph_messenger_fini(&client->msgr); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 671 | kfree(client); |
| 672 | return ERR_PTR(err); |
| 673 | } |
| 674 | EXPORT_SYMBOL(ceph_create_client); |
| 675 | |
| 676 | void ceph_destroy_client(struct ceph_client *client) |
| 677 | { |
| 678 | dout("destroy_client %p\n", client); |
| 679 | |
Guanjun He | a2a3258 | 2012-07-08 19:50:33 -0700 | [diff] [blame] | 680 | atomic_set(&client->msgr.stopping, 1); |
| 681 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 682 | /* unmount */ |
| 683 | ceph_osdc_stop(&client->osdc); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 684 | ceph_monc_stop(&client->monc); |
Ilya Dryomov | 757856d | 2015-06-25 17:47:45 +0300 | [diff] [blame] | 685 | ceph_messenger_fini(&client->msgr); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 686 | |
| 687 | ceph_debugfs_client_cleanup(client); |
| 688 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 689 | ceph_destroy_options(client->options); |
| 690 | |
| 691 | kfree(client); |
| 692 | dout("destroy_client %p done\n", client); |
| 693 | } |
| 694 | EXPORT_SYMBOL(ceph_destroy_client); |
| 695 | |
| 696 | /* |
| 697 | * true if we have the mon map (and have thus joined the cluster) |
| 698 | */ |
Zhang Zhuoyu | 3b33f69 | 2016-03-25 05:18:39 -0400 | [diff] [blame] | 699 | static bool have_mon_and_osd_map(struct ceph_client *client) |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 700 | { |
| 701 | return client->monc.monmap && client->monc.monmap->epoch && |
| 702 | client->osdc.osdmap && client->osdc.osdmap->epoch; |
| 703 | } |
| 704 | |
| 705 | /* |
| 706 | * mount: join the ceph cluster, and open root directory. |
| 707 | */ |
| 708 | int __ceph_open_session(struct ceph_client *client, unsigned long started) |
| 709 | { |
Ilya Dryomov | a319bf5 | 2015-05-15 12:02:17 +0300 | [diff] [blame] | 710 | unsigned long timeout = client->options->mount_timeout; |
Ilya Dryomov | 216639d | 2015-05-19 12:03:33 +0300 | [diff] [blame] | 711 | long err; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 712 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 713 | /* open session, and wait for mon and osd maps */ |
| 714 | err = ceph_monc_open_session(&client->monc); |
| 715 | if (err < 0) |
| 716 | return err; |
| 717 | |
| 718 | while (!have_mon_and_osd_map(client)) { |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 719 | if (timeout && time_after_eq(jiffies, started + timeout)) |
Ilya Dryomov | 216639d | 2015-05-19 12:03:33 +0300 | [diff] [blame] | 720 | return -ETIMEDOUT; |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 721 | |
| 722 | /* wait */ |
| 723 | dout("mount waiting for mon_map\n"); |
| 724 | err = wait_event_interruptible_timeout(client->auth_wq, |
| 725 | have_mon_and_osd_map(client) || (client->auth_err < 0), |
Ilya Dryomov | a319bf5 | 2015-05-15 12:02:17 +0300 | [diff] [blame] | 726 | ceph_timeout_jiffies(timeout)); |
Ilya Dryomov | 216639d | 2015-05-19 12:03:33 +0300 | [diff] [blame] | 727 | if (err < 0) |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 728 | return err; |
| 729 | if (client->auth_err < 0) |
| 730 | return client->auth_err; |
| 731 | } |
| 732 | |
Ilya Dryomov | 033268a | 2016-08-12 14:59:58 +0200 | [diff] [blame] | 733 | pr_info("client%llu fsid %pU\n", ceph_client_gid(client), |
| 734 | &client->fsid); |
Ilya Dryomov | 02ac956 | 2016-01-06 12:56:21 +0300 | [diff] [blame] | 735 | ceph_debugfs_client_init(client); |
| 736 | |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 737 | return 0; |
| 738 | } |
| 739 | EXPORT_SYMBOL(__ceph_open_session); |
| 740 | |
| 741 | |
| 742 | int ceph_open_session(struct ceph_client *client) |
| 743 | { |
| 744 | int ret; |
| 745 | unsigned long started = jiffies; /* note the start time */ |
| 746 | |
| 747 | dout("open_session start\n"); |
| 748 | mutex_lock(&client->mount_mutex); |
| 749 | |
| 750 | ret = __ceph_open_session(client, started); |
| 751 | |
| 752 | mutex_unlock(&client->mount_mutex); |
| 753 | return ret; |
| 754 | } |
| 755 | EXPORT_SYMBOL(ceph_open_session); |
| 756 | |
| 757 | |
| 758 | static int __init init_ceph_lib(void) |
| 759 | { |
| 760 | int ret = 0; |
| 761 | |
| 762 | ret = ceph_debugfs_init(); |
| 763 | if (ret < 0) |
| 764 | goto out; |
| 765 | |
Tommi Virtanen | 4b2a58a | 2011-03-28 14:59:38 -0700 | [diff] [blame] | 766 | ret = ceph_crypto_init(); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 767 | if (ret < 0) |
| 768 | goto out_debugfs; |
| 769 | |
Tommi Virtanen | 4b2a58a | 2011-03-28 14:59:38 -0700 | [diff] [blame] | 770 | ret = ceph_msgr_init(); |
| 771 | if (ret < 0) |
| 772 | goto out_crypto; |
| 773 | |
Alex Elder | 5522ae0 | 2013-05-01 12:43:04 -0500 | [diff] [blame] | 774 | ret = ceph_osdc_setup(); |
| 775 | if (ret < 0) |
| 776 | goto out_msgr; |
| 777 | |
Sage Weil | 4f6a7e5 | 2013-02-23 10:41:09 -0800 | [diff] [blame] | 778 | pr_info("loaded (mon/osd proto %d/%d)\n", |
| 779 | CEPH_MONC_PROTOCOL, CEPH_OSDC_PROTOCOL); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 780 | |
| 781 | return 0; |
| 782 | |
Alex Elder | 5522ae0 | 2013-05-01 12:43:04 -0500 | [diff] [blame] | 783 | out_msgr: |
| 784 | ceph_msgr_exit(); |
Tommi Virtanen | 4b2a58a | 2011-03-28 14:59:38 -0700 | [diff] [blame] | 785 | out_crypto: |
| 786 | ceph_crypto_shutdown(); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 787 | out_debugfs: |
| 788 | ceph_debugfs_cleanup(); |
| 789 | out: |
| 790 | return ret; |
| 791 | } |
| 792 | |
| 793 | static void __exit exit_ceph_lib(void) |
| 794 | { |
| 795 | dout("exit_ceph_lib\n"); |
Yan, Zheng | 51e9273 | 2016-02-05 15:36:22 +0800 | [diff] [blame] | 796 | WARN_ON(!ceph_strings_empty()); |
| 797 | |
Alex Elder | 5522ae0 | 2013-05-01 12:43:04 -0500 | [diff] [blame] | 798 | ceph_osdc_cleanup(); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 799 | ceph_msgr_exit(); |
Tommi Virtanen | 4b2a58a | 2011-03-28 14:59:38 -0700 | [diff] [blame] | 800 | ceph_crypto_shutdown(); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 801 | ceph_debugfs_cleanup(); |
| 802 | } |
| 803 | |
| 804 | module_init(init_ceph_lib); |
| 805 | module_exit(exit_ceph_lib); |
| 806 | |
| 807 | MODULE_AUTHOR("Sage Weil <sage@newdream.net>"); |
| 808 | MODULE_AUTHOR("Yehuda Sadeh <yehuda@hq.newdream.net>"); |
| 809 | MODULE_AUTHOR("Patience Warnick <patience@newdream.net>"); |
Hong Zhiguo | 6c13a6b | 2015-06-10 21:13:25 +0800 | [diff] [blame] | 810 | MODULE_DESCRIPTION("Ceph core library"); |
Yehuda Sadeh | 3d14c5d | 2010-04-06 15:14:15 -0700 | [diff] [blame] | 811 | MODULE_LICENSE("GPL"); |