Lines Matching full:ls
27 static int rcom_response(struct dlm_ls *ls) in rcom_response() argument
29 return test_bit(LSFL_RCOM_READY, &ls->ls_flags); in rcom_response()
32 static int create_rcom(struct dlm_ls *ls, int to_nodeid, int type, int len, in create_rcom() argument
51 rc->rc_header.h_lockspace = ls->ls_global_id; in create_rcom()
58 spin_lock(&ls->ls_recover_lock); in create_rcom()
59 rc->rc_seq = ls->ls_recover_seq; in create_rcom()
60 spin_unlock(&ls->ls_recover_lock); in create_rcom()
67 static void send_rcom(struct dlm_ls *ls, struct dlm_mhandle *mh, in send_rcom() argument
74 static void set_rcom_status(struct dlm_ls *ls, struct rcom_status *rs, in set_rcom_status() argument
84 static void set_rcom_config(struct dlm_ls *ls, struct rcom_config *rf, in set_rcom_config() argument
87 rf->rf_lvblen = cpu_to_le32(ls->ls_lvblen); in set_rcom_config()
88 rf->rf_lsflags = cpu_to_le32(ls->ls_exflags); in set_rcom_config()
90 rf->rf_our_slot = cpu_to_le16(ls->ls_slot); in set_rcom_config()
92 rf->rf_generation = cpu_to_le32(ls->ls_generation); in set_rcom_config()
95 static int check_rcom_config(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid) in check_rcom_config() argument
100 log_error(ls, "version mismatch: %x nodeid %d: %x", in check_rcom_config()
106 if (le32_to_cpu(rf->rf_lvblen) != ls->ls_lvblen || in check_rcom_config()
107 le32_to_cpu(rf->rf_lsflags) != ls->ls_exflags) { in check_rcom_config()
108 log_error(ls, "config mismatch: %d,%x nodeid %d: %d,%x", in check_rcom_config()
109 ls->ls_lvblen, ls->ls_exflags, nodeid, in check_rcom_config()
117 static void allow_sync_reply(struct dlm_ls *ls, uint64_t *new_seq) in allow_sync_reply() argument
119 spin_lock(&ls->ls_rcom_spin); in allow_sync_reply()
120 *new_seq = ++ls->ls_rcom_seq; in allow_sync_reply()
121 set_bit(LSFL_RCOM_WAIT, &ls->ls_flags); in allow_sync_reply()
122 spin_unlock(&ls->ls_rcom_spin); in allow_sync_reply()
125 static void disallow_sync_reply(struct dlm_ls *ls) in disallow_sync_reply() argument
127 spin_lock(&ls->ls_rcom_spin); in disallow_sync_reply()
128 clear_bit(LSFL_RCOM_WAIT, &ls->ls_flags); in disallow_sync_reply()
129 clear_bit(LSFL_RCOM_READY, &ls->ls_flags); in disallow_sync_reply()
130 spin_unlock(&ls->ls_rcom_spin); in disallow_sync_reply()
144 int dlm_rcom_status(struct dlm_ls *ls, int nodeid, uint32_t status_flags) in dlm_rcom_status() argument
150 ls->ls_recover_nodeid = nodeid; in dlm_rcom_status()
153 rc = ls->ls_recover_buf; in dlm_rcom_status()
154 rc->rc_result = dlm_recover_status(ls); in dlm_rcom_status()
159 error = create_rcom(ls, nodeid, DLM_RCOM_STATUS, in dlm_rcom_status()
164 set_rcom_status(ls, (struct rcom_status *)rc->rc_buf, status_flags); in dlm_rcom_status()
166 allow_sync_reply(ls, &rc->rc_id); in dlm_rcom_status()
167 memset(ls->ls_recover_buf, 0, dlm_config.ci_buffer_size); in dlm_rcom_status()
169 send_rcom(ls, mh, rc); in dlm_rcom_status()
171 error = dlm_wait_function(ls, &rcom_response); in dlm_rcom_status()
172 disallow_sync_reply(ls); in dlm_rcom_status()
178 rc = ls->ls_recover_buf; in dlm_rcom_status()
182 log_debug(ls, "remote node %d not ready", nodeid); in dlm_rcom_status()
186 error = check_rcom_config(ls, rc, nodeid); in dlm_rcom_status()
194 static void receive_rcom_status(struct dlm_ls *ls, struct dlm_rcom *rc_in) in receive_rcom_status() argument
206 status = dlm_recover_status(ls); in receive_rcom_status()
213 status = dlm_recover_status(ls); in receive_rcom_status()
217 spin_lock(&ls->ls_recover_lock); in receive_rcom_status()
218 status = ls->ls_recover_status; in receive_rcom_status()
219 num_slots = ls->ls_num_slots; in receive_rcom_status()
220 spin_unlock(&ls->ls_recover_lock); in receive_rcom_status()
224 error = create_rcom(ls, nodeid, DLM_RCOM_STATUS_REPLY, in receive_rcom_status()
233 set_rcom_config(ls, (struct rcom_config *)rc->rc_buf, num_slots); in receive_rcom_status()
238 spin_lock(&ls->ls_recover_lock); in receive_rcom_status()
239 if (ls->ls_num_slots != num_slots) { in receive_rcom_status()
240 spin_unlock(&ls->ls_recover_lock); in receive_rcom_status()
241 log_debug(ls, "receive_rcom_status num_slots %d to %d", in receive_rcom_status()
242 num_slots, ls->ls_num_slots); in receive_rcom_status()
244 set_rcom_config(ls, (struct rcom_config *)rc->rc_buf, 0); in receive_rcom_status()
248 dlm_slots_copy_out(ls, rc); in receive_rcom_status()
249 spin_unlock(&ls->ls_recover_lock); in receive_rcom_status()
252 send_rcom(ls, mh, rc); in receive_rcom_status()
255 static void receive_sync_reply(struct dlm_ls *ls, struct dlm_rcom *rc_in) in receive_sync_reply() argument
257 spin_lock(&ls->ls_rcom_spin); in receive_sync_reply()
258 if (!test_bit(LSFL_RCOM_WAIT, &ls->ls_flags) || in receive_sync_reply()
259 rc_in->rc_id != ls->ls_rcom_seq) { in receive_sync_reply()
260 log_debug(ls, "reject reply %d from %d seq %llx expect %llx", in receive_sync_reply()
263 (unsigned long long)ls->ls_rcom_seq); in receive_sync_reply()
266 memcpy(ls->ls_recover_buf, rc_in, rc_in->rc_header.h_length); in receive_sync_reply()
267 set_bit(LSFL_RCOM_READY, &ls->ls_flags); in receive_sync_reply()
268 clear_bit(LSFL_RCOM_WAIT, &ls->ls_flags); in receive_sync_reply()
269 wake_up(&ls->ls_wait_general); in receive_sync_reply()
271 spin_unlock(&ls->ls_rcom_spin); in receive_sync_reply()
274 int dlm_rcom_names(struct dlm_ls *ls, int nodeid, char *last_name, int last_len) in dlm_rcom_names() argument
280 ls->ls_recover_nodeid = nodeid; in dlm_rcom_names()
283 error = create_rcom(ls, nodeid, DLM_RCOM_NAMES, last_len, &rc, &mh); in dlm_rcom_names()
288 allow_sync_reply(ls, &rc->rc_id); in dlm_rcom_names()
289 memset(ls->ls_recover_buf, 0, dlm_config.ci_buffer_size); in dlm_rcom_names()
291 send_rcom(ls, mh, rc); in dlm_rcom_names()
293 error = dlm_wait_function(ls, &rcom_response); in dlm_rcom_names()
294 disallow_sync_reply(ls); in dlm_rcom_names()
301 static void receive_rcom_names(struct dlm_ls *ls, struct dlm_rcom *rc_in) in receive_rcom_names() argument
311 error = create_rcom(ls, nodeid, DLM_RCOM_NAMES_REPLY, outlen, &rc, &mh); in receive_rcom_names()
317 dlm_copy_master_names(ls, rc_in->rc_buf, inlen, rc->rc_buf, outlen, in receive_rcom_names()
319 send_rcom(ls, mh, rc); in receive_rcom_names()
326 struct dlm_ls *ls = r->res_ls; in dlm_send_rcom_lookup() local
329 error = create_rcom(ls, dir_nodeid, DLM_RCOM_LOOKUP, r->res_length, in dlm_send_rcom_lookup()
336 send_rcom(ls, mh, rc); in dlm_send_rcom_lookup()
341 static void receive_rcom_lookup(struct dlm_ls *ls, struct dlm_rcom *rc_in) in receive_rcom_lookup() argument
348 error = create_rcom(ls, nodeid, DLM_RCOM_LOOKUP_REPLY, 0, &rc, &mh); in receive_rcom_lookup()
354 log_error(ls, "receive_rcom_lookup dump from %d", nodeid); in receive_rcom_lookup()
355 dlm_dump_rsb_name(ls, rc_in->rc_buf, len); in receive_rcom_lookup()
359 error = dlm_master_lookup(ls, nodeid, rc_in->rc_buf, len, in receive_rcom_lookup()
367 send_rcom(ls, mh, rc); in receive_rcom_lookup()
370 static void receive_rcom_lookup_reply(struct dlm_ls *ls, struct dlm_rcom *rc_in) in receive_rcom_lookup_reply() argument
372 dlm_recover_master_reply(ls, rc_in); in receive_rcom_lookup_reply()
407 struct dlm_ls *ls = r->res_ls; in dlm_send_rcom_lock() local
414 len += ls->ls_lvblen; in dlm_send_rcom_lock()
416 error = create_rcom(ls, r->res_nodeid, DLM_RCOM_LOCK, len, &rc, &mh); in dlm_send_rcom_lock()
424 send_rcom(ls, mh, rc); in dlm_send_rcom_lock()
430 static void receive_rcom_lock(struct dlm_ls *ls, struct dlm_rcom *rc_in) in receive_rcom_lock() argument
436 dlm_recover_master_copy(ls, rc_in); in receive_rcom_lock()
438 error = create_rcom(ls, nodeid, DLM_RCOM_LOCK_REPLY, in receive_rcom_lock()
450 send_rcom(ls, mh, rc); in receive_rcom_lock()
536 void dlm_receive_rcom(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid) in dlm_receive_rcom() argument
570 spin_lock(&ls->ls_recover_lock); in dlm_receive_rcom()
571 status = ls->ls_recover_status; in dlm_receive_rcom()
572 stop = test_bit(LSFL_RECOVER_STOP, &ls->ls_flags); in dlm_receive_rcom()
573 seq = ls->ls_recover_seq; in dlm_receive_rcom()
574 spin_unlock(&ls->ls_recover_lock); in dlm_receive_rcom()
590 receive_rcom_status(ls, rc); in dlm_receive_rcom()
594 receive_rcom_names(ls, rc); in dlm_receive_rcom()
598 receive_rcom_lookup(ls, rc); in dlm_receive_rcom()
604 receive_rcom_lock(ls, rc); in dlm_receive_rcom()
608 receive_sync_reply(ls, rc); in dlm_receive_rcom()
612 receive_sync_reply(ls, rc); in dlm_receive_rcom()
616 receive_rcom_lookup_reply(ls, rc); in dlm_receive_rcom()
622 dlm_recover_process_copy(ls, rc); in dlm_receive_rcom()
626 log_error(ls, "receive_rcom bad type %d", rc->rc_type); in dlm_receive_rcom()
631 log_limit(ls, "dlm_receive_rcom ignore msg %d " in dlm_receive_rcom()
638 status, ls->ls_generation); in dlm_receive_rcom()
641 log_error(ls, "recovery message %d from %d is too short", in dlm_receive_rcom()