Skip to content

Commit

Permalink
VSOCK: Introduce vsock_auto_bind helper
Browse files Browse the repository at this point in the history
This peace of code is called three times, let's have a helper for it.

Signed-off-by: Asias He <asias@redhat.com>
Acked-by: Andy King <acking@vmware.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
  • Loading branch information
Asias He authored and David S. Miller committed Jun 24, 2013
1 parent b33698e commit b3a6dfe
Showing 1 changed file with 21 additions and 28 deletions.
49 changes: 21 additions & 28 deletions net/vmw_vsock/af_vsock.c
Original file line number Diff line number Diff line change
Expand Up @@ -165,6 +165,18 @@ static struct list_head vsock_bind_table[VSOCK_HASH_SIZE + 1];
static struct list_head vsock_connected_table[VSOCK_HASH_SIZE];
static DEFINE_SPINLOCK(vsock_table_lock);

/* Autobind this socket to the local address if necessary. */
static int vsock_auto_bind(struct vsock_sock *vsk)
{
struct sock *sk = sk_vsock(vsk);
struct sockaddr_vm local_addr;

if (vsock_addr_bound(&vsk->local_addr))
return 0;
vsock_addr_init(&local_addr, VMADDR_CID_ANY, VMADDR_PORT_ANY);
return __vsock_bind(sk, &local_addr);
}

static void vsock_init_tables(void)
{
int i;
Expand Down Expand Up @@ -956,15 +968,10 @@ static int vsock_dgram_sendmsg(struct kiocb *kiocb, struct socket *sock,

lock_sock(sk);

if (!vsock_addr_bound(&vsk->local_addr)) {
struct sockaddr_vm local_addr;

vsock_addr_init(&local_addr, VMADDR_CID_ANY, VMADDR_PORT_ANY);
err = __vsock_bind(sk, &local_addr);
if (err != 0)
goto out;
err = vsock_auto_bind(vsk);
if (err)
goto out;

}

/* If the provided message contains an address, use that. Otherwise
* fall back on the socket's remote handle (if it has been connected).
Expand Down Expand Up @@ -1038,15 +1045,9 @@ static int vsock_dgram_connect(struct socket *sock,

lock_sock(sk);

if (!vsock_addr_bound(&vsk->local_addr)) {
struct sockaddr_vm local_addr;

vsock_addr_init(&local_addr, VMADDR_CID_ANY, VMADDR_PORT_ANY);
err = __vsock_bind(sk, &local_addr);
if (err != 0)
goto out;

}
err = vsock_auto_bind(vsk);
if (err)
goto out;

if (!transport->dgram_allow(remote_addr->svm_cid,
remote_addr->svm_port)) {
Expand Down Expand Up @@ -1163,17 +1164,9 @@ static int vsock_stream_connect(struct socket *sock, struct sockaddr *addr,
memcpy(&vsk->remote_addr, remote_addr,
sizeof(vsk->remote_addr));

/* Autobind this socket to the local address if necessary. */
if (!vsock_addr_bound(&vsk->local_addr)) {
struct sockaddr_vm local_addr;

vsock_addr_init(&local_addr, VMADDR_CID_ANY,
VMADDR_PORT_ANY);
err = __vsock_bind(sk, &local_addr);
if (err != 0)
goto out;

}
err = vsock_auto_bind(vsk);
if (err)
goto out;

sk->sk_state = SS_CONNECTING;

Expand Down

0 comments on commit b3a6dfe

Please sign in to comment.