~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

TOMOYO Linux Cross Reference
Linux/include/linux/ceph/msgr.h

Version: ~ [ linux-5.18 ] ~ [ linux-5.17.9 ] ~ [ linux-5.16.20 ] ~ [ linux-5.15.41 ] ~ [ linux-5.14.21 ] ~ [ linux-5.13.19 ] ~ [ linux-5.12.19 ] ~ [ linux-5.11.22 ] ~ [ linux-5.10.117 ] ~ [ linux-5.9.16 ] ~ [ linux-5.8.18 ] ~ [ linux-5.7.19 ] ~ [ linux-5.6.19 ] ~ [ linux-5.5.19 ] ~ [ linux-5.4.195 ] ~ [ linux-5.3.18 ] ~ [ linux-5.2.21 ] ~ [ linux-5.1.21 ] ~ [ linux-5.0.21 ] ~ [ linux-4.20.17 ] ~ [ linux-4.19.244 ] ~ [ linux-4.18.20 ] ~ [ linux-4.17.19 ] ~ [ linux-4.16.18 ] ~ [ linux-4.15.18 ] ~ [ linux-4.14.280 ] ~ [ linux-4.13.16 ] ~ [ linux-4.12.14 ] ~ [ linux-4.11.12 ] ~ [ linux-4.10.17 ] ~ [ linux-4.9.315 ] ~ [ linux-4.8.17 ] ~ [ linux-4.7.10 ] ~ [ linux-4.6.7 ] ~ [ linux-4.5.7 ] ~ [ linux-4.4.302 ] ~ [ linux-4.3.6 ] ~ [ linux-4.2.8 ] ~ [ linux-4.1.52 ] ~ [ linux-4.0.9 ] ~ [ linux-3.10.108 ] ~ [ linux-2.6.32.71 ] ~ [ linux-2.6.0 ] ~ [ linux-2.4.37.11 ] ~ [ unix-v6-master ] ~ [ ccs-tools-1.8.9 ] ~ [ policy-sample ] ~
Architecture: ~ [ i386 ] ~ [ alpha ] ~ [ m68k ] ~ [ mips ] ~ [ ppc ] ~ [ sparc ] ~ [ sparc64 ] ~

  1 #ifndef CEPH_MSGR_H
  2 #define CEPH_MSGR_H
  3 
  4 /*
  5  * Data types for message passing layer used by Ceph.
  6  */
  7 
  8 #define CEPH_MON_PORT    6789  /* default monitor port */
  9 
 10 /*
 11  * client-side processes will try to bind to ports in this
 12  * range, simply for the benefit of tools like nmap or wireshark
 13  * that would like to identify the protocol.
 14  */
 15 #define CEPH_PORT_FIRST  6789
 16 #define CEPH_PORT_START  6800  /* non-monitors start here */
 17 #define CEPH_PORT_LAST   6900
 18 
 19 /*
 20  * tcp connection banner.  include a protocol version. and adjust
 21  * whenever the wire protocol changes.  try to keep this string length
 22  * constant.
 23  */
 24 #define CEPH_BANNER "ceph v027"
 25 #define CEPH_BANNER_MAX_LEN 30
 26 
 27 
 28 /*
 29  * Rollover-safe type and comparator for 32-bit sequence numbers.
 30  * Comparator returns -1, 0, or 1.
 31  */
 32 typedef __u32 ceph_seq_t;
 33 
 34 static inline __s32 ceph_seq_cmp(__u32 a, __u32 b)
 35 {
 36        return (__s32)a - (__s32)b;
 37 }
 38 
 39 
 40 /*
 41  * entity_name -- logical name for a process participating in the
 42  * network, e.g. 'mds0' or 'osd3'.
 43  */
 44 struct ceph_entity_name {
 45         __u8 type;      /* CEPH_ENTITY_TYPE_* */
 46         __le64 num;
 47 } __attribute__ ((packed));
 48 
 49 #define CEPH_ENTITY_TYPE_MON    0x01
 50 #define CEPH_ENTITY_TYPE_MDS    0x02
 51 #define CEPH_ENTITY_TYPE_OSD    0x04
 52 #define CEPH_ENTITY_TYPE_CLIENT 0x08
 53 #define CEPH_ENTITY_TYPE_AUTH   0x20
 54 
 55 #define CEPH_ENTITY_TYPE_ANY    0xFF
 56 
 57 extern const char *ceph_entity_type_name(int type);
 58 
 59 /*
 60  * entity_addr -- network address
 61  */
 62 struct ceph_entity_addr {
 63         __le32 type;
 64         __le32 nonce;  /* unique id for process (e.g. pid) */
 65         struct sockaddr_storage in_addr;
 66 } __attribute__ ((packed));
 67 
 68 struct ceph_entity_inst {
 69         struct ceph_entity_name name;
 70         struct ceph_entity_addr addr;
 71 } __attribute__ ((packed));
 72 
 73 
 74 /* used by message exchange protocol */
 75 #define CEPH_MSGR_TAG_READY         1  /* server->client: ready for messages */
 76 #define CEPH_MSGR_TAG_RESETSESSION  2  /* server->client: reset, try again */
 77 #define CEPH_MSGR_TAG_WAIT          3  /* server->client: wait for racing
 78                                           incoming connection */
 79 #define CEPH_MSGR_TAG_RETRY_SESSION 4  /* server->client + cseq: try again
 80                                           with higher cseq */
 81 #define CEPH_MSGR_TAG_RETRY_GLOBAL  5  /* server->client + gseq: try again
 82                                           with higher gseq */
 83 #define CEPH_MSGR_TAG_CLOSE         6  /* closing pipe */
 84 #define CEPH_MSGR_TAG_MSG           7  /* message */
 85 #define CEPH_MSGR_TAG_ACK           8  /* message ack */
 86 #define CEPH_MSGR_TAG_KEEPALIVE     9  /* just a keepalive byte! */
 87 #define CEPH_MSGR_TAG_BADPROTOVER  10  /* bad protocol version */
 88 #define CEPH_MSGR_TAG_BADAUTHORIZER 11 /* bad authorizer */
 89 #define CEPH_MSGR_TAG_FEATURES      12 /* insufficient features */
 90 #define CEPH_MSGR_TAG_SEQ           13 /* 64-bit int follows with seen seq number */
 91 
 92 
 93 /*
 94  * connection negotiation
 95  */
 96 struct ceph_msg_connect {
 97         __le64 features;     /* supported feature bits */
 98         __le32 host_type;    /* CEPH_ENTITY_TYPE_* */
 99         __le32 global_seq;   /* count connections initiated by this host */
100         __le32 connect_seq;  /* count connections initiated in this session */
101         __le32 protocol_version;
102         __le32 authorizer_protocol;
103         __le32 authorizer_len;
104         __u8  flags;         /* CEPH_MSG_CONNECT_* */
105 } __attribute__ ((packed));
106 
107 struct ceph_msg_connect_reply {
108         __u8 tag;
109         __le64 features;     /* feature bits for this session */
110         __le32 global_seq;
111         __le32 connect_seq;
112         __le32 protocol_version;
113         __le32 authorizer_len;
114         __u8 flags;
115 } __attribute__ ((packed));
116 
117 #define CEPH_MSG_CONNECT_LOSSY  1  /* messages i send may be safely dropped */
118 
119 
120 /*
121  * message header
122  */
123 struct ceph_msg_header_old {
124         __le64 seq;       /* message seq# for this session */
125         __le64 tid;       /* transaction id */
126         __le16 type;      /* message type */
127         __le16 priority;  /* priority.  higher value == higher priority */
128         __le16 version;   /* version of message encoding */
129 
130         __le32 front_len; /* bytes in main payload */
131         __le32 middle_len;/* bytes in middle payload */
132         __le32 data_len;  /* bytes of data payload */
133         __le16 data_off;  /* sender: include full offset;
134                              receiver: mask against ~PAGE_MASK */
135 
136         struct ceph_entity_inst src, orig_src;
137         __le32 reserved;
138         __le32 crc;       /* header crc32c */
139 } __attribute__ ((packed));
140 
141 struct ceph_msg_header {
142         __le64 seq;       /* message seq# for this session */
143         __le64 tid;       /* transaction id */
144         __le16 type;      /* message type */
145         __le16 priority;  /* priority.  higher value == higher priority */
146         __le16 version;   /* version of message encoding */
147 
148         __le32 front_len; /* bytes in main payload */
149         __le32 middle_len;/* bytes in middle payload */
150         __le32 data_len;  /* bytes of data payload */
151         __le16 data_off;  /* sender: include full offset;
152                              receiver: mask against ~PAGE_MASK */
153 
154         struct ceph_entity_name src;
155         __le16 compat_version;
156         __le16 reserved;
157         __le32 crc;       /* header crc32c */
158 } __attribute__ ((packed));
159 
160 #define CEPH_MSG_PRIO_LOW     64
161 #define CEPH_MSG_PRIO_DEFAULT 127
162 #define CEPH_MSG_PRIO_HIGH    196
163 #define CEPH_MSG_PRIO_HIGHEST 255
164 
165 /*
166  * follows data payload
167  */
168 struct ceph_msg_footer_old {
169         __le32 front_crc, middle_crc, data_crc;
170         __u8 flags;
171 } __attribute__ ((packed));
172 
173 struct ceph_msg_footer {
174         __le32 front_crc, middle_crc, data_crc;
175         // sig holds the 64 bits of the digital signature for the message PLR
176         __le64  sig;
177         __u8 flags;
178 } __attribute__ ((packed));
179 
180 #define CEPH_MSG_FOOTER_COMPLETE  (1<<0)   /* msg wasn't aborted */
181 #define CEPH_MSG_FOOTER_NOCRC     (1<<1)   /* no data crc */
182 #define CEPH_MSG_FOOTER_SIGNED    (1<<2)   /* msg was signed */
183 
184 
185 #endif
186 

~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

kernel.org | git.kernel.org | LWN.net | Project Home | Wiki (Japanese) | Wiki (English) | SVN repository | Mail admin

Linux® is a registered trademark of Linus Torvalds in the United States and other countries.
TOMOYO® is a registered trademark of NTT DATA CORPORATION.

osdn.jp