Lines Matching defs:sock
13 #include <net/sock.h>
17 #include <trace/events/sock.h>
58 struct socket *sock;
71 void (*saved_data_ready)(struct sock *sk);
78 struct socket *sock;
84 void (*saved_data_ready)(struct sock *sk);
117 spin_lock_irqsave(&map->sock->sk->sk_receive_queue.lock, flags);
118 if (skb_queue_empty(&map->sock->sk->sk_receive_queue)) {
120 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock,
124 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, flags);
143 ret = inet_recvmsg(map->sock, &msg, wanted, MSG_DONTWAIT);
149 spin_lock_irqsave(&map->sock->sk->sk_receive_queue.lock, flags);
150 if (ret > 0 && !skb_queue_empty(&map->sock->sk->sk_receive_queue))
152 spin_unlock_irqrestore(&map->sock->sk->sk_receive_queue.lock, flags);
203 ret = inet_sendmsg(map->sock, &msg, size);
289 static void pvcalls_sk_state_change(struct sock *sock)
291 struct sock_mapping *map = sock->sk_user_data;
300 static void pvcalls_sk_data_ready(struct sock *sock)
302 struct sock_mapping *map = sock->sk_user_data;
305 trace_sk_data_ready(sock);
321 struct socket *sock)
329 sock_release(sock);
334 map->sock = sock;
376 write_lock_bh(&map->sock->sk->sk_callback_lock);
377 map->saved_data_ready = map->sock->sk->sk_data_ready;
378 map->sock->sk->sk_user_data = map;
379 map->sock->sk->sk_data_ready = pvcalls_sk_data_ready;
380 map->sock->sk->sk_state_change = pvcalls_sk_state_change;
381 write_unlock_bh(&map->sock->sk->sk_callback_lock);
397 struct socket *sock;
409 ret = sock_create(AF_INET, SOCK_STREAM, 0, &sock);
412 ret = inet_stream_connect(sock, sa, req->u.connect.len, 0);
414 sock_release(sock);
422 sock);
441 if (map->sock->sk != NULL) {
442 write_lock_bh(&map->sock->sk->sk_callback_lock);
443 map->sock->sk->sk_user_data = NULL;
444 map->sock->sk->sk_data_ready = map->saved_data_ready;
445 write_unlock_bh(&map->sock->sk->sk_callback_lock);
455 sock_release(map->sock);
465 if (mappass->sock->sk != NULL) {
466 write_lock_bh(&mappass->sock->sk->sk_callback_lock);
467 mappass->sock->sk->sk_user_data = NULL;
468 mappass->sock->sk->sk_data_ready = mappass->saved_data_ready;
469 write_unlock_bh(&mappass->sock->sk->sk_callback_lock);
471 sock_release(mappass->sock);
523 struct socket *sock;
545 sock = sock_alloc();
546 if (sock == NULL)
548 sock->type = mappass->sock->type;
549 sock->ops = mappass->sock->ops;
551 ret = inet_accept(mappass->sock, sock, O_NONBLOCK, true);
553 sock_release(sock);
561 sock);
586 static void pvcalls_pass_sk_data_ready(struct sock *sock)
588 struct sockpass_mapping *mappass = sock->sk_user_data;
594 trace_sk_data_ready(sock);
645 ret = sock_create(AF_INET, SOCK_STREAM, 0, &map->sock);
649 ret = inet_bind(map->sock, (struct sockaddr *)&req->u.bind.addr,
664 write_lock_bh(&map->sock->sk->sk_callback_lock);
665 map->saved_data_ready = map->sock->sk->sk_data_ready;
666 map->sock->sk->sk_user_data = map;
667 map->sock->sk->sk_data_ready = pvcalls_pass_sk_data_ready;
668 write_unlock_bh(&map->sock->sk->sk_callback_lock);
672 if (map && map->sock)
673 sock_release(map->sock);
702 ret = inet_listen(map->sock, req->u.listen.backlog);
790 icsk = inet_csk(mappass->sock->sk);
910 if (map == NULL || map->sock == NULL || map->sock->sk == NULL ||
911 map->sock->sk->sk_user_data != map) {