Home
last modified time | relevance | path

Searched refs:first_peer_device (Results 1 - 18 of 18) sorted by relevance

/kernel/linux/linux-6.6/drivers/block/drbd/
H A Ddrbd_worker.c433 make_ov_request(first_peer_device(device), cancel); in w_resync_timer()
436 make_resync_request(first_peer_device(device), cancel); in w_resync_timer()
448 &first_peer_device(device)->connection->sender_work, in resync_timer_fn()
803 if (drbd_send_ov_request(first_peer_device(device), sector, size)) { in make_ov_request()
824 ov_out_of_sync_print(first_peer_device(device)); in w_ov_finished()
825 drbd_resync_finished(first_peer_device(device)); in w_ov_finished()
837 drbd_resync_finished(first_peer_device(device)); in w_resync_finished()
844 struct drbd_connection *connection = first_peer_device(device)->connection; in ping_peer()
1399 return pd_send_unplug_remote(first_peer_device(device)); in w_send_write_hint()
1428 struct drbd_peer_device *const peer_device = first_peer_device(devic in w_send_out_of_sync()
[all...]
H A Ddrbd_req.c125 struct drbd_peer_device *peer_device = first_peer_device(device); in drbd_req_destroy()
244 req->epoch == atomic_read(&first_peer_device(device)->connection->current_tle_nr)) in drbd_req_complete()
245 start_new_tl_epoch(first_peer_device(device)->connection); in drbd_req_complete()
416 struct drbd_peer_device *peer_device = first_peer_device(device); in mod_rq_state()
986 struct drbd_connection *connection = first_peer_device(device)->connection; in maybe_pull_ahead()
1022 start_new_tl_epoch(first_peer_device(device)->connection); in maybe_pull_ahead()
1107 struct drbd_peer_device *peer_device = first_peer_device(device); in drbd_process_write_request()
1320 struct drbd_peer_device *peer_device = first_peer_device(device); in drbd_send_and_submit()
1360 req->epoch = atomic_read(&first_peer_device(device)->connection->current_tle_nr); in drbd_send_and_submit()
1366 first_peer_device(devic in drbd_send_and_submit()
[all...]
H A Ddrbd_proc.c269 nc = rcu_dereference(first_peer_device(device)->connection->net_conf); in drbd_seq_show()
298 first_peer_device(device)->connection->epochs, in drbd_seq_show()
H A Ddrbd_state.c542 rv = is_valid_soft_transition(os, ns, first_peer_device(device)->connection); in _req_st_cond()
591 rv = is_valid_soft_transition(os, ns, first_peer_device(device)->connection); in drbd_req_state()
600 if (drbd_send_state_req(first_peer_device(device), mask, val)) { in drbd_req_state()
625 D_ASSERT(device, current != first_peer_device(device)->connection->worker.task); in drbd_req_state()
838 nc = rcu_dereference(first_peer_device(device)->connection->net_conf); in is_valid_state()
843 else if (conn_highest_peer(first_peer_device(device)->connection) == R_PRIMARY) in is_valid_state()
884 first_peer_device(device)->connection->agreed_pro_version < 88) in is_valid_state()
1266 struct drbd_peer_device *peer_device = first_peer_device(device); in _drbd_set_state()
1529 D_ASSERT(device, current == first_peer_device(device)->connection->worker.task); in drbd_bitmap_io_from_worker()
1709 struct drbd_peer_device *peer_device = first_peer_device(devic in after_state_ch()
[all...]
H A Ddrbd_nl.c364 struct drbd_connection *connection = first_peer_device(device)->connection; in drbd_khelper()
617 struct drbd_peer_device *const peer_device = first_peer_device(device); in drbd_set_role()
1211 first_peer_device(device)->connection; in decide_on_discard_support()
1250 struct drbd_connection *connection = first_peer_device(device)->connection; in fixup_write_zeroes()
1324 if (first_peer_device(device)->connection->agreed_pro_version < 94) in drbd_reconsider_queue_parameters()
1327 else if (first_peer_device(device)->connection->agreed_pro_version == 94) in drbd_reconsider_queue_parameters()
1329 else if (first_peer_device(device)->connection->agreed_pro_version < 100) in drbd_reconsider_queue_parameters()
1750 peer_device = first_peer_device(device); in drbd_adm_attach()
2767 iass = test_bit(RESOLVE_CONFLICTS, &first_peer_device(device)->connection->flags); in resync_after_online_grow()
2824 if (rs.no_resync && first_peer_device(devic in drbd_adm_resize()
[all...]
H A Ddrbd_int.h884 struct mutex *state_mutex; /* either own_state_mutex or first_peer_device(device)->connection->cstate_mutex */
945 static inline struct drbd_peer_device *first_peer_device(struct drbd_device *device) in first_peer_device() function
1853 first_peer_device(device)->connection; in drbd_device_post_work()
2073 nc = rcu_dereference(first_peer_device(device)->connection->net_conf); in drbd_get_max_buffers()
2116 if (first_peer_device(device)->connection->agreed_pro_version < 96) in drbd_state_is_stable()
2218 drbd_queue_work(&first_peer_device(device)-> in dec_ap_bio()
2232 return first_peer_device(device)->connection->agreed_pro_version >= 97 && in verify_can_do_stop_sector()
2233 first_peer_device(device)->connection->agreed_pro_version != 100; in verify_can_do_stop_sector()
H A Ddrbd_main.c295 struct drbd_connection *connection = first_peer_device(device)->connection; in tl_abort_disk_io()
1116 use_rle = rcu_dereference(first_peer_device(device)->connection->net_conf)->use_rle; in fill_bitmap_rle_bits()
1118 if (!use_rle || first_peer_device(device)->connection->agreed_pro_version < 90) in fill_bitmap_rle_bits()
1931 &first_peer_device(device)->connection->sender_work, in drbd_queue_unplug()
2022 if (first_peer_device(device)->connection->receiver.t_state != NONE) in drbd_device_cleanup()
2024 first_peer_device(device)->connection->receiver.t_state); in drbd_device_cleanup()
2042 D_ASSERT(device, first_peer_device(device)->connection->net_conf == NULL); in drbd_device_cleanup()
2062 D_ASSERT(device, list_empty(&first_peer_device(device)->connection->sender_work.q)); in drbd_device_cleanup()
3558 D_ASSERT(device, current != first_peer_device(device)->connection->worker.task); in drbd_bitmap_io()
3686 nc = rcu_dereference(first_peer_device(devic in drbd_wait_misc()
[all...]
H A Ddrbd_actlog.c764 struct drbd_connection *connection = first_peer_device(device)->connection; in maybe_schedule_on_disk_bitmap_update()
823 drbd_advance_rs_marks(first_peer_device(device), still_to_go); in update_sync_bits()
H A Ddrbd_receiver.c2422 struct drbd_peer_device *peer_device = first_peer_device(device); in fail_postponed_requests()
/kernel/linux/linux-5.10/drivers/block/drbd/
H A Ddrbd_worker.c453 &first_peer_device(device)->connection->sender_work, in resync_timer_fn()
590 struct drbd_peer_device *const peer_device = first_peer_device(device); in make_resync_request()
805 if (drbd_send_ov_request(first_peer_device(device), sector, size)) { in make_ov_request()
846 struct drbd_connection *connection = first_peer_device(device)->connection; in ping_peer()
856 struct drbd_connection *connection = first_peer_device(device)->connection; in drbd_resync_finished()
1399 return pd_send_unplug_remote(first_peer_device(device)); in w_send_write_hint()
1428 struct drbd_peer_device *const peer_device = first_peer_device(device); in w_send_out_of_sync()
1459 struct drbd_peer_device *const peer_device = first_peer_device(device); in w_send_dblock()
1492 struct drbd_peer_device *const peer_device = first_peer_device(device); in w_send_read_req()
1735 struct drbd_peer_device *peer_device = first_peer_device(devic in drbd_start_resync()
[all...]
H A Ddrbd_req.c245 req->epoch == atomic_read(&first_peer_device(device)->connection->current_tle_nr)) in drbd_req_complete()
246 start_new_tl_epoch(first_peer_device(device)->connection); in drbd_req_complete()
405 struct drbd_peer_device *peer_device = first_peer_device(device); in mod_rq_state()
552 struct drbd_peer_device *const peer_device = first_peer_device(device); in __req_mod()
975 struct drbd_connection *connection = first_peer_device(device)->connection; in maybe_pull_ahead()
1011 start_new_tl_epoch(first_peer_device(device)->connection); in maybe_pull_ahead()
1346 req->epoch = atomic_read(&first_peer_device(device)->connection->current_tle_nr); in drbd_send_and_submit()
1352 first_peer_device(device)->connection->current_tle_writes++; in drbd_send_and_submit()
1354 list_add_tail(&req->tl_requests, &first_peer_device(device)->connection->transfer_log); in drbd_send_and_submit()
1691 struct drbd_connection *connection = first_peer_device(devic in request_timer_fn()
[all...]
H A Ddrbd_main.c304 struct drbd_connection *connection = first_peer_device(device)->connection; in tl_abort_disk_io()
1130 use_rle = rcu_dereference(first_peer_device(device)->connection->net_conf)->use_rle; in fill_bitmap_rle_bits()
1132 if (!use_rle || first_peer_device(device)->connection->agreed_pro_version < 90) in fill_bitmap_rle_bits()
1221 struct drbd_socket *sock = &first_peer_device(device)->connection->data; in send_bitmap_rle_or_plain()
1222 unsigned int header_size = drbd_header_size(first_peer_device(device)->connection); in send_bitmap_rle_or_plain()
1233 err = __send_command(first_peer_device(device)->connection, device->vnr, sock, in send_bitmap_rle_or_plain()
1254 err = __send_command(first_peer_device(device)->connection, device->vnr, sock, P_BITMAP, len, NULL, 0); in send_bitmap_rle_or_plain()
1314 struct drbd_socket *sock = &first_peer_device(device)->connection->data; in drbd_send_bitmap()
1960 &first_peer_device(device)->connection->sender_work, in drbd_queue_unplug()
2052 if (first_peer_device(devic in drbd_device_cleanup()
[all...]
H A Ddrbd_proc.c269 nc = rcu_dereference(first_peer_device(device)->connection->net_conf); in drbd_seq_show()
298 first_peer_device(device)->connection->epochs, in drbd_seq_show()
H A Ddrbd_state.c542 rv = is_valid_soft_transition(os, ns, first_peer_device(device)->connection); in _req_st_cond()
591 rv = is_valid_soft_transition(os, ns, first_peer_device(device)->connection); in drbd_req_state()
600 if (drbd_send_state_req(first_peer_device(device), mask, val)) { in drbd_req_state()
625 D_ASSERT(device, current != first_peer_device(device)->connection->worker.task); in drbd_req_state()
838 nc = rcu_dereference(first_peer_device(device)->connection->net_conf); in is_valid_state()
843 else if (conn_highest_peer(first_peer_device(device)->connection) == R_PRIMARY) in is_valid_state()
884 first_peer_device(device)->connection->agreed_pro_version < 88) in is_valid_state()
1227 if (first_peer_device(device)->connection->agreed_pro_version < 90) in set_ov_position()
1264 struct drbd_peer_device *peer_device = first_peer_device(device); in _drbd_set_state()
1526 D_ASSERT(device, current == first_peer_device(devic in drbd_bitmap_io_from_worker()
[all...]
H A Ddrbd_nl.c364 struct drbd_connection *connection = first_peer_device(device)->connection; in drbd_khelper()
617 struct drbd_peer_device *const peer_device = first_peer_device(device); in drbd_set_role()
1215 struct drbd_connection *connection = first_peer_device(device)->connection; in decide_on_discard_support()
1259 struct drbd_connection *connection = first_peer_device(device)->connection; in fixup_write_zeroes()
1273 struct drbd_peer_device *peer_device = first_peer_device(device); in decide_on_write_same_support()
1391 if (first_peer_device(device)->connection->agreed_pro_version < 94) in drbd_reconsider_queue_parameters()
1394 else if (first_peer_device(device)->connection->agreed_pro_version == 94) in drbd_reconsider_queue_parameters()
1396 else if (first_peer_device(device)->connection->agreed_pro_version < 100) in drbd_reconsider_queue_parameters()
1811 peer_device = first_peer_device(device); in drbd_adm_attach()
2823 iass = test_bit(RESOLVE_CONFLICTS, &first_peer_device(devic in resync_after_online_grow()
[all...]
H A Ddrbd_int.h954 struct mutex *state_mutex; /* either own_state_mutex or first_peer_device(device)->connection->cstate_mutex */
1015 static inline struct drbd_peer_device *first_peer_device(struct drbd_device *device) in first_peer_device() function
1917 first_peer_device(device)->connection; in drbd_device_post_work()
2143 nc = rcu_dereference(first_peer_device(device)->connection->net_conf); in drbd_get_max_buffers()
2186 if (first_peer_device(device)->connection->agreed_pro_version < 96) in drbd_state_is_stable()
2288 drbd_queue_work(&first_peer_device(device)-> in dec_ap_bio()
2302 return first_peer_device(device)->connection->agreed_pro_version >= 97 && in verify_can_do_stop_sector()
2303 first_peer_device(device)->connection->agreed_pro_version != 100; in verify_can_do_stop_sector()
H A Ddrbd_actlog.c763 struct drbd_connection *connection = first_peer_device(device)->connection; in maybe_schedule_on_disk_bitmap_update()
H A Ddrbd_receiver.c3271 struct drbd_peer_device *const peer_device = first_peer_device(device); in __must_hold()
4822 unsigned int header_size = drbd_header_size(first_peer_device(device)->connection); in INFO_bm_xfer_stats()

Completed in 57 milliseconds