Home
last modified time | relevance | path

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

12

/net/rxrpc/
Dcall_object.c46 void rxrpc_poke_call(struct rxrpc_call *call, enum rxrpc_call_poke_trace what) in rxrpc_poke_call() argument
48 struct rxrpc_local *local = call->local; in rxrpc_poke_call()
51 if (!test_bit(RXRPC_CALL_DISCONNECTED, &call->flags)) { in rxrpc_poke_call()
53 busy = !list_empty(&call->attend_link); in rxrpc_poke_call()
54 trace_rxrpc_poke_call(call, busy, what); in rxrpc_poke_call()
55 if (!busy && !rxrpc_try_get_call(call, rxrpc_call_get_poke)) in rxrpc_poke_call()
58 list_add_tail(&call->attend_link, &local->call_attend_q); in rxrpc_poke_call()
68 struct rxrpc_call *call = from_timer(call, t, timer); in rxrpc_call_timer_expired() local
70 _enter("%d", call->debug_id); in rxrpc_call_timer_expired()
72 if (!__rxrpc_call_is_complete(call)) { in rxrpc_call_timer_expired()
[all …]
Dinput.c23 static void rxrpc_proto_abort(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_proto_abort() argument
26 rxrpc_abort_call(call, seq, RX_PROTOCOL_ERROR, -EBADMSG, why); in rxrpc_proto_abort()
32 static void rxrpc_congestion_management(struct rxrpc_call *call, in rxrpc_congestion_management() argument
38 unsigned int cumulative_acks = call->cong_cumul_acks; in rxrpc_congestion_management()
39 unsigned int cwnd = call->cong_cwnd; in rxrpc_congestion_management()
43 (call->tx_top - call->acks_hard_ack) - summary->nr_acks; in rxrpc_congestion_management()
45 if (test_and_clear_bit(RXRPC_CALL_RETRANS_TIMEOUT, &call->flags)) { in rxrpc_congestion_management()
47 call->cong_ssthresh = max_t(unsigned int, in rxrpc_congestion_management()
50 if (cwnd >= call->cong_ssthresh && in rxrpc_congestion_management()
51 call->cong_mode == RXRPC_CALL_SLOW_START) { in rxrpc_congestion_management()
[all …]
Dcall_event.c23 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial, in rxrpc_propose_ping() argument
29 if (time_before(ping_at, call->ping_at)) { in rxrpc_propose_ping()
30 WRITE_ONCE(call->ping_at, ping_at); in rxrpc_propose_ping()
31 rxrpc_reduce_call_timer(call, ping_at, now, in rxrpc_propose_ping()
33 trace_rxrpc_propose_ack(call, why, RXRPC_ACK_PING, serial); in rxrpc_propose_ping()
40 void rxrpc_propose_delay_ACK(struct rxrpc_call *call, rxrpc_serial_t serial, in rxrpc_propose_delay_ACK() argument
48 if (call->peer->srtt_us != 0) in rxrpc_propose_delay_ACK()
49 ack_at = usecs_to_jiffies(call->peer->srtt_us >> 3); in rxrpc_propose_delay_ACK()
53 ack_at += READ_ONCE(call->tx_backoff); in rxrpc_propose_delay_ACK()
55 if (time_before(ack_at, call->delay_ack_at)) { in rxrpc_propose_delay_ACK()
[all …]
Dsendmsg.c23 bool rxrpc_propose_abort(struct rxrpc_call *call, s32 abort_code, int error, in rxrpc_propose_abort() argument
26 _enter("{%d},%d,%d,%u", call->debug_id, abort_code, error, why); in rxrpc_propose_abort()
28 if (!call->send_abort && !rxrpc_call_is_complete(call)) { in rxrpc_propose_abort()
29 call->send_abort_why = why; in rxrpc_propose_abort()
30 call->send_abort_err = error; in rxrpc_propose_abort()
31 call->send_abort_seq = 0; in rxrpc_propose_abort()
33 smp_store_release(&call->send_abort, abort_code); in rxrpc_propose_abort()
34 rxrpc_poke_call(call, rxrpc_call_poke_abort); in rxrpc_propose_abort()
45 static int rxrpc_wait_to_be_connected(struct rxrpc_call *call, long *timeo) in rxrpc_wait_to_be_connected() argument
50 _enter("%d", call->debug_id); in rxrpc_wait_to_be_connected()
[all …]
Drxperf.c65 int (*deliver)(struct rxperf_call *call);
74 static int rxperf_deliver_param_block(struct rxperf_call *call);
75 static int rxperf_deliver_request(struct rxperf_call *call);
76 static int rxperf_process_call(struct rxperf_call *call);
82 static inline void rxperf_set_call_state(struct rxperf_call *call, in rxperf_set_call_state() argument
85 call->state = to; in rxperf_set_call_state()
88 static inline void rxperf_set_call_complete(struct rxperf_call *call, in rxperf_set_call_complete() argument
91 if (call->state != RXPERF_CALL_COMPLETE) { in rxperf_set_call_complete()
92 call->abort_code = remote_abort; in rxperf_set_call_complete()
93 call->error = error; in rxperf_set_call_complete()
[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(&call->notify_lock); in rxrpc_notify_socket()
40 call->notify_rx(sk, call, call->user_call_ID); in rxrpc_notify_socket()
41 spin_unlock(&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_get_notify_socket); in rxrpc_notify_socket()
[all …]
Doutput.c48 static void rxrpc_tx_backoff(struct rxrpc_call *call, int ret) in rxrpc_tx_backoff() argument
51 u16 tx_backoff = READ_ONCE(call->tx_backoff); in rxrpc_tx_backoff()
54 WRITE_ONCE(call->tx_backoff, tx_backoff + 1); in rxrpc_tx_backoff()
56 WRITE_ONCE(call->tx_backoff, 0); in rxrpc_tx_backoff()
68 static void rxrpc_set_keepalive(struct rxrpc_call *call) in rxrpc_set_keepalive() argument
70 unsigned long now = jiffies, keepalive_at = call->next_rx_timo / 6; in rxrpc_set_keepalive()
73 WRITE_ONCE(call->keepalive_at, keepalive_at); in rxrpc_set_keepalive()
74 rxrpc_reduce_call_timer(call, keepalive_at, now, in rxrpc_set_keepalive()
82 struct rxrpc_call *call, in rxrpc_fill_out_ack() argument
93 call->ackr_nr_unacked = 0; in rxrpc_fill_out_ack()
[all …]
Dcall_state.c13 bool rxrpc_set_call_completion(struct rxrpc_call *call, in rxrpc_set_call_completion() argument
18 if (__rxrpc_call_state(call) == RXRPC_CALL_COMPLETE) in rxrpc_set_call_completion()
21 call->abort_code = abort_code; in rxrpc_set_call_completion()
22 call->error = error; in rxrpc_set_call_completion()
23 call->completion = compl; in rxrpc_set_call_completion()
25 rxrpc_set_call_state(call, RXRPC_CALL_COMPLETE); in rxrpc_set_call_completion()
26 trace_rxrpc_call_complete(call); in rxrpc_set_call_completion()
27 wake_up(&call->waitq); in rxrpc_set_call_completion()
28 rxrpc_notify_socket(call); in rxrpc_set_call_completion()
35 bool rxrpc_call_completed(struct rxrpc_call *call) in rxrpc_call_completed() argument
[all …]
Dcall_accept.c25 static void rxrpc_dummy_notify(struct sock *sk, struct rxrpc_call *call, in rxrpc_dummy_notify() argument
41 struct rxrpc_call *call, *xcall; in rxrpc_service_prealloc_one() local
98 call = rxrpc_alloc_call(rx, gfp, debug_id); in rxrpc_service_prealloc_one()
99 if (!call) in rxrpc_service_prealloc_one()
101 call->flags |= (1 << RXRPC_CALL_IS_SERVICE); in rxrpc_service_prealloc_one()
102 rxrpc_set_call_state(call, RXRPC_CALL_SERVER_PREALLOC); in rxrpc_service_prealloc_one()
103 __set_bit(RXRPC_CALL_EV_INITIAL_PING, &call->events); in rxrpc_service_prealloc_one()
105 trace_rxrpc_call(call->debug_id, refcount_read(&call->ref), in rxrpc_service_prealloc_one()
124 call->user_call_ID = user_call_ID; in rxrpc_service_prealloc_one()
125 call->notify_rx = notify_rx; in rxrpc_service_prealloc_one()
[all …]
Dconn_client.c73 static struct rxrpc_bundle *rxrpc_alloc_bundle(struct rxrpc_call *call, in rxrpc_alloc_bundle() argument
81 bundle->local = call->local; in rxrpc_alloc_bundle()
82 bundle->peer = rxrpc_get_peer(call->peer, rxrpc_peer_get_bundle); in rxrpc_alloc_bundle()
83 bundle->key = key_get(call->key); in rxrpc_alloc_bundle()
84 bundle->security = call->security; in rxrpc_alloc_bundle()
85 bundle->exclusive = test_bit(RXRPC_CALL_EXCLUSIVE, &call->flags); in rxrpc_alloc_bundle()
86 bundle->upgrade = test_bit(RXRPC_CALL_UPGRADE, &call->flags); in rxrpc_alloc_bundle()
87 bundle->service_id = call->dest_srx.srx_service; in rxrpc_alloc_bundle()
88 bundle->security_level = call->security_level; in rxrpc_alloc_bundle()
243 int rxrpc_look_up_bundle(struct rxrpc_call *call, gfp_t gfp) in rxrpc_look_up_bundle() argument
[all …]
Dtxbuf.c19 struct rxrpc_txbuf *rxrpc_alloc_txbuf(struct rxrpc_call *call, u8 packet_type, in rxrpc_alloc_txbuf() argument
29 txb->call_debug_id = call->debug_id; in rxrpc_alloc_txbuf()
36 txb->seq = call->tx_prepared + 1; in rxrpc_alloc_txbuf()
37 txb->wire.epoch = htonl(call->conn->proto.epoch); in rxrpc_alloc_txbuf()
38 txb->wire.cid = htonl(call->cid); in rxrpc_alloc_txbuf()
39 txb->wire.callNumber = htonl(call->call_id); in rxrpc_alloc_txbuf()
42 txb->wire.flags = call->conn->out_clientflag; in rxrpc_alloc_txbuf()
44 txb->wire.securityIndex = call->security_ix; in rxrpc_alloc_txbuf()
46 txb->wire.serviceId = htons(call->dest_srx.srx_service); in rxrpc_alloc_txbuf()
105 void rxrpc_shrink_call_tx_buffer(struct rxrpc_call *call) in rxrpc_shrink_call_tx_buffer() argument
[all …]
Dconn_object.c149 struct rxrpc_call *call) in __rxrpc_disconnect_call() argument
152 &conn->channels[call->cid & RXRPC_CHANNELMASK]; in __rxrpc_disconnect_call()
154 _enter("%d,%x", conn->debug_id, call->cid); in __rxrpc_disconnect_call()
156 if (chan->call == call) { in __rxrpc_disconnect_call()
160 trace_rxrpc_disconnect_call(call); in __rxrpc_disconnect_call()
161 switch (call->completion) { in __rxrpc_disconnect_call()
163 chan->last_seq = call->rx_highest_seq; in __rxrpc_disconnect_call()
167 chan->last_abort = call->abort_code; in __rxrpc_disconnect_call()
178 chan->call = NULL; in __rxrpc_disconnect_call()
188 void rxrpc_disconnect_call(struct rxrpc_call *call) in rxrpc_disconnect_call() argument
[all …]
Drxkad.c148 static int rxkad_how_much_data(struct rxrpc_call *call, size_t remain, in rxkad_how_much_data() argument
153 switch (call->conn->security_level) { in rxkad_how_much_data()
233 static struct skcipher_request *rxkad_get_call_crypto(struct rxrpc_call *call) in rxkad_get_call_crypto() argument
235 struct crypto_skcipher *tfm = &call->conn->rxkad.cipher->base; in rxkad_get_call_crypto()
243 static void rxkad_free_call_crypto(struct rxrpc_call *call) in rxkad_free_call_crypto() argument
250 static int rxkad_secure_packet_auth(const struct rxrpc_call *call, in rxkad_secure_packet_auth() argument
262 check = txb->seq ^ call->call_id; in rxkad_secure_packet_auth()
278 skcipher_request_set_sync_tfm(req, call->conn->rxkad.cipher); in rxkad_secure_packet_auth()
291 static int rxkad_secure_packet_encrypt(const struct rxrpc_call *call, in rxkad_secure_packet_encrypt() argument
305 check = txb->seq ^ call->call_id; in rxkad_secure_packet_encrypt()
[all …]
Dproc.c52 struct rxrpc_call *call; in rxrpc_call_seq_show() local
68 call = list_entry(v, struct rxrpc_call, link); in rxrpc_call_seq_show()
70 local = call->local; in rxrpc_call_seq_show()
76 sprintf(rbuff, "%pISpc", &call->dest_srx.transport); in rxrpc_call_seq_show()
78 state = rxrpc_call_state(call); in rxrpc_call_seq_show()
80 timeout = READ_ONCE(call->expect_rx_by); in rxrpc_call_seq_show()
84 acks_hard_ack = READ_ONCE(call->acks_hard_ack); in rxrpc_call_seq_show()
90 call->dest_srx.srx_service, in rxrpc_call_seq_show()
91 call->cid, in rxrpc_call_seq_show()
92 call->call_id, in rxrpc_call_seq_show()
[all …]
Daf_rxrpc.c296 struct rxrpc_call *call; in rxrpc_kernel_begin_call() local
327 call = rxrpc_new_client_call(rx, &cp, srx, &p, gfp, debug_id); in rxrpc_kernel_begin_call()
329 if (!IS_ERR(call)) { in rxrpc_kernel_begin_call()
330 call->notify_rx = notify_rx; in rxrpc_kernel_begin_call()
331 mutex_unlock(&call->user_mutex); in rxrpc_kernel_begin_call()
334 _leave(" = %p", call); in rxrpc_kernel_begin_call()
335 return call; in rxrpc_kernel_begin_call()
355 void rxrpc_kernel_shutdown_call(struct socket *sock, struct rxrpc_call *call) in rxrpc_kernel_shutdown_call() argument
357 _enter("%d{%d}", call->debug_id, refcount_read(&call->ref)); in rxrpc_kernel_shutdown_call()
359 mutex_lock(&call->user_mutex); in rxrpc_kernel_shutdown_call()
[all …]
Dar-internal.h479 struct rxrpc_call *call; /* Active call */ member
776 struct rxrpc_call_params call; member
866 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial,
872 void rxrpc_resend(struct rxrpc_call *call, struct sk_buff *ack_skb);
874 void rxrpc_reduce_call_timer(struct rxrpc_call *call,
879 bool rxrpc_input_call_event(struct rxrpc_call *call, struct sk_buff *skb);
888 void rxrpc_poke_call(struct rxrpc_call *call, enum rxrpc_call_poke_trace what);
896 void rxrpc_start_call_timer(struct rxrpc_call *call);
908 static inline bool rxrpc_is_service_call(const struct rxrpc_call *call) in rxrpc_is_service_call() argument
910 return test_bit(RXRPC_CALL_IS_SERVICE, &call->flags); in rxrpc_is_service_call()
[all …]
Dio_thread.c322 struct rxrpc_call *call = NULL; in rxrpc_input_packet_on_conn() local
359 if (chan->call || in rxrpc_input_packet_on_conn()
382 call = rxrpc_try_get_call(chan->call, rxrpc_call_get_input); in rxrpc_input_packet_on_conn()
386 rxrpc_put_call(call, rxrpc_call_put_input); in rxrpc_input_packet_on_conn()
391 if (call) { in rxrpc_input_packet_on_conn()
392 rxrpc_implicit_end_call(call, skb); in rxrpc_input_packet_on_conn()
393 rxrpc_put_call(call, rxrpc_call_put_input); in rxrpc_input_packet_on_conn()
394 call = NULL; in rxrpc_input_packet_on_conn()
398 if (!call) { in rxrpc_input_packet_on_conn()
405 ret = rxrpc_input_call_event(call, skb); in rxrpc_input_packet_on_conn()
[all …]
Dconn_event.c198 struct rxrpc_call *call; in rxrpc_abort_calls() local
204 call = conn->channels[i].call; in rxrpc_abort_calls()
205 if (call) in rxrpc_abort_calls()
206 rxrpc_set_call_completion(call, in rxrpc_abort_calls()
219 static void rxrpc_call_is_secure(struct rxrpc_call *call) in rxrpc_call_is_secure() argument
221 if (call && __rxrpc_call_state(call) == RXRPC_CALL_SERVER_SECURING) { in rxrpc_call_is_secure()
222 rxrpc_set_call_state(call, RXRPC_CALL_SERVER_RECV_REQUEST); in rxrpc_call_is_secure()
223 rxrpc_notify_socket(call); in rxrpc_call_is_secure()
436 rxrpc_call_is_secure(conn->channels[loop].call); in rxrpc_input_conn_event()
Dinsecure.c20 static int none_how_much_data(struct rxrpc_call *call, size_t remain, in none_how_much_data() argument
28 static int none_secure_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) in none_secure_packet() argument
33 static int none_verify_packet(struct rxrpc_call *call, struct sk_buff *skb) in none_verify_packet() argument
41 static void none_free_call_crypto(struct rxrpc_call *call) in none_free_call_crypto() argument
Dpeer_event.c205 struct rxrpc_call *call; in rxrpc_distribute_error() local
212 call = hlist_entry(error_targets.first, in rxrpc_distribute_error()
214 hlist_del_init(&call->error_link); in rxrpc_distribute_error()
217 rxrpc_see_call(call, rxrpc_call_see_distribute_error); in rxrpc_distribute_error()
218 rxrpc_set_call_completion(call, compl, 0, -err); in rxrpc_distribute_error()
219 rxrpc_input_call_event(call, skb); in rxrpc_distribute_error()
Dsecurity.c68 int rxrpc_init_client_call_security(struct rxrpc_call *call) in rxrpc_init_client_call_security() argument
72 struct key *key = call->key; in rxrpc_init_client_call_security()
90 call->security = sec; in rxrpc_init_client_call_security()
91 call->security_ix = sec->security_index; in rxrpc_init_client_call_security()
Drtt.c147 void rxrpc_peer_add_rtt(struct rxrpc_call *call, enum rxrpc_rtt_rx_trace why, in rxrpc_peer_add_rtt() argument
152 struct rxrpc_peer *peer = call->peer; in rxrpc_peer_add_rtt()
165 trace_rxrpc_rtt_rx(call, why, rtt_slot, send_serial, resp_serial, in rxrpc_peer_add_rtt()
Dpeer_object.c467 void rxrpc_kernel_get_peer(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_get_peer() argument
470 *_srx = call->peer->srx; in rxrpc_kernel_get_peer()
482 bool rxrpc_kernel_get_srtt(struct socket *sock, struct rxrpc_call *call, in rxrpc_kernel_get_srtt() argument
485 struct rxrpc_peer *peer = call->peer; in rxrpc_kernel_get_srtt()
492 *_srtt = call->peer->srtt_us >> 3; in rxrpc_kernel_get_srtt()
/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/
Dcompat.c423 COMPAT_SYSCALL_DEFINE2(socketcall, int, call, u32 __user *, args) in COMPAT_SYSCALL_DEFINE2() argument
430 if (call < SYS_SOCKET || call > SYS_SENDMMSG) in COMPAT_SYSCALL_DEFINE2()
432 len = nas[call]; in COMPAT_SYSCALL_DEFINE2()
446 switch (call) { in COMPAT_SYSCALL_DEFINE2()

12