Lines Matching defs:sock
24 #include <net/sock.h>
607 struct drbd_socket *sock)
609 if (!sock->socket)
611 return sock->sbuf + drbd_header_size(connection);
614 void *conn_prepare_command(struct drbd_connection *connection, struct drbd_socket *sock)
618 mutex_lock(&sock->mutex);
619 p = __conn_prepare_command(connection, sock);
621 mutex_unlock(&sock->mutex);
626 void *drbd_prepare_command(struct drbd_peer_device *peer_device, struct drbd_socket *sock)
628 return conn_prepare_command(peer_device->connection, sock);
632 struct drbd_socket *sock, enum drbd_packet cmd,
648 header_size += prepare_header(connection, vnr, sock->sbuf, cmd,
650 err = drbd_send_all(connection, sock->socket, sock->sbuf, header_size,
653 err = drbd_send_all(connection, sock->socket, data, size, 0);
657 tcp_sock_set_nodelay(sock->socket->sk);
662 static int __conn_send_command(struct drbd_connection *connection, struct drbd_socket *sock,
666 return __send_command(connection, 0, sock, cmd, header_size, data, size);
669 int conn_send_command(struct drbd_connection *connection, struct drbd_socket *sock,
675 err = __conn_send_command(connection, sock, cmd, header_size, data, size);
676 mutex_unlock(&sock->mutex);
680 int drbd_send_command(struct drbd_peer_device *peer_device, struct drbd_socket *sock,
687 sock, cmd, header_size, data, size);
688 mutex_unlock(&sock->mutex);
694 struct drbd_socket *sock;
696 sock = &connection->meta;
697 if (!conn_prepare_command(connection, sock))
699 return conn_send_command(connection, sock, P_PING, 0, NULL, 0);
704 struct drbd_socket *sock;
706 sock = &connection->meta;
707 if (!conn_prepare_command(connection, sock))
709 return conn_send_command(connection, sock, P_PING_ACK, 0, NULL, 0);
714 struct drbd_socket *sock;
722 sock = &peer_device->connection->data;
723 p = drbd_prepare_command(peer_device, sock);
764 return drbd_send_command(peer_device, sock, cmd, size, NULL, 0);
769 struct drbd_socket *sock;
774 sock = &connection->data;
775 p = __conn_prepare_command(connection, sock);
808 return __conn_send_command(connection, sock, cmd, size, NULL, 0);
825 struct drbd_socket *sock;
832 sock = &peer_device->connection->data;
833 p = drbd_prepare_command(peer_device, sock);
853 return drbd_send_command(peer_device, sock, P_UUIDS, sizeof(*p), NULL, 0);
887 struct drbd_socket *sock;
902 sock = &peer_device->connection->data;
903 p = drbd_prepare_command(peer_device, sock);
906 drbd_send_command(peer_device, sock, P_SYNC_UUID, sizeof(*p), NULL, 0);
913 struct drbd_socket *sock;
920 sock = &peer_device->connection->data;
921 p = drbd_prepare_command(peer_device, sock);
984 return drbd_send_command(peer_device, sock, P_SIZES, packet_size, NULL, 0);
993 struct drbd_socket *sock;
996 sock = &peer_device->connection->data;
997 p = drbd_prepare_command(peer_device, sock);
1001 return drbd_send_command(peer_device, sock, P_STATE, sizeof(*p), NULL, 0);
1016 struct drbd_socket *sock;
1019 sock = &peer_device->connection->data;
1020 p = drbd_prepare_command(peer_device, sock);
1024 return drbd_send_command(peer_device, sock, P_STATE, sizeof(*p), NULL, 0);
1029 struct drbd_socket *sock;
1032 sock = &peer_device->connection->data;
1033 p = drbd_prepare_command(peer_device, sock);
1038 return drbd_send_command(peer_device, sock, P_STATE_CHG_REQ, sizeof(*p), NULL, 0);
1044 struct drbd_socket *sock;
1048 sock = &connection->data;
1049 p = conn_prepare_command(connection, sock);
1054 return conn_send_command(connection, sock, cmd, sizeof(*p), NULL, 0);
1059 struct drbd_socket *sock;
1062 sock = &peer_device->connection->meta;
1063 p = drbd_prepare_command(peer_device, sock);
1066 drbd_send_command(peer_device, sock, P_STATE_CHG_REPLY, sizeof(*p), NULL, 0);
1072 struct drbd_socket *sock;
1076 sock = &connection->meta;
1077 p = conn_prepare_command(connection, sock);
1080 conn_send_command(connection, sock, cmd, sizeof(*p), NULL, 0);
1208 struct drbd_socket *sock = &peer_device->connection->data;
1210 struct p_compressed_bm *p = sock->sbuf + header_size;
1220 err = __send_command(peer_device->connection, device->vnr, sock,
1233 unsigned long *p = sock->sbuf + header_size;
1241 err = __send_command(peer_device->connection, device->vnr, sock, P_BITMAP,
1303 struct drbd_socket *sock = &peer_device->connection->data;
1306 mutex_lock(&sock->mutex);
1307 if (sock->socket)
1309 mutex_unlock(&sock->mutex);
1315 struct drbd_socket *sock;
1321 sock = &connection->meta;
1322 p = conn_prepare_command(connection, sock);
1327 conn_send_command(connection, sock, P_BARRIER_ACK, sizeof(*p), NULL, 0);
1341 struct drbd_socket *sock;
1347 sock = &peer_device->connection->meta;
1348 p = drbd_prepare_command(peer_device, sock);
1355 return drbd_send_command(peer_device, sock, cmd, sizeof(*p), NULL, 0);
1405 struct drbd_socket *sock;
1408 sock = &peer_device->connection->data;
1409 p = drbd_prepare_command(peer_device, sock);
1415 return drbd_send_command(peer_device, sock, P_RS_DEALLOCATED, sizeof(*p), NULL, 0);
1421 struct drbd_socket *sock;
1424 sock = &peer_device->connection->data;
1425 p = drbd_prepare_command(peer_device, sock);
1431 return drbd_send_command(peer_device, sock, cmd, sizeof(*p), NULL, 0);
1437 struct drbd_socket *sock;
1442 sock = &peer_device->connection->data;
1443 p = drbd_prepare_command(peer_device, sock);
1449 return drbd_send_command(peer_device, sock, cmd, sizeof(*p), digest, digest_size);
1454 struct drbd_socket *sock;
1457 sock = &peer_device->connection->data;
1458 p = drbd_prepare_command(peer_device, sock);
1464 return drbd_send_command(peer_device, sock, P_OV_REQUEST, sizeof(*p), NULL, 0);
1471 static int we_should_drop_the_connection(struct drbd_connection *connection, struct socket *sock)
1476 drop_it = connection->meta.socket == sock
1496 struct sock *sk = connection->data.socket->sk;
1668 struct drbd_socket *sock;
1675 sock = &peer_device->connection->data;
1676 p = drbd_prepare_command(peer_device, sock);
1704 err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*t), NULL, 0);
1713 err = __send_command(peer_device->connection, device->vnr, sock, P_DATA,
1748 mutex_unlock(&sock->mutex); /* locked by drbd_prepare_command() */
1761 struct drbd_socket *sock;
1766 sock = &peer_device->connection->data;
1767 p = drbd_prepare_command(peer_device, sock);
1780 err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*p) + digest_size, NULL, peer_req->i.size);
1783 mutex_unlock(&sock->mutex); /* locked by drbd_prepare_command() */
1790 struct drbd_socket *sock;
1793 sock = &peer_device->connection->data;
1794 p = drbd_prepare_command(peer_device, sock);
1799 return drbd_send_command(peer_device, sock, P_OUT_OF_SYNC, sizeof(*p), NULL, 0);
1805 Packets sent via the data socket "sock"
1808 sock msock
1818 int drbd_send(struct drbd_connection *connection, struct socket *sock,
1825 if (!sock)
1832 if (sock == connection->data.socket) {
1839 rv = sock_sendmsg(sock, &msg);
1841 if (we_should_drop_the_connection(connection, sock))
1855 if (sock == connection->data.socket)
1861 sock == connection->meta.socket ? "msock" : "sock",
1876 int drbd_send_all(struct drbd_connection *connection, struct socket *sock, void *buffer,
1881 err = drbd_send(connection, sock, buffer, size, msg_flags);