Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 1 | #ifndef DRBD_STATE_H |
| 2 | #define DRBD_STATE_H |
| 3 | |
Andreas Gruenbacher | 5476169 | 2011-05-30 16:15:21 +0200 | [diff] [blame] | 4 | struct drbd_device; |
Andreas Gruenbacher | bde89a9 | 2011-05-30 16:32:41 +0200 | [diff] [blame] | 5 | struct drbd_connection; |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 6 | |
| 7 | /** |
| 8 | * DOC: DRBD State macros |
| 9 | * |
| 10 | * These macros are used to express state changes in easily readable form. |
| 11 | * |
| 12 | * The NS macros expand to a mask and a value, that can be bit ored onto the |
| 13 | * current state as soon as the spinlock (req_lock) was taken. |
| 14 | * |
| 15 | * The _NS macros are used for state functions that get called with the |
| 16 | * spinlock. These macros expand directly to the new state value. |
| 17 | * |
| 18 | * Besides the basic forms NS() and _NS() additional _?NS[23] are defined |
| 19 | * to express state changes that affect more than one aspect of the state. |
| 20 | * |
| 21 | * E.g. NS2(conn, C_CONNECTED, peer, R_SECONDARY) |
| 22 | * Means that the network connection was established and that the peer |
| 23 | * is in secondary role. |
| 24 | */ |
| 25 | #define role_MASK R_MASK |
| 26 | #define peer_MASK R_MASK |
| 27 | #define disk_MASK D_MASK |
| 28 | #define pdsk_MASK D_MASK |
| 29 | #define conn_MASK C_MASK |
| 30 | #define susp_MASK 1 |
| 31 | #define user_isp_MASK 1 |
| 32 | #define aftr_isp_MASK 1 |
| 33 | #define susp_nod_MASK 1 |
| 34 | #define susp_fen_MASK 1 |
| 35 | |
| 36 | #define NS(T, S) \ |
| 37 | ({ union drbd_state mask; mask.i = 0; mask.T = T##_MASK; mask; }), \ |
| 38 | ({ union drbd_state val; val.i = 0; val.T = (S); val; }) |
| 39 | #define NS2(T1, S1, T2, S2) \ |
| 40 | ({ union drbd_state mask; mask.i = 0; mask.T1 = T1##_MASK; \ |
| 41 | mask.T2 = T2##_MASK; mask; }), \ |
| 42 | ({ union drbd_state val; val.i = 0; val.T1 = (S1); \ |
| 43 | val.T2 = (S2); val; }) |
| 44 | #define NS3(T1, S1, T2, S2, T3, S3) \ |
| 45 | ({ union drbd_state mask; mask.i = 0; mask.T1 = T1##_MASK; \ |
| 46 | mask.T2 = T2##_MASK; mask.T3 = T3##_MASK; mask; }), \ |
| 47 | ({ union drbd_state val; val.i = 0; val.T1 = (S1); \ |
| 48 | val.T2 = (S2); val.T3 = (S3); val; }) |
| 49 | |
| 50 | #define _NS(D, T, S) \ |
Philipp Reisner | 78bae59 | 2011-03-28 15:40:12 +0200 | [diff] [blame] | 51 | D, ({ union drbd_state __ns; __ns = drbd_read_state(D); __ns.T = (S); __ns; }) |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 52 | #define _NS2(D, T1, S1, T2, S2) \ |
Philipp Reisner | 78bae59 | 2011-03-28 15:40:12 +0200 | [diff] [blame] | 53 | D, ({ union drbd_state __ns; __ns = drbd_read_state(D); __ns.T1 = (S1); \ |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 54 | __ns.T2 = (S2); __ns; }) |
| 55 | #define _NS3(D, T1, S1, T2, S2, T3, S3) \ |
Philipp Reisner | 78bae59 | 2011-03-28 15:40:12 +0200 | [diff] [blame] | 56 | D, ({ union drbd_state __ns; __ns = drbd_read_state(D); __ns.T1 = (S1); \ |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 57 | __ns.T2 = (S2); __ns.T3 = (S3); __ns; }) |
| 58 | |
| 59 | enum chg_state_flags { |
Philipp Reisner | 435693e | 2011-03-25 15:11:30 +0100 | [diff] [blame] | 60 | CS_HARD = 1 << 0, |
| 61 | CS_VERBOSE = 1 << 1, |
| 62 | CS_WAIT_COMPLETE = 1 << 2, |
| 63 | CS_SERIALIZE = 1 << 3, |
| 64 | CS_ORDERED = CS_WAIT_COMPLETE + CS_SERIALIZE, |
| 65 | CS_LOCAL_ONLY = 1 << 4, /* Do not consider a device pair wide state change */ |
| 66 | CS_DC_ROLE = 1 << 5, /* DC = display as connection state change */ |
| 67 | CS_DC_PEER = 1 << 6, |
| 68 | CS_DC_CONN = 1 << 7, |
| 69 | CS_DC_DISK = 1 << 8, |
| 70 | CS_DC_PDSK = 1 << 9, |
Philipp Reisner | 706cb24 | 2011-03-29 15:20:27 +0200 | [diff] [blame] | 71 | CS_DC_SUSP = 1 << 10, |
Philipp Reisner | 435693e | 2011-03-25 15:11:30 +0100 | [diff] [blame] | 72 | CS_DC_MASK = CS_DC_ROLE + CS_DC_PEER + CS_DC_CONN + CS_DC_DISK + CS_DC_PDSK, |
Philipp Reisner | 706cb24 | 2011-03-29 15:20:27 +0200 | [diff] [blame] | 73 | CS_IGN_OUTD_FAIL = 1 << 11, |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 74 | }; |
| 75 | |
Philipp Reisner | da9fbc2 | 2011-03-29 10:52:01 +0200 | [diff] [blame] | 76 | /* drbd_dev_state and drbd_state are different types. This is to stress the |
| 77 | small difference. There is no suspended flag (.susp), and no suspended |
| 78 | while fence handler runs flas (susp_fen). */ |
| 79 | union drbd_dev_state { |
| 80 | struct { |
| 81 | #if defined(__LITTLE_ENDIAN_BITFIELD) |
| 82 | unsigned role:2 ; /* 3/4 primary/secondary/unknown */ |
| 83 | unsigned peer:2 ; /* 3/4 primary/secondary/unknown */ |
| 84 | unsigned conn:5 ; /* 17/32 cstates */ |
| 85 | unsigned disk:4 ; /* 8/16 from D_DISKLESS to D_UP_TO_DATE */ |
| 86 | unsigned pdsk:4 ; /* 8/16 from D_DISKLESS to D_UP_TO_DATE */ |
| 87 | unsigned _unused:1 ; |
| 88 | unsigned aftr_isp:1 ; /* isp .. imposed sync pause */ |
| 89 | unsigned peer_isp:1 ; |
| 90 | unsigned user_isp:1 ; |
| 91 | unsigned _pad:11; /* 0 unused */ |
| 92 | #elif defined(__BIG_ENDIAN_BITFIELD) |
| 93 | unsigned _pad:11; |
| 94 | unsigned user_isp:1 ; |
| 95 | unsigned peer_isp:1 ; |
| 96 | unsigned aftr_isp:1 ; /* isp .. imposed sync pause */ |
| 97 | unsigned _unused:1 ; |
| 98 | unsigned pdsk:4 ; /* 8/16 from D_DISKLESS to D_UP_TO_DATE */ |
| 99 | unsigned disk:4 ; /* 8/16 from D_DISKLESS to D_UP_TO_DATE */ |
| 100 | unsigned conn:5 ; /* 17/32 cstates */ |
| 101 | unsigned peer:2 ; /* 3/4 primary/secondary/unknown */ |
| 102 | unsigned role:2 ; /* 3/4 primary/secondary/unknown */ |
| 103 | #else |
| 104 | # error "this endianess is not supported" |
| 105 | #endif |
| 106 | }; |
| 107 | unsigned int i; |
| 108 | }; |
| 109 | |
Andreas Gruenbacher | b30ab79 | 2011-07-03 13:26:43 +0200 | [diff] [blame] | 110 | extern enum drbd_state_rv drbd_change_state(struct drbd_device *device, |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 111 | enum chg_state_flags f, |
| 112 | union drbd_state mask, |
| 113 | union drbd_state val); |
Andreas Gruenbacher | 5476169 | 2011-05-30 16:15:21 +0200 | [diff] [blame] | 114 | extern void drbd_force_state(struct drbd_device *, union drbd_state, |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 115 | union drbd_state); |
Andreas Gruenbacher | 5476169 | 2011-05-30 16:15:21 +0200 | [diff] [blame] | 116 | extern enum drbd_state_rv _drbd_request_state(struct drbd_device *, |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 117 | union drbd_state, |
| 118 | union drbd_state, |
| 119 | enum chg_state_flags); |
Andreas Gruenbacher | 5476169 | 2011-05-30 16:15:21 +0200 | [diff] [blame] | 120 | extern enum drbd_state_rv __drbd_set_state(struct drbd_device *, union drbd_state, |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 121 | enum chg_state_flags, |
| 122 | struct completion *done); |
Andreas Gruenbacher | 5476169 | 2011-05-30 16:15:21 +0200 | [diff] [blame] | 123 | extern void print_st_err(struct drbd_device *, union drbd_state, |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 124 | union drbd_state, int); |
| 125 | |
Philipp Reisner | bbeb641 | 2011-02-10 13:45:46 +0100 | [diff] [blame] | 126 | enum drbd_state_rv |
Andreas Gruenbacher | bde89a9 | 2011-05-30 16:32:41 +0200 | [diff] [blame] | 127 | _conn_request_state(struct drbd_connection *connection, union drbd_state mask, union drbd_state val, |
Philipp Reisner | bbeb641 | 2011-02-10 13:45:46 +0100 | [diff] [blame] | 128 | enum chg_state_flags flags); |
| 129 | |
| 130 | enum drbd_state_rv |
Andreas Gruenbacher | bde89a9 | 2011-05-30 16:32:41 +0200 | [diff] [blame] | 131 | conn_request_state(struct drbd_connection *connection, union drbd_state mask, union drbd_state val, |
Philipp Reisner | bbeb641 | 2011-02-10 13:45:46 +0100 | [diff] [blame] | 132 | enum chg_state_flags flags); |
| 133 | |
Andreas Gruenbacher | b30ab79 | 2011-07-03 13:26:43 +0200 | [diff] [blame] | 134 | extern void drbd_resume_al(struct drbd_device *device); |
Andreas Gruenbacher | bde89a9 | 2011-05-30 16:32:41 +0200 | [diff] [blame] | 135 | extern bool conn_all_vols_unconf(struct drbd_connection *connection); |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 136 | |
| 137 | /** |
| 138 | * drbd_request_state() - Reqest a state change |
Andreas Gruenbacher | b30ab79 | 2011-07-03 13:26:43 +0200 | [diff] [blame] | 139 | * @device: DRBD device. |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 140 | * @mask: mask of state bits to change. |
| 141 | * @val: value of new state bits. |
| 142 | * |
| 143 | * This is the most graceful way of requesting a state change. It is verbose |
| 144 | * quite verbose in case the state change is not possible, and all those |
| 145 | * state changes are globally serialized. |
| 146 | */ |
Andreas Gruenbacher | b30ab79 | 2011-07-03 13:26:43 +0200 | [diff] [blame] | 147 | static inline int drbd_request_state(struct drbd_device *device, |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 148 | union drbd_state mask, |
| 149 | union drbd_state val) |
| 150 | { |
Andreas Gruenbacher | b30ab79 | 2011-07-03 13:26:43 +0200 | [diff] [blame] | 151 | return _drbd_request_state(device, mask, val, CS_VERBOSE + CS_ORDERED); |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 152 | } |
| 153 | |
Andreas Gruenbacher | bde89a9 | 2011-05-30 16:32:41 +0200 | [diff] [blame] | 154 | enum drbd_role conn_highest_role(struct drbd_connection *connection); |
| 155 | enum drbd_role conn_highest_peer(struct drbd_connection *connection); |
| 156 | enum drbd_disk_state conn_highest_disk(struct drbd_connection *connection); |
| 157 | enum drbd_disk_state conn_lowest_disk(struct drbd_connection *connection); |
| 158 | enum drbd_disk_state conn_highest_pdsk(struct drbd_connection *connection); |
| 159 | enum drbd_conns conn_lowest_conn(struct drbd_connection *connection); |
Philipp Reisner | cb70345 | 2011-03-24 11:03:07 +0100 | [diff] [blame] | 160 | |
Philipp Reisner | b890733 | 2011-01-27 14:07:51 +0100 | [diff] [blame] | 161 | #endif |