diff options
Diffstat (limited to 'fs/ceph/msgr.h')
| -rw-r--r-- | fs/ceph/msgr.h | 25 |
1 files changed, 21 insertions, 4 deletions
diff --git a/fs/ceph/msgr.h b/fs/ceph/msgr.h index 8aaab414f3f8..680d3d648cac 100644 --- a/fs/ceph/msgr.h +++ b/fs/ceph/msgr.h | |||
| @@ -1,5 +1,5 @@ | |||
| 1 | #ifndef __MSGR_H | 1 | #ifndef CEPH_MSGR_H |
| 2 | #define __MSGR_H | 2 | #define CEPH_MSGR_H |
| 3 | 3 | ||
| 4 | /* | 4 | /* |
| 5 | * Data types for message passing layer used by Ceph. | 5 | * Data types for message passing layer used by Ceph. |
| @@ -50,7 +50,6 @@ struct ceph_entity_name { | |||
| 50 | #define CEPH_ENTITY_TYPE_MDS 0x02 | 50 | #define CEPH_ENTITY_TYPE_MDS 0x02 |
| 51 | #define CEPH_ENTITY_TYPE_OSD 0x04 | 51 | #define CEPH_ENTITY_TYPE_OSD 0x04 |
| 52 | #define CEPH_ENTITY_TYPE_CLIENT 0x08 | 52 | #define CEPH_ENTITY_TYPE_CLIENT 0x08 |
| 53 | #define CEPH_ENTITY_TYPE_ADMIN 0x10 | ||
| 54 | #define CEPH_ENTITY_TYPE_AUTH 0x20 | 53 | #define CEPH_ENTITY_TYPE_AUTH 0x20 |
| 55 | 54 | ||
| 56 | #define CEPH_ENTITY_TYPE_ANY 0xFF | 55 | #define CEPH_ENTITY_TYPE_ANY 0xFF |
| @@ -120,7 +119,7 @@ struct ceph_msg_connect_reply { | |||
| 120 | /* | 119 | /* |
| 121 | * message header | 120 | * message header |
| 122 | */ | 121 | */ |
| 123 | struct ceph_msg_header { | 122 | struct ceph_msg_header_old { |
| 124 | __le64 seq; /* message seq# for this session */ | 123 | __le64 seq; /* message seq# for this session */ |
| 125 | __le64 tid; /* transaction id */ | 124 | __le64 tid; /* transaction id */ |
| 126 | __le16 type; /* message type */ | 125 | __le16 type; /* message type */ |
| @@ -138,6 +137,24 @@ struct ceph_msg_header { | |||
| 138 | __le32 crc; /* header crc32c */ | 137 | __le32 crc; /* header crc32c */ |
| 139 | } __attribute__ ((packed)); | 138 | } __attribute__ ((packed)); |
| 140 | 139 | ||
| 140 | struct ceph_msg_header { | ||
| 141 | __le64 seq; /* message seq# for this session */ | ||
| 142 | __le64 tid; /* transaction id */ | ||
| 143 | __le16 type; /* message type */ | ||
| 144 | __le16 priority; /* priority. higher value == higher priority */ | ||
| 145 | __le16 version; /* version of message encoding */ | ||
| 146 | |||
| 147 | __le32 front_len; /* bytes in main payload */ | ||
| 148 | __le32 middle_len;/* bytes in middle payload */ | ||
| 149 | __le32 data_len; /* bytes of data payload */ | ||
| 150 | __le16 data_off; /* sender: include full offset; | ||
| 151 | receiver: mask against ~PAGE_MASK */ | ||
| 152 | |||
| 153 | struct ceph_entity_name src; | ||
| 154 | __le32 reserved; | ||
| 155 | __le32 crc; /* header crc32c */ | ||
| 156 | } __attribute__ ((packed)); | ||
| 157 | |||
| 141 | #define CEPH_MSG_PRIO_LOW 64 | 158 | #define CEPH_MSG_PRIO_LOW 64 |
| 142 | #define CEPH_MSG_PRIO_DEFAULT 127 | 159 | #define CEPH_MSG_PRIO_DEFAULT 127 |
| 143 | #define CEPH_MSG_PRIO_HIGH 196 | 160 | #define CEPH_MSG_PRIO_HIGH 196 |
