Home
last modified time | relevance | path

Searched refs:call (Results 1 – 25 of 37) sorted by relevance

12

/net/rxrpc/
Dar-call.c105 static void rxrpc_call_hash_add(struct rxrpc_call *call) in rxrpc_call_hash_add() argument
111 switch (call->proto) { in rxrpc_call_hash_add()
113 addr_size = sizeof(call->peer_ip.ipv4_addr); in rxrpc_call_hash_add()
116 addr_size = sizeof(call->peer_ip.ipv6_addr); in rxrpc_call_hash_add()
121 key = rxrpc_call_hashfunc(call->in_clientflag, call->cid, in rxrpc_call_hash_add()
122 call->call_id, call->epoch, in rxrpc_call_hash_add()
123 call->service_id, call->proto, in rxrpc_call_hash_add()
124 call->conn->trans->local, addr_size, in rxrpc_call_hash_add()
125 call->peer_ip.ipv6_addr); in rxrpc_call_hash_add()
127 call->hash_key = key; in rxrpc_call_hash_add()
[all …]
Dar-ack.c93 void __rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, in __rxrpc_propose_ACK() argument
102 call->debug_id, rxrpc_acks(ack_reason), ntohl(serial), in __rxrpc_propose_ACK()
105 if (prior < rxrpc_ack_priority[call->ackr_reason]) { in __rxrpc_propose_ACK()
113 if (prior == rxrpc_ack_priority[call->ackr_reason]) { in __rxrpc_propose_ACK()
115 call->ackr_serial = serial; in __rxrpc_propose_ACK()
121 call->ackr_reason = ack_reason; in __rxrpc_propose_ACK()
122 call->ackr_serial = serial; in __rxrpc_propose_ACK()
154 if (!timer_pending(&call->ack_timer) || in __rxrpc_propose_ACK()
155 time_after(call->ack_timer.expires, expiry)) in __rxrpc_propose_ACK()
156 mod_timer(&call->ack_timer, expiry); in __rxrpc_propose_ACK()
[all …]
Dar-input.c42 int rxrpc_queue_rcv_skb(struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_queue_rcv_skb() argument
46 struct rxrpc_sock *rx = call->socket; in rxrpc_queue_rcv_skb()
55 ASSERTCMP(sp->call, ==, call); in rxrpc_queue_rcv_skb()
59 if (test_bit(RXRPC_CALL_TERMINAL_MSG, &call->flags)) { in rxrpc_queue_rcv_skb()
61 ASSERTCMP(call->state, >=, RXRPC_CALL_COMPLETE); in rxrpc_queue_rcv_skb()
63 sp->call = NULL; in rxrpc_queue_rcv_skb()
64 rxrpc_put_call(call); in rxrpc_queue_rcv_skb()
86 if (!test_bit(RXRPC_CALL_TERMINAL_MSG, &call->flags) && in rxrpc_queue_rcv_skb()
87 !test_bit(RXRPC_CALL_RELEASED, &call->flags) && in rxrpc_queue_rcv_skb()
88 call->socket->sk.sk_state != RXRPC_CLOSE) { in rxrpc_queue_rcv_skb()
[all …]
Dar-output.c28 struct rxrpc_call *call,
108 static void rxrpc_send_abort(struct rxrpc_call *call, u32 abort_code) in rxrpc_send_abort() argument
110 write_lock_bh(&call->state_lock); in rxrpc_send_abort()
112 if (call->state <= RXRPC_CALL_COMPLETE) { in rxrpc_send_abort()
113 call->state = RXRPC_CALL_LOCALLY_ABORTED; in rxrpc_send_abort()
114 call->abort_code = abort_code; in rxrpc_send_abort()
115 set_bit(RXRPC_CALL_ABORT, &call->events); in rxrpc_send_abort()
116 del_timer_sync(&call->resend_timer); in rxrpc_send_abort()
117 del_timer_sync(&call->ack_timer); in rxrpc_send_abort()
118 clear_bit(RXRPC_CALL_RESEND_TIMER, &call->events); in rxrpc_send_abort()
[all …]
Dar-skbuff.c24 static void rxrpc_request_final_ACK(struct rxrpc_call *call) in rxrpc_request_final_ACK() argument
27 write_lock(&call->state_lock); in rxrpc_request_final_ACK()
29 switch (call->state) { in rxrpc_request_final_ACK()
31 call->state = RXRPC_CALL_CLIENT_FINAL_ACK; in rxrpc_request_final_ACK()
36 rxrpc_get_call(call); in rxrpc_request_final_ACK()
37 set_bit(RXRPC_CALL_ACK_FINAL, &call->events); in rxrpc_request_final_ACK()
38 if (try_to_del_timer_sync(&call->ack_timer) >= 0) in rxrpc_request_final_ACK()
39 rxrpc_queue_call(call); in rxrpc_request_final_ACK()
43 call->state = RXRPC_CALL_SERVER_ACK_REQUEST; in rxrpc_request_final_ACK()
48 write_unlock(&call->state_lock); in rxrpc_request_final_ACK()
[all …]
Dar-accept.c82 struct rxrpc_call *call; in rxrpc_accept_incoming_call() local
123 call = rxrpc_incoming_call(rx, conn, &sp->hdr, GFP_NOIO); in rxrpc_accept_incoming_call()
125 if (IS_ERR(call)) { in rxrpc_accept_incoming_call()
127 ret = PTR_ERR(call); in rxrpc_accept_incoming_call()
137 if (!test_and_set_bit(RXRPC_CALL_INIT_ACCEPT, &call->flags)) { in rxrpc_accept_incoming_call()
138 rxrpc_get_call(call); in rxrpc_accept_incoming_call()
140 spin_lock(&call->conn->state_lock); in rxrpc_accept_incoming_call()
142 call->conn->state == RXRPC_CONN_SERVER_UNSECURED) { in rxrpc_accept_incoming_call()
144 list_add_tail(&call->accept_link, &rx->secureq); in rxrpc_accept_incoming_call()
145 call->conn->state = RXRPC_CONN_SERVER_CHALLENGING; in rxrpc_accept_incoming_call()
[all …]
Dar-recvmsg.c23 void rxrpc_remove_user_ID(struct rxrpc_sock *rx, struct rxrpc_call *call) in rxrpc_remove_user_ID() argument
25 _debug("RELEASE CALL %d", call->debug_id); in rxrpc_remove_user_ID()
27 if (test_bit(RXRPC_CALL_HAS_USERID, &call->flags)) { in rxrpc_remove_user_ID()
29 rb_erase(&call->sock_node, &call->socket->calls); in rxrpc_remove_user_ID()
30 clear_bit(RXRPC_CALL_HAS_USERID, &call->flags); in rxrpc_remove_user_ID()
34 read_lock_bh(&call->state_lock); in rxrpc_remove_user_ID()
35 if (!test_bit(RXRPC_CALL_RELEASED, &call->flags) && in rxrpc_remove_user_ID()
36 !test_and_set_bit(RXRPC_CALL_RELEASE, &call->events)) in rxrpc_remove_user_ID()
37 rxrpc_queue_call(call); in rxrpc_remove_user_ID()
38 read_unlock_bh(&call->state_lock); in rxrpc_remove_user_ID()
[all …]
Dar-connevent.c31 struct rxrpc_call *call; in rxrpc_abort_calls() local
39 call = rb_entry(p, struct rxrpc_call, conn_node); in rxrpc_abort_calls()
40 write_lock(&call->state_lock); in rxrpc_abort_calls()
41 if (call->state <= RXRPC_CALL_COMPLETE) { in rxrpc_abort_calls()
42 call->state = state; in rxrpc_abort_calls()
43 call->abort_code = abort_code; in rxrpc_abort_calls()
45 set_bit(RXRPC_CALL_CONN_ABORT, &call->events); in rxrpc_abort_calls()
47 set_bit(RXRPC_CALL_RCVD_ABORT, &call->events); in rxrpc_abort_calls()
48 rxrpc_queue_call(call); in rxrpc_abort_calls()
50 write_unlock(&call->state_lock); in rxrpc_abort_calls()
[all …]
Dar-proc.c50 struct rxrpc_call *call; in rxrpc_call_seq_show() local
61 call = list_entry(v, struct rxrpc_call, link); in rxrpc_call_seq_show()
62 trans = call->conn->trans; in rxrpc_call_seq_show()
77 ntohs(call->conn->service_id), in rxrpc_call_seq_show()
78 ntohl(call->conn->cid), in rxrpc_call_seq_show()
79 ntohl(call->call_id), in rxrpc_call_seq_show()
80 call->conn->in_clientflag ? "Svc" : "Clt", in rxrpc_call_seq_show()
81 atomic_read(&call->usage), in rxrpc_call_seq_show()
82 rxrpc_call_states[call->state], in rxrpc_call_seq_show()
83 call->abort_code, in rxrpc_call_seq_show()
[all …]
Dar-error.c207 struct rxrpc_call *call, *_n; in rxrpc_UDP_error_handler() local
214 list_for_each_entry_safe(call, _n, &trans->peer->error_targets, in rxrpc_UDP_error_handler()
216 write_lock(&call->state_lock); in rxrpc_UDP_error_handler()
217 if (call->state != RXRPC_CALL_COMPLETE && in rxrpc_UDP_error_handler()
218 call->state < RXRPC_CALL_NETWORK_ERROR) { in rxrpc_UDP_error_handler()
219 call->state = RXRPC_CALL_NETWORK_ERROR; in rxrpc_UDP_error_handler()
220 set_bit(RXRPC_CALL_RCVD_ERROR, &call->events); in rxrpc_UDP_error_handler()
221 rxrpc_queue_call(call); in rxrpc_UDP_error_handler()
223 write_unlock(&call->state_lock); in rxrpc_UDP_error_handler()
224 list_del_init(&call->error_link); in rxrpc_UDP_error_handler()
Drxkad.c153 static int rxkad_secure_packet_auth(const struct rxrpc_call *call, in rxkad_secure_packet_auth() argument
180 desc.tfm = call->conn->cipher; in rxkad_secure_packet_auth()
197 static int rxkad_secure_packet_encrypt(const struct rxrpc_call *call, in rxkad_secure_packet_encrypt() argument
224 token = call->conn->key->payload.data; in rxkad_secure_packet_encrypt()
226 desc.tfm = call->conn->cipher; in rxkad_secure_packet_encrypt()
239 len = data_size + call->conn->size_align - 1; in rxkad_secure_packet_encrypt()
240 len &= ~(call->conn->size_align - 1); in rxkad_secure_packet_encrypt()
253 static int rxkad_secure_packet(const struct rxrpc_call *call, in rxkad_secure_packet() argument
272 call->debug_id, key_serial(call->conn->key), ntohl(sp->hdr.seq), in rxkad_secure_packet()
275 if (!call->conn->cipher) in rxkad_secure_packet()
[all …]
Dar-security.c226 int rxrpc_secure_packet(const struct rxrpc_call *call, in rxrpc_secure_packet() argument
231 if (call->conn->security) in rxrpc_secure_packet()
232 return call->conn->security->secure_packet( in rxrpc_secure_packet()
233 call, skb, data_size, sechdr); in rxrpc_secure_packet()
240 int rxrpc_verify_packet(const struct rxrpc_call *call, struct sk_buff *skb, in rxrpc_verify_packet() argument
243 if (call->conn->security) in rxrpc_verify_packet()
244 return call->conn->security->verify_packet( in rxrpc_verify_packet()
245 call, skb, _abort_code); in rxrpc_verify_packet()
Dar-connection.c303 struct rxrpc_call *call) in rxrpc_add_call_ID_to_conn() argument
311 call_id = call->call_id; in rxrpc_add_call_ID_to_conn()
326 rb_link_node(&call->conn_node, parent, p); in rxrpc_add_call_ID_to_conn()
327 rb_insert_color(&call->conn_node, &conn->calls); in rxrpc_add_call_ID_to_conn()
338 struct rxrpc_call *call, in rxrpc_connect_exclusive() argument
404 conn->channels[chan] = call; in rxrpc_connect_exclusive()
405 call->conn = conn; in rxrpc_connect_exclusive()
406 call->channel = chan; in rxrpc_connect_exclusive()
407 call->cid = conn->cid | htonl(chan); in rxrpc_connect_exclusive()
408 call->call_id = htonl(++conn->call_counter); in rxrpc_connect_exclusive()
[all …]
Daf_rxrpc.c277 struct rxrpc_call *call; in rxrpc_kernel_begin_call() local
289 call = ERR_CAST(trans); in rxrpc_kernel_begin_call()
296 call = ERR_PTR(-ENOTCONN); in rxrpc_kernel_begin_call()
313 call = ERR_CAST(bundle); in rxrpc_kernel_begin_call()
317 call = rxrpc_get_client_call(rx, trans, bundle, user_call_ID, true, in rxrpc_kernel_begin_call()
324 _leave(" = %p", call); in rxrpc_kernel_begin_call()
325 return call; in rxrpc_kernel_begin_call()
337 void rxrpc_kernel_end_call(struct rxrpc_call *call) in rxrpc_kernel_end_call() argument
339 _enter("%d{%d}", call->debug_id, atomic_read(&call->usage)); in rxrpc_kernel_end_call()
340 rxrpc_remove_user_ID(call->socket, call); in rxrpc_kernel_end_call()
[all …]
Dar-internal.h83 struct rxrpc_call *call; /* call with which associated */ member
418 static inline void rxrpc_abort_call(struct rxrpc_call *call, u32 abort_code) in rxrpc_abort_call() argument
420 write_lock_bh(&call->state_lock); in rxrpc_abort_call()
421 if (call->state < RXRPC_CALL_COMPLETE) { in rxrpc_abort_call()
422 call->abort_code = abort_code; in rxrpc_abort_call()
423 call->state = RXRPC_CALL_LOCALLY_ABORTED; in rxrpc_abort_call()
424 set_bit(RXRPC_CALL_ABORT, &call->events); in rxrpc_abort_call()
426 write_unlock_bh(&call->state_lock); in rxrpc_abort_call()
DMakefile9 ar-call.o \
/net/ax25/
Dax25_uid.c84 if (ax25cmp(&sax->sax25_call, &ax25_uid->call) == 0) { in ax25_uid_ioctl()
113 ax25_uid->call = sax->sax25_call; in ax25_uid_ioctl()
128 if (ax25cmp(&sax->sax25_call, &ax25_uid->call) == 0) in ax25_uid_ioctl()
180 ax2asc(buf, &pt->call)); in ax25_uid_seq_show()
/net/netfilter/
Dnfnetlink_cttimeout.c517 [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,
Dnfnetlink_acct.c374 [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,
Dxt_osf.c146 .call = xt_osf_add_callback,
151 .call = xt_osf_remove_callback,
Dnf_conntrack_netlink.c3102 [IPCTNL_MSG_CT_NEW] = { .call = ctnetlink_new_conntrack,
3105 [IPCTNL_MSG_CT_GET] = { .call = ctnetlink_get_conntrack,
3108 [IPCTNL_MSG_CT_DELETE] = { .call = ctnetlink_del_conntrack,
3111 [IPCTNL_MSG_CT_GET_CTRZERO] = { .call = ctnetlink_get_conntrack,
3114 [IPCTNL_MSG_CT_GET_STATS_CPU] = { .call = ctnetlink_stat_ct_cpu },
3115 [IPCTNL_MSG_CT_GET_STATS] = { .call = ctnetlink_stat_ct },
3116 [IPCTNL_MSG_CT_GET_DYING] = { .call = ctnetlink_get_ct_dying },
3117 [IPCTNL_MSG_CT_GET_UNCONFIRMED] = { .call = ctnetlink_get_ct_unconfirmed },
3121 [IPCTNL_MSG_EXP_GET] = { .call = ctnetlink_get_expect,
3124 [IPCTNL_MSG_EXP_NEW] = { .call = ctnetlink_new_expect,
[all …]
Dnfnetlink_cthelper.c717 [NFNL_MSG_CTHELPER_NEW] = { .call = nfnl_cthelper_new,
720 [NFNL_MSG_CTHELPER_GET] = { .call = nfnl_cthelper_get,
723 [NFNL_MSG_CTHELPER_DEL] = { .call = nfnl_cthelper_del,
/net/netfilter/ipset/
Dip_set_core.c1759 .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 = ip_set_swap,
1788 .call = ip_set_dump,
1793 .call = ip_set_dump,
1798 .call = ip_set_uadd,
1803 .call = ip_set_udel,
[all …]
/net/
Dcompat.c798 COMPAT_SYSCALL_DEFINE2(socketcall, int, call, u32 __user *, args) in COMPAT_SYSCALL_DEFINE2() argument
805 if (call < SYS_SOCKET || call > SYS_SENDMMSG) in COMPAT_SYSCALL_DEFINE2()
807 len = nas[call]; in COMPAT_SYSCALL_DEFINE2()
821 switch (call) { in COMPAT_SYSCALL_DEFINE2()
/net/ceph/
DKconfig26 execution slightly when debug call sites are enabled (e.g.,

12