Commit b9ca2f5f authored by Stefano Garzarella's avatar Stefano Garzarella Committed by David S. Miller

vsock: add vsock_create_connected() called by transports

All transports call __vsock_create() with the same parameters,
most of them depending on the parent socket. In order to simplify
the VSOCK core APIs exposed to the transports, this patch adds
the vsock_create_connected() callable from transports to create
a new socket when a connection request is received.
We also unexported the __vsock_create().
Suggested-by: default avatarStefan Hajnoczi <stefanha@redhat.com>
Reviewed-by: default avatarStefan Hajnoczi <stefanha@redhat.com>
Reviewed-by: default avatarJorgen Hansen <jhansen@vmware.com>
Signed-off-by: default avatarStefano Garzarella <sgarzare@redhat.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent b9f2b0ff
...@@ -76,10 +76,7 @@ struct vsock_sock { ...@@ -76,10 +76,7 @@ struct vsock_sock {
s64 vsock_stream_has_data(struct vsock_sock *vsk); s64 vsock_stream_has_data(struct vsock_sock *vsk);
s64 vsock_stream_has_space(struct vsock_sock *vsk); s64 vsock_stream_has_space(struct vsock_sock *vsk);
struct sock *__vsock_create(struct net *net, struct sock *vsock_create_connected(struct sock *parent);
struct socket *sock,
struct sock *parent,
gfp_t priority, unsigned short type, int kern);
/**** TRANSPORT ****/ /**** TRANSPORT ****/
......
...@@ -567,12 +567,12 @@ static int __vsock_bind(struct sock *sk, struct sockaddr_vm *addr) ...@@ -567,12 +567,12 @@ static int __vsock_bind(struct sock *sk, struct sockaddr_vm *addr)
static void vsock_connect_timeout(struct work_struct *work); static void vsock_connect_timeout(struct work_struct *work);
struct sock *__vsock_create(struct net *net, static struct sock *__vsock_create(struct net *net,
struct socket *sock, struct socket *sock,
struct sock *parent, struct sock *parent,
gfp_t priority, gfp_t priority,
unsigned short type, unsigned short type,
int kern) int kern)
{ {
struct sock *sk; struct sock *sk;
struct vsock_sock *psk; struct vsock_sock *psk;
...@@ -639,7 +639,6 @@ struct sock *__vsock_create(struct net *net, ...@@ -639,7 +639,6 @@ struct sock *__vsock_create(struct net *net,
return sk; return sk;
} }
EXPORT_SYMBOL_GPL(__vsock_create);
static void __vsock_release(struct sock *sk, int level) static void __vsock_release(struct sock *sk, int level)
{ {
...@@ -703,6 +702,13 @@ static int vsock_queue_rcv_skb(struct sock *sk, struct sk_buff *skb) ...@@ -703,6 +702,13 @@ static int vsock_queue_rcv_skb(struct sock *sk, struct sk_buff *skb)
return err; return err;
} }
struct sock *vsock_create_connected(struct sock *parent)
{
return __vsock_create(sock_net(parent), NULL, parent, GFP_KERNEL,
parent->sk_type, 0);
}
EXPORT_SYMBOL_GPL(vsock_create_connected);
s64 vsock_stream_has_data(struct vsock_sock *vsk) s64 vsock_stream_has_data(struct vsock_sock *vsk)
{ {
return vsk->transport->stream_has_data(vsk); return vsk->transport->stream_has_data(vsk);
......
...@@ -360,8 +360,7 @@ static void hvs_open_connection(struct vmbus_channel *chan) ...@@ -360,8 +360,7 @@ static void hvs_open_connection(struct vmbus_channel *chan)
if (sk->sk_ack_backlog >= sk->sk_max_ack_backlog) if (sk->sk_ack_backlog >= sk->sk_max_ack_backlog)
goto out; goto out;
new = __vsock_create(sock_net(sk), NULL, sk, GFP_KERNEL, new = vsock_create_connected(sk);
sk->sk_type, 0);
if (!new) if (!new)
goto out; goto out;
......
...@@ -1004,8 +1004,7 @@ virtio_transport_recv_listen(struct sock *sk, struct virtio_vsock_pkt *pkt) ...@@ -1004,8 +1004,7 @@ virtio_transport_recv_listen(struct sock *sk, struct virtio_vsock_pkt *pkt)
return -ENOMEM; return -ENOMEM;
} }
child = __vsock_create(sock_net(sk), NULL, sk, GFP_KERNEL, child = vsock_create_connected(sk);
sk->sk_type, 0);
if (!child) { if (!child) {
virtio_transport_reset(vsk, pkt); virtio_transport_reset(vsk, pkt);
return -ENOMEM; return -ENOMEM;
......
...@@ -1004,8 +1004,7 @@ static int vmci_transport_recv_listen(struct sock *sk, ...@@ -1004,8 +1004,7 @@ static int vmci_transport_recv_listen(struct sock *sk,
return -ECONNREFUSED; return -ECONNREFUSED;
} }
pending = __vsock_create(sock_net(sk), NULL, sk, GFP_KERNEL, pending = vsock_create_connected(sk);
sk->sk_type, 0);
if (!pending) { if (!pending) {
vmci_transport_send_reset(sk, pkt); vmci_transport_send_reset(sk, pkt);
return -ENOMEM; return -ENOMEM;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment