Lines Matching full:connection
151 * @connection: DRBD connection.
157 * termination of the connection.
159 void tl_release(struct drbd_connection *connection, unsigned int barrier_nr, in tl_release() argument
167 spin_lock_irq(&connection->resource->req_lock); in tl_release()
171 list_for_each_entry(r, &connection->transfer_log, tl_requests) { in tl_release()
196 drbd_err(connection, "BAD! BarrierAck #%u received, but no epoch in tl!?\n", in tl_release()
201 drbd_err(connection, "BAD! BarrierAck #%u received, expected #%u!\n", in tl_release()
207 drbd_err(connection, "BAD! BarrierAck #%u received with n_writes=%u, expected n_writes=%u!\n", in tl_release()
216 list_for_each_entry(req, &connection->transfer_log, tl_requests) in tl_release()
221 req = list_prepare_entry(tmp, &connection->transfer_log, tl_requests); in tl_release()
222 list_for_each_entry_safe_from(req, r, &connection->transfer_log, tl_requests) { in tl_release()
226 peer_device = conn_peer_device(connection, req->device->vnr); in tl_release()
229 spin_unlock_irq(&connection->resource->req_lock); in tl_release()
234 spin_unlock_irq(&connection->resource->req_lock); in tl_release()
235 conn_request_state(connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD); in tl_release()
241 * @connection: DRBD connection to operate on.
248 void _tl_restart(struct drbd_connection *connection, enum drbd_req_event what) in _tl_restart() argument
253 list_for_each_entry_safe(req, r, &connection->transfer_log, tl_requests) { in _tl_restart()
254 peer_device = conn_peer_device(connection, req->device->vnr); in _tl_restart()
259 void tl_restart(struct drbd_connection *connection, enum drbd_req_event what) in tl_restart() argument
261 spin_lock_irq(&connection->resource->req_lock); in tl_restart()
262 _tl_restart(connection, what); in tl_restart()
263 spin_unlock_irq(&connection->resource->req_lock); in tl_restart()
268 * @connection: DRBD connection.
270 * This is called after the connection to the peer was lost. The storage covered
274 void tl_clear(struct drbd_connection *connection) in tl_clear() argument
276 tl_restart(connection, CONNECTION_LOST_WHILE_PENDING); in tl_clear()
285 struct drbd_connection *connection = first_peer_device(device)->connection; in tl_abort_disk_io() local
288 spin_lock_irq(&connection->resource->req_lock); in tl_abort_disk_io()
289 list_for_each_entry_safe(req, r, &connection->transfer_log, tl_requests) { in tl_abort_disk_io()
296 spin_unlock_irq(&connection->resource->req_lock); in tl_abort_disk_io()
344 if (thi->connection) in drbd_thread_setup()
345 kref_put(&thi->connection->kref, drbd_destroy_connection); in drbd_thread_setup()
359 thi->connection = NULL; in drbd_thread_init()
386 if (thi->connection) in drbd_thread_start()
387 kref_get(&thi->connection->kref); in drbd_thread_start()
401 if (thi->connection) in drbd_thread_start()
402 kref_put(&thi->connection->kref, drbd_destroy_connection); in drbd_thread_start()
530 unsigned int drbd_header_size(struct drbd_connection *connection) in drbd_header_size() argument
532 if (connection->agreed_pro_version >= 100) { in drbd_header_size()
570 static unsigned int prepare_header(struct drbd_connection *connection, int vnr, in prepare_header() argument
573 if (connection->agreed_pro_version >= 100) in prepare_header()
575 else if (connection->agreed_pro_version >= 95 && in prepare_header()
582 static void *__conn_prepare_command(struct drbd_connection *connection, in __conn_prepare_command() argument
587 return sock->sbuf + drbd_header_size(connection); in __conn_prepare_command()
590 void *conn_prepare_command(struct drbd_connection *connection, struct drbd_socket *sock) in conn_prepare_command() argument
595 p = __conn_prepare_command(connection, sock); in conn_prepare_command()
604 return conn_prepare_command(peer_device->connection, sock); in drbd_prepare_command()
607 static int __send_command(struct drbd_connection *connection, int vnr, in __send_command() argument
624 header_size += prepare_header(connection, vnr, sock->sbuf, cmd, in __send_command()
626 err = drbd_send_all(connection, sock->socket, sock->sbuf, header_size, in __send_command()
629 err = drbd_send_all(connection, sock->socket, data, size, 0); in __send_command()
638 static int __conn_send_command(struct drbd_connection *connection, struct drbd_socket *sock, in __conn_send_command() argument
642 return __send_command(connection, 0, sock, cmd, header_size, data, size); in __conn_send_command()
645 int conn_send_command(struct drbd_connection *connection, struct drbd_socket *sock, in conn_send_command() argument
651 err = __conn_send_command(connection, sock, cmd, header_size, data, size); in conn_send_command()
662 err = __send_command(peer_device->connection, peer_device->device->vnr, in drbd_send_command()
668 int drbd_send_ping(struct drbd_connection *connection) in drbd_send_ping() argument
672 sock = &connection->meta; in drbd_send_ping()
673 if (!conn_prepare_command(connection, sock)) in drbd_send_ping()
675 return conn_send_command(connection, sock, P_PING, 0, NULL, 0); in drbd_send_ping()
678 int drbd_send_ping_ack(struct drbd_connection *connection) in drbd_send_ping_ack() argument
682 sock = &connection->meta; in drbd_send_ping_ack()
683 if (!conn_prepare_command(connection, sock)) in drbd_send_ping_ack()
685 return conn_send_command(connection, sock, P_PING_ACK, 0, NULL, 0); in drbd_send_ping_ack()
693 const int apv = peer_device->connection->agreed_pro_version; in drbd_send_sync_param()
698 sock = &peer_device->connection->data; in drbd_send_sync_param()
704 nc = rcu_dereference(peer_device->connection->net_conf); in drbd_send_sync_param()
743 int __drbd_send_protocol(struct drbd_connection *connection, enum drbd_packet cmd) in __drbd_send_protocol() argument
750 sock = &connection->data; in __drbd_send_protocol()
751 p = __conn_prepare_command(connection, sock); in __drbd_send_protocol()
756 nc = rcu_dereference(connection->net_conf); in __drbd_send_protocol()
758 if (nc->tentative && connection->agreed_pro_version < 92) { in __drbd_send_protocol()
760 drbd_err(connection, "--dry-run is not supported by peer"); in __drbd_send_protocol()
765 if (connection->agreed_pro_version >= 87) in __drbd_send_protocol()
780 if (connection->agreed_pro_version >= 87) in __drbd_send_protocol()
784 return __conn_send_command(connection, sock, cmd, size, NULL, 0); in __drbd_send_protocol()
787 int drbd_send_protocol(struct drbd_connection *connection) in drbd_send_protocol() argument
791 mutex_lock(&connection->data.mutex); in drbd_send_protocol()
792 err = __drbd_send_protocol(connection, P_PROTOCOL); in drbd_send_protocol()
793 mutex_unlock(&connection->data.mutex); in drbd_send_protocol()
808 sock = &peer_device->connection->data; in _drbd_send_uuids()
822 uuid_flags |= rcu_dereference(peer_device->connection->net_conf)->discard_my_data ? 1 : 0; in _drbd_send_uuids()
878 sock = &peer_device->connection->data; in drbd_gen_and_send_sync_uuid()
896 sock = &peer_device->connection->data; in drbd_send_sizes()
902 if (peer_device->connection->agreed_features & DRBD_FF_WSAME) in drbd_send_sizes()
945 if (peer_device->connection->agreed_pro_version <= 94) in drbd_send_sizes()
947 else if (peer_device->connection->agreed_pro_version < 100) in drbd_send_sizes()
972 sock = &peer_device->connection->data; in drbd_send_current_state()
995 sock = &peer_device->connection->data; in drbd_send_state()
1008 sock = &peer_device->connection->data; in drbd_send_state_req()
1017 int conn_send_state_req(struct drbd_connection *connection, union drbd_state mask, union drbd_state… in conn_send_state_req() argument
1023 cmd = connection->agreed_pro_version < 100 ? P_STATE_CHG_REQ : P_CONN_ST_CHG_REQ; in conn_send_state_req()
1024 sock = &connection->data; in conn_send_state_req()
1025 p = conn_prepare_command(connection, sock); in conn_send_state_req()
1030 return conn_send_command(connection, sock, cmd, sizeof(*p), NULL, 0); in conn_send_state_req()
1038 sock = &peer_device->connection->meta; in drbd_send_sr_reply()
1046 void conn_send_sr_reply(struct drbd_connection *connection, enum drbd_state_rv retcode) in conn_send_sr_reply() argument
1050 …enum drbd_packet cmd = connection->agreed_pro_version < 100 ? P_STATE_CHG_REPLY : P_CONN_ST_CHG_RE… in conn_send_sr_reply()
1052 sock = &connection->meta; in conn_send_sr_reply()
1053 p = conn_prepare_command(connection, sock); in conn_send_sr_reply()
1056 conn_send_command(connection, sock, cmd, sizeof(*p), NULL, 0); in conn_send_sr_reply()
1092 use_rle = rcu_dereference(first_peer_device(device)->connection->net_conf)->use_rle; in fill_bitmap_rle_bits()
1094 if (!use_rle || first_peer_device(device)->connection->agreed_pro_version < 90) in fill_bitmap_rle_bits()
1184 struct drbd_socket *sock = &peer_device->connection->data; in send_bitmap_rle_or_plain()
1185 unsigned int header_size = drbd_header_size(peer_device->connection); in send_bitmap_rle_or_plain()
1196 err = __send_command(peer_device->connection, device->vnr, sock, in send_bitmap_rle_or_plain()
1217 err = __send_command(peer_device->connection, device->vnr, sock, P_BITMAP, in send_bitmap_rle_or_plain()
1279 struct drbd_socket *sock = &peer_device->connection->data; in drbd_send_bitmap()
1289 void drbd_send_b_ack(struct drbd_connection *connection, u32 barrier_nr, u32 set_size) in drbd_send_b_ack() argument
1294 if (connection->cstate < C_WF_REPORT_PARAMS) in drbd_send_b_ack()
1297 sock = &connection->meta; in drbd_send_b_ack()
1298 p = conn_prepare_command(connection, sock); in drbd_send_b_ack()
1303 conn_send_command(connection, sock, P_BARRIER_ACK, sizeof(*p), NULL, 0); in drbd_send_b_ack()
1323 sock = &peer_device->connection->meta; in _drbd_send_ack()
1340 if (peer_device->connection->peer_integrity_tfm) in drbd_send_ack_dp()
1341 data_size -= crypto_shash_digestsize(peer_device->connection->peer_integrity_tfm); in drbd_send_ack_dp()
1384 sock = &peer_device->connection->data; in drbd_send_rs_deallocated()
1400 sock = &peer_device->connection->data; in drbd_send_drequest()
1418 sock = &peer_device->connection->data; in drbd_send_drequest_csum()
1433 sock = &peer_device->connection->data; in drbd_send_ov_request()
1445 * true if we think connection is dead
1447 static int we_should_drop_the_connection(struct drbd_connection *connection, struct socket *sock) in we_should_drop_the_connection() argument
1452 drop_it = connection->meta.socket == sock in we_should_drop_the_connection()
1453 || !connection->ack_receiver.task in we_should_drop_the_connection()
1454 || get_t_state(&connection->ack_receiver) != RUNNING in we_should_drop_the_connection()
1455 || connection->cstate < C_WF_REPORT_PARAMS; in we_should_drop_the_connection()
1460 drop_it = !--connection->ko_count; in we_should_drop_the_connection()
1462 drbd_err(connection, "[%s/%d] sock_sendmsg time expired, ko = %u\n", in we_should_drop_the_connection()
1463 current->comm, current->pid, connection->ko_count); in we_should_drop_the_connection()
1464 request_ping(connection); in we_should_drop_the_connection()
1470 static void drbd_update_congested(struct drbd_connection *connection) in drbd_update_congested() argument
1472 struct sock *sk = connection->data.socket->sk; in drbd_update_congested()
1474 set_bit(NET_CONGESTED, &connection->flags); in drbd_update_congested()
1505 socket = peer_device->connection->data.socket; in _drbd_no_send_page()
1507 err = drbd_send_all(peer_device->connection, socket, addr, size, msg_flags); in _drbd_no_send_page()
1517 struct socket *socket = peer_device->connection->data.socket; in _drbd_send_page()
1532 drbd_update_congested(peer_device->connection); in _drbd_send_page()
1542 if (we_should_drop_the_connection(peer_device->connection, socket)) in _drbd_send_page()
1555 clear_bit(NET_CONGESTED, &peer_device->connection->flags); in _drbd_send_page()
1627 static u32 bio_flags_to_wire(struct drbd_connection *connection, in bio_flags_to_wire() argument
1630 if (connection->agreed_pro_version >= 95) in bio_flags_to_wire()
1636 ((connection->agreed_features & DRBD_FF_WZEROES) ? in bio_flags_to_wire()
1657 sock = &peer_device->connection->data; in drbd_send_dblock()
1659 digest_size = peer_device->connection->integrity_tfm ? in drbd_send_dblock()
1660 crypto_shash_digestsize(peer_device->connection->integrity_tfm) : 0; in drbd_send_dblock()
1667 dp_flags = bio_flags_to_wire(peer_device->connection, req->master_bio); in drbd_send_dblock()
1671 if (peer_device->connection->agreed_pro_version >= 100) { in drbd_send_dblock()
1686 err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*t), NULL, 0); in drbd_send_dblock()
1694 drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, digest_out); in drbd_send_dblock()
1695 err = __send_command(peer_device->connection, device->vnr, sock, P_DATA, in drbd_send_dblock()
1719 drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, digest); in drbd_send_dblock()
1748 sock = &peer_device->connection->data; in drbd_send_block()
1751 digest_size = peer_device->connection->integrity_tfm ? in drbd_send_block()
1752 crypto_shash_digestsize(peer_device->connection->integrity_tfm) : 0; in drbd_send_block()
1761 drbd_csum_ee(peer_device->connection->integrity_tfm, peer_req, p + 1); in drbd_send_block()
1762 …err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*p) + digest_size, NU… in drbd_send_block()
1775 sock = &peer_device->connection->data; in drbd_send_out_of_sync()
1800 int drbd_send(struct drbd_connection *connection, struct socket *sock, in drbd_send() argument
1814 if (sock == connection->data.socket) { in drbd_send()
1816 connection->ko_count = rcu_dereference(connection->net_conf)->ko_count; in drbd_send()
1818 drbd_update_congested(connection); in drbd_send()
1823 if (we_should_drop_the_connection(connection, sock)) in drbd_send()
1837 if (sock == connection->data.socket) in drbd_send()
1838 clear_bit(NET_CONGESTED, &connection->flags); in drbd_send()
1842 drbd_err(connection, "%s_sendmsg returned %d\n", in drbd_send()
1843 sock == connection->meta.socket ? "msock" : "sock", in drbd_send()
1845 conn_request_state(connection, NS(conn, C_BROKEN_PIPE), CS_HARD); in drbd_send()
1847 conn_request_state(connection, NS(conn, C_TIMEOUT), CS_HARD); in drbd_send()
1858 int drbd_send_all(struct drbd_connection *connection, struct socket *sock, void *buffer, in drbd_send_all() argument
1863 err = drbd_send(connection, sock, buffer, size, msg_flags); in drbd_send_all()
1913 &first_peer_device(device)->connection->sender_work, in drbd_queue_unplug()
2003 if (first_peer_device(device)->connection->receiver.t_state != NONE) in drbd_device_cleanup()
2005 first_peer_device(device)->connection->receiver.t_state); in drbd_device_cleanup()
2023 D_ASSERT(device, first_peer_device(device)->connection->net_conf == NULL); in drbd_device_cleanup()
2042 D_ASSERT(device, list_empty(&first_peer_device(device)->connection->sender_work.q)); in drbd_device_cleanup()
2187 /* not for_each_connection(connection, resource): in drbd_destroy_device()
2191 kref_put(&peer_device->connection->kref, drbd_destroy_connection); in drbd_destroy_device()
2292 struct drbd_connection *connection, *tmp; in drbd_free_resource() local
2294 for_each_connection_safe(connection, tmp, resource) { in drbd_free_resource()
2295 list_del(&connection->connections); in drbd_free_resource()
2296 drbd_debugfs_connection_cleanup(connection); in drbd_free_resource()
2297 kref_put(&connection->kref, drbd_destroy_connection); in drbd_free_resource()
2399 struct drbd_connection *connection; in conn_get_by_addrs() local
2403 for_each_connection_rcu(connection, resource) { in conn_get_by_addrs()
2404 if (connection->my_addr_len == my_addr_len && in conn_get_by_addrs()
2405 connection->peer_addr_len == peer_addr_len && in conn_get_by_addrs()
2406 !memcmp(&connection->my_addr, my_addr, my_addr_len) && in conn_get_by_addrs()
2407 !memcmp(&connection->peer_addr, peer_addr, peer_addr_len)) { in conn_get_by_addrs()
2408 kref_get(&connection->kref); in conn_get_by_addrs()
2413 connection = NULL; in conn_get_by_addrs()
2416 return connection; in conn_get_by_addrs()
2436 void conn_free_crypto(struct drbd_connection *connection) in conn_free_crypto() argument
2438 drbd_free_sock(connection); in conn_free_crypto()
2440 crypto_free_shash(connection->csums_tfm); in conn_free_crypto()
2441 crypto_free_shash(connection->verify_tfm); in conn_free_crypto()
2442 crypto_free_shash(connection->cram_hmac_tfm); in conn_free_crypto()
2443 crypto_free_shash(connection->integrity_tfm); in conn_free_crypto()
2444 crypto_free_shash(connection->peer_integrity_tfm); in conn_free_crypto()
2445 kfree(connection->int_dig_in); in conn_free_crypto()
2446 kfree(connection->int_dig_vv); in conn_free_crypto()
2448 connection->csums_tfm = NULL; in conn_free_crypto()
2449 connection->verify_tfm = NULL; in conn_free_crypto()
2450 connection->cram_hmac_tfm = NULL; in conn_free_crypto()
2451 connection->integrity_tfm = NULL; in conn_free_crypto()
2452 connection->peer_integrity_tfm = NULL; in conn_free_crypto()
2453 connection->int_dig_in = NULL; in conn_free_crypto()
2454 connection->int_dig_vv = NULL; in conn_free_crypto()
2459 struct drbd_connection *connection; in set_resource_options() local
2495 for_each_connection_rcu(connection, resource) { in set_resource_options()
2496 connection->receiver.reset_cpu_mask = 1; in set_resource_options()
2497 connection->ack_receiver.reset_cpu_mask = 1; in set_resource_options()
2498 connection->worker.reset_cpu_mask = 1; in set_resource_options()
2544 struct drbd_connection *connection; in conn_create() local
2546 connection = kzalloc(sizeof(struct drbd_connection), GFP_KERNEL); in conn_create()
2547 if (!connection) in conn_create()
2550 if (drbd_alloc_socket(&connection->data)) in conn_create()
2552 if (drbd_alloc_socket(&connection->meta)) in conn_create()
2555 connection->current_epoch = kzalloc(sizeof(struct drbd_epoch), GFP_KERNEL); in conn_create()
2556 if (!connection->current_epoch) in conn_create()
2559 INIT_LIST_HEAD(&connection->transfer_log); in conn_create()
2561 INIT_LIST_HEAD(&connection->current_epoch->list); in conn_create()
2562 connection->epochs = 1; in conn_create()
2563 spin_lock_init(&connection->epoch_lock); in conn_create()
2565 connection->send.seen_any_write_yet = false; in conn_create()
2566 connection->send.current_epoch_nr = 0; in conn_create()
2567 connection->send.current_epoch_writes = 0; in conn_create()
2573 connection->cstate = C_STANDALONE; in conn_create()
2574 mutex_init(&connection->cstate_mutex); in conn_create()
2575 init_waitqueue_head(&connection->ping_wait); in conn_create()
2576 idr_init(&connection->peer_devices); in conn_create()
2578 drbd_init_workqueue(&connection->sender_work); in conn_create()
2579 mutex_init(&connection->data.mutex); in conn_create()
2580 mutex_init(&connection->meta.mutex); in conn_create()
2582 drbd_thread_init(resource, &connection->receiver, drbd_receiver, "receiver"); in conn_create()
2583 connection->receiver.connection = connection; in conn_create()
2584 drbd_thread_init(resource, &connection->worker, drbd_worker, "worker"); in conn_create()
2585 connection->worker.connection = connection; in conn_create()
2586 drbd_thread_init(resource, &connection->ack_receiver, drbd_ack_receiver, "ack_recv"); in conn_create()
2587 connection->ack_receiver.connection = connection; in conn_create()
2589 kref_init(&connection->kref); in conn_create()
2591 connection->resource = resource; in conn_create()
2597 list_add_tail_rcu(&connection->connections, &resource->connections); in conn_create()
2598 drbd_debugfs_connection_add(connection); in conn_create()
2599 return connection; in conn_create()
2605 kfree(connection->current_epoch); in conn_create()
2606 drbd_free_socket(&connection->meta); in conn_create()
2607 drbd_free_socket(&connection->data); in conn_create()
2608 kfree(connection); in conn_create()
2614 struct drbd_connection *connection = container_of(kref, struct drbd_connection, kref); in drbd_destroy_connection() local
2615 struct drbd_resource *resource = connection->resource; in drbd_destroy_connection()
2617 if (atomic_read(&connection->current_epoch->epoch_size) != 0) in drbd_destroy_connection()
2618 drbd_err(connection, "epoch_size:%d\n", atomic_read(&connection->current_epoch->epoch_size)); in drbd_destroy_connection()
2619 kfree(connection->current_epoch); in drbd_destroy_connection()
2621 idr_destroy(&connection->peer_devices); in drbd_destroy_connection()
2623 drbd_free_socket(&connection->meta); in drbd_destroy_connection()
2624 drbd_free_socket(&connection->data); in drbd_destroy_connection()
2625 kfree(connection->int_dig_in); in drbd_destroy_connection()
2626 kfree(connection->int_dig_vv); in drbd_destroy_connection()
2627 kfree(connection); in drbd_destroy_connection()
2648 struct drbd_connection *connection, *n; in drbd_create_device() local
2730 for_each_connection(connection, resource) { in drbd_create_device()
2734 peer_device->connection = connection; in drbd_create_device()
2740 id = idr_alloc(&connection->peer_devices, peer_device, vnr, vnr + 1, GFP_KERNEL); in drbd_create_device()
2746 kref_get(&connection->kref); in drbd_create_device()
2759 /* inherit the connection state */ in drbd_create_device()
2774 for_each_connection_safe(connection, n, resource) { in drbd_create_device()
2775 peer_device = idr_remove(&connection->peer_devices, vnr); in drbd_create_device()
2777 kref_put(&connection->kref, drbd_destroy_connection); in drbd_create_device()
2802 struct drbd_connection *connection; in drbd_delete_device() local
2809 for_each_connection(connection, resource) { in drbd_delete_device()
2810 idr_remove(&connection->peer_devices, device->vnr); in drbd_delete_device()
2907 void drbd_free_sock(struct drbd_connection *connection) in drbd_free_sock() argument
2909 if (connection->data.socket) in drbd_free_sock()
2910 drbd_free_one_sock(&connection->data); in drbd_free_sock()
2911 if (connection->meta.socket) in drbd_free_sock()
2912 drbd_free_one_sock(&connection->meta); in drbd_free_sock()
2917 void conn_md_sync(struct drbd_connection *connection) in conn_md_sync() argument
2923 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in conn_md_sync()
3481 D_ASSERT(device, current == peer_device->connection->worker.task); in drbd_queue_bitmap_io()
3502 drbd_queue_work(&peer_device->connection->sender_work, in drbd_queue_bitmap_io()
3528 D_ASSERT(device, current != first_peer_device(device)->connection->worker.task); in drbd_bitmap_io()
3657 nc = rcu_dereference(first_peer_device(device)->connection->net_conf); in drbd_wait_misc()