diff options
Diffstat (limited to 'net/tipc/socket.c')
-rw-r--r-- | net/tipc/socket.c | 42 |
1 files changed, 22 insertions, 20 deletions
diff --git a/net/tipc/socket.c b/net/tipc/socket.c index ddcb2a753aa6..1848693ebb82 100644 --- a/net/tipc/socket.c +++ b/net/tipc/socket.c | |||
@@ -63,6 +63,7 @@ | |||
63 | struct tipc_sock { | 63 | struct tipc_sock { |
64 | struct sock sk; | 64 | struct sock sk; |
65 | struct tipc_port *p; | 65 | struct tipc_port *p; |
66 | struct tipc_portid peer_name; | ||
66 | }; | 67 | }; |
67 | 68 | ||
68 | #define tipc_sk(sk) ((struct tipc_sock *)(sk)) | 69 | #define tipc_sk(sk) ((struct tipc_sock *)(sk)) |
@@ -377,27 +378,29 @@ static int bind(struct socket *sock, struct sockaddr *uaddr, int uaddr_len) | |||
377 | * @sock: socket structure | 378 | * @sock: socket structure |
378 | * @uaddr: area for returned socket address | 379 | * @uaddr: area for returned socket address |
379 | * @uaddr_len: area for returned length of socket address | 380 | * @uaddr_len: area for returned length of socket address |
380 | * @peer: 0 to obtain socket name, 1 to obtain peer socket name | 381 | * @peer: 0 = own ID, 1 = current peer ID, 2 = current/former peer ID |
381 | * | 382 | * |
382 | * Returns 0 on success, errno otherwise | 383 | * Returns 0 on success, errno otherwise |
383 | * | 384 | * |
384 | * NOTE: This routine doesn't need to take the socket lock since it doesn't | 385 | * NOTE: This routine doesn't need to take the socket lock since it only |
385 | * access any non-constant socket information. | 386 | * accesses socket information that is unchanging (or which changes in |
387 | * a completely predictable manner). | ||
386 | */ | 388 | */ |
387 | 389 | ||
388 | static int get_name(struct socket *sock, struct sockaddr *uaddr, | 390 | static int get_name(struct socket *sock, struct sockaddr *uaddr, |
389 | int *uaddr_len, int peer) | 391 | int *uaddr_len, int peer) |
390 | { | 392 | { |
391 | struct sockaddr_tipc *addr = (struct sockaddr_tipc *)uaddr; | 393 | struct sockaddr_tipc *addr = (struct sockaddr_tipc *)uaddr; |
392 | u32 portref = tipc_sk_port(sock->sk)->ref; | 394 | struct tipc_sock *tsock = tipc_sk(sock->sk); |
393 | u32 res; | ||
394 | 395 | ||
395 | if (peer) { | 396 | if (peer) { |
396 | res = tipc_peer(portref, &addr->addr.id); | 397 | if ((sock->state != SS_CONNECTED) && |
397 | if (res) | 398 | ((peer != 2) || (sock->state != SS_DISCONNECTING))) |
398 | return res; | 399 | return -ENOTCONN; |
400 | addr->addr.id.ref = tsock->peer_name.ref; | ||
401 | addr->addr.id.node = tsock->peer_name.node; | ||
399 | } else { | 402 | } else { |
400 | tipc_ownidentity(portref, &addr->addr.id); | 403 | tipc_ownidentity(tsock->p->ref, &addr->addr.id); |
401 | } | 404 | } |
402 | 405 | ||
403 | *uaddr_len = sizeof(*addr); | 406 | *uaddr_len = sizeof(*addr); |
@@ -766,18 +769,17 @@ exit: | |||
766 | 769 | ||
767 | static int auto_connect(struct socket *sock, struct tipc_msg *msg) | 770 | static int auto_connect(struct socket *sock, struct tipc_msg *msg) |
768 | { | 771 | { |
769 | struct tipc_port *tport = tipc_sk_port(sock->sk); | 772 | struct tipc_sock *tsock = tipc_sk(sock->sk); |
770 | struct tipc_portid peer; | ||
771 | 773 | ||
772 | if (msg_errcode(msg)) { | 774 | if (msg_errcode(msg)) { |
773 | sock->state = SS_DISCONNECTING; | 775 | sock->state = SS_DISCONNECTING; |
774 | return -ECONNREFUSED; | 776 | return -ECONNREFUSED; |
775 | } | 777 | } |
776 | 778 | ||
777 | peer.ref = msg_origport(msg); | 779 | tsock->peer_name.ref = msg_origport(msg); |
778 | peer.node = msg_orignode(msg); | 780 | tsock->peer_name.node = msg_orignode(msg); |
779 | tipc_connect2port(tport->ref, &peer); | 781 | tipc_connect2port(tsock->p->ref, &tsock->peer_name); |
780 | tipc_set_portimportance(tport->ref, msg_importance(msg)); | 782 | tipc_set_portimportance(tsock->p->ref, msg_importance(msg)); |
781 | sock->state = SS_CONNECTED; | 783 | sock->state = SS_CONNECTED; |
782 | return 0; | 784 | return 0; |
783 | } | 785 | } |
@@ -1529,9 +1531,9 @@ static int accept(struct socket *sock, struct socket *new_sock, int flags) | |||
1529 | res = tipc_create(sock_net(sock->sk), new_sock, 0); | 1531 | res = tipc_create(sock_net(sock->sk), new_sock, 0); |
1530 | if (!res) { | 1532 | if (!res) { |
1531 | struct sock *new_sk = new_sock->sk; | 1533 | struct sock *new_sk = new_sock->sk; |
1532 | struct tipc_port *new_tport = tipc_sk_port(new_sk); | 1534 | struct tipc_sock *new_tsock = tipc_sk(new_sk); |
1535 | struct tipc_port *new_tport = new_tsock->p; | ||
1533 | u32 new_ref = new_tport->ref; | 1536 | u32 new_ref = new_tport->ref; |
1534 | struct tipc_portid id; | ||
1535 | struct tipc_msg *msg = buf_msg(buf); | 1537 | struct tipc_msg *msg = buf_msg(buf); |
1536 | 1538 | ||
1537 | lock_sock(new_sk); | 1539 | lock_sock(new_sk); |
@@ -1545,9 +1547,9 @@ static int accept(struct socket *sock, struct socket *new_sock, int flags) | |||
1545 | 1547 | ||
1546 | /* Connect new socket to it's peer */ | 1548 | /* Connect new socket to it's peer */ |
1547 | 1549 | ||
1548 | id.ref = msg_origport(msg); | 1550 | new_tsock->peer_name.ref = msg_origport(msg); |
1549 | id.node = msg_orignode(msg); | 1551 | new_tsock->peer_name.node = msg_orignode(msg); |
1550 | tipc_connect2port(new_ref, &id); | 1552 | tipc_connect2port(new_ref, &new_tsock->peer_name); |
1551 | new_sock->state = SS_CONNECTED; | 1553 | new_sock->state = SS_CONNECTED; |
1552 | 1554 | ||
1553 | tipc_set_portimportance(new_ref, msg_importance(msg)); | 1555 | tipc_set_portimportance(new_ref, msg_importance(msg)); |