/net/rds/ |
H A D | rdma_transport.c | 73 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 D | transport.c | 43 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 D | bind.c | 167 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 D | connection.c | 75 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...] |
/net/rxrpc/ |
H A D | ar-error.c | 31 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 D | ar-transport.c | 38 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 D | ar-proc.c | 49 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 D | ar-accept.c | 79 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 D | ar-input.c | 571 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);
|
H A D | ar-call.c | 124 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 D | ar-connection.c | 70 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 D | ar-output.c | 133 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 D | af_rxrpc.c | 229 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 D | ar-internal.h | 57 struct rxrpc_transport *trans; /* transport handler */ member in struct:rxrpc_sock 241 struct rxrpc_transport *trans; /* transport session */ member in struct:rxrpc_connection
|
/net/sctp/ |
H A D | tsnmap.c | 111 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 D | transport.c | 597 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;
|
H A D | sm_sideeffect.c | 158 struct sctp_transport *trans = asoc->peer.last_data_from; local 162 (!trans && (asoc->param_flags & SPP_SACKDELAY_DISABLE)) || 163 (trans && (trans->param_flags & SPP_SACKDELAY_DISABLE))) 198 if (trans) { 200 if (asoc->peer.sack_cnt >= trans->sackfreq - 1) 204 trans->sackdelay;
|
H A D | associola.c | 1094 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 D | sm_make_chunk.c | 762 struct sctp_transport *trans; local 843 list_for_each_entry(trans, &asoc->peer.transport_addr_list, 845 trans->sack_generation = 0;
|
H A D | socket.c | 589 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...] |
/net/llc/ |
H A D | llc_sap.c | 138 * @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 D | llc_conn.c | 36 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/netfilter/ |
H A D | nf_tables_api.c | 112 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/mac80211/ |
H A D | mlme.c | 3418 u16 trans = 1; local 3428 trans = auth_data->sae_trans; 3430 auth_data->expected_transaction = trans; 3437 ieee80211_send_auth(sdata, trans, auth_data->algorithm, status,
|