Home
last modified time | relevance | path

Searched refs:trans (Results 1 – 25 of 28) sorted by relevance

12

/net/rds/
Dtransport.c50 void rds_trans_register(struct rds_transport *trans) in rds_trans_register() argument
52 BUG_ON(strlen(trans->t_name) + 1 > TRANSNAMSIZ); in rds_trans_register()
56 if (transports[trans->t_type]) in rds_trans_register()
58 trans->t_type); in rds_trans_register()
60 transports[trans->t_type] = trans; in rds_trans_register()
61 printk(KERN_INFO "Registered RDS/%s transport\n", trans->t_name); in rds_trans_register()
68 void rds_trans_unregister(struct rds_transport *trans) in rds_trans_unregister() argument
72 transports[trans->t_type] = NULL; in rds_trans_unregister()
73 printk(KERN_INFO "Unregistered RDS/%s transport\n", trans->t_name); in rds_trans_unregister()
79 void rds_trans_put(struct rds_transport *trans) in rds_trans_put() argument
[all …]
Dconnection.c86 struct rds_transport *trans, in rds_conn_lookup() argument
94 conn->c_trans == trans && in rds_conn_lookup()
163 struct rds_transport *trans, in __rds_conn_create() argument
173 int npaths = (trans->t_mp_capable ? RDS_MPATH_WORKERS : 1); in __rds_conn_create()
176 conn = rds_conn_lookup(net, head, laddr, faddr, trans, tos, dev_if); in __rds_conn_create()
243 if (trans->t_prefer_loopback) { in __rds_conn_create()
250 trans = &rds_loop_transport; in __rds_conn_create()
264 conn->c_trans = trans; in __rds_conn_create()
276 ret = trans->conn_alloc(conn, GFP_ATOMIC); in __rds_conn_create()
287 strnlen(trans->t_name, sizeof(trans->t_name)) ? in __rds_conn_create()
[all …]
Dbind.c168 struct rds_transport *trans; in rds_bind() local
246 trans = rs->rs_transport; in rds_bind()
247 if (!trans->laddr_check || in rds_bind()
248 trans->laddr_check(sock_net(sock->sk), in rds_bind()
254 trans = rds_trans_get_preferred(sock_net(sock->sk), in rds_bind()
256 if (!trans) { in rds_bind()
262 rs->rs_transport = trans; in rds_bind()
Drdma_transport.c55 struct rds_transport *trans; in rds_rdma_cm_event_handler_cmn() local
64 trans = &rds_ib_transport; in rds_rdma_cm_event_handler_cmn()
85 ret = trans->cm_handle_connect(cm_id, event, isv6); in rds_rdma_cm_event_handler_cmn()
109 ret = trans->cm_initiate_connect(cm_id, isv6); in rds_rdma_cm_event_handler_cmn()
118 trans->cm_connect_complete(conn, event); in rds_rdma_cm_event_handler_cmn()
Dstats.c126 goto trans; in rds_stats_info()
140 trans: in rds_stats_info()
Drds.h767 struct rds_transport *trans,
773 struct rds_transport *trans,
1007 void rds_trans_register(struct rds_transport *trans);
1008 void rds_trans_unregister(struct rds_transport *trans);
1012 void rds_trans_put(struct rds_transport *trans);
Daf_rds.c488 int trans; in rds_getsockopt() local
519 trans = (rs->rs_transport ? rs->rs_transport->t_type : in rds_getsockopt()
521 if (put_user(trans, (int __user *)optval) || in rds_getsockopt()
/net/netfilter/
Dnf_tables_api.c155 struct nft_trans *trans; in nft_trans_alloc_gfp() local
157 trans = kzalloc(sizeof(struct nft_trans) + size, gfp); in nft_trans_alloc_gfp()
158 if (trans == NULL) in nft_trans_alloc_gfp()
161 INIT_LIST_HEAD(&trans->list); in nft_trans_alloc_gfp()
162 INIT_LIST_HEAD(&trans->binding_list); in nft_trans_alloc_gfp()
163 trans->msg_type = msg_type; in nft_trans_alloc_gfp()
164 trans->ctx = *ctx; in nft_trans_alloc_gfp()
166 return trans; in nft_trans_alloc_gfp()
175 static void nft_trans_list_del(struct nft_trans *trans) in nft_trans_list_del() argument
177 list_del(&trans->list); in nft_trans_list_del()
[all …]
Dnf_tables_offload.c509 struct nft_trans *trans) in nft_flow_rule_offload_abort() argument
514 list_for_each_entry_continue_reverse(trans, &nft_net->commit_list, list) { in nft_flow_rule_offload_abort()
515 if (trans->ctx.family != NFPROTO_NETDEV) in nft_flow_rule_offload_abort()
518 switch (trans->msg_type) { in nft_flow_rule_offload_abort()
520 if (!(trans->ctx.chain->flags & NFT_CHAIN_HW_OFFLOAD) || in nft_flow_rule_offload_abort()
521 nft_trans_chain_update(trans)) in nft_flow_rule_offload_abort()
524 err = nft_flow_offload_chain(trans->ctx.chain, NULL, in nft_flow_rule_offload_abort()
528 if (!(trans->ctx.chain->flags & NFT_CHAIN_HW_OFFLOAD)) in nft_flow_rule_offload_abort()
531 err = nft_flow_offload_chain(trans->ctx.chain, NULL, in nft_flow_rule_offload_abort()
535 if (!(trans->ctx.chain->flags & NFT_CHAIN_HW_OFFLOAD)) in nft_flow_rule_offload_abort()
[all …]
/net/sctp/
Dassociola.c1107 struct sctp_transport *trans; in sctp_assoc_update() local
1123 trans = list_entry(pos, struct sctp_transport, transports); in sctp_assoc_update()
1124 if (!sctp_assoc_lookup_paddr(new, &trans->ipaddr)) { in sctp_assoc_update()
1125 sctp_assoc_rm_peer(asoc, trans); in sctp_assoc_update()
1130 sctp_transport_reset(trans); in sctp_assoc_update()
1162 list_for_each_entry(trans, &new->peer.transport_addr_list, in sctp_assoc_update()
1164 if (!sctp_assoc_add_peer(asoc, &trans->ipaddr, in sctp_assoc_update()
1165 GFP_ATOMIC, trans->state)) in sctp_assoc_update()
1225 static u8 sctp_trans_score(const struct sctp_transport *trans) in sctp_trans_score() argument
1227 switch (trans->state) { in sctp_trans_score()
[all …]
Dsocket.c641 struct sctp_transport *trans; in sctp_send_asconf_add_ip() local
643 list_for_each_entry(trans, in sctp_send_asconf_add_ip()
645 trans->cwnd = min(4*asoc->pathmtu, max_t(__u32, in sctp_send_asconf_add_ip()
647 trans->ssthresh = asoc->peer.i.a_rwnd; in sctp_send_asconf_add_ip()
648 trans->rto = asoc->rto_initial; in sctp_send_asconf_add_ip()
649 sctp_max_rto(asoc, trans); in sctp_send_asconf_add_ip()
650 trans->rtt = trans->srtt = trans->rttvar = 0; in sctp_send_asconf_add_ip()
652 sctp_transport_route(trans, NULL, in sctp_send_asconf_add_ip()
2426 struct sctp_transport *trans, in sctp_apply_peer_addr_params() argument
2435 if (params->spp_flags & SPP_HB_DEMAND && trans) { in sctp_apply_peer_addr_params()
[all …]
Dtsnmap.c96 struct sctp_transport *trans) in sctp_tsnmap_mark() argument
115 if (trans) in sctp_tsnmap_mark()
116 trans->sack_generation = in sctp_tsnmap_mark()
117 trans->asoc->peer.sack_generation; in sctp_tsnmap_mark()
Dtransport.c789 unsigned long sctp_transport_timeout(struct sctp_transport *trans) in sctp_transport_timeout() argument
792 unsigned long timeout = trans->rto >> 1; in sctp_transport_timeout()
794 if (trans->state != SCTP_UNCONFIRMED && in sctp_transport_timeout()
795 trans->state != SCTP_PF) in sctp_transport_timeout()
796 timeout += trans->hbinterval; in sctp_transport_timeout()
Dsm_sideeffect.c141 struct sctp_transport *trans = asoc->peer.last_data_from; in sctp_gen_sack() local
147 (!trans && (asoc->param_flags & SPP_SACKDELAY_DISABLE)) || in sctp_gen_sack()
148 (trans && (trans->param_flags & SPP_SACKDELAY_DISABLE))) in sctp_gen_sack()
183 if (trans) { in sctp_gen_sack()
185 if (asoc->peer.sack_cnt >= trans->sackfreq - 1) in sctp_gen_sack()
189 trans->sackdelay; in sctp_gen_sack()
Dsm_make_chunk.c759 struct sctp_transport *trans; in sctp_make_sack() local
844 list_for_each_entry(trans, &asoc->peer.transport_addr_list, in sctp_make_sack()
846 trans->sack_generation = 0; in sctp_make_sack()
/net/vmw_vsock/
Dhyperv_transport.c242 struct hvsock *hvs = vsk->trans; in hvs_channel_cb()
341 hvs_new = vnew->trans; in hvs_open_connection()
344 hvs = vsock_sk(sk)->trans; in hvs_open_connection()
440 vsk->trans = hvs; in hvs_sock_init()
450 struct hvsock *h = vsk->trans; in hvs_connect()
480 hvs_shutdown_lock_held(vsk->trans, mode); in hvs_shutdown()
510 hvs_shutdown_lock_held(vsk->trans, SHUTDOWN_MASK); in hvs_close_lock_held()
534 struct hvsock *hvs = vsk->trans; in hvs_destruct()
589 struct hvsock *hvs = vsk->trans; in hvs_stream_dequeue()
629 struct hvsock *hvs = vsk->trans; in hvs_stream_enqueue()
[all …]
Dvirtio_transport_common.c218 vvs = vsk->trans; in virtio_transport_send_pkt_info()
309 struct virtio_vsock_sock *vvs = vsk->trans; in virtio_transport_stream_do_peek()
358 struct virtio_vsock_sock *vvs = vsk->trans; in virtio_transport_stream_do_dequeue()
427 struct virtio_vsock_sock *vvs = vsk->trans; in virtio_transport_seqpacket_do_dequeue()
524 struct virtio_vsock_sock *vvs = vsk->trans; in virtio_transport_seqpacket_enqueue()
550 struct virtio_vsock_sock *vvs = vsk->trans; in virtio_transport_stream_has_data()
563 struct virtio_vsock_sock *vvs = vsk->trans; in virtio_transport_seqpacket_has_data()
576 struct virtio_vsock_sock *vvs = vsk->trans; in virtio_transport_has_space()
588 struct virtio_vsock_sock *vvs = vsk->trans; in virtio_transport_stream_has_space()
608 vsk->trans = vvs; in virtio_transport_do_socket_init()
[all …]
Dvmci_transport.c854 struct vmci_transport *trans = client_data; in vmci_transport_peer_detach_cb() local
863 !vmci_handle_is_equal(trans->qp_handle, e_payload->handle)) in vmci_transport_peer_detach_cb()
872 spin_lock_bh(&trans->lock); in vmci_transport_peer_detach_cb()
873 if (!trans->sk) in vmci_transport_peer_detach_cb()
879 bh_lock_sock(trans->sk); in vmci_transport_peer_detach_cb()
881 vmci_transport_handle_detach(trans->sk); in vmci_transport_peer_detach_cb()
883 bh_unlock_sock(trans->sk); in vmci_transport_peer_detach_cb()
885 spin_unlock_bh(&trans->lock); in vmci_transport_peer_detach_cb()
1582 vsk->trans = kmalloc(sizeof(struct vmci_transport), GFP_KERNEL); in vmci_transport_socket_init()
1583 if (!vsk->trans) in vmci_transport_socket_init()
[all …]
Dvmci_transport.h30 #define vmci_trans(_vsk) ((struct vmci_transport *)((_vsk)->trans))
/net/xfrm/
Dxfrm_input.c766 struct xfrm_trans_tasklet *trans = container_of(work, struct xfrm_trans_tasklet, work); in xfrm_trans_reinject() local
771 spin_lock_bh(&trans->queue_lock); in xfrm_trans_reinject()
772 skb_queue_splice_init(&trans->queue, &queue); in xfrm_trans_reinject()
773 spin_unlock_bh(&trans->queue_lock); in xfrm_trans_reinject()
786 struct xfrm_trans_tasklet *trans; in xfrm_trans_queue_net() local
788 trans = this_cpu_ptr(&xfrm_trans_tasklet); in xfrm_trans_queue_net()
790 if (skb_queue_len(&trans->queue) >= READ_ONCE(netdev_max_backlog)) in xfrm_trans_queue_net()
797 spin_lock_bh(&trans->queue_lock); in xfrm_trans_queue_net()
798 __skb_queue_tail(&trans->queue, skb); in xfrm_trans_queue_net()
799 spin_unlock_bh(&trans->queue_lock); in xfrm_trans_queue_net()
[all …]
/net/llc/
Dllc_sap.c146 struct llc_sap_state_trans *trans, in llc_exec_sap_trans_actions() argument
150 const llc_sap_action_t *next_action = trans->ev_actions; in llc_exec_sap_trans_actions()
170 struct llc_sap_state_trans *trans; in llc_sap_next_state() local
174 trans = llc_find_sap_trans(sap, skb); in llc_sap_next_state()
175 if (!trans) in llc_sap_next_state()
182 rc = llc_exec_sap_trans_actions(sap, trans, skb); in llc_sap_next_state()
188 sap->state = trans->next_state; in llc_sap_next_state()
Dllc_conn.c36 struct llc_conn_state_trans *trans,
360 struct llc_conn_state_trans *trans; in llc_conn_service() local
365 trans = llc_qualify_conn_ev(sk, skb); in llc_conn_service()
366 if (trans) { in llc_conn_service()
367 rc = llc_exec_conn_trans_actions(sk, trans, skb); in llc_conn_service()
368 if (!rc && trans->next_state != NO_STATE_CHANGE) { in llc_conn_service()
369 llc->state = trans->next_state; in llc_conn_service()
434 struct llc_conn_state_trans *trans, in llc_exec_conn_trans_actions() argument
440 for (next_action = trans->ev_actions; in llc_exec_conn_trans_actions()
/net/9p/
Dtrans_rdma.c155 struct p9_trans_rdma *rdma = clnt->trans; in p9_rdma_show_options()
245 struct p9_trans_rdma *rdma = c->trans; in p9_cm_event_handler()
296 struct p9_trans_rdma *rdma = client->trans; in recv_done()
347 struct p9_trans_rdma *rdma = client->trans; in send_done()
388 struct p9_trans_rdma *rdma = client->trans; in post_recv()
423 struct p9_trans_rdma *rdma = client->trans; in rdma_request()
561 rdma = client->trans; in rdma_close()
609 struct p9_trans_rdma *rdma = client->trans; in rdma_cancelled()
666 client->trans = rdma; in rdma_create_trans()
Dtrans_fd.c232 ts = client->trans; in p9_fd_poll()
261 ts = client->trans; in p9_fd_read()
428 ts = client->trans; in p9_fd_write()
590 struct p9_trans_fd *ts = client->trans; in p9_conn_create()
672 struct p9_trans_fd *ts = client->trans; in p9_fd_request()
698 struct p9_trans_fd *ts = client->trans; in p9_fd_cancel()
719 struct p9_trans_fd *ts = client->trans; in p9_fd_cancelled()
854 client->trans = ts; in p9_fd_open()
890 client->trans = p; in p9_socket_open()
940 ts = client->trans; in p9_fd_close()
Dtrans_virtio.c108 struct virtio_chan *chan = client->trans; in p9_virtio_close()
261 struct virtio_chan *chan = client->trans; in p9_virtio_request()
400 struct virtio_chan *chan = client->trans; in p9_virtio_zc_request()
686 client->trans = (void *)chan; in p9_virtio_create()

12