Searched refs:trans (Results 1 - 25 of 37) sorted by relevance

12

/net/rds/
H A Dtransport.c43 int rds_trans_register(struct rds_transport *trans) argument
45 BUG_ON(strlen(trans->t_name) + 1 > TRANSNAMSIZ);
49 if (transports[trans->t_type])
51 trans->t_type);
53 transports[trans->t_type] = trans;
54 printk(KERN_INFO "Registered RDS/%s transport\n", trans->t_name);
63 void rds_trans_unregister(struct rds_transport *trans) argument
67 transports[trans->t_type] = NULL;
68 printk(KERN_INFO "Unregistered RDS/%s transport\n", trans
74 rds_trans_put(struct rds_transport *trans) argument
83 struct rds_transport *trans; local
114 struct rds_transport *trans; local
[all...]
H A Dconnection.c75 struct rds_transport *trans)
81 conn->c_trans == trans) {
121 struct rds_transport *trans, gfp_t gfp,
131 conn = rds_conn_lookup(head, laddr, faddr, trans);
177 if (is_outgoing && trans->t_prefer_loopback) {
182 trans = &rds_loop_transport;
186 conn->c_trans = trans;
188 ret = trans->conn_alloc(conn, gfp);
206 trans->t_name ? trans
73 rds_conn_lookup(struct hlist_head *head, __be32 laddr, __be32 faddr, struct rds_transport *trans) argument
120 __rds_conn_create(__be32 laddr, __be32 faddr, struct rds_transport *trans, gfp_t gfp, int is_outgoing) argument
249 rds_conn_create(__be32 laddr, __be32 faddr, struct rds_transport *trans, gfp_t gfp) argument
256 rds_conn_create_outgoing(__be32 laddr, __be32 faddr, struct rds_transport *trans, gfp_t gfp) argument
[all...]
H A Drdma_transport.c73 struct rds_transport *trans; local
80 trans = &rds_iw_transport;
82 trans = &rds_ib_transport;
103 ret = trans->cm_handle_connect(cm_id, event);
114 ret = trans->cm_initiate_connect(cm_id);
118 trans->cm_connect_complete(conn, event);
H A Dbind.c167 struct rds_transport *trans; local
184 trans = rds_trans_get_preferred(sin->sin_addr.s_addr);
185 if (!trans) {
193 rs->rs_transport = trans;
H A Dstats.c123 goto trans;
137 trans:
H A Drds.h616 struct rds_transport *trans, gfp_t gfp);
618 struct rds_transport *trans, gfp_t gfp);
803 int rds_trans_register(struct rds_transport *trans);
804 void rds_trans_unregister(struct rds_transport *trans);
806 void rds_trans_put(struct rds_transport *trans);
/net/rxrpc/
H A Dar-transport.c38 struct rxrpc_transport *trans; local
42 trans = kzalloc(sizeof(struct rxrpc_transport), gfp);
43 if (trans) {
44 trans->local = local;
45 trans->peer = peer;
46 INIT_LIST_HEAD(&trans->link);
47 trans->bundles = RB_ROOT;
48 trans->client_conns = RB_ROOT;
49 trans->server_conns = RB_ROOT;
50 skb_queue_head_init(&trans
82 struct rxrpc_transport *trans, *candidate; local
156 struct rxrpc_transport *trans; local
186 rxrpc_put_transport(struct rxrpc_transport *trans) argument
206 rxrpc_cleanup_transport(struct rxrpc_transport *trans) argument
222 struct rxrpc_transport *trans, *_p; local
[all...]
H A Dar-proc.c49 struct rxrpc_transport *trans; local
62 trans = call->conn->trans;
65 &trans->local->srx.transport.sin.sin_addr,
66 ntohs(trans->local->srx.transport.sin.sin_port));
69 &trans->peer->srx.transport.sin.sin_addr,
70 ntohs(trans->peer->srx.transport.sin.sin_port));
132 struct rxrpc_transport *trans; local
145 trans = conn->trans;
[all...]
H A Dar-connection.c70 struct rxrpc_transport *trans,
79 rx, key_serial(key), trans->debug_id, ntohs(service_id));
81 if (rx->trans == trans && rx->bundle) {
88 spin_lock(&trans->client_lock);
90 p = trans->bundles.rb_node;
102 spin_unlock(&trans->client_lock);
115 spin_lock(&trans->client_lock);
117 pp = &trans->bundles.rb_node;
136 rb_insert_color(&bundle->node, &trans
69 rxrpc_get_bundle(struct rxrpc_sock *rx, struct rxrpc_transport *trans, struct key *key, __be16 service_id, gfp_t gfp) argument
175 rxrpc_put_bundle(struct rxrpc_transport *trans, struct rxrpc_conn_bundle *bundle) argument
335 rxrpc_connect_exclusive(struct rxrpc_sock *rx, struct rxrpc_transport *trans, __be16 service_id, struct rxrpc_call *call, gfp_t gfp) argument
429 rxrpc_connect_call(struct rxrpc_sock *rx, struct rxrpc_transport *trans, struct rxrpc_conn_bundle *bundle, struct rxrpc_call *call, gfp_t gfp) argument
622 rxrpc_incoming_connection(struct rxrpc_transport *trans, struct rxrpc_header *hdr, gfp_t gfp) argument
753 rxrpc_find_connection(struct rxrpc_transport *trans, struct rxrpc_header *hdr) argument
[all...]
H A Dar-error.c31 struct rxrpc_transport *trans; local
62 trans = rxrpc_find_transport(local, peer);
63 if (!trans) {
66 _leave(" [no trans]");
111 skb_queue_tail(&trans->error_queue, skb);
112 rxrpc_queue_work(&trans->error_handler);
124 struct rxrpc_transport *trans = local
131 skb = skb_dequeue(&trans->error_queue);
211 spin_lock_bh(&trans->peer->lock);
212 trans
[all...]
H A Daf_rxrpc.c229 struct rxrpc_transport *trans; local
249 trans = rxrpc_get_transport(rx->local, peer, gfp);
251 _leave(" = %p", trans);
252 return trans;
276 struct rxrpc_transport *trans; local
286 trans = rxrpc_name_to_transport(sock, (struct sockaddr *) srx,
288 if (IS_ERR(trans)) {
289 call = ERR_CAST(trans);
290 trans = NULL;
294 trans
378 struct rxrpc_transport *trans; local
447 struct rxrpc_transport *trans; local
[all...]
H A Dar-output.c133 struct rxrpc_transport *trans, struct msghdr *msg,
147 ASSERT(trans != NULL);
155 if (trans) {
165 bundle = rxrpc_get_bundle(rx, trans, key, service_id,
171 call = rxrpc_get_client_call(rx, trans, bundle, user_call_ID,
173 if (trans)
174 rxrpc_put_bundle(trans, bundle);
338 int rxrpc_send_packet(struct rxrpc_transport *trans, struct sk_buff *skb) argument
349 msg.msg_name = &trans->peer->srx.transport.sin;
350 msg.msg_namelen = sizeof(trans
132 rxrpc_client_sendmsg(struct kiocb *iocb, struct rxrpc_sock *rx, struct rxrpc_transport *trans, struct msghdr *msg, size_t len) argument
[all...]
H A Dar-call.c124 call->conn->trans->local, addr_size,
253 struct rxrpc_transport *trans,
263 ASSERT(trans != NULL);
274 ret = rxrpc_connect_call(rx, trans, bundle, call, gfp);
282 call->local = trans->local;
286 trans->peer->srx.transport.sin.sin_addr.s_addr;
290 trans->peer->srx.transport.sin6.sin6_addr.in6_u.u6_addr8,
300 spin_lock(&call->conn->trans->peer->lock);
301 list_add(&call->error_link, &call->conn->trans->peer->error_targets);
302 spin_unlock(&call->conn->trans
251 rxrpc_alloc_client_call( struct rxrpc_sock *rx, struct rxrpc_transport *trans, struct rxrpc_conn_bundle *bundle, gfp_t gfp) argument
315 rxrpc_get_client_call(struct rxrpc_sock *rx, struct rxrpc_transport *trans, struct rxrpc_conn_bundle *bundle, unsigned long user_call_ID, int create, gfp_t gfp) argument
[all...]
H A Dar-accept.c79 struct rxrpc_transport *trans; local
107 trans = rxrpc_get_transport(local, peer, GFP_NOIO);
109 if (IS_ERR(trans)) {
110 _debug("no trans");
115 conn = rxrpc_incoming_connection(trans, &sp->hdr, GFP_NOIO);
116 rxrpc_put_transport(trans);
H A Dar-input.c571 rxrpc_reject_packet(call->conn->trans->local, skb);
601 struct rxrpc_transport *trans; local
609 trans = rxrpc_find_transport(local, peer);
611 if (!trans)
614 conn = rxrpc_find_connection(trans, &sp->hdr);
615 rxrpc_put_transport(trans);
/net/netfilter/
H A Dnf_tables_api.c112 struct nft_trans *trans; local
114 trans = kzalloc(sizeof(struct nft_trans) + size, GFP_KERNEL);
115 if (trans == NULL)
118 trans->msg_type = msg_type;
119 trans->ctx = *ctx;
121 return trans;
124 static void nft_trans_destroy(struct nft_trans *trans) argument
126 list_del(&trans->list);
127 kfree(trans);
144 struct nft_trans *trans; local
171 struct nft_trans *trans; local
248 struct nft_trans *trans; local
262 struct nft_trans *trans; local
297 struct nft_trans *trans; local
600 struct nft_trans *trans; local
1236 struct nft_trans *trans; local
1886 struct nft_trans *trans = NULL; local
2252 struct nft_trans *trans; local
2819 nft_ctx_init_from_elemattr(struct nft_ctx *ctx, const struct sk_buff *skb, const struct nlmsghdr *nlh, const struct nlattr * const nla[], bool trans) argument
3078 struct nft_trans *trans; local
3096 struct nft_trans *trans; local
3233 struct nft_trans *trans; local
3466 nft_chain_commit_update(struct nft_trans *trans) argument
3487 nf_tables_commit_release(struct nft_trans *trans) argument
3509 struct nft_trans *trans, *next; local
3622 nf_tables_abort_release(struct nft_trans *trans) argument
3644 struct nft_trans *trans, *next; local
[all...]
/net/sctp/
H A Dassociola.c1094 struct sctp_transport *trans; local
1108 trans = list_entry(pos, struct sctp_transport, transports);
1109 if (!sctp_assoc_lookup_paddr(new, &trans->ipaddr)) {
1110 sctp_assoc_rm_peer(asoc, trans);
1115 sctp_transport_reset(trans);
1147 list_for_each_entry(trans, &new->peer.transport_addr_list,
1149 if (!sctp_assoc_lookup_paddr(asoc, &trans->ipaddr))
1150 sctp_assoc_add_peer(asoc, &trans->ipaddr,
1151 GFP_ATOMIC, trans->state);
1224 static u8 sctp_trans_score(const struct sctp_transport *trans) argument
1268 struct sctp_transport *trans = asoc->peer.retran_path; local
1306 struct sctp_transport *trans, *trans_pri = NULL, *trans_sec = NULL; local
[all...]
H A Dtsnmap.c111 struct sctp_transport *trans)
130 if (trans)
131 trans->sack_generation =
132 trans->asoc->peer.sack_generation;
110 sctp_tsnmap_mark(struct sctp_tsnmap *map, __u32 tsn, struct sctp_transport *trans) argument
H A Dsocket.c589 struct sctp_transport *trans; local
591 list_for_each_entry(trans,
594 dst_release(trans->dst);
595 trans->cwnd = min(4*asoc->pathmtu, max_t(__u32,
597 trans->ssthresh = asoc->peer.i.a_rwnd;
598 trans->rto = asoc->rto_initial;
599 sctp_max_rto(asoc, trans);
600 trans->rtt = trans->srtt = trans
2363 sctp_apply_peer_addr_params(struct sctp_paddrparams *params, struct sctp_transport *trans, struct sctp_association *asoc, struct sctp_sock *sp, int hb_change, int pmtud_change, int sackdelay_change) argument
2510 struct sctp_transport *trans = NULL; local
2632 struct sctp_transport *trans = NULL; local
2859 struct sctp_transport *trans; local
3607 struct sctp_transport *trans; local
4600 struct sctp_transport *trans = NULL; local
5811 struct sctp_transport *trans; local
[all...]
H A Dtransport.c597 unsigned long sctp_transport_timeout(struct sctp_transport *trans) argument
600 unsigned long timeout = (trans->rto >> 1) + prandom_u32_max(trans->rto);
602 if (trans->state != SCTP_UNCONFIRMED &&
603 trans->state != SCTP_PF)
604 timeout += trans->hbinterval;
/net/llc/
H A Dllc_sap.c138 * @trans: pointer to transition that it's actions must be performed
145 struct llc_sap_state_trans *trans,
149 llc_sap_action_t *next_action = trans->ev_actions;
169 struct llc_sap_state_trans *trans; local
173 trans = llc_find_sap_trans(sap, skb);
174 if (!trans)
181 rc = llc_exec_sap_trans_actions(sap, trans, skb);
187 sap->state = trans->next_state;
144 llc_exec_sap_trans_actions(struct llc_sap *sap, struct llc_sap_state_trans *trans, struct sk_buff *skb) argument
H A Dllc_conn.c36 struct llc_conn_state_trans *trans,
379 struct llc_conn_state_trans *trans; local
384 trans = llc_qualify_conn_ev(sk, skb);
385 if (trans) {
386 rc = llc_exec_conn_trans_actions(sk, trans, skb);
387 if (!rc && trans->next_state != NO_STATE_CHANGE) {
388 llc->state = trans->next_state;
446 * @trans: transition that it's actions must be performed
453 struct llc_conn_state_trans *trans,
459 for (next_action = trans
452 llc_exec_conn_trans_actions(struct sock *sk, struct llc_conn_state_trans *trans, struct sk_buff *skb) argument
[all...]
/net/vmw_vsock/
H A Dvmci_transport.h38 #define vmci_trans(_vsk) ((struct vmci_transport *)((_vsk)->trans))
/net/9p/
H A Dtrans_rdma.c231 struct p9_trans_rdma *rdma = c->trans;
338 struct p9_trans_rdma *rdma = client->trans;
397 struct p9_trans_rdma *rdma = client->trans;
425 struct p9_trans_rdma *rdma = client->trans;
559 rdma = client->trans;
605 struct p9_trans_rdma *rdma = client->trans;
643 client->trans = rdma;
H A Dtrans_fd.c56 * @rfd: file descriptor for reading (trans=fd)
57 * @wfd: file descriptor for writing (trans=fd)
58 * @port: port to connect to (trans=tcp)
238 ts = client->trans;
277 ts = client->trans;
420 ts = client->trans;
581 struct p9_trans_fd *ts = client->trans;
663 struct p9_trans_fd *ts = client->trans;
803 client->trans = ts;
830 client->trans
[all...]

Completed in 233 milliseconds

12