/net/rxrpc/ |
H A D | ar-call.c | 1 /* RxRPC individual remote procedure call handling 22 * Maximum lifetime of a call (in jiffies). 27 * Time till dead call expires after last use (in jiffies). 103 * Add a call to the hashtable 105 static void rxrpc_call_hash_add(struct rxrpc_call *call) argument 111 switch (call->proto) { 113 addr_size = sizeof(call->peer_ip.ipv4_addr); 116 addr_size = sizeof(call->peer_ip.ipv6_addr); 121 key = rxrpc_call_hashfunc(call->in_clientflag, call 137 rxrpc_call_hash_del(struct rxrpc_call *call) argument 162 struct rxrpc_call *call = NULL; local 204 struct rxrpc_call *call; local 257 struct rxrpc_call *call; local 322 struct rxrpc_call *call, *candidate; local 420 struct rxrpc_call *call, *candidate; local 577 struct rxrpc_call *call; local 613 rxrpc_release_call(struct rxrpc_call *call) argument 741 struct rxrpc_call *call = (struct rxrpc_call *) _call; local 755 rxrpc_mark_call_released(struct rxrpc_call *call) argument 782 struct rxrpc_call *call; local 811 __rxrpc_put_call(struct rxrpc_call *call) argument 830 rxrpc_cleanup_call(struct rxrpc_call *call) argument 899 struct rxrpc_call *call = local 921 struct rxrpc_call *call; local 970 struct rxrpc_call *call = (struct rxrpc_call *) _call; local 990 struct rxrpc_call *call = (struct rxrpc_call *) _call; local 1007 struct rxrpc_call *call = (struct rxrpc_call *) _call; local [all...] |
H A D | ar-skbuff.c | 24 static void rxrpc_request_final_ACK(struct rxrpc_call *call) argument 26 /* the call may be aborted before we have a chance to ACK it */ 27 write_lock(&call->state_lock); 29 switch (call->state) { 31 call->state = RXRPC_CALL_CLIENT_FINAL_ACK; 34 /* get an extra ref on the call for the final-ACK generator to 36 rxrpc_get_call(call); 37 set_bit(RXRPC_CALL_ACK_FINAL, &call->events); 38 if (try_to_del_timer_sync(&call->ack_timer) >= 0) 39 rxrpc_queue_call(call); 54 rxrpc_hard_ACK_data(struct rxrpc_call *call, struct rxrpc_skb_priv *sp) argument 108 struct rxrpc_call *call = sp->call; local [all...] |
H A D | ar-ack.c | 93 void __rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, argument 102 call->debug_id, rxrpc_acks(ack_reason), ntohl(serial), 105 if (prior < rxrpc_ack_priority[call->ackr_reason]) { 113 if (prior == rxrpc_ack_priority[call->ackr_reason]) { 115 call->ackr_serial = serial; 121 call->ackr_reason = ack_reason; 122 call->ackr_serial = serial; 154 if (!timer_pending(&call->ack_timer) || 155 time_after(call->ack_timer.expires, expiry)) 156 mod_timer(&call 172 rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, __be32 serial, bool immediate) argument 187 rxrpc_set_resend(struct rxrpc_call *call, u8 resend, unsigned long resend_at) argument 215 rxrpc_resend(struct rxrpc_call *call) argument 285 rxrpc_resend_timer(struct rxrpc_call *call) argument 336 rxrpc_process_soft_ACKs(struct rxrpc_call *call, struct rxrpc_ackpacket *ack, struct sk_buff *skb) argument 424 rxrpc_rotate_tx_window(struct rxrpc_call *call, u32 hard) argument 452 rxrpc_clear_tx_window(struct rxrpc_call *call) argument 460 rxrpc_drain_rx_oos_queue(struct rxrpc_call *call) argument 516 rxrpc_insert_oos_packet(struct rxrpc_call *call, struct sk_buff *skb) argument 568 rxrpc_zap_tx_window(struct rxrpc_call *call) argument 598 rxrpc_extract_ackinfo(struct rxrpc_call *call, struct sk_buff *skb, unsigned int latest, int nAcks) argument 630 rxrpc_process_rx_queue(struct rxrpc_call *call, u32 *_abort_code) argument 826 rxrpc_post_message(struct rxrpc_call *call, u32 mark, u32 error, bool fatal) argument 879 struct rxrpc_call *call = local [all...] |
H A D | ar-input.c | 36 * - the caller must hold a lock on call->lock 42 int rxrpc_queue_rcv_skb(struct rxrpc_call *call, struct sk_buff *skb, argument 46 struct rxrpc_sock *rx = call->socket; 55 ASSERTCMP(sp->call, ==, call); 57 /* if we've already posted the terminal message for a call, then we 59 if (test_bit(RXRPC_CALL_TERMINAL_MSG, &call->flags)) { 61 ASSERTCMP(call->state, >=, RXRPC_CALL_COMPLETE); 63 sp->call = NULL; 64 rxrpc_put_call(call); 134 rxrpc_fast_process_data(struct rxrpc_call *call, struct sk_buff *skb, u32 seq) argument 280 rxrpc_assume_implicit_ackall(struct rxrpc_call *call, u32 serial) argument 310 rxrpc_fast_process_packet(struct rxrpc_call *call, struct sk_buff *skb) argument 450 rxrpc_process_jumbo_packet(struct rxrpc_call *call, struct sk_buff *jumbo) argument 519 rxrpc_post_packet_to_call(struct rxrpc_call *call, struct sk_buff *skb) argument 720 struct rxrpc_call *call; local [all...] |
H A D | ar-output.c | 28 struct rxrpc_call *call, 106 * abort a call, sending an ABORT packet to the peer 108 static void rxrpc_send_abort(struct rxrpc_call *call, u32 abort_code) argument 110 write_lock_bh(&call->state_lock); 112 if (call->state <= RXRPC_CALL_COMPLETE) { 113 call->state = RXRPC_CALL_LOCALLY_ABORTED; 114 call->abort_code = abort_code; 115 set_bit(RXRPC_CALL_ABORT, &call->events); 116 del_timer_sync(&call->resend_timer); 117 del_timer_sync(&call 138 struct rxrpc_call *call; local 213 rxrpc_kernel_send_data(struct rxrpc_call *call, struct msghdr *msg, size_t len) argument 255 rxrpc_kernel_abort_call(struct rxrpc_call *call, u32 abort_code) argument 281 struct rxrpc_call *call; local 402 rxrpc_wait_for_tx_window(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo) argument 440 rxrpc_instant_resend(struct rxrpc_call *call) argument 456 rxrpc_queue_packet(struct rxrpc_call *call, struct sk_buff *skb, bool last) argument 526 rxrpc_send_data(struct kiocb *iocb, struct rxrpc_sock *rx, struct rxrpc_call *call, struct msghdr *msg, size_t len) argument [all...] |
H A D | ar-accept.c | 1 /* incoming call handling 70 * accept an incoming call that needs peer, transport and/or connection setting 82 struct rxrpc_call *call; local 123 call = rxrpc_incoming_call(rx, conn, &sp->hdr, GFP_NOIO); 125 if (IS_ERR(call)) { 126 _debug("no call"); 127 ret = PTR_ERR(call); 131 /* attach the call to the socket */ 137 if (!test_and_set_bit(RXRPC_CALL_INIT_ACCEPT, &call->flags)) { 138 rxrpc_get_call(call); 322 struct rxrpc_call *call; local 415 struct rxrpc_call *call; local 483 struct rxrpc_call *call; local [all...] |
H A D | ar-recvmsg.c | 20 * removal a call's user ID from the socket tree to make the user ID available 21 * again and so that it won't be seen again in association with that call 23 void rxrpc_remove_user_ID(struct rxrpc_sock *rx, struct rxrpc_call *call) argument 25 _debug("RELEASE CALL %d", call->debug_id); 27 if (test_bit(RXRPC_CALL_HAS_USERID, &call->flags)) { 29 rb_erase(&call->sock_node, &call->socket->calls); 30 clear_bit(RXRPC_CALL_HAS_USERID, &call->flags); 34 read_lock_bh(&call->state_lock); 35 if (!test_bit(RXRPC_CALL_RELEASED, &call 50 struct rxrpc_call *call = NULL, *continue_call = NULL; local 365 struct rxrpc_call *call = sp->call; local [all...] |
H A D | ar-proc.c | 50 struct rxrpc_call *call; local 61 call = list_entry(v, struct rxrpc_call, link); 62 trans = call->conn->trans; 77 ntohs(call->conn->service_id), 78 ntohl(call->conn->cid), 79 ntohl(call->call_id), 80 call->conn->in_clientflag ? "Svc" : "Clt", 81 atomic_read(&call->usage), 82 rxrpc_call_states[call->state], 83 call [all...] |
H A D | ar-connevent.c | 31 struct rxrpc_call *call; local 39 call = rb_entry(p, struct rxrpc_call, conn_node); 40 write_lock(&call->state_lock); 41 if (call->state <= RXRPC_CALL_COMPLETE) { 42 call->state = state; 43 call->abort_code = abort_code; 45 set_bit(RXRPC_CALL_CONN_ABORT, &call->events); 47 set_bit(RXRPC_CALL_RCVD_ABORT, &call->events); 48 rxrpc_queue_call(call); 50 write_unlock(&call 129 rxrpc_call_is_secure(struct rxrpc_call *call) argument [all...] |
H A D | ar-error.c | 207 struct rxrpc_call *call, *_n; local 214 list_for_each_entry_safe(call, _n, &trans->peer->error_targets, 216 write_lock(&call->state_lock); 217 if (call->state != RXRPC_CALL_COMPLETE && 218 call->state < RXRPC_CALL_NETWORK_ERROR) { 219 call->state = RXRPC_CALL_NETWORK_ERROR; 220 set_bit(RXRPC_CALL_RCVD_ERROR, &call->events); 221 rxrpc_queue_call(call); 223 write_unlock(&call->state_lock); 224 list_del_init(&call [all...] |
H A D | ar-security.c | 226 int rxrpc_secure_packet(const struct rxrpc_call *call, argument 231 if (call->conn->security) 232 return call->conn->security->secure_packet( 233 call, skb, data_size, sechdr); 240 int rxrpc_verify_packet(const struct rxrpc_call *call, struct sk_buff *skb, argument 243 if (call->conn->security) 244 return call->conn->security->verify_packet( 245 call, skb, _abort_code);
|
H A D | rxkad.c | 153 static int rxkad_secure_packet_auth(const struct rxrpc_call *call, argument 180 desc.tfm = call->conn->cipher; 197 static int rxkad_secure_packet_encrypt(const struct rxrpc_call *call, argument 224 token = call->conn->key->payload.data; 226 desc.tfm = call->conn->cipher; 239 len = data_size + call->conn->size_align - 1; 240 len &= ~(call->conn->size_align - 1); 253 static int rxkad_secure_packet(const struct rxrpc_call *call, argument 272 call->debug_id, key_serial(call 327 rxkad_verify_packet_auth(const struct rxrpc_call *call, struct sk_buff *skb, u32 *_abort_code) argument 401 rxkad_verify_packet_encrypt(const struct rxrpc_call *call, struct sk_buff *skb, u32 *_abort_code) argument 486 rxkad_verify_packet(const struct rxrpc_call *call, struct sk_buff *skb, u32 *_abort_code) argument [all...] |
H A D | Makefile | 9 ar-call.o \
|
H A D | ar-connection.c | 300 * add a call to a connection's call-by-ID tree 303 struct rxrpc_call *call) 311 call_id = call->call_id; 326 rb_link_node(&call->conn_node, parent, p); 327 rb_insert_color(&call->conn_node, &conn->calls); 333 * connect a call on an exclusive connection 338 struct rxrpc_call *call, 393 * call to it 404 conn->channels[chan] = call; 302 rxrpc_add_call_ID_to_conn(struct rxrpc_connection *conn, struct rxrpc_call *call) 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 [all...] |
H A D | af_rxrpc.c | 256 * rxrpc_kernel_begin_call - Allow a kernel service to begin a call 257 * @sock: The socket on which to make the call 262 * Allow a kernel service to begin a call on the nominated socket. This just 264 * call IDs as appropriate. The call to be used is returned. 277 struct rxrpc_call *call; local 289 call = ERR_CAST(trans); 296 call = ERR_PTR(-ENOTCONN); 313 call = ERR_CAST(bundle); 317 call 337 rxrpc_kernel_end_call(struct rxrpc_call *call) argument [all...] |
H A D | ar-internal.h | 83 struct rxrpc_call *call; /* call with which associated */ member in struct:rxrpc_skb_priv 100 RXRPC_CMD_ACCEPT, /* [server] accept incoming call */ 101 RXRPC_CMD_REJECT_BUSY, /* [server] reject a call as busy */ 153 struct work_struct acceptor; /* incoming call processor */ 274 unsigned int call_counter; /* call ID counter */ 294 * RxRPC call definition 298 struct rxrpc_connection *conn; /* connection carrying call */ 300 struct timer_list lifetimer; /* lifetime remaining on call */ 304 struct work_struct destroyer; /* call destroye 418 rxrpc_abort_call(struct rxrpc_call *call, u32 abort_code) argument [all...] |
/net/ax25/ |
H A D | ax25_uid.c | 84 if (ax25cmp(&sax->sax25_call, &ax25_uid->call) == 0) { 113 ax25_uid->call = sax->sax25_call; 128 if (ax25cmp(&sax->sax25_call, &ax25_uid->call) == 0) 180 ax2asc(buf, &pt->call));
|
/net/netfilter/ |
H A D | nfnetlink_acct.c | 374 [NFNL_MSG_ACCT_NEW] = { .call = nfnl_acct_new, 377 [NFNL_MSG_ACCT_GET] = { .call = nfnl_acct_get, 380 [NFNL_MSG_ACCT_GET_CTRZERO] = { .call = nfnl_acct_get, 383 [NFNL_MSG_ACCT_DEL] = { .call = nfnl_acct_del,
|
H A D | nfnetlink_cttimeout.c | 517 [IPCTNL_MSG_TIMEOUT_NEW] = { .call = cttimeout_new_timeout, 520 [IPCTNL_MSG_TIMEOUT_GET] = { .call = cttimeout_get_timeout, 523 [IPCTNL_MSG_TIMEOUT_DELETE] = { .call = cttimeout_del_timeout, 526 [IPCTNL_MSG_TIMEOUT_DEFAULT_SET]= { .call = cttimeout_default_set, 529 [IPCTNL_MSG_TIMEOUT_DEFAULT_GET]= { .call = cttimeout_default_get,
|
H A D | xt_osf.c | 139 .call = xt_osf_add_callback, 144 .call = xt_osf_remove_callback,
|
H A D | nfnetlink_cthelper.c | 625 [NFNL_MSG_CTHELPER_NEW] = { .call = nfnl_cthelper_new, 628 [NFNL_MSG_CTHELPER_GET] = { .call = nfnl_cthelper_get, 631 [NFNL_MSG_CTHELPER_DEL] = { .call = nfnl_cthelper_del,
|
H A D | nfnetlink.c | 214 else if (nc->call) 215 err = nc->call(net->nfnl, skb, nlh,
|
H A D | nf_conntrack_netlink.c | 3103 [IPCTNL_MSG_CT_NEW] = { .call = ctnetlink_new_conntrack, 3106 [IPCTNL_MSG_CT_GET] = { .call = ctnetlink_get_conntrack, 3109 [IPCTNL_MSG_CT_DELETE] = { .call = ctnetlink_del_conntrack, 3112 [IPCTNL_MSG_CT_GET_CTRZERO] = { .call = ctnetlink_get_conntrack, 3115 [IPCTNL_MSG_CT_GET_STATS_CPU] = { .call = ctnetlink_stat_ct_cpu }, 3116 [IPCTNL_MSG_CT_GET_STATS] = { .call = ctnetlink_stat_ct }, 3117 [IPCTNL_MSG_CT_GET_DYING] = { .call = ctnetlink_get_ct_dying }, 3118 [IPCTNL_MSG_CT_GET_UNCONFIRMED] = { .call = ctnetlink_get_ct_unconfirmed }, 3122 [IPCTNL_MSG_EXP_GET] = { .call = ctnetlink_get_expect, 3125 [IPCTNL_MSG_EXP_NEW] = { .call [all...] |
/net/netfilter/ipset/ |
H A D | ip_set_core.c | 646 * Routines to call by external subsystems, which do not 647 * call nfnl_lock for us. 956 /* Must call it without holding any lock */ 977 * External systems (i.e. xt_set) must call 1759 .call = ip_set_none, 1763 .call = ip_set_create, 1768 .call = ip_set_destroy, 1773 .call = ip_set_flush, 1778 .call = ip_set_rename, 1783 .call [all...] |
/net/ |
H A D | compat.c | 799 COMPAT_SYSCALL_DEFINE2(socketcall, int, call, u32 __user *, args) 805 if (call < SYS_SOCKET || call > SYS_SENDMMSG) 807 if (copy_from_user(a, args, nas[call])) 812 switch (call) {
|