Home
last modified time | relevance | path

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

12

/net/rxrpc/
Dcall_object.c46 struct rxrpc_call *call = from_timer(call, t, timer); in rxrpc_call_timer_expired() local
48 _enter("%d", call->debug_id); in rxrpc_call_timer_expired()
50 if (call->state < RXRPC_CALL_COMPLETE) { in rxrpc_call_timer_expired()
51 trace_rxrpc_timer(call, rxrpc_timer_expired, jiffies); in rxrpc_call_timer_expired()
52 rxrpc_queue_call(call); in rxrpc_call_timer_expired()
65 struct rxrpc_call *call; in rxrpc_find_call_by_user_ID() local
74 call = rb_entry(p, struct rxrpc_call, sock_node); in rxrpc_find_call_by_user_ID()
76 if (user_call_ID < call->user_call_ID) in rxrpc_find_call_by_user_ID()
78 else if (user_call_ID > call->user_call_ID) in rxrpc_find_call_by_user_ID()
89 rxrpc_get_call(call, rxrpc_call_got); in rxrpc_find_call_by_user_ID()
[all …]
Dcall_event.c23 static void rxrpc_propose_ping(struct rxrpc_call *call, in rxrpc_propose_ping() argument
28 !test_and_set_bit(RXRPC_CALL_EV_PING, &call->events)) in rxrpc_propose_ping()
29 rxrpc_queue_call(call); in rxrpc_propose_ping()
34 if (time_before(ping_at, call->ping_at)) { in rxrpc_propose_ping()
35 WRITE_ONCE(call->ping_at, ping_at); in rxrpc_propose_ping()
36 rxrpc_reduce_call_timer(call, ping_at, now, in rxrpc_propose_ping()
45 static void __rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, in __rxrpc_propose_ACK() argument
57 rxrpc_propose_ping(call, immediate, background); in __rxrpc_propose_ACK()
66 call->ackr_reason, rxrpc_ack_priority[call->ackr_reason]); in __rxrpc_propose_ACK()
67 if (ack_reason == call->ackr_reason) { in __rxrpc_propose_ACK()
[all …]
Dsendmsg.c24 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_intr() argument
29 if (call->tx_top - call->tx_hard_ack < in rxrpc_wait_for_tx_window_intr()
30 min_t(unsigned int, call->tx_winsize, in rxrpc_wait_for_tx_window_intr()
31 call->cong_cwnd + call->cong_extra)) in rxrpc_wait_for_tx_window_intr()
34 if (call->state >= RXRPC_CALL_COMPLETE) in rxrpc_wait_for_tx_window_intr()
35 return call->error; in rxrpc_wait_for_tx_window_intr()
40 trace_rxrpc_transmit(call, rxrpc_transmit_wait); in rxrpc_wait_for_tx_window_intr()
41 mutex_unlock(&call->user_mutex); in rxrpc_wait_for_tx_window_intr()
43 if (mutex_lock_interruptible(&call->user_mutex) < 0) in rxrpc_wait_for_tx_window_intr()
53 struct rxrpc_call *call) in rxrpc_wait_for_tx_window_nonintr() argument
[all …]
Dinput.c27 struct rxrpc_call *call, rxrpc_seq_t seq) in rxrpc_proto_abort() argument
29 if (rxrpc_abort_call(why, call, seq, RX_PROTOCOL_ERROR, -EBADMSG)) { in rxrpc_proto_abort()
30 set_bit(RXRPC_CALL_EV_ABORT, &call->events); in rxrpc_proto_abort()
31 rxrpc_queue_call(call); in rxrpc_proto_abort()
38 static void rxrpc_congestion_management(struct rxrpc_call *call, in rxrpc_congestion_management() argument
44 unsigned int cumulative_acks = call->cong_cumul_acks; in rxrpc_congestion_management()
45 unsigned int cwnd = call->cong_cwnd; in rxrpc_congestion_management()
49 (call->tx_top - call->tx_hard_ack) - summary->nr_acks; in rxrpc_congestion_management()
51 if (test_and_clear_bit(RXRPC_CALL_RETRANS_TIMEOUT, &call->flags)) { in rxrpc_congestion_management()
53 call->cong_ssthresh = max_t(unsigned int, in rxrpc_congestion_management()
[all …]
Drecvmsg.c23 void rxrpc_notify_socket(struct rxrpc_call *call) in rxrpc_notify_socket() argument
28 _enter("%d", call->debug_id); in rxrpc_notify_socket()
30 if (!list_empty(&call->recvmsg_link)) in rxrpc_notify_socket()
35 rx = rcu_dereference(call->socket); in rxrpc_notify_socket()
38 if (call->notify_rx) { in rxrpc_notify_socket()
39 spin_lock_bh(&call->notify_lock); in rxrpc_notify_socket()
40 call->notify_rx(sk, call, call->user_call_ID); in rxrpc_notify_socket()
41 spin_unlock_bh(&call->notify_lock); in rxrpc_notify_socket()
44 if (list_empty(&call->recvmsg_link)) { in rxrpc_notify_socket()
45 rxrpc_get_call(call, rxrpc_call_got); in rxrpc_notify_socket()
[all …]
Dcall_accept.c37 struct rxrpc_call *call; in rxrpc_service_prealloc_one() local
94 call = rxrpc_alloc_call(rx, gfp, debug_id); in rxrpc_service_prealloc_one()
95 if (!call) in rxrpc_service_prealloc_one()
97 call->flags |= (1 << RXRPC_CALL_IS_SERVICE); in rxrpc_service_prealloc_one()
98 call->state = RXRPC_CALL_SERVER_PREALLOC; in rxrpc_service_prealloc_one()
100 trace_rxrpc_call(call->debug_id, rxrpc_call_new_service, in rxrpc_service_prealloc_one()
101 atomic_read(&call->usage), in rxrpc_service_prealloc_one()
123 call->user_call_ID = user_call_ID; in rxrpc_service_prealloc_one()
124 call->notify_rx = notify_rx; in rxrpc_service_prealloc_one()
125 rxrpc_get_call(call, rxrpc_call_got_kernel); in rxrpc_service_prealloc_one()
[all …]
Doutput.c36 static void rxrpc_tx_backoff(struct rxrpc_call *call, int ret) in rxrpc_tx_backoff() argument
39 u16 tx_backoff = READ_ONCE(call->tx_backoff); in rxrpc_tx_backoff()
42 WRITE_ONCE(call->tx_backoff, tx_backoff + 1); in rxrpc_tx_backoff()
44 WRITE_ONCE(call->tx_backoff, 0); in rxrpc_tx_backoff()
56 static void rxrpc_set_keepalive(struct rxrpc_call *call) in rxrpc_set_keepalive() argument
58 unsigned long now = jiffies, keepalive_at = call->next_rx_timo / 6; in rxrpc_set_keepalive()
61 WRITE_ONCE(call->keepalive_at, keepalive_at); in rxrpc_set_keepalive()
62 rxrpc_reduce_call_timer(call, keepalive_at, now, in rxrpc_set_keepalive()
70 struct rxrpc_call *call, in rxrpc_fill_out_ack() argument
83 serial = call->ackr_serial; in rxrpc_fill_out_ack()
[all …]
Dconn_client.c276 struct rxrpc_call *call, in rxrpc_get_client_conn() argument
287 _enter("{%d,%lx},", call->debug_id, call->user_call_ID); in rxrpc_get_client_conn()
293 call->cong_cwnd = cp->peer->cong_cwnd; in rxrpc_get_client_conn()
294 if (call->cong_cwnd >= call->cong_ssthresh) in rxrpc_get_client_conn()
295 call->cong_mode = RXRPC_CALL_CONGEST_AVOIDANCE; in rxrpc_get_client_conn()
297 call->cong_mode = RXRPC_CALL_SLOW_START; in rxrpc_get_client_conn()
352 list_add(&call->chan_wait_link, &candidate->waiting_calls); in rxrpc_get_client_conn()
355 call->conn = candidate; in rxrpc_get_client_conn()
356 call->security = candidate->security; in rxrpc_get_client_conn()
357 call->security_ix = candidate->security_ix; in rxrpc_get_client_conn()
[all …]
Drxkad.c150 static struct skcipher_request *rxkad_get_call_crypto(struct rxrpc_call *call) in rxkad_get_call_crypto() argument
152 struct crypto_skcipher *tfm = &call->conn->cipher->base; in rxkad_get_call_crypto()
153 struct skcipher_request *cipher_req = call->cipher_req; in rxkad_get_call_crypto()
159 call->cipher_req = cipher_req; in rxkad_get_call_crypto()
168 static void rxkad_free_call_crypto(struct rxrpc_call *call) in rxkad_free_call_crypto() argument
170 if (call->cipher_req) in rxkad_free_call_crypto()
171 skcipher_request_free(call->cipher_req); in rxkad_free_call_crypto()
172 call->cipher_req = NULL; in rxkad_free_call_crypto()
178 static int rxkad_secure_packet_auth(const struct rxrpc_call *call, in rxkad_secure_packet_auth() argument
192 check = sp->hdr.seq ^ call->call_id; in rxkad_secure_packet_auth()
[all …]
Dproc.c60 struct rxrpc_call *call; in rxrpc_call_seq_show() local
75 call = list_entry(v, struct rxrpc_call, link); in rxrpc_call_seq_show()
77 rx = rcu_dereference(call->socket); in rxrpc_call_seq_show()
88 peer = call->peer; in rxrpc_call_seq_show()
94 if (call->state != RXRPC_CALL_SERVER_PREALLOC) { in rxrpc_call_seq_show()
95 timeout = READ_ONCE(call->expect_rx_by); in rxrpc_call_seq_show()
99 tx_hard_ack = READ_ONCE(call->tx_hard_ack); in rxrpc_call_seq_show()
100 rx_hard_ack = READ_ONCE(call->rx_hard_ack); in rxrpc_call_seq_show()
106 call->service_id, in rxrpc_call_seq_show()
107 call->cid, in rxrpc_call_seq_show()
[all …]
Dconn_object.c167 struct rxrpc_call *call) in __rxrpc_disconnect_call() argument
170 &conn->channels[call->cid & RXRPC_CHANNELMASK]; in __rxrpc_disconnect_call()
172 _enter("%d,%x", conn->debug_id, call->cid); in __rxrpc_disconnect_call()
174 if (rcu_access_pointer(chan->call) == call) { in __rxrpc_disconnect_call()
178 trace_rxrpc_disconnect_call(call); in __rxrpc_disconnect_call()
179 switch (call->completion) { in __rxrpc_disconnect_call()
181 chan->last_seq = call->rx_hard_ack; in __rxrpc_disconnect_call()
185 chan->last_abort = call->abort_code; in __rxrpc_disconnect_call()
199 rcu_assign_pointer(chan->call, NULL); in __rxrpc_disconnect_call()
209 void rxrpc_disconnect_call(struct rxrpc_call *call) in rxrpc_disconnect_call() argument
[all …]
Dar-internal.h422 struct rxrpc_call __rcu *call; /* Active call */ member
727 struct rxrpc_call_params call; member
762 static inline void rxrpc_reduce_call_timer(struct rxrpc_call *call, in rxrpc_reduce_call_timer() argument
767 trace_rxrpc_timer(call, why, now); in rxrpc_reduce_call_timer()
768 timer_reduce(&call->timer, expire_at); in rxrpc_reduce_call_timer()
798 static inline bool rxrpc_is_service_call(const struct rxrpc_call *call) in rxrpc_is_service_call() argument
800 return test_bit(RXRPC_CALL_IS_SERVICE, &call->flags); in rxrpc_is_service_call()
803 static inline bool rxrpc_is_client_call(const struct rxrpc_call *call) in rxrpc_is_client_call() argument
805 return !rxrpc_is_service_call(call); in rxrpc_is_client_call()
811 static inline bool __rxrpc_set_call_completion(struct rxrpc_call *call, in __rxrpc_set_call_completion() argument
[all …]
Daf_rxrpc.c292 struct rxrpc_call *call; in rxrpc_kernel_begin_call() local
321 call = rxrpc_new_client_call(rx, &cp, srx, &p, gfp, debug_id); in rxrpc_kernel_begin_call()
323 if (!IS_ERR(call)) { in rxrpc_kernel_begin_call()
324 call->notify_rx = notify_rx; in rxrpc_kernel_begin_call()
325 mutex_unlock(&call->user_mutex); in rxrpc_kernel_begin_call()
329 _leave(" = %p", call); in rxrpc_kernel_begin_call()
330 return call; in rxrpc_kernel_begin_call()
350 void rxrpc_kernel_end_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_end_call() argument
352 _enter("%d{%d}", call->debug_id, atomic_read(&call->usage)); in rxrpc_kernel_end_call()
354 mutex_lock(&call->user_mutex); in rxrpc_kernel_end_call()
[all …]
Dconn_event.c155 struct rxrpc_call *call; in rxrpc_abort_calls() local
163 call = rcu_dereference_protected( in rxrpc_abort_calls()
164 conn->channels[i].call, in rxrpc_abort_calls()
166 if (call) { in rxrpc_abort_calls()
168 trace_rxrpc_abort(call->debug_id, in rxrpc_abort_calls()
169 "CON", call->cid, in rxrpc_abort_calls()
170 call->call_id, 0, in rxrpc_abort_calls()
174 trace_rxrpc_rx_abort(call, serial, in rxrpc_abort_calls()
176 if (rxrpc_set_call_completion(call, compl, in rxrpc_abort_calls()
179 rxrpc_notify_socket(call); in rxrpc_abort_calls()
[all …]
Dinsecure.c21 static int none_secure_packet(struct rxrpc_call *call, in none_secure_packet() argument
29 static int none_verify_packet(struct rxrpc_call *call, struct sk_buff *skb, in none_verify_packet() argument
36 static void none_free_call_crypto(struct rxrpc_call *call) in none_free_call_crypto() argument
40 static void none_locate_data(struct rxrpc_call *call, struct sk_buff *skb, in none_locate_data() argument
Dpeer_event.c288 struct rxrpc_call *call; in rxrpc_distribute_error() local
290 hlist_for_each_entry_rcu(call, &peer->error_targets, error_link) { in rxrpc_distribute_error()
291 rxrpc_see_call(call); in rxrpc_distribute_error()
292 if (call->state < RXRPC_CALL_COMPLETE && in rxrpc_distribute_error()
293 rxrpc_set_call_completion(call, compl, 0, -error)) in rxrpc_distribute_error()
294 rxrpc_notify_socket(call); in rxrpc_distribute_error()
302 void rxrpc_peer_add_rtt(struct rxrpc_call *call, enum rxrpc_rtt_rx_trace why, in rxrpc_peer_add_rtt() argument
306 struct rxrpc_peer *peer = call->peer; in rxrpc_peer_add_rtt()
340 trace_rxrpc_rtt_rx(call, why, send_serial, resp_serial, rtt, in rxrpc_peer_add_rtt()
Dpeer_object.c490 void rxrpc_kernel_get_peer(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_get_peer() argument
493 *_srx = call->peer->srx; in rxrpc_kernel_get_peer()
504 u64 rxrpc_kernel_get_rtt(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_get_rtt() argument
506 return call->peer->rtt; in rxrpc_kernel_get_rtt()
/net/ax25/
Dax25_uid.c80 if (ax25cmp(&sax->sax25_call, &ax25_uid->call) == 0) { in ax25_uid_ioctl()
109 ax25_uid->call = sax->sax25_call; in ax25_uid_ioctl()
124 if (ax25cmp(&sax->sax25_call, &ax25_uid->call) == 0) in ax25_uid_ioctl()
176 ax2asc(buf, &pt->call)); in ax25_uid_seq_show()
/net/netfilter/
Dnfnetlink_cttimeout.c548 [IPCTNL_MSG_TIMEOUT_NEW] = { .call = cttimeout_new_timeout,
551 [IPCTNL_MSG_TIMEOUT_GET] = { .call = cttimeout_get_timeout,
554 [IPCTNL_MSG_TIMEOUT_DELETE] = { .call = cttimeout_del_timeout,
557 [IPCTNL_MSG_TIMEOUT_DEFAULT_SET]= { .call = cttimeout_default_set,
560 [IPCTNL_MSG_TIMEOUT_DEFAULT_GET]= { .call = cttimeout_default_get,
Dnfnetlink_acct.c380 [NFNL_MSG_ACCT_NEW] = { .call = nfnl_acct_new,
383 [NFNL_MSG_ACCT_GET] = { .call = nfnl_acct_get,
386 [NFNL_MSG_ACCT_GET_CTRZERO] = { .call = nfnl_acct_get,
389 [NFNL_MSG_ACCT_DEL] = { .call = nfnl_acct_del,
Dnfnetlink_osf.c377 .call = nfnl_osf_add_callback,
382 .call = nfnl_osf_remove_callback,
Dnf_conntrack_netlink.c3515 [IPCTNL_MSG_CT_NEW] = { .call = ctnetlink_new_conntrack,
3518 [IPCTNL_MSG_CT_GET] = { .call = ctnetlink_get_conntrack,
3521 [IPCTNL_MSG_CT_DELETE] = { .call = ctnetlink_del_conntrack,
3524 [IPCTNL_MSG_CT_GET_CTRZERO] = { .call = ctnetlink_get_conntrack,
3527 [IPCTNL_MSG_CT_GET_STATS_CPU] = { .call = ctnetlink_stat_ct_cpu },
3528 [IPCTNL_MSG_CT_GET_STATS] = { .call = ctnetlink_stat_ct },
3529 [IPCTNL_MSG_CT_GET_DYING] = { .call = ctnetlink_get_ct_dying },
3530 [IPCTNL_MSG_CT_GET_UNCONFIRMED] = { .call = ctnetlink_get_ct_unconfirmed },
3534 [IPCTNL_MSG_EXP_GET] = { .call = ctnetlink_get_expect,
3537 [IPCTNL_MSG_EXP_NEW] = { .call = ctnetlink_new_expect,
[all …]
/net/netfilter/ipset/
Dip_set_core.c1949 .call = ip_set_none,
1953 .call = ip_set_create,
1958 .call = ip_set_destroy,
1963 .call = ip_set_flush,
1968 .call = ip_set_rename,
1973 .call = ip_set_swap,
1978 .call = ip_set_dump,
1983 .call = ip_set_dump,
1988 .call = ip_set_uadd,
1993 .call = ip_set_udel,
[all …]
/net/
Dcompat.c719 COMPAT_SYSCALL_DEFINE2(socketcall, int, call, u32 __user *, args) in COMPAT_SYSCALL_DEFINE2() argument
726 if (call < SYS_SOCKET || call > SYS_SENDMMSG) in COMPAT_SYSCALL_DEFINE2()
728 len = nas[call]; in COMPAT_SYSCALL_DEFINE2()
742 switch (call) { in COMPAT_SYSCALL_DEFINE2()
/net/ceph/
DKconfig27 execution slightly when debug call sites are enabled (e.g.,

12