110 	struct pep_sock *pn = pep_sk(sk);  in pep_indicate()  local
121 	ph->pipe_handle = pn->pipe_handle;  in pep_indicate()
131 	struct pep_sock *pn = pep_sk(sk);  in pipe_handler_request()  local
142 	ph->pipe_handle = pn->pipe_handle;  in pipe_handler_request()
149 	struct pep_sock *pn = pep_sk(sk);  in pipe_handler_send_created_ind()  local
152 		pn->tx_fc, pn->rx_fc,  in pipe_handler_send_created_ind()
229 	struct pep_sock *pn = pep_sk(sk);  in pipe_grant_credits()  local
233 	switch (pn->rx_fc) {  in pipe_grant_credits()
239 			pn->rx_credits = 1;  in pipe_grant_credits()
242 		if ((pn->rx_credits + CREDITS_THR) > CREDITS_MAX)  in pipe_grant_credits()
245 					CREDITS_MAX - pn->rx_credits,  in pipe_grant_credits()
247 			pn->rx_credits = CREDITS_MAX;  in pipe_grant_credits()
254 	struct pep_sock *pn = pep_sk(sk);  in pipe_rcv_status()  local
270 		switch (pn->tx_fc) {  in pipe_rcv_status()
274 				atomic_set(&pn->tx_credits, 0);  in pipe_rcv_status()
277 				atomic_set(&pn->tx_credits, wake = 1);  in pipe_rcv_status()
283 				atomic_set(&pn->tx_credits, wake = 1);  in pipe_rcv_status()
289 		if (pn->tx_fc != PN_MULTI_CREDIT_FLOW_CONTROL)  in pipe_rcv_status()
291 		atomic_add(wake = hdr->data[3], &pn->tx_credits);  in pipe_rcv_status()
306 	struct pep_sock *pn = pep_sk(sk);  in pipe_rcv_created()  local
310 	pn->rx_fc = pn->tx_fc = PN_LEGACY_FLOW_CONTROL;  in pipe_rcv_created()
322 			pn->tx_fc = data[0] & 3;  in pipe_rcv_created()
323 			pn->rx_fc = data[1] & 3;  in pipe_rcv_created()
335 	struct pep_sock *pn = pep_sk(sk);  in pipe_do_rcv()  local
362 			pn->init_enable = 0;  in pipe_do_rcv()
365 			pn->init_enable = 1;  in pipe_do_rcv()
373 		atomic_set(&pn->tx_credits, 0);  in pipe_do_rcv()
378 		if (skb_queue_len(&pn->ctrlreq_queue) >= PNPIPE_CTRLREQ_MAX) {  in pipe_do_rcv()
383 		queue = &pn->ctrlreq_queue;  in pipe_do_rcv()
391 		if (!pn_flow_safe(pn->rx_fc)) {  in pipe_do_rcv()
399 		if (pn->rx_credits == 0) {  in pipe_do_rcv()
404 		pn->rx_credits--;  in pipe_do_rcv()
422 		if (!pn->init_enable)  in pipe_do_rcv()
426 		if (!pn_flow_safe(pn->tx_fc)) {  in pipe_do_rcv()
427 			atomic_set(&pn->tx_credits, 1);  in pipe_do_rcv()
438 		pn->rx_credits = 0;  in pipe_do_rcv()
462 	struct pep_sock *pn = pep_sk(sk);  in pipe_destruct()  local
465 	skb_queue_purge(&pn->ctrlreq_queue);  in pipe_destruct()
484 	struct pep_sock *pn = pep_sk(sk);  in pep_connresp_rcv()  local
508 			pn->tx_fc = pipe_negotiate_fc(data + 2, len - 2);  in pep_connresp_rcv()
514 			pn->rx_fc = pipe_negotiate_fc(data + 2, len - 2);  in pep_connresp_rcv()
538 	struct pep_sock *pn = pep_sk(sk);  in pipe_start_flow_control()  local
540 	if (!pn_flow_safe(pn->tx_fc)) {  in pipe_start_flow_control()
541 		atomic_set(&pn->tx_credits, 1);  in pipe_start_flow_control()
551 	struct pep_sock *pn = pep_sk(sk);  in pipe_handler_do_rcv()  local
561 		if (!pn_flow_safe(pn->rx_fc)) {  in pipe_handler_do_rcv()
569 		if (pn->rx_credits == 0) {  in pipe_handler_do_rcv()
574 		pn->rx_credits--;  in pipe_handler_do_rcv()
591 		if (pn->init_enable == PN_PIPE_DISABLE)  in pipe_handler_do_rcv()
656 	struct pep_sock *pn = pep_sk(sk);  in pep_do_rcv()  local
673 	sknode = pep_find_pipe(&pn->hlist, &dst, pipe_handle);  in pep_do_rcv()
717 	struct pep_sock *pn = pep_sk(sk);  in pipe_do_remove()  local
728 	ph->pipe_handle = pn->pipe_handle;  in pipe_do_remove()
736 	struct pep_sock *pn = pep_sk(sk);  in pep_sock_close()  local
753 	ifindex = pn->ifindex;  in pep_sock_close()
754 	pn->ifindex = 0;  in pep_sock_close()
765 	struct pep_sock *pn = pep_sk(sk), *newpn;  in pep_sock_accept()  local
828 	newsk = pep_find_pipe(&pn->hlist, &dst, pipe_handle);  in pep_sock_accept()
875 	sk_add_node(newsk, &pn->hlist);  in pep_sock_accept()
885 	struct pep_sock *pn = pep_sk(sk);  in pep_sock_connect()  local
889 	if (pn->pipe_handle == PN_PIPE_INVALID_HANDLE)  in pep_sock_connect()
890 		pn->pipe_handle = 1; /* anything but INVALID_HANDLE */  in pep_sock_connect()
893 				pn->init_enable, data, 4);  in pep_sock_connect()
895 		pn->pipe_handle = PN_PIPE_INVALID_HANDLE;  in pep_sock_connect()
920 	struct pep_sock *pn = pep_sk(sk);  in pep_ioctl()  local
933 		    !skb_queue_empty(&pn->ctrlreq_queue))  in pep_ioctl()
934 			answ = skb_peek(&pn->ctrlreq_queue)->len;  in pep_ioctl()
960 	struct pep_sock *pn = pep_sk(sk);  in pep_init()  local
963 	INIT_HLIST_HEAD(&pn->hlist);  in pep_init()
964 	pn->listener = NULL;  in pep_init()
965 	skb_queue_head_init(&pn->ctrlreq_queue);  in pep_init()
966 	atomic_set(&pn->tx_credits, 0);  in pep_init()
967 	pn->ifindex = 0;  in pep_init()
968 	pn->peer_type = 0;  in pep_init()
969 	pn->pipe_handle = PN_PIPE_INVALID_HANDLE;  in pep_init()
970 	pn->rx_credits = 0;  in pep_init()
971 	pn->rx_fc = pn->tx_fc = PN_LEGACY_FLOW_CONTROL;  in pep_init()
972 	pn->init_enable = 1;  in pep_init()
973 	pn->aligned = 0;  in pep_init()
980 	struct pep_sock *pn = pep_sk(sk);  in pep_setsockopt()  local
997 		if (!pn->ifindex == !val)  in pep_setsockopt()
1007 				pn->ifindex = err;  in pep_setsockopt()
1011 			pn->ifindex = 0;  in pep_setsockopt()
1021 			pn->pipe_handle = val;  in pep_setsockopt()
1027 		pn->init_enable = !!val;  in pep_setsockopt()
1042 	struct pep_sock *pn = pep_sk(sk);  in pep_getsockopt()  local
1052 		val = pn->ifindex ? PNPIPE_ENCAP_IP : PNPIPE_ENCAP_NONE;  in pep_getsockopt()
1056 		val = pn->ifindex;  in pep_getsockopt()
1060 		val = pn->pipe_handle;  in pep_getsockopt()
1066 		val = pn->init_enable;  in pep_getsockopt()
1083 	struct pep_sock *pn = pep_sk(sk);  in pipe_skb_send()  local
1087 	if (pn_flow_safe(pn->tx_fc) &&  in pipe_skb_send()
1088 	    !atomic_add_unless(&pn->tx_credits, -1, 0)) {  in pipe_skb_send()
1093 	skb_push(skb, 3 + pn->aligned);  in pipe_skb_send()
1097 	if (pn->aligned) {  in pipe_skb_send()
1102 	ph->pipe_handle = pn->pipe_handle;  in pipe_skb_send()
1105 	if (err && pn_flow_safe(pn->tx_fc))  in pipe_skb_send()
1106 		atomic_inc(&pn->tx_credits);  in pipe_skb_send()
1113 	struct pep_sock *pn = pep_sk(sk);  in pep_sendmsg()  local
1132 	skb_reserve(skb, MAX_PHONET_HEADER + 3 + pn->aligned);  in pep_sendmsg()
1158 	done = atomic_read(&pn->tx_credits);  in pep_sendmsg()
1172 		done = sk_wait_event(sk, &timeo, atomic_read(&pn->tx_credits), &wait);  in pep_sendmsg()
1192 	struct pep_sock *pn = pep_sk(sk);  in pep_writeable()  local
1194 	return atomic_read(&pn->tx_credits);  in pep_writeable()
1252 		struct pep_sock *pn = pep_sk(sk);  in pep_recvmsg()  local
1256 		skb = skb_dequeue(&pn->ctrlreq_queue);  in pep_recvmsg()
1296 	struct pep_sock *pn = pep_sk(sk);  in pep_sock_unhash()  local
1301 	if (pn->listener != NULL) {  in pep_sock_unhash()
1302 		skparent = pn->listener;  in pep_sock_unhash()
1303 		pn->listener = NULL;  in pep_sock_unhash()
1306 		pn = pep_sk(skparent);  in pep_sock_unhash()
1314 	if (hlist_empty(&pn->hlist))  in pep_sock_unhash()
1315 		pn_sock_unhash(&pn->pn_sk.sk);  in pep_sock_unhash()