Lines Matching +full:imp +full:- +full:res +full:- +full:offset +full:- +full:value
4 * Copyright (c) 2001-2007, 2012-2017, Ericsson AB
5 * Copyright (c) 2004-2008, 2010-2013, Wind River Systems
71 * struct tipc_sock - TIPC socket structure
72 * @sk: socket - interacts with 'port' and with user via the socket API
75 * @published: non-zero if port has one or more associated names
149 return msg_prevnode(&tsk->phdr); in tsk_own_node()
154 return msg_destnode(&tsk->phdr); in tsk_peer_node()
159 return msg_destport(&tsk->phdr); in tsk_peer_port()
164 return msg_src_droppable(&tsk->phdr) != 0; in tsk_unreliable()
169 msg_set_src_droppable(&tsk->phdr, unreliable ? 1 : 0); in tsk_set_unreliable()
174 return msg_dest_droppable(&tsk->phdr) != 0; in tsk_unreturnable()
179 msg_set_dest_droppable(&tsk->phdr, unreturnable ? 1 : 0); in tsk_set_unreturnable()
184 return msg_importance(&tsk->phdr); in tsk_importance()
187 static int tsk_set_importance(struct tipc_sock *tsk, int imp) in tsk_set_importance() argument
189 if (imp > TIPC_CRITICAL_IMPORTANCE) in tsk_set_importance()
190 return -EINVAL; in tsk_set_importance()
191 msg_set_importance(&tsk->phdr, (u32)imp); in tsk_set_importance()
202 return tsk->snt_unacked > tsk->snd_win; in tsk_conn_cong()
220 * - If block based flow control is not supported by peer we
225 if (likely(tsk->peer_caps & TIPC_BLOCK_FLOWCTL)) in tsk_inc()
231 * tsk_advance_rx_queue - discard first buffer in socket receive queue
237 kfree_skb(__skb_dequeue(&sk->sk_receive_queue)); in tsk_advance_rx_queue()
257 * tsk_rej_rx_queue - reject all buffers in socket receive queue
265 while ((skb = __skb_dequeue(&sk->sk_receive_queue))) in tsk_rej_rx_queue()
271 return sk->sk_state == TIPC_ESTABLISHED; in tipc_sk_connected()
274 /* tipc_sk_type_connectionless - check if the socket is datagram socket
281 return sk->sk_type == SOCK_RDM || sk->sk_type == SOCK_DGRAM; in tipc_sk_type_connectionless()
284 /* tsk_peer_msg - verify if message was sent by connected port's peer
291 struct sock *sk = &tsk->sk; in tsk_peer_msg()
317 /* tipc_set_sk_state - set the sk_state of the socket
326 int oldsk_state = sk->sk_state; in tipc_set_sk_state()
327 int res = -EINVAL; in tipc_set_sk_state() local
331 res = 0; in tipc_set_sk_state()
336 res = 0; in tipc_set_sk_state()
341 res = 0; in tipc_set_sk_state()
346 res = 0; in tipc_set_sk_state()
350 if (!res) in tipc_set_sk_state()
351 sk->sk_state = state; in tipc_set_sk_state()
353 return res; in tipc_set_sk_state()
358 struct sock *sk = sock->sk; in tipc_sk_sock_err()
360 int typ = sock->type; in tipc_sk_sock_err()
365 if (sk->sk_state == TIPC_DISCONNECTING) in tipc_sk_sock_err()
366 return -EPIPE; in tipc_sk_sock_err()
368 return -ENOTCONN; in tipc_sk_sock_err()
371 return -EAGAIN; in tipc_sk_sock_err()
387 sk_ = (sock_)->sk; \
402 * tipc_sk_create - create a TIPC socket
404 * @sock: pre-allocated socket structure
423 return -EPROTONOSUPPORT; in tipc_sk_create()
425 switch (sock->type) { in tipc_sk_create()
437 return -EPROTOTYPE; in tipc_sk_create()
443 return -ENOMEM; in tipc_sk_create()
446 tsk->max_pkt = MAX_PKT_DEFAULT; in tipc_sk_create()
447 INIT_LIST_HEAD(&tsk->publications); in tipc_sk_create()
448 INIT_LIST_HEAD(&tsk->cong_links); in tipc_sk_create()
449 msg = &tsk->phdr; in tipc_sk_create()
452 sock->ops = ops; in tipc_sk_create()
457 return -EINVAL; in tipc_sk_create()
466 msg_set_origport(msg, tsk->portid); in tipc_sk_create()
467 timer_setup(&sk->sk_timer, tipc_sk_timeout, 0); in tipc_sk_create()
468 sk->sk_shutdown = 0; in tipc_sk_create()
469 sk->sk_backlog_rcv = tipc_sk_backlog_rcv; in tipc_sk_create()
470 sk->sk_rcvbuf = sysctl_tipc_rmem[1]; in tipc_sk_create()
471 sk->sk_data_ready = tipc_data_ready; in tipc_sk_create()
472 sk->sk_write_space = tipc_write_space; in tipc_sk_create()
473 sk->sk_destruct = tipc_sock_destruct; in tipc_sk_create()
474 tsk->conn_timeout = CONN_TIMEOUT_DEFAULT; in tipc_sk_create()
475 tsk->group_is_open = true; in tipc_sk_create()
476 atomic_set(&tsk->dupl_rcvcnt, 0); in tipc_sk_create()
479 tsk->snd_win = tsk_adv_blocks(RCVBUF_MIN); in tipc_sk_create()
480 tsk->rcv_win = tsk->snd_win; in tipc_sk_create()
484 if (sock->type == SOCK_DGRAM) in tipc_sk_create()
495 sock_put(&tsk->sk); in tipc_sk_callback()
501 struct sock *sk = sock->sk; in __tipc_shutdown()
508 /* Avoid that hi-prio shutdown msgs bypass msgs in link wakeup queue */ in __tipc_shutdown()
509 tipc_wait_for_cond(sock, &timeout, (!tsk->cong_link_cnt && in __tipc_shutdown()
515 while ((skb = __skb_dequeue(&sk->sk_receive_queue)) != NULL) { in __tipc_shutdown()
516 if (TIPC_SKB_CB(skb)->bytes_read) { in __tipc_shutdown()
521 sk->sk_state != TIPC_DISCONNECTING) { in __tipc_shutdown()
523 tipc_node_remove_conn(net, dnode, tsk->portid); in __tipc_shutdown()
531 if (sk->sk_state != TIPC_DISCONNECTING) { in __tipc_shutdown()
535 tsk->portid, error); in __tipc_shutdown()
537 tipc_node_xmit_skb(net, skb, dnode, tsk->portid); in __tipc_shutdown()
538 tipc_node_remove_conn(net, dnode, tsk->portid); in __tipc_shutdown()
544 * tipc_release - destroy a TIPC socket
551 * is partially-read, it is discarded and the next one is rejected instead.)
561 struct sock *sk = sock->sk; in tipc_release()
566 * releases a pre-allocated child socket that was never used) in tipc_release()
575 sk->sk_shutdown = SHUTDOWN_MASK; in tipc_release()
578 sk_stop_timer(sk, &sk->sk_timer); in tipc_release()
584 tipc_dest_list_purge(&tsk->cong_links); in tipc_release()
585 tsk->cong_link_cnt = 0; in tipc_release()
586 call_rcu(&tsk->rcu, tipc_sk_callback); in tipc_release()
587 sock->sk = NULL; in tipc_release()
593 * tipc_bind - associate or disassocate TIPC name(s) with a socket
598 * Name and name sequence binding is indicated using a positive scope value;
599 * a negative scope value unbinds the specified name. Specifying no name
605 * access any non-constant socket information.
610 struct sock *sk = sock->sk; in tipc_bind()
613 int res = -EINVAL; in tipc_bind() local
617 res = tipc_sk_withdraw(tsk, 0, NULL); in tipc_bind()
620 if (tsk->group) { in tipc_bind()
621 res = -EACCES; in tipc_bind()
625 res = -EINVAL; in tipc_bind()
628 if (addr->family != AF_TIPC) { in tipc_bind()
629 res = -EAFNOSUPPORT; in tipc_bind()
633 if (addr->addrtype == TIPC_ADDR_NAME) in tipc_bind()
634 addr->addr.nameseq.upper = addr->addr.nameseq.lower; in tipc_bind()
635 else if (addr->addrtype != TIPC_ADDR_NAMESEQ) { in tipc_bind()
636 res = -EAFNOSUPPORT; in tipc_bind()
640 if ((addr->addr.nameseq.type < TIPC_RESERVED_TYPES) && in tipc_bind()
641 (addr->addr.nameseq.type != TIPC_TOP_SRV) && in tipc_bind()
642 (addr->addr.nameseq.type != TIPC_CFG_SRV)) { in tipc_bind()
643 res = -EACCES; in tipc_bind()
647 res = (addr->scope >= 0) ? in tipc_bind()
648 tipc_sk_publish(tsk, addr->scope, &addr->addr.nameseq) : in tipc_bind()
649 tipc_sk_withdraw(tsk, -addr->scope, &addr->addr.nameseq); in tipc_bind()
652 return res; in tipc_bind()
656 * tipc_getname - get port ID of socket or peer socket
672 struct sock *sk = sock->sk; in tipc_getname()
678 ((peer != 2) || (sk->sk_state != TIPC_DISCONNECTING))) in tipc_getname()
679 return -ENOTCONN; in tipc_getname()
680 addr->addr.id.ref = tsk_peer_port(tsk); in tipc_getname()
681 addr->addr.id.node = tsk_peer_node(tsk); in tipc_getname()
683 addr->addr.id.ref = tsk->portid; in tipc_getname()
684 addr->addr.id.node = tipc_own_addr(sock_net(sk)); in tipc_getname()
687 addr->addrtype = TIPC_ADDR_ID; in tipc_getname()
688 addr->family = AF_TIPC; in tipc_getname()
689 addr->scope = 0; in tipc_getname()
690 addr->addr.name.domain = 0; in tipc_getname()
696 * tipc_poll - read and possibly block on pollmask
701 * Returns pollmask value
705 * since the pollmask info is potentially out-of-date the moment this routine
716 struct sock *sk = sock->sk; in tipc_poll()
722 if (sk->sk_shutdown & RCV_SHUTDOWN) in tipc_poll()
724 if (sk->sk_shutdown == SHUTDOWN_MASK) in tipc_poll()
727 switch (sk->sk_state) { in tipc_poll()
729 if (!tsk->cong_link_cnt && !tsk_conn_cong(tsk)) in tipc_poll()
734 if (!skb_queue_empty_lockless(&sk->sk_receive_queue)) in tipc_poll()
738 if (tsk->group_is_open && !tsk->cong_link_cnt) in tipc_poll()
742 if (skb_queue_empty_lockless(&sk->sk_receive_queue)) in tipc_poll()
754 * tipc_sendmcast - send multicast message
767 struct sock *sk = sock->sk; in tipc_sendmcast()
769 struct tipc_msg *hdr = &tsk->phdr; in tipc_sendmcast()
772 struct tipc_mc_method *method = &tsk->mc_method; in tipc_sendmcast()
777 if (tsk->group) in tipc_sendmcast()
778 return -EACCES; in tipc_sendmcast()
781 rc = tipc_wait_for_cond(sock, &timeout, !tsk->cong_link_cnt); in tipc_sendmcast()
787 tipc_nametbl_lookup_dst_nodes(net, seq->type, seq->lower, in tipc_sendmcast()
788 seq->upper, &dsts); in tipc_sendmcast()
790 return -EHOSTUNREACH; in tipc_sendmcast()
798 msg_set_nametype(hdr, seq->type); in tipc_sendmcast()
799 msg_set_namelower(hdr, seq->lower); in tipc_sendmcast()
800 msg_set_nameupper(hdr, seq->upper); in tipc_sendmcast()
809 &tsk->cong_link_cnt); in tipc_sendmcast()
817 * tipc_send_group_msg - send a message to a member in the group
829 u16 bc_snd_nxt = tipc_group_bc_snd_nxt(tsk->group); in tipc_send_group_msg()
830 struct tipc_mc_method *method = &tsk->mc_method; in tipc_send_group_msg()
832 struct tipc_msg *hdr = &tsk->phdr; in tipc_send_group_msg()
845 mtu = tipc_node_get_mtu(net, dnode, tsk->portid); in tipc_send_group_msg()
851 rc = tipc_node_xmit(net, &pkts, dnode, tsk->portid); in tipc_send_group_msg()
852 if (unlikely(rc == -ELINKCONG)) { in tipc_send_group_msg()
853 tipc_dest_push(&tsk->cong_links, dnode, 0); in tipc_send_group_msg()
854 tsk->cong_link_cnt++; in tipc_send_group_msg()
861 method->rcast = true; in tipc_send_group_msg()
862 method->mandatory = true; in tipc_send_group_msg()
867 * tipc_send_group_unicast - send message to a member in the group
879 struct sock *sk = sock->sk; in tipc_send_group_unicast()
880 DECLARE_SOCKADDR(struct sockaddr_tipc *, dest, m->msg_name); in tipc_send_group_unicast()
888 node = dest->addr.id.node; in tipc_send_group_unicast()
889 port = dest->addr.id.ref; in tipc_send_group_unicast()
891 return -EHOSTUNREACH; in tipc_send_group_unicast()
895 !tipc_dest_find(&tsk->cong_links, node, 0) && in tipc_send_group_unicast()
896 tsk->group && in tipc_send_group_unicast()
897 !tipc_group_cong(tsk->group, node, port, blks, in tipc_send_group_unicast()
903 return -EHOSTUNREACH; in tipc_send_group_unicast()
911 * tipc_send_group_anycast - send message to any member with given identity
923 DECLARE_SOCKADDR(struct sockaddr_tipc *, dest, m->msg_name); in tipc_send_group_anycast()
924 struct sock *sk = sock->sk; in tipc_send_group_anycast()
926 struct list_head *cong_links = &tsk->cong_links; in tipc_send_group_anycast()
928 struct tipc_msg *hdr = &tsk->phdr; in tipc_send_group_anycast()
942 inst = dest->addr.name.name.instance; in tipc_send_group_anycast()
946 exclude = tipc_group_exclude(tsk->group); in tipc_send_group_anycast()
950 /* Look for a non-congested destination member, if any */ in tipc_send_group_anycast()
954 return -EHOSTUNREACH; in tipc_send_group_anycast()
956 cong = tipc_group_cong(tsk->group, node, port, blks, in tipc_send_group_anycast()
976 tsk->group && in tipc_send_group_anycast()
977 !tipc_group_cong(tsk->group, node, port, in tipc_send_group_anycast()
988 return -EHOSTUNREACH; in tipc_send_group_anycast()
996 * tipc_send_group_bcast - send message to all members in communication group
1008 DECLARE_SOCKADDR(struct sockaddr_tipc *, dest, m->msg_name); in tipc_send_group_bcast()
1009 struct sock *sk = sock->sk; in tipc_send_group_bcast()
1013 struct tipc_mc_method *method = &tsk->mc_method; in tipc_send_group_bcast()
1014 bool ack = method->mandatory && method->rcast; in tipc_send_group_bcast()
1016 struct tipc_msg *hdr = &tsk->phdr; in tipc_send_group_bcast()
1019 int rc = -EHOSTUNREACH; in tipc_send_group_bcast()
1023 !tsk->cong_link_cnt && tsk->group && in tipc_send_group_bcast()
1024 !tipc_group_bc_cong(tsk->group, blks)); in tipc_send_group_bcast()
1028 dsts = tipc_group_dests(tsk->group); in tipc_send_group_bcast()
1029 if (!dsts->local && !dsts->remote) in tipc_send_group_bcast()
1030 return -EHOSTUNREACH; in tipc_send_group_bcast()
1035 msg_set_nameinst(hdr, dest->addr.name.name.instance); in tipc_send_group_bcast()
1043 msg_set_grp_bc_seqno(hdr, tipc_group_bc_snd_nxt(tsk->group)); in tipc_send_group_bcast()
1055 rc = tipc_mcast_xmit(net, &pkts, method, dsts, &tsk->cong_link_cnt); in tipc_send_group_bcast()
1060 tipc_group_update_bc_members(tsk->group, blks, ack); in tipc_send_group_bcast()
1063 method->mandatory = false; in tipc_send_group_bcast()
1064 method->expires = jiffies; in tipc_send_group_bcast()
1070 * tipc_send_group_mcast - send message to all members with given identity
1082 struct sock *sk = sock->sk; in tipc_send_group_mcast()
1083 DECLARE_SOCKADDR(struct sockaddr_tipc *, dest, m->msg_name); in tipc_send_group_mcast()
1085 struct tipc_group *grp = tsk->group; in tipc_send_group_mcast()
1086 struct tipc_msg *hdr = &tsk->phdr; in tipc_send_group_mcast()
1095 inst = dest->addr.name.name.instance; in tipc_send_group_mcast()
1101 return -EHOSTUNREACH; in tipc_send_group_mcast()
1104 tipc_dest_pop(&dsts, &dest->addr.id.node, &dest->addr.id.ref); in tipc_send_group_mcast()
1113 * tipc_sk_mcast_rcv - Deliver multicast messages to all destination sockets
1117 * Multi-threaded: parallel calls with reference to same queues may occur
1135 skb = tipc_skb_peek(arrvq, &inputq->lock); in tipc_sk_mcast_rcv()
1136 for (; skb; skb = tipc_skb_peek(arrvq, &inputq->lock)) { in tipc_sk_mcast_rcv()
1145 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1151 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1187 spin_lock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1192 spin_unlock_bh(&inputq->lock); in tipc_sk_mcast_rcv()
1200 * tipc_sk_conn_proto_rcv - receive a connection mng protocol message
1210 struct sock *sk = &tsk->sk; in tipc_sk_conn_proto_rcv()
1222 sk->sk_state_change(sk); in tipc_sk_conn_proto_rcv()
1225 * - convert msg to abort msg and add to inqueue in tipc_sk_conn_proto_rcv()
1235 tsk->probe_unacked = false; in tipc_sk_conn_proto_rcv()
1244 tsk->snt_unacked -= msg_conn_ack(hdr); in tipc_sk_conn_proto_rcv()
1245 if (tsk->peer_caps & TIPC_BLOCK_FLOWCTL) in tipc_sk_conn_proto_rcv()
1246 tsk->snd_win = msg_adv_win(hdr); in tipc_sk_conn_proto_rcv()
1248 sk->sk_write_space(sk); in tipc_sk_conn_proto_rcv()
1257 * tipc_sendmsg - send message in connectionless manner
1272 struct sock *sk = sock->sk; in tipc_sendmsg()
1284 struct sock *sk = sock->sk; in __tipc_sendmsg()
1287 DECLARE_SOCKADDR(struct sockaddr_tipc *, dest, m->msg_name); in __tipc_sendmsg()
1288 long timeout = sock_sndtimeo(sk, m->msg_flags & MSG_DONTWAIT); in __tipc_sendmsg()
1289 struct list_head *clinks = &tsk->cong_links; in __tipc_sendmsg()
1291 struct tipc_group *grp = tsk->group; in __tipc_sendmsg()
1292 struct tipc_msg *hdr = &tsk->phdr; in __tipc_sendmsg()
1300 return -EMSGSIZE; in __tipc_sendmsg()
1303 if (unlikely(m->msg_namelen < sizeof(*dest))) in __tipc_sendmsg()
1304 return -EINVAL; in __tipc_sendmsg()
1305 if (unlikely(dest->family != AF_TIPC)) in __tipc_sendmsg()
1306 return -EINVAL; in __tipc_sendmsg()
1312 if (dest->addrtype == TIPC_ADDR_NAME) in __tipc_sendmsg()
1314 if (dest->addrtype == TIPC_ADDR_ID) in __tipc_sendmsg()
1316 if (dest->addrtype == TIPC_ADDR_MCAST) in __tipc_sendmsg()
1318 return -EINVAL; in __tipc_sendmsg()
1322 dest = &tsk->peer; in __tipc_sendmsg()
1323 if (!syn && dest->family != AF_TIPC) in __tipc_sendmsg()
1324 return -EDESTADDRREQ; in __tipc_sendmsg()
1328 if (sk->sk_state == TIPC_LISTEN) in __tipc_sendmsg()
1329 return -EPIPE; in __tipc_sendmsg()
1330 if (sk->sk_state != TIPC_OPEN) in __tipc_sendmsg()
1331 return -EISCONN; in __tipc_sendmsg()
1332 if (tsk->published) in __tipc_sendmsg()
1333 return -EOPNOTSUPP; in __tipc_sendmsg()
1334 if (dest->addrtype == TIPC_ADDR_NAME) { in __tipc_sendmsg()
1335 tsk->conn_type = dest->addr.name.name.type; in __tipc_sendmsg()
1336 tsk->conn_instance = dest->addr.name.name.instance; in __tipc_sendmsg()
1340 seq = &dest->addr.nameseq; in __tipc_sendmsg()
1341 if (dest->addrtype == TIPC_ADDR_MCAST) in __tipc_sendmsg()
1344 if (dest->addrtype == TIPC_ADDR_NAME) { in __tipc_sendmsg()
1345 type = dest->addr.name.name.type; in __tipc_sendmsg()
1346 inst = dest->addr.name.name.instance; in __tipc_sendmsg()
1347 dnode = dest->addr.name.domain; in __tipc_sendmsg()
1357 return -EHOSTUNREACH; in __tipc_sendmsg()
1358 } else if (dest->addrtype == TIPC_ADDR_ID) { in __tipc_sendmsg()
1359 dnode = dest->addr.id.node; in __tipc_sendmsg()
1363 msg_set_destport(hdr, dest->addr.id.ref); in __tipc_sendmsg()
1366 return -EINVAL; in __tipc_sendmsg()
1376 mtu = tipc_node_get_mtu(net, dnode, tsk->portid); in __tipc_sendmsg()
1381 rc = tipc_node_xmit(net, &pkts, dnode, tsk->portid); in __tipc_sendmsg()
1382 if (unlikely(rc == -ELINKCONG)) { in __tipc_sendmsg()
1384 tsk->cong_link_cnt++; in __tipc_sendmsg()
1395 * tipc_sendstream - send stream-oriented data
1407 struct sock *sk = sock->sk; in tipc_sendstream()
1419 struct sock *sk = sock->sk; in __tipc_sendstream()
1420 DECLARE_SOCKADDR(struct sockaddr_tipc *, dest, m->msg_name); in __tipc_sendstream()
1421 long timeout = sock_sndtimeo(sk, m->msg_flags & MSG_DONTWAIT); in __tipc_sendstream()
1423 struct tipc_msg *hdr = &tsk->phdr; in __tipc_sendstream()
1433 return -EMSGSIZE; in __tipc_sendstream()
1439 tsk->peer_caps = tipc_node_get_capabilities(net, dnode); in __tipc_sendstream()
1440 tsk->snt_unacked = tsk_inc(tsk, dlen + msg_hdr_sz(hdr)); in __tipc_sendstream()
1447 (!tsk->cong_link_cnt && in __tipc_sendstream()
1453 send = min_t(size_t, dlen - sent, TIPC_MAX_USER_MSG_SIZE); in __tipc_sendstream()
1454 rc = tipc_msg_build(hdr, m, sent, send, tsk->max_pkt, &pkts); in __tipc_sendstream()
1458 rc = tipc_node_xmit(net, &pkts, dnode, tsk->portid); in __tipc_sendstream()
1459 if (unlikely(rc == -ELINKCONG)) { in __tipc_sendstream()
1460 tsk->cong_link_cnt = 1; in __tipc_sendstream()
1464 tsk->snt_unacked += tsk_inc(tsk, send + MIN_H_SIZE); in __tipc_sendstream()
1473 * tipc_send_packet - send a connection-oriented message
1485 return -EMSGSIZE; in tipc_send_packet()
1490 /* tipc_sk_finish_conn - complete the setup of a connection
1495 struct sock *sk = &tsk->sk; in tipc_sk_finish_conn()
1497 struct tipc_msg *msg = &tsk->phdr; in tipc_sk_finish_conn()
1505 sk_reset_timer(sk, &sk->sk_timer, jiffies + CONN_PROBING_INTV); in tipc_sk_finish_conn()
1507 tipc_node_add_conn(net, peer_node, tsk->portid, peer_port); in tipc_sk_finish_conn()
1508 tsk->max_pkt = tipc_node_get_mtu(net, peer_node, tsk->portid); in tipc_sk_finish_conn()
1509 tsk->peer_caps = tipc_node_get_capabilities(net, peer_node); in tipc_sk_finish_conn()
1510 if (tsk->peer_caps & TIPC_BLOCK_FLOWCTL) in tipc_sk_finish_conn()
1514 tsk->rcv_win = FLOWCTL_MSG_WIN; in tipc_sk_finish_conn()
1515 tsk->snd_win = FLOWCTL_MSG_WIN; in tipc_sk_finish_conn()
1519 * tipc_sk_set_orig_addr - capture sender's address for received message
1527 DECLARE_SOCKADDR(struct sockaddr_pair *, srcaddr, m->msg_name); in tipc_sk_set_orig_addr()
1533 srcaddr->sock.family = AF_TIPC; in tipc_sk_set_orig_addr()
1534 srcaddr->sock.addrtype = TIPC_ADDR_ID; in tipc_sk_set_orig_addr()
1535 srcaddr->sock.scope = 0; in tipc_sk_set_orig_addr()
1536 srcaddr->sock.addr.id.ref = msg_origport(hdr); in tipc_sk_set_orig_addr()
1537 srcaddr->sock.addr.id.node = msg_orignode(hdr); in tipc_sk_set_orig_addr()
1538 srcaddr->sock.addr.name.domain = 0; in tipc_sk_set_orig_addr()
1539 m->msg_namelen = sizeof(struct sockaddr_tipc); in tipc_sk_set_orig_addr()
1545 srcaddr->member.family = AF_TIPC; in tipc_sk_set_orig_addr()
1546 srcaddr->member.addrtype = TIPC_ADDR_NAME; in tipc_sk_set_orig_addr()
1547 srcaddr->member.scope = 0; in tipc_sk_set_orig_addr()
1548 srcaddr->member.addr.name.name.type = msg_nametype(hdr); in tipc_sk_set_orig_addr()
1549 srcaddr->member.addr.name.name.instance = TIPC_SKB_CB(skb)->orig_member; in tipc_sk_set_orig_addr()
1550 srcaddr->member.addr.name.domain = 0; in tipc_sk_set_orig_addr()
1551 m->msg_namelen = sizeof(*srcaddr); in tipc_sk_set_orig_addr()
1555 * tipc_sk_anc_data_recv - optionally capture ancillary data for received message
1572 int res; in tipc_sk_anc_data_recv() local
1574 if (likely(m->msg_controllen == 0)) in tipc_sk_anc_data_recv()
1583 res = put_cmsg(m, SOL_TIPC, TIPC_ERRINFO, 8, anc_data); in tipc_sk_anc_data_recv()
1584 if (res) in tipc_sk_anc_data_recv()
1585 return res; in tipc_sk_anc_data_recv()
1588 return -ENOMEM; in tipc_sk_anc_data_recv()
1590 res = put_cmsg(m, SOL_TIPC, TIPC_RETDATA, anc_data[1], in tipc_sk_anc_data_recv()
1592 if (res) in tipc_sk_anc_data_recv()
1593 return res; in tipc_sk_anc_data_recv()
1613 has_name = (tsk->conn_type != 0); in tipc_sk_anc_data_recv()
1614 anc_data[0] = tsk->conn_type; in tipc_sk_anc_data_recv()
1615 anc_data[1] = tsk->conn_instance; in tipc_sk_anc_data_recv()
1616 anc_data[2] = tsk->conn_instance; in tipc_sk_anc_data_recv()
1622 res = put_cmsg(m, SOL_TIPC, TIPC_DESTNAME, 12, anc_data); in tipc_sk_anc_data_recv()
1623 if (res) in tipc_sk_anc_data_recv()
1624 return res; in tipc_sk_anc_data_recv()
1632 struct sock *sk = &tsk->sk; in tipc_sk_send_ack()
1643 tsk->portid, TIPC_OK); in tipc_sk_send_ack()
1647 msg_set_conn_ack(msg, tsk->rcv_unacked); in tipc_sk_send_ack()
1648 tsk->rcv_unacked = 0; in tipc_sk_send_ack()
1651 if (tsk->peer_caps & TIPC_BLOCK_FLOWCTL) { in tipc_sk_send_ack()
1652 tsk->rcv_win = tsk_adv_blocks(tsk->sk.sk_rcvbuf); in tipc_sk_send_ack()
1653 msg_set_adv_win(msg, tsk->rcv_win); in tipc_sk_send_ack()
1660 struct sock *sk = sock->sk; in tipc_wait_for_rcvmsg()
1670 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_rcvmsg()
1671 if (sk->sk_shutdown & RCV_SHUTDOWN) { in tipc_wait_for_rcvmsg()
1672 err = -ENOTCONN; in tipc_wait_for_rcvmsg()
1680 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_rcvmsg()
1682 err = -EAGAIN; in tipc_wait_for_rcvmsg()
1699 * tipc_recvmsg - receive packet-oriented message
1712 struct sock *sk = sock->sk; in tipc_recvmsg()
1724 return -EINVAL; in tipc_recvmsg()
1727 if (unlikely(connected && sk->sk_state == TIPC_OPEN)) { in tipc_recvmsg()
1728 rc = -ENOTCONN; in tipc_recvmsg()
1738 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
1756 /* Capture data if non-error msg, otherwise just set return value */ in tipc_recvmsg()
1760 m->msg_flags |= MSG_TRUNC; in tipc_recvmsg()
1765 if (err != TIPC_CONN_SHUTDOWN && connected && !m->msg_control) in tipc_recvmsg()
1766 rc = -ECONNRESET; in tipc_recvmsg()
1774 m->msg_flags |= MSG_EOR; in tipc_recvmsg()
1775 m->msg_flags |= MSG_OOB; in tipc_recvmsg()
1784 if (tsk->group && msg_in_group(hdr) && !grp_evt) { in tipc_recvmsg()
1786 tipc_group_update_rcv_win(tsk->group, tsk_blocks(hlen + dlen), in tipc_recvmsg()
1798 tsk->rcv_unacked += tsk_inc(tsk, hlen + dlen); in tipc_recvmsg()
1799 if (tsk->rcv_unacked >= tsk->rcv_win / TIPC_ACK_RATE) in tipc_recvmsg()
1807 * tipc_recvstream - receive stream-oriented data
1820 struct sock *sk = sock->sk; in tipc_recvstream()
1826 int offset, required, copy, copied = 0; in tipc_recvstream() local
1832 return -EINVAL; in tipc_recvstream()
1836 if (unlikely(sk->sk_state == TIPC_OPEN)) { in tipc_recvstream()
1837 rc = -ENOTCONN; in tipc_recvstream()
1848 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvstream()
1855 /* Discard any empty non-errored (SYN-) message */ in tipc_recvstream()
1872 offset = skb_cb->bytes_read; in tipc_recvstream()
1873 copy = min_t(int, dlen - offset, buflen - copied); in tipc_recvstream()
1874 rc = skb_copy_datagram_msg(skb, hlen + offset, m, copy); in tipc_recvstream()
1878 offset += copy; in tipc_recvstream()
1879 if (unlikely(offset < dlen)) { in tipc_recvstream()
1881 skb_cb->bytes_read = offset; in tipc_recvstream()
1886 if ((err != TIPC_CONN_SHUTDOWN) && !m->msg_control) in tipc_recvstream()
1887 rc = -ECONNRESET; in tipc_recvstream()
1898 tsk->rcv_unacked += tsk_inc(tsk, hlen + dlen); in tipc_recvstream()
1899 if (unlikely(tsk->rcv_unacked >= tsk->rcv_win / TIPC_ACK_RATE)) in tipc_recvstream()
1906 } while (!skb_queue_empty(&sk->sk_receive_queue) || copied < required); in tipc_recvstream()
1913 * tipc_write_space - wake up thread if port congestion is released
1921 wq = rcu_dereference(sk->sk_wq); in tipc_write_space()
1923 wake_up_interruptible_sync_poll(&wq->wait, EPOLLOUT | in tipc_write_space()
1929 * tipc_data_ready - wake up threads to indicate messages have been received
1938 wq = rcu_dereference(sk->sk_wq); in tipc_data_ready()
1940 wake_up_interruptible_sync_poll(&wq->wait, EPOLLIN | in tipc_data_ready()
1947 __skb_queue_purge(&sk->sk_receive_queue); in tipc_sock_destruct()
1957 struct tipc_group *grp = tsk->group; in tipc_sk_proto_rcv()
1965 tipc_dest_del(&tsk->cong_links, msg_orignode(hdr), 0); in tipc_sk_proto_rcv()
1968 tsk->cong_link_cnt--; in tipc_sk_proto_rcv()
1975 tipc_group_member_evt(tsk->group, &wakeup, &sk->sk_rcvbuf, in tipc_sk_proto_rcv()
1983 sk->sk_write_space(sk); in tipc_sk_proto_rcv()
1989 * tipc_filter_connect - Handle incoming message for a connection-based socket
1997 struct sock *sk = &tsk->sk; in tipc_sk_filter_connect()
2006 switch (sk->sk_state) { in tipc_sk_filter_connect()
2015 sk->sk_err = ECONNREFUSED; in tipc_sk_filter_connect()
2016 sk->sk_state_change(sk); in tipc_sk_filter_connect()
2022 sk->sk_err = ECONNREFUSED; in tipc_sk_filter_connect()
2023 sk->sk_state_change(sk); in tipc_sk_filter_connect()
2029 sk->sk_err = EINVAL; in tipc_sk_filter_connect()
2030 sk->sk_state_change(sk); in tipc_sk_filter_connect()
2035 msg_set_importance(&tsk->phdr, msg_importance(hdr)); in tipc_sk_filter_connect()
2041 /* If empty 'ACK-' message, wake up sleeping connect() */ in tipc_sk_filter_connect()
2042 sk->sk_state_change(sk); in tipc_sk_filter_connect()
2044 /* 'ACK-' message is neither accepted nor rejected: */ in tipc_sk_filter_connect()
2057 /* Accept only connection-based messages sent by peer */ in tipc_sk_filter_connect()
2065 tsk->portid); in tipc_sk_filter_connect()
2066 sk->sk_state_change(sk); in tipc_sk_filter_connect()
2070 pr_err("Unknown sk_state %u\n", sk->sk_state); in tipc_sk_filter_connect()
2077 * rcvbuf_limit - get proper overload limit of socket receive queue
2100 return sk->sk_rcvbuf; in rcvbuf_limit()
2103 return sk->sk_rcvbuf << msg_importance(hdr); in rcvbuf_limit()
2105 if (likely(tsk->peer_caps & TIPC_BLOCK_FLOWCTL)) in rcvbuf_limit()
2106 return sk->sk_rcvbuf; in rcvbuf_limit()
2112 * tipc_sk_filter_rcv - validate incoming message
2127 struct tipc_group *grp = tsk->group; in tipc_sk_filter_rcv()
2133 TIPC_SKB_CB(skb)->bytes_read = 0; in tipc_sk_filter_rcv()
2151 else if (sk_rmem_alloc_get(sk) + skb->truesize >= limit) { in tipc_sk_filter_rcv()
2152 atomic_inc(&sk->sk_drops); in tipc_sk_filter_rcv()
2161 __skb_queue_tail(&sk->sk_receive_queue, skb); in tipc_sk_filter_rcv()
2163 sk->sk_data_ready(sk); in tipc_sk_filter_rcv()
2168 * tipc_sk_backlog_rcv - handle incoming message from backlog queue
2183 added = sk_rmem_alloc_get(sk) - before; in tipc_sk_backlog_rcv()
2184 atomic_add(added, &tipc_sk(sk)->dupl_rcvcnt); in tipc_sk_backlog_rcv()
2192 * tipc_sk_enqueue - extract all buffers with destination 'dport' from
2223 /* Try backlog, compensating for double-counted bytes */ in tipc_sk_enqueue()
2224 dcnt = &tipc_sk(sk)->dupl_rcvcnt; in tipc_sk_enqueue()
2225 if (!sk->sk_backlog.len) in tipc_sk_enqueue()
2233 atomic_inc(&sk->sk_drops); in tipc_sk_enqueue()
2241 * tipc_sk_rcv - handle a chain of incoming buffers
2261 sk = &tsk->sk; in tipc_sk_rcv()
2262 if (likely(spin_trylock_bh(&sk->sk_lock.slock))) { in tipc_sk_rcv()
2264 spin_unlock_bh(&sk->sk_lock.slock); in tipc_sk_rcv()
2293 struct sock *sk = sock->sk; in tipc_wait_for_connect()
2301 return -ETIMEDOUT; in tipc_wait_for_connect()
2307 sk->sk_state != TIPC_CONNECTING, &wait); in tipc_wait_for_connect()
2315 if (addr->family != AF_TIPC) in tipc_sockaddr_is_sane()
2317 if (addr->addrtype == TIPC_SERVICE_RANGE) in tipc_sockaddr_is_sane()
2318 return (addr->addr.nameseq.lower <= addr->addr.nameseq.upper); in tipc_sockaddr_is_sane()
2319 return (addr->addrtype == TIPC_SERVICE_ADDR || in tipc_sockaddr_is_sane()
2320 addr->addrtype == TIPC_SOCKET_ADDR); in tipc_sockaddr_is_sane()
2324 * tipc_connect - establish a connection to another TIPC port
2328 * @flags: file-related flags associated with socket
2335 struct sock *sk = sock->sk; in tipc_connect()
2339 long timeout = (flags & O_NONBLOCK) ? 0 : tsk->conn_timeout; in tipc_connect()
2341 int res = 0; in tipc_connect() local
2344 return -EINVAL; in tipc_connect()
2348 if (tsk->group) { in tipc_connect()
2349 res = -EINVAL; in tipc_connect()
2353 if (dst->family == AF_UNSPEC) { in tipc_connect()
2354 memset(&tsk->peer, 0, sizeof(struct sockaddr_tipc)); in tipc_connect()
2356 res = -EINVAL; in tipc_connect()
2360 res = -EINVAL; in tipc_connect()
2365 memcpy(&tsk->peer, dest, destlen); in tipc_connect()
2367 } else if (dst->addrtype == TIPC_SERVICE_RANGE) { in tipc_connect()
2368 res = -EINVAL; in tipc_connect()
2372 previous = sk->sk_state; in tipc_connect()
2374 switch (sk->sk_state) { in tipc_connect()
2376 /* Send a 'SYN-' to destination */ in tipc_connect()
2380 /* If connect is in non-blocking case, set MSG_DONTWAIT to in tipc_connect()
2386 res = __tipc_sendmsg(sock, &m, 0); in tipc_connect()
2387 if ((res < 0) && (res != -EWOULDBLOCK)) in tipc_connect()
2391 * difference is that return value in non-blocking in tipc_connect()
2394 res = -EINPROGRESS; in tipc_connect()
2399 res = -EALREADY; in tipc_connect()
2404 res = tipc_wait_for_connect(sock, &timeout); in tipc_connect()
2407 res = -EISCONN; in tipc_connect()
2410 res = -EINVAL; in tipc_connect()
2415 return res; in tipc_connect()
2419 * tipc_listen - allow socket to listen for incoming connections
2427 struct sock *sk = sock->sk; in tipc_listen()
2428 int res; in tipc_listen() local
2431 res = tipc_set_sk_state(sk, TIPC_LISTEN); in tipc_listen()
2434 return res; in tipc_listen()
2439 struct sock *sk = sock->sk; in tipc_wait_for_accept()
2443 /* True wake-one mechanism for incoming connections: only in tipc_wait_for_accept()
2451 if (timeo && skb_queue_empty(&sk->sk_receive_queue)) { in tipc_wait_for_accept()
2457 if (!skb_queue_empty(&sk->sk_receive_queue)) in tipc_wait_for_accept()
2459 err = -EAGAIN; in tipc_wait_for_accept()
2471 * tipc_accept - wait for connection request
2474 * @flags: file-related flags associated with socket
2481 struct sock *new_sk, *sk = sock->sk; in tipc_accept()
2486 int res; in tipc_accept() local
2490 if (sk->sk_state != TIPC_LISTEN) { in tipc_accept()
2491 res = -EINVAL; in tipc_accept()
2495 res = tipc_wait_for_accept(sock, timeo); in tipc_accept()
2496 if (res) in tipc_accept()
2499 buf = skb_peek(&sk->sk_receive_queue); in tipc_accept()
2501 res = tipc_sk_create(sock_net(sock->sk), new_sock, 0, kern); in tipc_accept()
2502 if (res) in tipc_accept()
2504 security_sk_clone(sock->sk, new_sock->sk); in tipc_accept()
2506 new_sk = new_sock->sk; in tipc_accept()
2524 new_tsock->conn_type = msg_nametype(msg); in tipc_accept()
2525 new_tsock->conn_instance = msg_nameinst(msg); in tipc_accept()
2529 * Respond to 'SYN-' by discarding it & returning 'ACK'-. in tipc_accept()
2538 __skb_dequeue(&sk->sk_receive_queue); in tipc_accept()
2539 __skb_queue_head(&new_sk->sk_receive_queue, buf); in tipc_accept()
2545 return res; in tipc_accept()
2549 * tipc_shutdown - shutdown socket connection
2559 struct sock *sk = sock->sk; in tipc_shutdown()
2560 int res; in tipc_shutdown() local
2563 return -EINVAL; in tipc_shutdown()
2568 sk->sk_shutdown = SHUTDOWN_MASK; in tipc_shutdown()
2570 if (sk->sk_state == TIPC_DISCONNECTING) { in tipc_shutdown()
2572 __skb_queue_purge(&sk->sk_receive_queue); in tipc_shutdown()
2574 res = 0; in tipc_shutdown()
2576 res = -ENOTCONN; in tipc_shutdown()
2579 sk->sk_state_change(sk); in tipc_shutdown()
2582 return res; in tipc_shutdown()
2592 u32 own_port = tsk->portid; in tipc_sk_timeout()
2602 sk_reset_timer(sk, &sk->sk_timer, jiffies + HZ / 20); in tipc_sk_timeout()
2606 if (tsk->probe_unacked) { in tipc_sk_timeout()
2609 sk->sk_state_change(sk); in tipc_sk_timeout()
2616 tsk->probe_unacked = true; in tipc_sk_timeout()
2617 sk_reset_timer(sk, &sk->sk_timer, jiffies + CONN_PROBING_INTV); in tipc_sk_timeout()
2628 struct sock *sk = &tsk->sk; in tipc_sk_publish()
2637 return -EINVAL; in tipc_sk_publish()
2638 key = tsk->portid + tsk->pub_count + 1; in tipc_sk_publish()
2639 if (key == tsk->portid) in tipc_sk_publish()
2640 return -EADDRINUSE; in tipc_sk_publish()
2642 publ = tipc_nametbl_publish(net, seq->type, seq->lower, seq->upper, in tipc_sk_publish()
2643 scope, tsk->portid, key); in tipc_sk_publish()
2645 return -EINVAL; in tipc_sk_publish()
2647 list_add(&publ->binding_sock, &tsk->publications); in tipc_sk_publish()
2648 tsk->pub_count++; in tipc_sk_publish()
2649 tsk->published = 1; in tipc_sk_publish()
2656 struct net *net = sock_net(&tsk->sk); in tipc_sk_withdraw()
2659 int rc = -EINVAL; in tipc_sk_withdraw()
2664 list_for_each_entry_safe(publ, safe, &tsk->publications, binding_sock) { in tipc_sk_withdraw()
2666 if (publ->scope != scope) in tipc_sk_withdraw()
2668 if (publ->type != seq->type) in tipc_sk_withdraw()
2670 if (publ->lower != seq->lower) in tipc_sk_withdraw()
2672 if (publ->upper != seq->upper) in tipc_sk_withdraw()
2674 tipc_nametbl_withdraw(net, publ->type, publ->lower, in tipc_sk_withdraw()
2675 publ->upper, publ->key); in tipc_sk_withdraw()
2679 tipc_nametbl_withdraw(net, publ->type, publ->lower, in tipc_sk_withdraw()
2680 publ->upper, publ->key); in tipc_sk_withdraw()
2683 if (list_empty(&tsk->publications)) in tipc_sk_withdraw()
2684 tsk->published = 0; in tipc_sk_withdraw()
2688 /* tipc_sk_reinit: set non-zero address in all existing sockets
2698 rhashtable_walk_enter(&tn->sk_rht, &iter); in tipc_sk_reinit()
2704 sock_hold(&tsk->sk); in tipc_sk_reinit()
2706 lock_sock(&tsk->sk); in tipc_sk_reinit()
2707 msg = &tsk->phdr; in tipc_sk_reinit()
2710 release_sock(&tsk->sk); in tipc_sk_reinit()
2712 sock_put(&tsk->sk); in tipc_sk_reinit()
2716 } while (tsk == ERR_PTR(-EAGAIN)); in tipc_sk_reinit()
2727 tsk = rhashtable_lookup_fast(&tn->sk_rht, &portid, tsk_rht_params); in tipc_sk_lookup()
2729 sock_hold(&tsk->sk); in tipc_sk_lookup()
2737 struct sock *sk = &tsk->sk; in tipc_sk_insert()
2740 u32 remaining = (TIPC_MAX_PORT - TIPC_MIN_PORT) + 1; in tipc_sk_insert()
2743 while (remaining--) { in tipc_sk_insert()
2747 tsk->portid = portid; in tipc_sk_insert()
2748 sock_hold(&tsk->sk); in tipc_sk_insert()
2749 if (!rhashtable_lookup_insert_fast(&tn->sk_rht, &tsk->node, in tipc_sk_insert()
2752 sock_put(&tsk->sk); in tipc_sk_insert()
2755 return -1; in tipc_sk_insert()
2760 struct sock *sk = &tsk->sk; in tipc_sk_remove()
2763 if (!rhashtable_remove_fast(&tn->sk_rht, &tsk->node, tsk_rht_params)) { in tipc_sk_remove()
2764 WARN_ON(refcount_read(&sk->sk_refcnt) == 1); in tipc_sk_remove()
2783 return rhashtable_init(&tn->sk_rht, &tsk_rht_params); in tipc_sk_rht_init()
2793 rhashtable_destroy(&tn->sk_rht); in tipc_sk_rht_destroy()
2798 struct net *net = sock_net(&tsk->sk); in tipc_sk_join()
2799 struct tipc_group *grp = tsk->group; in tipc_sk_join()
2800 struct tipc_msg *hdr = &tsk->phdr; in tipc_sk_join()
2804 if (mreq->type < TIPC_RESERVED_TYPES) in tipc_sk_join()
2805 return -EACCES; in tipc_sk_join()
2806 if (mreq->scope > TIPC_NODE_SCOPE) in tipc_sk_join()
2807 return -EINVAL; in tipc_sk_join()
2809 return -EACCES; in tipc_sk_join()
2810 grp = tipc_group_create(net, tsk->portid, mreq, &tsk->group_is_open); in tipc_sk_join()
2812 return -ENOMEM; in tipc_sk_join()
2813 tsk->group = grp; in tipc_sk_join()
2814 msg_set_lookup_scope(hdr, mreq->scope); in tipc_sk_join()
2815 msg_set_nametype(hdr, mreq->type); in tipc_sk_join()
2817 seq.type = mreq->type; in tipc_sk_join()
2818 seq.lower = mreq->instance; in tipc_sk_join()
2820 tipc_nametbl_build_group(net, grp, mreq->type, mreq->scope); in tipc_sk_join()
2821 rc = tipc_sk_publish(tsk, mreq->scope, &seq); in tipc_sk_join()
2824 tsk->group = NULL; in tipc_sk_join()
2828 tsk->mc_method.rcast = true; in tipc_sk_join()
2829 tsk->mc_method.mandatory = true; in tipc_sk_join()
2830 tipc_group_join(net, grp, &tsk->sk.sk_rcvbuf); in tipc_sk_join()
2836 struct net *net = sock_net(&tsk->sk); in tipc_sk_leave()
2837 struct tipc_group *grp = tsk->group; in tipc_sk_leave()
2842 return -EINVAL; in tipc_sk_leave()
2845 tsk->group = NULL; in tipc_sk_leave()
2851 * tipc_setsockopt - set socket option
2855 * @ov: pointer to new option value
2856 * @ol: length of option value
2866 struct sock *sk = sock->sk; in tipc_setsockopt()
2869 u32 value = 0; in tipc_setsockopt() local
2870 int res = 0; in tipc_setsockopt() local
2872 if ((lvl == IPPROTO_TCP) && (sock->type == SOCK_STREAM)) in tipc_setsockopt()
2875 return -ENOPROTOOPT; in tipc_setsockopt()
2882 if (ol < sizeof(value)) in tipc_setsockopt()
2883 return -EINVAL; in tipc_setsockopt()
2884 if (get_user(value, (u32 __user *)ov)) in tipc_setsockopt()
2885 return -EFAULT; in tipc_setsockopt()
2889 return -EINVAL; in tipc_setsockopt()
2891 return -EFAULT; in tipc_setsockopt()
2895 return -EINVAL; in tipc_setsockopt()
2902 res = tsk_set_importance(tsk, value); in tipc_setsockopt()
2905 if (sock->type != SOCK_STREAM) in tipc_setsockopt()
2906 tsk_set_unreliable(tsk, value); in tipc_setsockopt()
2908 res = -ENOPROTOOPT; in tipc_setsockopt()
2911 tsk_set_unreturnable(tsk, value); in tipc_setsockopt()
2914 tipc_sk(sk)->conn_timeout = value; in tipc_setsockopt()
2917 tsk->mc_method.rcast = false; in tipc_setsockopt()
2918 tsk->mc_method.mandatory = true; in tipc_setsockopt()
2921 tsk->mc_method.rcast = true; in tipc_setsockopt()
2922 tsk->mc_method.mandatory = true; in tipc_setsockopt()
2925 res = tipc_sk_join(tsk, &mreq); in tipc_setsockopt()
2928 res = tipc_sk_leave(tsk); in tipc_setsockopt()
2931 res = -EINVAL; in tipc_setsockopt()
2936 return res; in tipc_setsockopt()
2940 * tipc_getsockopt - get socket option
2944 * @ov: receptacle for option value
2945 * @ol: receptacle for length of option value
2955 struct sock *sk = sock->sk; in tipc_getsockopt()
2959 u32 value; in tipc_getsockopt() local
2960 int res; in tipc_getsockopt() local
2962 if ((lvl == IPPROTO_TCP) && (sock->type == SOCK_STREAM)) in tipc_getsockopt()
2965 return -ENOPROTOOPT; in tipc_getsockopt()
2966 res = get_user(len, ol); in tipc_getsockopt()
2967 if (res) in tipc_getsockopt()
2968 return res; in tipc_getsockopt()
2974 value = tsk_importance(tsk); in tipc_getsockopt()
2977 value = tsk_unreliable(tsk); in tipc_getsockopt()
2980 value = tsk_unreturnable(tsk); in tipc_getsockopt()
2983 value = tsk->conn_timeout; in tipc_getsockopt()
2984 /* no need to set "res", since already 0 at this point */ in tipc_getsockopt()
2987 value = 0; /* was tipc_queue_size, now obsolete */ in tipc_getsockopt()
2990 value = skb_queue_len(&sk->sk_receive_queue); in tipc_getsockopt()
2994 if (tsk->group) in tipc_getsockopt()
2995 tipc_group_self(tsk->group, &seq, &scope); in tipc_getsockopt()
2996 value = seq.type; in tipc_getsockopt()
2999 res = -EINVAL; in tipc_getsockopt()
3004 if (res) in tipc_getsockopt()
3005 return res; /* "get" failed */ in tipc_getsockopt()
3007 if (len < sizeof(value)) in tipc_getsockopt()
3008 return -EINVAL; in tipc_getsockopt()
3010 if (copy_to_user(ov, &value, sizeof(value))) in tipc_getsockopt()
3011 return -EFAULT; in tipc_getsockopt()
3013 return put_user(sizeof(value), ol); in tipc_getsockopt()
3018 struct net *net = sock_net(sock->sk); in tipc_ioctl()
3026 return -EFAULT; in tipc_ioctl()
3031 return -EFAULT; in tipc_ioctl()
3034 return -EADDRNOTAVAIL; in tipc_ioctl()
3037 return -EFAULT; in tipc_ioctl()
3039 return -EADDRNOTAVAIL; in tipc_ioctl()
3041 return -EFAULT; in tipc_ioctl()
3044 return -ENOIOCTLCMD; in tipc_ioctl()
3050 struct tipc_sock *tsk2 = tipc_sk(sock2->sk); in tipc_socketpair()
3051 struct tipc_sock *tsk1 = tipc_sk(sock1->sk); in tipc_socketpair()
3052 u32 onode = tipc_own_addr(sock_net(sock1->sk)); in tipc_socketpair()
3054 tsk1->peer.family = AF_TIPC; in tipc_socketpair()
3055 tsk1->peer.addrtype = TIPC_ADDR_ID; in tipc_socketpair()
3056 tsk1->peer.scope = TIPC_NODE_SCOPE; in tipc_socketpair()
3057 tsk1->peer.addr.id.ref = tsk2->portid; in tipc_socketpair()
3058 tsk1->peer.addr.id.node = onode; in tipc_socketpair()
3059 tsk2->peer.family = AF_TIPC; in tipc_socketpair()
3060 tsk2->peer.addrtype = TIPC_ADDR_ID; in tipc_socketpair()
3061 tsk2->peer.scope = TIPC_NODE_SCOPE; in tipc_socketpair()
3062 tsk2->peer.addr.id.ref = tsk1->portid; in tipc_socketpair()
3063 tsk2->peer.addr.id.node = onode; in tipc_socketpair()
3065 tipc_sk_finish_conn(tsk1, tsk2->portid, onode); in tipc_socketpair()
3066 tipc_sk_finish_conn(tsk2, tsk1->portid, onode); in tipc_socketpair()
3149 * tipc_socket_init - initialize TIPC socket interface
3155 int res; in tipc_socket_init() local
3157 res = proto_register(&tipc_proto, 1); in tipc_socket_init()
3158 if (res) { in tipc_socket_init()
3163 res = sock_register(&tipc_family_ops); in tipc_socket_init()
3164 if (res) { in tipc_socket_init()
3170 return res; in tipc_socket_init()
3174 * tipc_socket_stop - stop TIPC socket interface
3199 if (tsk->conn_type != 0) { in __tipc_nl_add_sk_con()
3202 if (nla_put_u32(skb, TIPC_NLA_CON_TYPE, tsk->conn_type)) in __tipc_nl_add_sk_con()
3204 if (nla_put_u32(skb, TIPC_NLA_CON_INST, tsk->conn_instance)) in __tipc_nl_add_sk_con()
3214 return -EMSGSIZE; in __tipc_nl_add_sk_con()
3220 struct net *net = sock_net(skb->sk); in __tipc_nl_add_sk_info()
3221 struct sock *sk = &tsk->sk; in __tipc_nl_add_sk_info()
3223 if (nla_put_u32(skb, TIPC_NLA_SOCK_REF, tsk->portid) || in __tipc_nl_add_sk_info()
3225 return -EMSGSIZE; in __tipc_nl_add_sk_info()
3229 return -EMSGSIZE; in __tipc_nl_add_sk_info()
3230 } else if (!list_empty(&tsk->publications)) { in __tipc_nl_add_sk_info()
3232 return -EMSGSIZE; in __tipc_nl_add_sk_info()
3244 hdr = genlmsg_put(skb, NETLINK_CB(cb->skb).portid, cb->nlh->nlmsg_seq, in __tipc_nl_add_sk()
3266 return -EMSGSIZE; in __tipc_nl_add_sk()
3274 struct rhashtable_iter *iter = (void *)cb->args[4]; in tipc_nl_sk_walk()
3282 if (err == -EAGAIN) { in tipc_nl_sk_walk()
3289 sock_hold(&tsk->sk); in tipc_nl_sk_walk()
3291 lock_sock(&tsk->sk); in tipc_nl_sk_walk()
3294 release_sock(&tsk->sk); in tipc_nl_sk_walk()
3295 sock_put(&tsk->sk); in tipc_nl_sk_walk()
3298 release_sock(&tsk->sk); in tipc_nl_sk_walk()
3300 sock_put(&tsk->sk); in tipc_nl_sk_walk()
3304 return skb->len; in tipc_nl_sk_walk()
3310 return __tipc_dump_start(cb, sock_net(cb->skb->sk)); in tipc_dump_start()
3316 /* tipc_nl_name_table_dump() uses cb->args[0...3]. */ in __tipc_dump_start()
3317 struct rhashtable_iter *iter = (void *)cb->args[4]; in __tipc_dump_start()
3323 return -ENOMEM; in __tipc_dump_start()
3325 cb->args[4] = (long)iter; in __tipc_dump_start()
3328 rhashtable_walk_enter(&tn->sk_rht, iter); in __tipc_dump_start()
3334 struct rhashtable_iter *hti = (void *)cb->args[4]; in tipc_dump_done()
3346 struct sock *sk = &tsk->sk; in tipc_sk_fill_sock_diag()
3351 if (!(sk_filter_state & (1 << sk->sk_state))) in tipc_sk_fill_sock_diag()
3361 if (nla_put_u32(skb, TIPC_NLA_SOCK_TYPE, (u32)sk->sk_type) || in tipc_sk_fill_sock_diag()
3362 nla_put_u32(skb, TIPC_NLA_SOCK_TIPC_STATE, (u32)sk->sk_state) || in tipc_sk_fill_sock_diag()
3365 from_kuid_munged(sk_user_ns(NETLINK_CB(cb->skb).sk), in tipc_sk_fill_sock_diag()
3377 skb_queue_len(&sk->sk_receive_queue)) || in tipc_sk_fill_sock_diag()
3379 skb_queue_len(&sk->sk_write_queue)) || in tipc_sk_fill_sock_diag()
3381 atomic_read(&sk->sk_drops))) in tipc_sk_fill_sock_diag()
3384 if (tsk->cong_link_cnt && in tipc_sk_fill_sock_diag()
3394 if (tsk->group) in tipc_sk_fill_sock_diag()
3395 if (tipc_group_fill_sock_diag(tsk->group, skb)) in tipc_sk_fill_sock_diag()
3407 return -EMSGSIZE; in tipc_sk_fill_sock_diag()
3424 hdr = genlmsg_put(skb, NETLINK_CB(cb->skb).portid, cb->nlh->nlmsg_seq, in __tipc_nl_add_sk_publ()
3433 if (nla_put_u32(skb, TIPC_NLA_PUBL_KEY, publ->key)) in __tipc_nl_add_sk_publ()
3435 if (nla_put_u32(skb, TIPC_NLA_PUBL_TYPE, publ->type)) in __tipc_nl_add_sk_publ()
3437 if (nla_put_u32(skb, TIPC_NLA_PUBL_LOWER, publ->lower)) in __tipc_nl_add_sk_publ()
3439 if (nla_put_u32(skb, TIPC_NLA_PUBL_UPPER, publ->upper)) in __tipc_nl_add_sk_publ()
3452 return -EMSGSIZE; in __tipc_nl_add_sk_publ()
3464 list_for_each_entry(p, &tsk->publications, binding_sock) { in __tipc_nl_list_sk_publ()
3465 if (p->key == *last_publ) in __tipc_nl_list_sk_publ()
3468 if (p->key != *last_publ) { in __tipc_nl_list_sk_publ()
3475 cb->prev_seq = 1; in __tipc_nl_list_sk_publ()
3477 return -EPIPE; in __tipc_nl_list_sk_publ()
3480 p = list_first_entry(&tsk->publications, struct publication, in __tipc_nl_list_sk_publ()
3484 list_for_each_entry_from(p, &tsk->publications, binding_sock) { in __tipc_nl_list_sk_publ()
3487 *last_publ = p->key; in __tipc_nl_list_sk_publ()
3499 u32 tsk_portid = cb->args[0]; in tipc_nl_publ_dump()
3500 u32 last_publ = cb->args[1]; in tipc_nl_publ_dump()
3501 u32 done = cb->args[2]; in tipc_nl_publ_dump()
3502 struct net *net = sock_net(skb->sk); in tipc_nl_publ_dump()
3509 err = tipc_nlmsg_parse(cb->nlh, &attrs); in tipc_nl_publ_dump()
3514 return -EINVAL; in tipc_nl_publ_dump()
3523 return -EINVAL; in tipc_nl_publ_dump()
3533 return -EINVAL; in tipc_nl_publ_dump()
3535 lock_sock(&tsk->sk); in tipc_nl_publ_dump()
3539 release_sock(&tsk->sk); in tipc_nl_publ_dump()
3540 sock_put(&tsk->sk); in tipc_nl_publ_dump()
3542 cb->args[0] = tsk_portid; in tipc_nl_publ_dump()
3543 cb->args[1] = last_publ; in tipc_nl_publ_dump()
3544 cb->args[2] = done; in tipc_nl_publ_dump()
3546 return skb->len; in tipc_nl_publ_dump()