include/linux/ceph/messenger.h

   1 /* SPDX-License-Identifier: GPL-2.0 */
   2 #ifndef __FS_CEPH_MESSENGER_H
   3 #define __FS_CEPH_MESSENGER_H
   4
   5 #include <linux/bvec.h>
   6 #include <linux/crypto.h>
   7 #include <linux/kref.h>
   8 #include <linux/mutex.h>
   9 #include <linux/net.h>
  10 #include <linux/radix-tree.h>
  11 #include <linux/uio.h>
  12 #include <linux/workqueue.h>
  13 #include <net/net_namespace.h>
  14
  15 #include <linux/ceph/types.h>
  16 #include <linux/ceph/buffer.h>
  17
  18 struct ceph_msg;
  19 struct ceph_connection;
  20 struct ceph_msg_data_cursor;
  21
  22 /*
  23  * Ceph defines these callbacks for handling connection events.
  24  */
  25 struct ceph_connection_operations {
  26         struct ceph_connection *(*get)(struct ceph_connection *);
  27         void (*put)(struct ceph_connection *);
  28
  29         /* handle an incoming message. */
  30         void (*dispatch) (struct ceph_connection *con, struct ceph_msg *m);
  31
  32         /* authorize an outgoing connection */
  33         struct ceph_auth_handshake *(*get_authorizer) (
  34                                 struct ceph_connection *con,
  35                                int *proto, int force_new);
  36         int (*add_authorizer_challenge)(struct ceph_connection *con,
  37                                         void *challenge_buf,
  38                                         int challenge_buf_len);
  39         int (*verify_authorizer_reply) (struct ceph_connection *con);
  40         int (*invalidate_authorizer)(struct ceph_connection *con);
  41
  42         /* there was some error on the socket (disconnect, whatever) */
  43         void (*fault) (struct ceph_connection *con);
  44
  45         /* a remote host as terminated a message exchange session, and messages
  46          * we sent (or they tried to send us) may be lost. */
  47         void (*peer_reset) (struct ceph_connection *con);
  48
  49         struct ceph_msg * (*alloc_msg) (struct ceph_connection *con,
  50                                         struct ceph_msg_header *hdr,
  51                                         int *skip);
  52
  53         void (*reencode_message) (struct ceph_msg *msg);
  54
  55         int (*sign_message) (struct ceph_msg *msg);
  56         int (*check_message_signature) (struct ceph_msg *msg);
  57
  58         /* msgr2 authentication exchange */
  59         int (*get_auth_request)(struct ceph_connection *con,
  60                                 void *buf, int *buf_len,
  61                                 void **authorizer, int *authorizer_len);
  62         int (*handle_auth_reply_more)(struct ceph_connection *con,
  63                                       void *reply, int reply_len,
  64                                       void *buf, int *buf_len,
  65                                       void **authorizer, int *authorizer_len);
  66         int (*handle_auth_done)(struct ceph_connection *con,
  67                                 u64 global_id, void *reply, int reply_len,
  68                                 u8 *session_key, int *session_key_len,
  69                                 u8 *con_secret, int *con_secret_len);
  70         int (*handle_auth_bad_method)(struct ceph_connection *con,
  71                                       int used_proto, int result,
  72                                       const int *allowed_protos, int proto_cnt,
  73                                       const int *allowed_modes, int mode_cnt);
  74
  75         /**
  76          * sparse_read: read sparse data
  77          * @con: connection we're reading from
  78          * @cursor: data cursor for reading extents
  79          * @buf: optional buffer to read into
  80          *
  81          * This should be called more than once, each time setting up to
  82          * receive an extent into the current cursor position, and zeroing
  83          * the holes between them.
  84          *
  85          * Returns amount of data to be read (in bytes), 0 if reading is
  86          * complete, or -errno if there was an error.
  87          *
  88          * If @buf is set on a >0 return, then the data should be read into
  89          * the provided buffer. Otherwise, it should be read into the cursor.
  90          *
  91          * The sparse read operation is expected to initialize the cursor
  92          * with a length covering up to the end of the last extent.
  93          */
  94         int (*sparse_read)(struct ceph_connection *con,
  95                            struct ceph_msg_data_cursor *cursor,
  96                            char **buf);
  97
  98 };
  99
 100 /* use format string %s%lld */
 101 #define ENTITY_NAME(n) ceph_entity_type_name((n).type), le64_to_cpu((n).num)
 102
 103 struct ceph_messenger {
 104         struct ceph_entity_inst inst;    /* my name+address */
 105         struct ceph_entity_addr my_enc_addr;
 106
 107         atomic_t stopping;
 108         possible_net_t net;
 109
 110         /*
 111          * the global_seq counts connections i (attempt to) initiate
 112          * in order to disambiguate certain connect race conditions.
 113          */
 114         u32 global_seq;
 115         spinlock_t global_seq_lock;
 116 };
 117
 118 enum ceph_msg_data_type {
 119         CEPH_MSG_DATA_NONE,     /* message contains no data payload */
 120         CEPH_MSG_DATA_PAGES,    /* data source/destination is a page array */
 121         CEPH_MSG_DATA_PAGELIST, /* data source/destination is a pagelist */
 122 #ifdef CONFIG_BLOCK
 123         CEPH_MSG_DATA_BIO,      /* data source/destination is a bio list */
 124 #endif /* CONFIG_BLOCK */
 125         CEPH_MSG_DATA_BVECS,    /* data source/destination is a bio_vec array */
 126         CEPH_MSG_DATA_ITER,     /* data source/destination is an iov_iter */
 127 };
 128
 129 #ifdef CONFIG_BLOCK
 130
 131 struct ceph_bio_iter {
 132         struct bio *bio;
 133         struct bvec_iter iter;
 134 };
 135
 136 #define __ceph_bio_iter_advance_step(it, n, STEP) do {                        \
 137         unsigned int __n = (n), __cur_n;                                      \
 138                                                                               \
 139         while (__n) {                                                         \
 140                 BUG_ON(!(it)->iter.bi_size);                                  \
 141                 __cur_n = min((it)->iter.bi_size, __n);                       \
 142                 (void)(STEP);                                                 \
 143                 bio_advance_iter((it)->bio, &(it)->iter, __cur_n);            \
 144                 if (!(it)->iter.bi_size && (it)->bio->bi_next) {              \
 145                         dout("__ceph_bio_iter_advance_step next bio\n");      \
 146                         (it)->bio = (it)->bio->bi_next;                       \
 147                         (it)->iter = (it)->bio->bi_iter;                      \
 148                 }                                                             \
 149                 __n -= __cur_n;                                               \
 150         }                                                                     \
 151 } while (0)
 152
 153 /*
 154  * Advance @it by @n bytes.
 155  */
 156 #define ceph_bio_iter_advance(it, n)                                          \
 157         __ceph_bio_iter_advance_step(it, n, 0)
 158
 159 /*
 160  * Advance @it by @n bytes, executing BVEC_STEP for each bio_vec.
 161  */
 162 #define ceph_bio_iter_advance_step(it, n, BVEC_STEP)                          \
 163         __ceph_bio_iter_advance_step(it, n, ({                                \
 164                 struct bio_vec bv;                                            \
 165                 struct bvec_iter __cur_iter;                                  \
 166                                                                               \
 167                 __cur_iter = (it)->iter;                                      \
 168                 __cur_iter.bi_size = __cur_n;                                 \
 169                 __bio_for_each_segment(bv, (it)->bio, __cur_iter, __cur_iter) \
 170                         (void)(BVEC_STEP);                                    \
 171         }))
 172
 173 #endif /* CONFIG_BLOCK */
 174
 175 struct ceph_bvec_iter {
 176         struct bio_vec *bvecs;
 177         struct bvec_iter iter;
 178 };
 179
 180 #define __ceph_bvec_iter_advance_step(it, n, STEP) do {                       \
 181         BUG_ON((n) > (it)->iter.bi_size);                                     \
 182         (void)(STEP);                                                         \
 183         bvec_iter_advance((it)->bvecs, &(it)->iter, (n));                     \
 184 } while (0)
 185
 186 /*
 187  * Advance @it by @n bytes.
 188  */
 189 #define ceph_bvec_iter_advance(it, n)                                         \
 190         __ceph_bvec_iter_advance_step(it, n, 0)
 191
 192 /*
 193  * Advance @it by @n bytes, executing BVEC_STEP for each bio_vec.
 194  */
 195 #define ceph_bvec_iter_advance_step(it, n, BVEC_STEP)                         \
 196         __ceph_bvec_iter_advance_step(it, n, ({                               \
 197                 struct bio_vec bv;                                            \
 198                 struct bvec_iter __cur_iter;                                  \
 199                                                                               \
 200                 __cur_iter = (it)->iter;                                      \
 201                 __cur_iter.bi_size = (n);                                     \
 202                 for_each_bvec(bv, (it)->bvecs, __cur_iter, __cur_iter)        \
 203                         (void)(BVEC_STEP);                                    \
 204         }))
 205
 206 #define ceph_bvec_iter_shorten(it, n) do {                                    \
 207         BUG_ON((n) > (it)->iter.bi_size);                                     \
 208         (it)->iter.bi_size = (n);                                             \
 209 } while (0)
 210
 211 struct ceph_msg_data {
 212         enum ceph_msg_data_type         type;
 213         union {
 214 #ifdef CONFIG_BLOCK
 215                 struct {
 216                         struct ceph_bio_iter    bio_pos;
 217                         u32                     bio_length;
 218                 };
 219 #endif /* CONFIG_BLOCK */
 220                 struct ceph_bvec_iter   bvec_pos;
 221                 struct {
 222                         struct page     **pages;
 223                         size_t          length;         /* total # bytes */
 224                         unsigned int    alignment;      /* first page */
 225                         bool            own_pages;
 226                 };
 227                 struct ceph_pagelist    *pagelist;
 228                 struct iov_iter         iter;
 229         };
 230 };
 231
 232 struct ceph_msg_data_cursor {
 233         size_t                  total_resid;    /* across all data items */
 234
 235         struct ceph_msg_data    *data;          /* current data item */
 236         size_t                  resid;          /* bytes not yet consumed */
 237         int                     sr_resid;       /* residual sparse_read len */
 238         bool                    need_crc;       /* crc update needed */
 239         union {
 240 #ifdef CONFIG_BLOCK
 241                 struct ceph_bio_iter    bio_iter;
 242 #endif /* CONFIG_BLOCK */
 243                 struct bvec_iter        bvec_iter;
 244                 struct {                                /* pages */
 245                         unsigned int    page_offset;    /* offset in page */
 246                         unsigned short  page_index;     /* index in array */
 247                         unsigned short  page_count;     /* pages in array */
 248                 };
 249                 struct {                                /* pagelist */
 250                         struct page     *page;          /* page from list */
 251                         size_t          offset;         /* bytes from list */
 252                 };
 253                 struct {
 254                         struct iov_iter         iov_iter;
 255                         unsigned int            lastlen;
 256                 };
 257         };
 258 };
 259
 260 /*
 261  * a single message.  it contains a header (src, dest, message type, etc.),
 262  * footer (crc values, mainly), a "front" message body, and possibly a
 263  * data payload (stored in some number of pages).
 264  */
 265 struct ceph_msg {
 266         struct ceph_msg_header hdr;     /* header */
 267         union {
 268                 struct ceph_msg_footer footer;          /* footer */
 269                 struct ceph_msg_footer_old old_footer;  /* old format footer */
 270         };
 271         struct kvec front;              /* unaligned blobs of message */
 272         struct ceph_buffer *middle;
 273
 274         size_t                          data_length;
 275         struct ceph_msg_data            *data;
 276         int                             num_data_items;
 277         int                             max_data_items;
 278         struct ceph_msg_data_cursor     cursor;
 279
 280         struct ceph_connection *con;
 281         struct list_head list_head;     /* links for connection lists */
 282
 283         struct kref kref;
 284         bool more_to_follow;
 285         bool needs_out_seq;
 286         u64 sparse_read_total;
 287         int front_alloc_len;
 288
 289         struct ceph_msgpool *pool;
 290 };
 291
 292 /*
 293  * connection states
 294  */
 295 #define CEPH_CON_S_CLOSED               1
 296 #define CEPH_CON_S_PREOPEN              2
 297 #define CEPH_CON_S_V1_BANNER            3
 298 #define CEPH_CON_S_V1_CONNECT_MSG       4
 299 #define CEPH_CON_S_V2_BANNER_PREFIX     5
 300 #define CEPH_CON_S_V2_BANNER_PAYLOAD    6
 301 #define CEPH_CON_S_V2_HELLO             7
 302 #define CEPH_CON_S_V2_AUTH              8
 303 #define CEPH_CON_S_V2_AUTH_SIGNATURE    9
 304 #define CEPH_CON_S_V2_SESSION_CONNECT   10
 305 #define CEPH_CON_S_V2_SESSION_RECONNECT 11
 306 #define CEPH_CON_S_OPEN                 12
 307 #define CEPH_CON_S_STANDBY              13
 308
 309 /*
 310  * ceph_connection flag bits
 311  */
 312 #define CEPH_CON_F_LOSSYTX              0  /* we can close channel or drop
 313                                               messages on errors */
 314 #define CEPH_CON_F_KEEPALIVE_PENDING    1  /* we need to send a keepalive */
 315 #define CEPH_CON_F_WRITE_PENDING        2  /* we have data ready to send */
 316 #define CEPH_CON_F_SOCK_CLOSED          3  /* socket state changed to closed */
 317 #define CEPH_CON_F_BACKOFF              4  /* need to retry queuing delayed
 318                                               work */
 319
 320 /* ceph connection fault delay defaults, for exponential backoff */
 321 #define BASE_DELAY_INTERVAL     (HZ / 4)
 322 #define MAX_DELAY_INTERVAL      (15 * HZ)
 323
 324 struct ceph_connection_v1_info {
 325         struct kvec out_kvec[8],         /* sending header/footer data */
 326                 *out_kvec_cur;
 327         int out_kvec_left;   /* kvec's left in out_kvec */
 328         int out_skip;        /* skip this many bytes */
 329         int out_kvec_bytes;  /* total bytes left */
 330         bool out_more;       /* there is more data after the kvecs */
 331         bool out_msg_done;
 332
 333         struct ceph_auth_handshake *auth;
 334         int auth_retry;       /* true if we need a newer authorizer */
 335
 336         /* connection negotiation temps */
 337         u8 in_banner[CEPH_BANNER_MAX_LEN];
 338         struct ceph_entity_addr actual_peer_addr;
 339         struct ceph_entity_addr peer_addr_for_me;
 340         struct ceph_msg_connect out_connect;
 341         struct ceph_msg_connect_reply in_reply;
 342
 343         int in_base_pos;     /* bytes read */
 344
 345         /* sparse reads */
 346         struct kvec in_sr_kvec; /* current location to receive into */
 347         u64 in_sr_len;          /* amount of data in this extent */
 348
 349         /* message in temps */
 350         u8 in_tag;           /* protocol control byte */
 351         struct ceph_msg_header in_hdr;
 352         __le64 in_temp_ack;  /* for reading an ack */
 353
 354         /* message out temps */
 355         struct ceph_msg_header out_hdr;
 356         __le64 out_temp_ack;  /* for writing an ack */
 357         struct ceph_timespec out_temp_keepalive2;  /* for writing keepalive2
 358                                                       stamp */
 359
 360         u32 connect_seq;      /* identify the most recent connection
 361                                  attempt for this session */
 362         u32 peer_global_seq;  /* peer's global seq for this connection */
 363 };
 364
 365 #define CEPH_CRC_LEN                    4
 366 #define CEPH_GCM_KEY_LEN                16
 367 #define CEPH_GCM_IV_LEN                 sizeof(struct ceph_gcm_nonce)
 368 #define CEPH_GCM_BLOCK_LEN              16
 369 #define CEPH_GCM_TAG_LEN                16
 370
 371 #define CEPH_PREAMBLE_LEN               32
 372 #define CEPH_PREAMBLE_INLINE_LEN        48
 373 #define CEPH_PREAMBLE_PLAIN_LEN         CEPH_PREAMBLE_LEN
 374 #define CEPH_PREAMBLE_SECURE_LEN        (CEPH_PREAMBLE_LEN +            \
 375                                          CEPH_PREAMBLE_INLINE_LEN +     \
 376                                          CEPH_GCM_TAG_LEN)
 377 #define CEPH_EPILOGUE_PLAIN_LEN         (1 + 3 * CEPH_CRC_LEN)
 378 #define CEPH_EPILOGUE_SECURE_LEN        (CEPH_GCM_BLOCK_LEN + CEPH_GCM_TAG_LEN)
 379
 380 #define CEPH_FRAME_MAX_SEGMENT_COUNT    4
 381
 382 struct ceph_frame_desc {
 383         int fd_tag;  /* FRAME_TAG_* */
 384         int fd_seg_cnt;
 385         int fd_lens[CEPH_FRAME_MAX_SEGMENT_COUNT];  /* logical */
 386         int fd_aligns[CEPH_FRAME_MAX_SEGMENT_COUNT];
 387 };
 388
 389 struct ceph_gcm_nonce {
 390         __le32 fixed;
 391         __le64 counter __packed;
 392 };
 393
 394 struct ceph_connection_v2_info {
 395         struct iov_iter in_iter;
 396         struct kvec in_kvecs[5];  /* recvmsg */
 397         struct bio_vec in_bvec;  /* recvmsg (in_cursor) */
 398         int in_kvec_cnt;
 399         int in_state;  /* IN_S_* */
 400
 401         struct iov_iter out_iter;
 402         struct kvec out_kvecs[8];  /* sendmsg */
 403         struct bio_vec out_bvec;  /* sendpage (out_cursor, out_zero),
 404                                      sendmsg (out_enc_pages) */
 405         int out_kvec_cnt;
 406         int out_state;  /* OUT_S_* */
 407
 408         int out_zero;  /* # of zero bytes to send */
 409         bool out_iter_sendpage;  /* use sendpage if possible */
 410
 411         struct ceph_frame_desc in_desc;
 412         struct ceph_msg_data_cursor in_cursor;
 413         struct ceph_msg_data_cursor out_cursor;
 414
 415         struct crypto_shash *hmac_tfm;  /* post-auth signature */
 416         struct crypto_aead *gcm_tfm;  /* on-wire encryption */
 417         struct aead_request *gcm_req;
 418         struct crypto_wait gcm_wait;
 419         struct ceph_gcm_nonce in_gcm_nonce;
 420         struct ceph_gcm_nonce out_gcm_nonce;
 421
 422         struct page **in_enc_pages;
 423         int in_enc_page_cnt;
 424         int in_enc_resid;
 425         int in_enc_i;
 426         struct page **out_enc_pages;
 427         int out_enc_page_cnt;
 428         int out_enc_resid;
 429         int out_enc_i;
 430
 431         int con_mode;  /* CEPH_CON_MODE_* */
 432
 433         void *conn_bufs[16];
 434         int conn_buf_cnt;
 435         int data_len_remain;
 436
 437         struct kvec in_sign_kvecs[8];
 438         struct kvec out_sign_kvecs[8];
 439         int in_sign_kvec_cnt;
 440         int out_sign_kvec_cnt;
 441
 442         u64 client_cookie;
 443         u64 server_cookie;
 444         u64 global_seq;
 445         u64 connect_seq;
 446         u64 peer_global_seq;
 447
 448         u8 in_buf[CEPH_PREAMBLE_SECURE_LEN];
 449         u8 out_buf[CEPH_PREAMBLE_SECURE_LEN];
 450         struct {
 451                 u8 late_status;  /* FRAME_LATE_STATUS_* */
 452                 union {
 453                         struct {
 454                                 u32 front_crc;
 455                                 u32 middle_crc;
 456                                 u32 data_crc;
 457                         } __packed;
 458                         u8 pad[CEPH_GCM_BLOCK_LEN - 1];
 459                 };
 460         } out_epil;
 461 };
 462
 463 /*
 464  * A single connection with another host.
 465  *
 466  * We maintain a queue of outgoing messages, and some session state to
 467  * ensure that we can preserve the lossless, ordered delivery of
 468  * messages in the case of a TCP disconnect.
 469  */
 470 struct ceph_connection {
 471         void *private;
 472
 473         const struct ceph_connection_operations *ops;
 474
 475         struct ceph_messenger *msgr;
 476
 477         int state;  /* CEPH_CON_S_* */
 478         atomic_t sock_state;
 479         struct socket *sock;
 480
 481         unsigned long flags;  /* CEPH_CON_F_* */
 482         const char *error_msg;  /* error message, if any */
 483
 484         struct ceph_entity_name peer_name; /* peer name */
 485         struct ceph_entity_addr peer_addr; /* peer address */
 486         u64 peer_features;
 487
 488         struct mutex mutex;
 489
 490         /* out queue */
 491         struct list_head out_queue;
 492         struct list_head out_sent;   /* sending or sent but unacked */
 493         u64 out_seq;                 /* last message queued for send */
 494
 495         u64 in_seq, in_seq_acked;  /* last message received, acked */
 496
 497         struct ceph_msg *in_msg;
 498         struct ceph_msg *out_msg;        /* sending message (== tail of
 499                                             out_sent) */
 500
 501         struct page *bounce_page;
 502         u32 in_front_crc, in_middle_crc, in_data_crc;  /* calculated crc */
 503
 504         struct timespec64 last_keepalive_ack; /* keepalive2 ack stamp */
 505
 506         struct delayed_work work;           /* send|recv work */
 507         unsigned long       delay;          /* current delay interval */
 508
 509         union {
 510                 struct ceph_connection_v1_info v1;
 511                 struct ceph_connection_v2_info v2;
 512         };
 513 };
 514
 515 extern struct page *ceph_zero_page;
 516
 517 void ceph_con_flag_clear(struct ceph_connection *con, unsigned long con_flag);
 518 void ceph_con_flag_set(struct ceph_connection *con, unsigned long con_flag);
 519 bool ceph_con_flag_test(struct ceph_connection *con, unsigned long con_flag);
 520 bool ceph_con_flag_test_and_clear(struct ceph_connection *con,
 521                                   unsigned long con_flag);
 522 bool ceph_con_flag_test_and_set(struct ceph_connection *con,
 523                                 unsigned long con_flag);
 524
 525 void ceph_encode_my_addr(struct ceph_messenger *msgr);
 526
 527 int ceph_tcp_connect(struct ceph_connection *con);
 528 int ceph_con_close_socket(struct ceph_connection *con);
 529 void ceph_con_reset_session(struct ceph_connection *con);
 530
 531 u32 ceph_get_global_seq(struct ceph_messenger *msgr, u32 gt);
 532 void ceph_con_discard_sent(struct ceph_connection *con, u64 ack_seq);
 533 void ceph_con_discard_requeued(struct ceph_connection *con, u64 reconnect_seq);
 534
 535 void ceph_msg_data_cursor_init(struct ceph_msg_data_cursor *cursor,
 536                                struct ceph_msg *msg, size_t length);
 537 struct page *ceph_msg_data_next(struct ceph_msg_data_cursor *cursor,
 538                                 size_t *page_offset, size_t *length);
 539 void ceph_msg_data_advance(struct ceph_msg_data_cursor *cursor, size_t bytes);
 540
 541 u32 ceph_crc32c_page(u32 crc, struct page *page, unsigned int page_offset,
 542                      unsigned int length);
 543
 544 bool ceph_addr_is_blank(const struct ceph_entity_addr *addr);
 545 int ceph_addr_port(const struct ceph_entity_addr *addr);
 546 void ceph_addr_set_port(struct ceph_entity_addr *addr, int p);
 547
 548 void ceph_con_process_message(struct ceph_connection *con);
 549 int ceph_con_in_msg_alloc(struct ceph_connection *con,
 550                           struct ceph_msg_header *hdr, int *skip);
 551 void ceph_con_get_out_msg(struct ceph_connection *con);
 552
 553 /* messenger_v1.c */
 554 int ceph_con_v1_try_read(struct ceph_connection *con);
 555 int ceph_con_v1_try_write(struct ceph_connection *con);
 556 void ceph_con_v1_revoke(struct ceph_connection *con);
 557 void ceph_con_v1_revoke_incoming(struct ceph_connection *con);
 558 bool ceph_con_v1_opened(struct ceph_connection *con);
 559 void ceph_con_v1_reset_session(struct ceph_connection *con);
 560 void ceph_con_v1_reset_protocol(struct ceph_connection *con);
 561
 562 /* messenger_v2.c */
 563 int ceph_con_v2_try_read(struct ceph_connection *con);
 564 int ceph_con_v2_try_write(struct ceph_connection *con);
 565 void ceph_con_v2_revoke(struct ceph_connection *con);
 566 void ceph_con_v2_revoke_incoming(struct ceph_connection *con);
 567 bool ceph_con_v2_opened(struct ceph_connection *con);
 568 void ceph_con_v2_reset_session(struct ceph_connection *con);
 569 void ceph_con_v2_reset_protocol(struct ceph_connection *con);
 570
 571
 572 extern const char *ceph_pr_addr(const struct ceph_entity_addr *addr);
 573
 574 extern int ceph_parse_ips(const char *c, const char *end,
 575                           struct ceph_entity_addr *addr,
 576                           int max_count, int *count, char delim);
 577
 578 extern int ceph_msgr_init(void);
 579 extern void ceph_msgr_exit(void);
 580 extern void ceph_msgr_flush(void);
 581
 582 extern void ceph_messenger_init(struct ceph_messenger *msgr,
 583                                 struct ceph_entity_addr *myaddr);
 584 extern void ceph_messenger_fini(struct ceph_messenger *msgr);
 585 extern void ceph_messenger_reset_nonce(struct ceph_messenger *msgr);
 586
 587 extern void ceph_con_init(struct ceph_connection *con, void *private,
 588                         const struct ceph_connection_operations *ops,
 589                         struct ceph_messenger *msgr);
 590 extern void ceph_con_open(struct ceph_connection *con,
 591                           __u8 entity_type, __u64 entity_num,
 592                           struct ceph_entity_addr *addr);
 593 extern bool ceph_con_opened(struct ceph_connection *con);
 594 extern void ceph_con_close(struct ceph_connection *con);
 595 extern void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg);
 596
 597 extern void ceph_msg_revoke(struct ceph_msg *msg);
 598 extern void ceph_msg_revoke_incoming(struct ceph_msg *msg);
 599
 600 extern void ceph_con_keepalive(struct ceph_connection *con);
 601 extern bool ceph_con_keepalive_expired(struct ceph_connection *con,
 602                                        unsigned long interval);
 603
 604 void ceph_msg_data_add_pages(struct ceph_msg *msg, struct page **pages,
 605                              size_t length, size_t alignment, bool own_pages);
 606 extern void ceph_msg_data_add_pagelist(struct ceph_msg *msg,
 607                                 struct ceph_pagelist *pagelist);
 608 #ifdef CONFIG_BLOCK
 609 void ceph_msg_data_add_bio(struct ceph_msg *msg, struct ceph_bio_iter *bio_pos,
 610                            u32 length);
 611 #endif /* CONFIG_BLOCK */
 612 void ceph_msg_data_add_bvecs(struct ceph_msg *msg,
 613                              struct ceph_bvec_iter *bvec_pos);
 614 void ceph_msg_data_add_iter(struct ceph_msg *msg,
 615                             struct iov_iter *iter);
 616
 617 struct ceph_msg *ceph_msg_new2(int type, int front_len, int max_data_items,
 618                                gfp_t flags, bool can_fail);
 619 extern struct ceph_msg *ceph_msg_new(int type, int front_len, gfp_t flags,
 620                                      bool can_fail);
 621
 622 extern struct ceph_msg *ceph_msg_get(struct ceph_msg *msg);
 623 extern void ceph_msg_put(struct ceph_msg *msg);
 624
 625 extern void ceph_msg_dump(struct ceph_msg *msg);
 626
 627 #endif