Lines Matching full:connection
175 * @connection: DRBD connection.
181 * termination of the connection.
183 void tl_release(struct drbd_connection *connection, unsigned int barrier_nr, in tl_release() argument
191 spin_lock_irq(&connection->resource->req_lock); in tl_release()
195 list_for_each_entry(r, &connection->transfer_log, tl_requests) { in tl_release()
220 drbd_err(connection, "BAD! BarrierAck #%u received, but no epoch in tl!?\n", in tl_release()
225 drbd_err(connection, "BAD! BarrierAck #%u received, expected #%u!\n", in tl_release()
231 drbd_err(connection, "BAD! BarrierAck #%u received with n_writes=%u, expected n_writes=%u!\n", in tl_release()
240 list_for_each_entry(req, &connection->transfer_log, tl_requests) in tl_release()
243 list_for_each_entry_safe_from(req, r, &connection->transfer_log, tl_requests) { in tl_release()
248 spin_unlock_irq(&connection->resource->req_lock); in tl_release()
253 spin_unlock_irq(&connection->resource->req_lock); in tl_release()
254 conn_request_state(connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD); in tl_release()
260 * @connection: DRBD connection to operate on.
267 void _tl_restart(struct drbd_connection *connection, enum drbd_req_event what) in _tl_restart() argument
271 list_for_each_entry_safe(req, r, &connection->transfer_log, tl_requests) in _tl_restart()
275 void tl_restart(struct drbd_connection *connection, enum drbd_req_event what) in tl_restart() argument
277 spin_lock_irq(&connection->resource->req_lock); in tl_restart()
278 _tl_restart(connection, what); in tl_restart()
279 spin_unlock_irq(&connection->resource->req_lock); in tl_restart()
286 * This is called after the connection to the peer was lost. The storage covered
290 void tl_clear(struct drbd_connection *connection) in tl_clear() argument
292 tl_restart(connection, CONNECTION_LOST_WHILE_PENDING); in tl_clear()
301 struct drbd_connection *connection = first_peer_device(device)->connection; in tl_abort_disk_io() local
304 spin_lock_irq(&connection->resource->req_lock); in tl_abort_disk_io()
305 list_for_each_entry_safe(req, r, &connection->transfer_log, tl_requests) { in tl_abort_disk_io()
312 spin_unlock_irq(&connection->resource->req_lock); in tl_abort_disk_io()
360 if (thi->connection) in drbd_thread_setup()
361 kref_put(&thi->connection->kref, drbd_destroy_connection); in drbd_thread_setup()
375 thi->connection = NULL; in drbd_thread_init()
402 if (thi->connection) in drbd_thread_start()
403 kref_get(&thi->connection->kref); in drbd_thread_start()
417 if (thi->connection) in drbd_thread_start()
418 kref_put(&thi->connection->kref, drbd_destroy_connection); in drbd_thread_start()
480 int conn_lowest_minor(struct drbd_connection *connection) in conn_lowest_minor() argument
486 peer_device = idr_get_next(&connection->peer_devices, &vnr); in conn_lowest_minor()
561 unsigned int drbd_header_size(struct drbd_connection *connection) in drbd_header_size() argument
563 if (connection->agreed_pro_version >= 100) { in drbd_header_size()
601 static unsigned int prepare_header(struct drbd_connection *connection, int vnr, in prepare_header() argument
604 if (connection->agreed_pro_version >= 100) in prepare_header()
606 else if (connection->agreed_pro_version >= 95 && in prepare_header()
613 static void *__conn_prepare_command(struct drbd_connection *connection, in __conn_prepare_command() argument
618 return sock->sbuf + drbd_header_size(connection); in __conn_prepare_command()
621 void *conn_prepare_command(struct drbd_connection *connection, struct drbd_socket *sock) in conn_prepare_command() argument
626 p = __conn_prepare_command(connection, sock); in conn_prepare_command()
635 return conn_prepare_command(peer_device->connection, sock); in drbd_prepare_command()
638 static int __send_command(struct drbd_connection *connection, int vnr, in __send_command() argument
655 header_size += prepare_header(connection, vnr, sock->sbuf, cmd, in __send_command()
657 err = drbd_send_all(connection, sock->socket, sock->sbuf, header_size, in __send_command()
660 err = drbd_send_all(connection, sock->socket, data, size, 0); in __send_command()
669 static int __conn_send_command(struct drbd_connection *connection, struct drbd_socket *sock, in __conn_send_command() argument
673 return __send_command(connection, 0, sock, cmd, header_size, data, size); in __conn_send_command()
676 int conn_send_command(struct drbd_connection *connection, struct drbd_socket *sock, in conn_send_command() argument
682 err = __conn_send_command(connection, sock, cmd, header_size, data, size); in conn_send_command()
693 err = __send_command(peer_device->connection, peer_device->device->vnr, in drbd_send_command()
699 int drbd_send_ping(struct drbd_connection *connection) in drbd_send_ping() argument
703 sock = &connection->meta; in drbd_send_ping()
704 if (!conn_prepare_command(connection, sock)) in drbd_send_ping()
706 return conn_send_command(connection, sock, P_PING, 0, NULL, 0); in drbd_send_ping()
709 int drbd_send_ping_ack(struct drbd_connection *connection) in drbd_send_ping_ack() argument
713 sock = &connection->meta; in drbd_send_ping_ack()
714 if (!conn_prepare_command(connection, sock)) in drbd_send_ping_ack()
716 return conn_send_command(connection, sock, P_PING_ACK, 0, NULL, 0); in drbd_send_ping_ack()
724 const int apv = peer_device->connection->agreed_pro_version; in drbd_send_sync_param()
729 sock = &peer_device->connection->data; in drbd_send_sync_param()
735 nc = rcu_dereference(peer_device->connection->net_conf); in drbd_send_sync_param()
773 int __drbd_send_protocol(struct drbd_connection *connection, enum drbd_packet cmd) in __drbd_send_protocol() argument
780 sock = &connection->data; in __drbd_send_protocol()
781 p = __conn_prepare_command(connection, sock); in __drbd_send_protocol()
786 nc = rcu_dereference(connection->net_conf); in __drbd_send_protocol()
788 if (nc->tentative && connection->agreed_pro_version < 92) { in __drbd_send_protocol()
790 drbd_err(connection, "--dry-run is not supported by peer"); in __drbd_send_protocol()
795 if (connection->agreed_pro_version >= 87) in __drbd_send_protocol()
810 if (connection->agreed_pro_version >= 87) in __drbd_send_protocol()
814 return __conn_send_command(connection, sock, cmd, size, NULL, 0); in __drbd_send_protocol()
817 int drbd_send_protocol(struct drbd_connection *connection) in drbd_send_protocol() argument
821 mutex_lock(&connection->data.mutex); in drbd_send_protocol()
822 err = __drbd_send_protocol(connection, P_PROTOCOL); in drbd_send_protocol()
823 mutex_unlock(&connection->data.mutex); in drbd_send_protocol()
838 sock = &peer_device->connection->data; in _drbd_send_uuids()
852 uuid_flags |= rcu_dereference(peer_device->connection->net_conf)->discard_my_data ? 1 : 0; in _drbd_send_uuids()
908 sock = &peer_device->connection->data; in drbd_gen_and_send_sync_uuid()
951 sock = &peer_device->connection->data; in drbd_send_sizes()
957 if (peer_device->connection->agreed_features & DRBD_FF_WSAME) in drbd_send_sizes()
980 if (peer_device->connection->agreed_pro_version <= 94) in drbd_send_sizes()
982 else if (peer_device->connection->agreed_pro_version < 100) in drbd_send_sizes()
1007 sock = &peer_device->connection->data; in drbd_send_current_state()
1030 sock = &peer_device->connection->data; in drbd_send_state()
1043 sock = &peer_device->connection->data; in drbd_send_state_req()
1052 int conn_send_state_req(struct drbd_connection *connection, union drbd_state mask, union drbd_state… in conn_send_state_req() argument
1058 cmd = connection->agreed_pro_version < 100 ? P_STATE_CHG_REQ : P_CONN_ST_CHG_REQ; in conn_send_state_req()
1059 sock = &connection->data; in conn_send_state_req()
1060 p = conn_prepare_command(connection, sock); in conn_send_state_req()
1065 return conn_send_command(connection, sock, cmd, sizeof(*p), NULL, 0); in conn_send_state_req()
1073 sock = &peer_device->connection->meta; in drbd_send_sr_reply()
1081 void conn_send_sr_reply(struct drbd_connection *connection, enum drbd_state_rv retcode) in conn_send_sr_reply() argument
1085 …enum drbd_packet cmd = connection->agreed_pro_version < 100 ? P_STATE_CHG_REPLY : P_CONN_ST_CHG_RE… in conn_send_sr_reply()
1087 sock = &connection->meta; in conn_send_sr_reply()
1088 p = conn_prepare_command(connection, sock); in conn_send_sr_reply()
1091 conn_send_command(connection, sock, cmd, sizeof(*p), NULL, 0); in conn_send_sr_reply()
1127 use_rle = rcu_dereference(first_peer_device(device)->connection->net_conf)->use_rle; in fill_bitmap_rle_bits()
1129 if (!use_rle || first_peer_device(device)->connection->agreed_pro_version < 90) in fill_bitmap_rle_bits()
1218 struct drbd_socket *sock = &first_peer_device(device)->connection->data; in send_bitmap_rle_or_plain()
1219 unsigned int header_size = drbd_header_size(first_peer_device(device)->connection); in send_bitmap_rle_or_plain()
1230 err = __send_command(first_peer_device(device)->connection, device->vnr, sock, in send_bitmap_rle_or_plain()
1251 …err = __send_command(first_peer_device(device)->connection, device->vnr, sock, P_BITMAP, len, NULL… in send_bitmap_rle_or_plain()
1311 struct drbd_socket *sock = &first_peer_device(device)->connection->data; in drbd_send_bitmap()
1321 void drbd_send_b_ack(struct drbd_connection *connection, u32 barrier_nr, u32 set_size) in drbd_send_b_ack() argument
1326 if (connection->cstate < C_WF_REPORT_PARAMS) in drbd_send_b_ack()
1329 sock = &connection->meta; in drbd_send_b_ack()
1330 p = conn_prepare_command(connection, sock); in drbd_send_b_ack()
1335 conn_send_command(connection, sock, P_BARRIER_ACK, sizeof(*p), NULL, 0); in drbd_send_b_ack()
1355 sock = &peer_device->connection->meta; in _drbd_send_ack()
1372 if (peer_device->connection->peer_integrity_tfm) in drbd_send_ack_dp()
1373 data_size -= crypto_shash_digestsize(peer_device->connection->peer_integrity_tfm); in drbd_send_ack_dp()
1416 sock = &peer_device->connection->data; in drbd_send_rs_deallocated()
1432 sock = &peer_device->connection->data; in drbd_send_drequest()
1450 sock = &peer_device->connection->data; in drbd_send_drequest_csum()
1465 sock = &peer_device->connection->data; in drbd_send_ov_request()
1477 * true if we think connection is dead
1479 static int we_should_drop_the_connection(struct drbd_connection *connection, struct socket *sock) in we_should_drop_the_connection() argument
1484 drop_it = connection->meta.socket == sock in we_should_drop_the_connection()
1485 || !connection->ack_receiver.task in we_should_drop_the_connection()
1486 || get_t_state(&connection->ack_receiver) != RUNNING in we_should_drop_the_connection()
1487 || connection->cstate < C_WF_REPORT_PARAMS; in we_should_drop_the_connection()
1492 drop_it = !--connection->ko_count; in we_should_drop_the_connection()
1494 drbd_err(connection, "[%s/%d] sock_sendmsg time expired, ko = %u\n", in we_should_drop_the_connection()
1495 current->comm, current->pid, connection->ko_count); in we_should_drop_the_connection()
1496 request_ping(connection); in we_should_drop_the_connection()
1502 static void drbd_update_congested(struct drbd_connection *connection) in drbd_update_congested() argument
1504 struct sock *sk = connection->data.socket->sk; in drbd_update_congested()
1506 set_bit(NET_CONGESTED, &connection->flags); in drbd_update_congested()
1537 socket = peer_device->connection->data.socket; in _drbd_no_send_page()
1539 err = drbd_send_all(peer_device->connection, socket, addr, size, msg_flags); in _drbd_no_send_page()
1549 struct socket *socket = peer_device->connection->data.socket; in _drbd_send_page()
1563 drbd_update_congested(peer_device->connection); in _drbd_send_page()
1570 if (we_should_drop_the_connection(peer_device->connection, socket)) in _drbd_send_page()
1583 clear_bit(NET_CONGESTED, &peer_device->connection->flags); in _drbd_send_page()
1655 static u32 bio_flags_to_wire(struct drbd_connection *connection, in bio_flags_to_wire() argument
1658 if (connection->agreed_pro_version >= 95) in bio_flags_to_wire()
1665 ((connection->agreed_features & DRBD_FF_WZEROES) ? in bio_flags_to_wire()
1687 sock = &peer_device->connection->data; in drbd_send_dblock()
1689 digest_size = peer_device->connection->integrity_tfm ? in drbd_send_dblock()
1690 crypto_shash_digestsize(peer_device->connection->integrity_tfm) : 0; in drbd_send_dblock()
1697 dp_flags = bio_flags_to_wire(peer_device->connection, req->master_bio); in drbd_send_dblock()
1701 if (peer_device->connection->agreed_pro_version >= 100) { in drbd_send_dblock()
1716 err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*t), NULL, 0); in drbd_send_dblock()
1732 drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, digest_out); in drbd_send_dblock()
1735 __send_command(peer_device->connection, device->vnr, sock, P_WSAME, in drbd_send_dblock()
1740 __send_command(peer_device->connection, device->vnr, sock, P_DATA, in drbd_send_dblock()
1764 drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, digest); in drbd_send_dblock()
1793 sock = &peer_device->connection->data; in drbd_send_block()
1796 digest_size = peer_device->connection->integrity_tfm ? in drbd_send_block()
1797 crypto_shash_digestsize(peer_device->connection->integrity_tfm) : 0; in drbd_send_block()
1806 drbd_csum_ee(peer_device->connection->integrity_tfm, peer_req, p + 1); in drbd_send_block()
1807 …err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*p) + digest_size, NU… in drbd_send_block()
1820 sock = &peer_device->connection->data; in drbd_send_out_of_sync()
1845 int drbd_send(struct drbd_connection *connection, struct socket *sock, in drbd_send() argument
1859 if (sock == connection->data.socket) { in drbd_send()
1861 connection->ko_count = rcu_dereference(connection->net_conf)->ko_count; in drbd_send()
1863 drbd_update_congested(connection); in drbd_send()
1868 if (we_should_drop_the_connection(connection, sock)) in drbd_send()
1882 if (sock == connection->data.socket) in drbd_send()
1883 clear_bit(NET_CONGESTED, &connection->flags); in drbd_send()
1887 drbd_err(connection, "%s_sendmsg returned %d\n", in drbd_send()
1888 sock == connection->meta.socket ? "msock" : "sock", in drbd_send()
1890 conn_request_state(connection, NS(conn, C_BROKEN_PIPE), CS_HARD); in drbd_send()
1892 conn_request_state(connection, NS(conn, C_TIMEOUT), CS_HARD); in drbd_send()
1903 int drbd_send_all(struct drbd_connection *connection, struct socket *sock, void *buffer, in drbd_send_all() argument
1908 err = drbd_send(connection, sock, buffer, size, msg_flags); in drbd_send_all()
1957 &first_peer_device(device)->connection->sender_work, in drbd_queue_unplug()
2049 if (first_peer_device(device)->connection->receiver.t_state != NONE) in drbd_device_cleanup()
2051 first_peer_device(device)->connection->receiver.t_state); in drbd_device_cleanup()
2069 D_ASSERT(device, first_peer_device(device)->connection->net_conf == NULL); in drbd_device_cleanup()
2090 D_ASSERT(device, list_empty(&first_peer_device(device)->connection->sender_work.q)); in drbd_device_cleanup()
2257 /* not for_each_connection(connection, resource): in drbd_destroy_device()
2261 kref_put(&peer_device->connection->kref, drbd_destroy_connection); in drbd_destroy_device()
2363 struct drbd_connection *connection, *tmp; in drbd_free_resource() local
2365 for_each_connection_safe(connection, tmp, resource) { in drbd_free_resource()
2366 list_del(&connection->connections); in drbd_free_resource()
2367 drbd_debugfs_connection_cleanup(connection); in drbd_free_resource()
2368 kref_put(&connection->kref, drbd_destroy_connection); in drbd_free_resource()
2470 struct drbd_connection *connection; in conn_get_by_addrs() local
2474 for_each_connection_rcu(connection, resource) { in conn_get_by_addrs()
2475 if (connection->my_addr_len == my_addr_len && in conn_get_by_addrs()
2476 connection->peer_addr_len == peer_addr_len && in conn_get_by_addrs()
2477 !memcmp(&connection->my_addr, my_addr, my_addr_len) && in conn_get_by_addrs()
2478 !memcmp(&connection->peer_addr, peer_addr, peer_addr_len)) { in conn_get_by_addrs()
2479 kref_get(&connection->kref); in conn_get_by_addrs()
2484 connection = NULL; in conn_get_by_addrs()
2487 return connection; in conn_get_by_addrs()
2507 void conn_free_crypto(struct drbd_connection *connection) in conn_free_crypto() argument
2509 drbd_free_sock(connection); in conn_free_crypto()
2511 crypto_free_shash(connection->csums_tfm); in conn_free_crypto()
2512 crypto_free_shash(connection->verify_tfm); in conn_free_crypto()
2513 crypto_free_shash(connection->cram_hmac_tfm); in conn_free_crypto()
2514 crypto_free_shash(connection->integrity_tfm); in conn_free_crypto()
2515 crypto_free_shash(connection->peer_integrity_tfm); in conn_free_crypto()
2516 kfree(connection->int_dig_in); in conn_free_crypto()
2517 kfree(connection->int_dig_vv); in conn_free_crypto()
2519 connection->csums_tfm = NULL; in conn_free_crypto()
2520 connection->verify_tfm = NULL; in conn_free_crypto()
2521 connection->cram_hmac_tfm = NULL; in conn_free_crypto()
2522 connection->integrity_tfm = NULL; in conn_free_crypto()
2523 connection->peer_integrity_tfm = NULL; in conn_free_crypto()
2524 connection->int_dig_in = NULL; in conn_free_crypto()
2525 connection->int_dig_vv = NULL; in conn_free_crypto()
2530 struct drbd_connection *connection; in set_resource_options() local
2566 for_each_connection_rcu(connection, resource) { in set_resource_options()
2567 connection->receiver.reset_cpu_mask = 1; in set_resource_options()
2568 connection->ack_receiver.reset_cpu_mask = 1; in set_resource_options()
2569 connection->worker.reset_cpu_mask = 1; in set_resource_options()
2615 struct drbd_connection *connection; in conn_create() local
2617 connection = kzalloc(sizeof(struct drbd_connection), GFP_KERNEL); in conn_create()
2618 if (!connection) in conn_create()
2621 if (drbd_alloc_socket(&connection->data)) in conn_create()
2623 if (drbd_alloc_socket(&connection->meta)) in conn_create()
2626 connection->current_epoch = kzalloc(sizeof(struct drbd_epoch), GFP_KERNEL); in conn_create()
2627 if (!connection->current_epoch) in conn_create()
2630 INIT_LIST_HEAD(&connection->transfer_log); in conn_create()
2632 INIT_LIST_HEAD(&connection->current_epoch->list); in conn_create()
2633 connection->epochs = 1; in conn_create()
2634 spin_lock_init(&connection->epoch_lock); in conn_create()
2636 connection->send.seen_any_write_yet = false; in conn_create()
2637 connection->send.current_epoch_nr = 0; in conn_create()
2638 connection->send.current_epoch_writes = 0; in conn_create()
2644 connection->cstate = C_STANDALONE; in conn_create()
2645 mutex_init(&connection->cstate_mutex); in conn_create()
2646 init_waitqueue_head(&connection->ping_wait); in conn_create()
2647 idr_init(&connection->peer_devices); in conn_create()
2649 drbd_init_workqueue(&connection->sender_work); in conn_create()
2650 mutex_init(&connection->data.mutex); in conn_create()
2651 mutex_init(&connection->meta.mutex); in conn_create()
2653 drbd_thread_init(resource, &connection->receiver, drbd_receiver, "receiver"); in conn_create()
2654 connection->receiver.connection = connection; in conn_create()
2655 drbd_thread_init(resource, &connection->worker, drbd_worker, "worker"); in conn_create()
2656 connection->worker.connection = connection; in conn_create()
2657 drbd_thread_init(resource, &connection->ack_receiver, drbd_ack_receiver, "ack_recv"); in conn_create()
2658 connection->ack_receiver.connection = connection; in conn_create()
2660 kref_init(&connection->kref); in conn_create()
2662 connection->resource = resource; in conn_create()
2668 list_add_tail_rcu(&connection->connections, &resource->connections); in conn_create()
2669 drbd_debugfs_connection_add(connection); in conn_create()
2670 return connection; in conn_create()
2676 kfree(connection->current_epoch); in conn_create()
2677 drbd_free_socket(&connection->meta); in conn_create()
2678 drbd_free_socket(&connection->data); in conn_create()
2679 kfree(connection); in conn_create()
2685 struct drbd_connection *connection = container_of(kref, struct drbd_connection, kref); in drbd_destroy_connection() local
2686 struct drbd_resource *resource = connection->resource; in drbd_destroy_connection()
2688 if (atomic_read(&connection->current_epoch->epoch_size) != 0) in drbd_destroy_connection()
2689 drbd_err(connection, "epoch_size:%d\n", atomic_read(&connection->current_epoch->epoch_size)); in drbd_destroy_connection()
2690 kfree(connection->current_epoch); in drbd_destroy_connection()
2692 idr_destroy(&connection->peer_devices); in drbd_destroy_connection()
2694 drbd_free_socket(&connection->meta); in drbd_destroy_connection()
2695 drbd_free_socket(&connection->data); in drbd_destroy_connection()
2696 kfree(connection->int_dig_in); in drbd_destroy_connection()
2697 kfree(connection->int_dig_vv); in drbd_destroy_connection()
2698 memset(connection, 0xfc, sizeof(*connection)); in drbd_destroy_connection()
2699 kfree(connection); in drbd_destroy_connection()
2720 struct drbd_connection *connection; in drbd_create_device() local
2797 for_each_connection(connection, resource) { in drbd_create_device()
2801 peer_device->connection = connection; in drbd_create_device()
2807 id = idr_alloc(&connection->peer_devices, peer_device, vnr, vnr + 1, GFP_KERNEL); in drbd_create_device()
2813 kref_get(&connection->kref); in drbd_create_device()
2824 /* inherit the connection state */ in drbd_create_device()
2837 idr_remove(&connection->peer_devices, vnr); in drbd_create_device()
2839 for_each_connection(connection, resource) { in drbd_create_device()
2840 peer_device = idr_remove(&connection->peer_devices, vnr); in drbd_create_device()
2842 kref_put(&connection->kref, drbd_destroy_connection); in drbd_create_device()
2869 struct drbd_connection *connection; in drbd_delete_device() local
2876 for_each_connection(connection, resource) { in drbd_delete_device()
2877 idr_remove(&connection->peer_devices, device->vnr); in drbd_delete_device()
2979 void drbd_free_sock(struct drbd_connection *connection) in drbd_free_sock() argument
2981 if (connection->data.socket) in drbd_free_sock()
2982 drbd_free_one_sock(&connection->data); in drbd_free_sock()
2983 if (connection->meta.socket) in drbd_free_sock()
2984 drbd_free_one_sock(&connection->meta); in drbd_free_sock()
2989 void conn_md_sync(struct drbd_connection *connection) in conn_md_sync() argument
2995 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in conn_md_sync()
3542 D_ASSERT(device, current == first_peer_device(device)->connection->worker.task); in drbd_queue_bitmap_io()
3562 drbd_queue_work(&first_peer_device(device)->connection->sender_work, in drbd_queue_bitmap_io()
3584 D_ASSERT(device, current != first_peer_device(device)->connection->worker.task); in drbd_bitmap_io()
3712 nc = rcu_dereference(first_peer_device(device)->connection->net_conf); in drbd_wait_misc()