| /linux/net/rxrpc/ |
| H A D | call_object.c | 2 /* RxRPC individual remote procedure call handling
47 void rxrpc_poke_call(struct rxrpc_call *call, enum rxrpc_call_poke_trace what) in rxrpc_poke_call()
49 struct rxrpc_local *local = call->local; in rxrpc_poke_call()
52 if (!test_bit(RXRPC_CALL_DISCONNECTED, &call->flags)) { in rxrpc_poke_call()
54 busy = !list_empty(&call->attend_link); in rxrpc_poke_call()
55 trace_rxrpc_poke_call(call, busy, what); in rxrpc_poke_call()
56 if (!busy && !rxrpc_try_get_call(call, rxrpc_call_get_poke)) in rxrpc_poke_call()
59 list_add_tail(&call->attend_link, &local->call_attend_q); in rxrpc_poke_call()
69 struct rxrpc_call *call = timer_container_of(call, in rxrpc_call_timer_expired()
45 rxrpc_poke_call(struct rxrpc_call * call,enum rxrpc_call_poke_trace what) rxrpc_poke_call() argument
67 struct rxrpc_call *call = timer_container_of(call, t, timer); rxrpc_call_timer_expired() local
88 struct rxrpc_call *call; rxrpc_find_call_by_user_ID() local
124 struct rxrpc_call *call; rxrpc_alloc_call() local
195 struct rxrpc_call *call; rxrpc_alloc_client_call() local
248 rxrpc_start_call_timer(struct rxrpc_call * call) rxrpc_start_call_timer() argument
278 rxrpc_put_call_slot(struct rxrpc_call * call) rxrpc_put_call_slot() argument
292 rxrpc_connect_call(struct rxrpc_call * call,gfp_t gfp) rxrpc_connect_call() argument
329 struct rxrpc_call *call, *xcall; rxrpc_new_client_call() local
440 rxrpc_incoming_call(struct rxrpc_sock * rx,struct rxrpc_call * call,struct sk_buff * skb) rxrpc_incoming_call() argument
501 rxrpc_see_call(struct rxrpc_call * call,enum rxrpc_call_trace why) rxrpc_see_call() argument
510 rxrpc_try_get_call(struct rxrpc_call * call,enum rxrpc_call_trace why) rxrpc_try_get_call() argument
524 rxrpc_get_call(struct rxrpc_call * call,enum rxrpc_call_trace why) rxrpc_get_call() argument
535 rxrpc_cleanup_tx_buffers(struct rxrpc_call * call) rxrpc_cleanup_tx_buffers() argument
552 rxrpc_cleanup_rx_buffers(struct rxrpc_call * call) rxrpc_cleanup_rx_buffers() argument
563 rxrpc_release_call(struct rxrpc_sock * rx,struct rxrpc_call * call) rxrpc_release_call() argument
610 struct rxrpc_call *call; rxrpc_release_calls_on_socket() local
645 rxrpc_put_call(struct rxrpc_call * call,enum rxrpc_call_trace why) rxrpc_put_call() argument
672 struct rxrpc_call *call = container_of(rcu, struct rxrpc_call, rcu); rxrpc_rcu_free_call() local
685 struct rxrpc_call *call = container_of(work, struct rxrpc_call, destroyer); rxrpc_destroy_call() local
704 rxrpc_cleanup_call(struct rxrpc_call * call) rxrpc_cleanup_call() argument
729 struct rxrpc_call *call; rxrpc_destroy_all_calls() local
768 rxrpc_kernel_query_call_security(struct rxrpc_call * call,u16 * _service_id,u32 * _enctype) rxrpc_kernel_query_call_security() argument
[all...] |
| H A D | call_event.c | 23 void rxrpc_propose_ping(struct rxrpc_call *call, u32 serial, in rxrpc_propose_ping() argument
30 trace_rxrpc_propose_ack(call, why, RXRPC_ACK_PING, serial); in rxrpc_propose_ping()
31 if (ktime_before(ping_at, call->ping_at)) { in rxrpc_propose_ping()
32 call->ping_at = ping_at; in rxrpc_propose_ping()
33 trace_rxrpc_timer_set(call, delay, rxrpc_timer_trace_ping); in rxrpc_propose_ping()
40 void rxrpc_propose_delay_ACK(struct rxrpc_call *call, rxrpc_serial_t serial, in rxrpc_propose_delay_ACK() argument
45 trace_rxrpc_propose_ack(call, why, RXRPC_ACK_DELAY, serial); in rxrpc_propose_delay_ACK()
47 if (call->srtt_us) in rxrpc_propose_delay_ACK()
48 delay = (call->srtt_us >> 3) * NSEC_PER_USEC; in rxrpc_propose_delay_ACK()
51 ktime_add_ms(delay, call in rxrpc_propose_delay_ACK()
60 rxrpc_retransmit_data(struct rxrpc_call * call,struct rxrpc_send_data_req * req) rxrpc_retransmit_data() argument
86 rxrpc_resend(struct rxrpc_call * call) rxrpc_resend() argument
131 rxrpc_resend_tlp(struct rxrpc_call * call) rxrpc_resend_tlp() argument
162 rxrpc_begin_service_reply(struct rxrpc_call * call) rxrpc_begin_service_reply() argument
175 rxrpc_close_tx_phase(struct rxrpc_call * call) rxrpc_close_tx_phase() argument
194 rxrpc_transmit_fresh_data(struct rxrpc_call * call,unsigned int limit,enum rxrpc_txdata_trace trace) rxrpc_transmit_fresh_data() argument
259 rxrpc_transmit_some_data(struct rxrpc_call * call,unsigned int limit,enum rxrpc_txdata_trace trace) rxrpc_transmit_some_data() argument
288 rxrpc_send_initial_ping(struct rxrpc_call * call) rxrpc_send_initial_ping() argument
300 rxrpc_input_call_event(struct rxrpc_call * call) rxrpc_input_call_event() argument
[all...] |
| H A D | input.c | 23 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
36 summary->in_flight = rxrpc_tx_in_flight(call); in rxrpc_congestion_management()
38 if (test_and_clear_bit(RXRPC_CALL_RETRANS_TIMEOUT, &call->flags)) { in rxrpc_congestion_management()
40 call->cong_ssthresh = umax(summary->in_flight / 2, 2); in rxrpc_congestion_management()
41 call->cong_cwnd = 1; in rxrpc_congestion_management()
42 if (call->cong_cwnd >= call->cong_ssthresh && in rxrpc_congestion_management()
43 call in rxrpc_congestion_management()
177 rxrpc_congestion_degrade(struct rxrpc_call * call) rxrpc_congestion_degrade() argument
204 rxrpc_add_data_rtt_sample(struct rxrpc_call * call,struct rxrpc_ack_summary * summary,struct rxrpc_txqueue * tq,int ix) rxrpc_add_data_rtt_sample() argument
220 rxrpc_rotate_tx_window(struct rxrpc_call * call,rxrpc_seq_t to,struct rxrpc_ack_summary * summary) rxrpc_rotate_tx_window() argument
347 rxrpc_end_tx_phase(struct rxrpc_call * call,bool reply_begun,enum rxrpc_abort_reason abort_why) rxrpc_end_tx_phase() argument
385 rxrpc_receiving_reply(struct rxrpc_call * call) rxrpc_receiving_reply() argument
409 rxrpc_end_rx_phase(struct rxrpc_call * call,rxrpc_serial_t serial) rxrpc_end_rx_phase() argument
434 rxrpc_input_update_ack_window(struct rxrpc_call * call,rxrpc_seq_t window,rxrpc_seq_t wtop) rxrpc_input_update_ack_window() argument
444 rxrpc_input_queue_data(struct rxrpc_call * call,struct sk_buff * skb,rxrpc_seq_t window,rxrpc_seq_t wtop,enum rxrpc_receive_trace why) rxrpc_input_queue_data() argument
469 rxrpc_input_data_one(struct rxrpc_call * call,struct sk_buff * skb,bool * _notify,rxrpc_serial_t * _ack_serial,int * _ack_reason) rxrpc_input_data_one() argument
612 rxrpc_input_split_jumbo(struct rxrpc_call * call,struct sk_buff * skb) rxrpc_input_split_jumbo() argument
682 rxrpc_input_data(struct rxrpc_call * call,struct sk_buff * skb) rxrpc_input_data() argument
736 rxrpc_complete_rtt_probe(struct rxrpc_call * call,ktime_t resp_time,rxrpc_serial_t acked_serial,rxrpc_serial_t ack_serial,enum rxrpc_rtt_rx_trace type) rxrpc_complete_rtt_probe() argument
786 rxrpc_input_ack_trailer(struct rxrpc_call * call,struct sk_buff * skb,struct rxrpc_acktrailer * trailer) rxrpc_input_ack_trailer() argument
857 rxrpc_input_soft_rtt(struct rxrpc_call * call,struct rxrpc_ack_summary * summary,struct rxrpc_txqueue * tq) rxrpc_input_soft_rtt() argument
869 rxrpc_input_soft_ack_tq(struct rxrpc_call * call,struct rxrpc_ack_summary * summary,struct rxrpc_txqueue * tq,unsigned long extracted_acks,int nr_reported,rxrpc_seq_t seq,rxrpc_seq_t * lowest_nak) rxrpc_input_soft_ack_tq() argument
959 rxrpc_input_soft_acks(struct rxrpc_call * call,struct rxrpc_ack_summary * summary,struct sk_buff * skb) rxrpc_input_soft_acks() argument
1026 rxrpc_is_ack_valid(struct rxrpc_call * call,rxrpc_seq_t hard_ack,rxrpc_seq_t prev_pkt) rxrpc_is_ack_valid() argument
1056 rxrpc_input_ack(struct rxrpc_call * call,struct sk_buff * skb) rxrpc_input_ack() argument
1206 rxrpc_input_ackall(struct rxrpc_call * call,struct sk_buff * skb) rxrpc_input_ackall() argument
1217 rxrpc_input_abort(struct rxrpc_call * call,struct sk_buff * skb) rxrpc_input_abort() argument
1230 rxrpc_input_call_packet(struct rxrpc_call * call,struct sk_buff * skb) rxrpc_input_call_packet() argument
1283 rxrpc_implicit_end_call(struct rxrpc_call * call,struct sk_buff * skb) rxrpc_implicit_end_call() argument
[all...] |
| H A D | sendmsg.c | 23 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()
32 trace_rxrpc_abort_call(call, abort_code); in rxrpc_propose_abort()
34 smp_store_release(&call->send_abort, abort_code); in rxrpc_propose_abort()
35 rxrpc_poke_call(call, rxrpc_call_poke_abor in rxrpc_propose_abort()
46 rxrpc_wait_to_be_connected(struct rxrpc_call * call,long * timeo) rxrpc_wait_to_be_connected() argument
95 rxrpc_check_tx_space(struct rxrpc_call * call,rxrpc_seq_t * _tx_win) rxrpc_check_tx_space() argument
108 rxrpc_wait_for_tx_window_intr(struct rxrpc_sock * rx,struct rxrpc_call * call,long * timeo) rxrpc_wait_for_tx_window_intr() argument
132 rxrpc_wait_for_tx_window_waitall(struct rxrpc_sock * rx,struct rxrpc_call * call) rxrpc_wait_for_tx_window_waitall() argument
172 rxrpc_wait_for_tx_window_nonintr(struct rxrpc_sock * rx,struct rxrpc_call * call,long * timeo) rxrpc_wait_for_tx_window_nonintr() argument
193 rxrpc_wait_for_tx_window(struct rxrpc_sock * rx,struct rxrpc_call * call,long * timeo,bool waitall) rxrpc_wait_for_tx_window() argument
229 rxrpc_notify_end_tx(struct rxrpc_sock * rx,struct rxrpc_call * call,rxrpc_notify_end_tx_t notify_end_tx) rxrpc_notify_end_tx() argument
241 rxrpc_queue_packet(struct rxrpc_sock * rx,struct rxrpc_call * call,struct rxrpc_txbuf * txb,rxrpc_notify_end_tx_t notify_end_tx) rxrpc_queue_packet() argument
281 rxrpc_alloc_txqueue(struct sock * sk,struct rxrpc_call * call) rxrpc_alloc_txqueue() argument
321 rxrpc_send_data(struct rxrpc_sock * rx,struct rxrpc_call * call,struct msghdr * msg,size_t len,rxrpc_notify_end_tx_t notify_end_tx,bool * _dropped_lock) rxrpc_send_data() argument
615 struct rxrpc_call *call; rxrpc_new_client_call_for_sendmsg() local
661 struct rxrpc_call *call; rxrpc_do_sendmsg() local
806 rxrpc_kernel_send_data(struct socket * sock,struct rxrpc_call * call,struct msghdr * msg,size_t len,rxrpc_notify_end_tx_t notify_end_tx) rxrpc_kernel_send_data() argument
844 rxrpc_kernel_abort_call(struct socket * sock,struct rxrpc_call * call,u32 abort_code,int error,enum rxrpc_abort_reason why) rxrpc_kernel_abort_call() argument
870 rxrpc_kernel_set_tx_length(struct socket * sock,struct rxrpc_call * call,s64 tx_total_len) rxrpc_kernel_set_tx_length() argument
[all...] |
| H A D | input_rack.c | 23 static void rxrpc_rack_mark_lost(struct rxrpc_call *call, in rxrpc_rack_mark_lost() argument
28 call->tx_nr_resent--; in rxrpc_rack_mark_lost()
30 call->tx_nr_lost++; in rxrpc_rack_mark_lost()
62 static void rxrpc_rack_update(struct rxrpc_call *call, in rxrpc_rack_update() argument
69 ktime_t rtt = ktime_sub(call->acks_latest_ts, xmit_ts); in rxrpc_rack_update()
72 call->tx_nr_lost--; in rxrpc_rack_update()
76 if (before(call->acks_highest_serial, tq->segment_serial[ix])) in rxrpc_rack_update()
78 if (rtt < minmax_get(&call->min_rtt)) in rxrpc_rack_update()
88 if (ktime_after(xmit_ts, call->rack_rtt_ts)) { in rxrpc_rack_update()
89 call->rack_rtt = rtt; in rxrpc_rack_update()
[all …]
|
| H A D | recvmsg.c | 20 * Post a call for attention by the socket or kernel service. Further
23 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 (test_bit(RXRPC_CALL_RELEASED, &call->flags)) { in rxrpc_notify_socket()
31 rxrpc_see_call(call, rxrpc_call_see_notify_released); in rxrpc_notify_socket()
37 rx = rcu_dereference(call->socket); in rxrpc_notify_socket()
40 if (call->notify_rx) { in rxrpc_notify_socket()
41 spin_lock_irq(&call->notify_lock); in rxrpc_notify_socket()
42 call->notify_rx(sk, call, cal in rxrpc_notify_socket()
68 rxrpc_recvmsg_term(struct rxrpc_call * call,struct msghdr * msg) rxrpc_recvmsg_term() argument
110 rxrpc_rotate_rx_window(struct rxrpc_call * call) rxrpc_rotate_rx_window() argument
159 rxrpc_verify_data(struct rxrpc_call * call,struct sk_buff * skb) rxrpc_verify_data() argument
201 rxrpc_recvmsg_user_id(struct rxrpc_call * call,struct msghdr * msg,int flags) rxrpc_recvmsg_user_id() argument
280 rxrpc_recvmsg_data(struct socket * sock,struct rxrpc_call * call,struct msghdr * msg,struct iov_iter * iter,size_t len,int flags,size_t * _offset) rxrpc_recvmsg_data() argument
411 struct rxrpc_call *call; rxrpc_recvmsg() local
645 rxrpc_kernel_recv_data(struct socket * sock,struct rxrpc_call * call,struct iov_iter * iter,size_t * _len,bool want_more,u32 * _abort,u16 * _service) rxrpc_kernel_recv_data() argument
[all...] |
| H A D | rxperf.c | 66 int (*deliver)(struct rxperf_call *call);
75 static int rxperf_deliver_param_block(struct rxperf_call *call);
76 static int rxperf_deliver_request(struct rxperf_call *call);
77 static int rxperf_process_call(struct rxperf_call *call);
83 static inline void rxperf_set_call_state(struct rxperf_call *call, in rxperf_set_call_state() argument
86 call->state = to; in rxperf_set_call_state()
89 static inline void rxperf_set_call_complete(struct rxperf_call *call, in rxperf_set_call_complete() argument
92 if (call->state != RXPERF_CALL_COMPLETE) { in rxperf_set_call_complete()
93 call->abort_code = remote_abort; in rxperf_set_call_complete()
94 call->error = error; in rxperf_set_call_complete()
[all …]
|
| H A D | output.c | 46 static void rxrpc_tx_backoff(struct rxrpc_call *call, int ret) in rxrpc_tx_backoff() argument
49 if (call->tx_backoff < 1000) in rxrpc_tx_backoff()
50 call->tx_backoff += 100; in rxrpc_tx_backoff()
52 call->tx_backoff = 0; in rxrpc_tx_backoff()
58 * lets the far side know we're still interested in this call and helps keep
64 static void rxrpc_set_keepalive(struct rxrpc_call *call, ktime_t now) in rxrpc_set_keepalive() argument
66 ktime_t delay = ms_to_ktime(READ_ONCE(call->next_rx_timo) / 6); in rxrpc_set_keepalive()
68 call->keepalive_at = ktime_add(ktime_get_real(), delay); in rxrpc_set_keepalive()
69 trace_rxrpc_timer_set(call, delay, rxrpc_timer_trace_keepalive); in rxrpc_set_keepalive()
75 static int rxrpc_alloc_ack(struct rxrpc_call *call, size_t sack_size) in rxrpc_alloc_ack() argument
[all …]
|
| H A D | call_state.c | 2 /* Call state changing functions.
11 * Transition a call to the complete state.
13 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()
[all …]
|
| H A D | call_accept.c | 2 /* incoming call handling
25 static void rxrpc_dummy_notify(struct sock *sk, struct rxrpc_call *call, in rxrpc_dummy_notify() argument
31 * Preallocate a single service call, connection and peer and, if possible,
40 struct rxrpc_call *call, *xcall; in rxrpc_service_prealloc_one() local
97 call = rxrpc_alloc_call(rx, gfp, debug_id); in rxrpc_service_prealloc_one()
98 if (!call) in rxrpc_service_prealloc_one()
100 call->flags |= (1 << RXRPC_CALL_IS_SERVICE); in rxrpc_service_prealloc_one()
101 rxrpc_set_call_state(call, RXRPC_CALL_SERVER_PREALLOC); in rxrpc_service_prealloc_one()
102 __set_bit(RXRPC_CALL_EV_INITIAL_PING, &call->events); in rxrpc_service_prealloc_one()
104 trace_rxrpc_call(call in rxrpc_service_prealloc_one()
221 struct rxrpc_call *call = b->call_backlog[tail]; rxrpc_discard_prealloc() local
254 struct rxrpc_call *call; rxrpc_alloc_incoming_call() local
343 struct rxrpc_call *call = NULL; rxrpc_new_incoming_call() local
[all...] |
| H A D | conn_client.c | 8 * call so as to handle retransmitted DATA packets in case the server didn't
15 * or a call ID counter overflows.
73 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 in rxrpc_alloc_bundle()
250 rxrpc_look_up_bundle(struct rxrpc_call * call,gfp_t gfp) rxrpc_look_up_bundle() argument
417 struct rxrpc_call *call = list_entry(bundle->waiting_calls.next, rxrpc_activate_one_channel() local
510 struct rxrpc_call *call; rxrpc_connect_client_calls() local
533 rxrpc_expose_client_call(struct rxrpc_call * call) rxrpc_expose_client_call() argument
573 rxrpc_disconnect_client_call(struct rxrpc_bundle * bundle,struct rxrpc_call * call) rxrpc_disconnect_client_call() argument
[all...] |
| /linux/fs/afs/ |
| H A D | rxrpc.c | 38 /* asynchronous incoming call initial processing */
162 * Allocate a call. in afs_alloc_call()
168 struct afs_call *call; in afs_alloc_call()
171 call = kzalloc_obj(*call, gfp); in afs_alloc_call()
172 if (!call) in afs_alloc_call()
175 call->type = type; in afs_alloc_call()
176 call->net = net; in afs_alloc_call()
177 call->debug_id = atomic_inc_return(&rxrpc_debug_id); in afs_alloc_call()
178 refcount_set(&call in afs_alloc_call()
160 struct afs_call *call; afs_alloc_call() local
184 afs_free_call(struct afs_call * call) afs_free_call() argument
217 afs_put_call(struct afs_call * call) afs_put_call() argument
234 struct afs_call *call = container_of(work, struct afs_call, free_work); afs_deferred_free_worker() local
243 afs_deferred_put_call(struct afs_call * call) afs_deferred_put_call() argument
261 afs_queue_call_work(struct afs_call * call) afs_queue_call_work() argument
277 struct afs_call *call; afs_alloc_flat_call() local
311 afs_flat_call_destructor(struct afs_call * call) afs_flat_call_destructor() argument
328 struct afs_call *call = (struct afs_call *)call_user_ID; afs_notify_end_request_tx() local
337 afs_make_call(struct afs_call * call,gfp_t gfp) afs_make_call() argument
484 afs_log_error(struct afs_call * call,s32 remote_abort) afs_log_error() argument
516 afs_deliver_to_call(struct afs_call * call) afs_deliver_to_call() argument
623 afs_wait_for_call_to_complete(struct afs_call * call) afs_wait_for_call_to_complete() argument
681 struct afs_call *call = (struct afs_call *)call_user_ID; afs_wake_up_call_waiter() local
694 struct afs_call *call = (struct afs_call *)call_user_ID; afs_wake_up_async_call() local
716 struct afs_call *call = container_of(work, struct afs_call, async_work); afs_process_async_call() local
731 struct afs_call *call = (struct afs_call *)user_call_ID; afs_rx_attach() local
743 struct afs_call *call = net->spare_incoming_call; afs_charge_preallocation() local
775 struct afs_call *call = (struct afs_call *)user_call_ID; afs_rx_discard_new_call() local
787 struct afs_call *call = (struct afs_call *)user_call_ID; afs_rx_new_call() local
802 afs_deliver_cm_op_id(struct afs_call * call) afs_deliver_cm_op_id() argument
841 struct afs_call *call = (struct afs_call *)call_user_ID; afs_notify_end_reply_tx() local
849 afs_send_empty_reply(struct afs_call * call) afs_send_empty_reply() argument
886 afs_send_simple_reply(struct afs_call * call,const void * buf,size_t len) afs_send_simple_reply() argument
926 afs_extract_data(struct afs_call * call,bool want_more) afs_extract_data() argument
969 afs_protocol_error(struct afs_call * call,enum afs_eproto_cause cause) afs_protocol_error() argument
[all...] |
| H A D | cmservice.c | 105 * route an incoming cache manager call
108 bool afs_cm_incoming_call(struct afs_call *call) in afs_cm_incoming_call() argument
110 _enter("{%u, CB.OP %u}", call->service_id, call->operation_ID); in afs_cm_incoming_call()
112 switch (call->operation_ID) { in afs_cm_incoming_call()
114 call->type = &afs_SRXCBCallBack; in afs_cm_incoming_call()
117 call->type = &afs_SRXCBInitCallBackState; in afs_cm_incoming_call()
120 call->type = &afs_SRXCBInitCallBackState3; in afs_cm_incoming_call()
123 call->type = &afs_SRXCBProbe; in afs_cm_incoming_call()
126 call->type = &afs_SRXCBProbeUuid; in afs_cm_incoming_call()
129 call->type = &afs_SRXCBTellMeAboutYourself; in afs_cm_incoming_call()
[all …]
|
| H A D | vlclient.c | 15 * Deliver reply data to a VL.GetEntryByNameU call.
17 static int afs_deliver_vl_get_entry_by_name_u(struct afs_call *call) in afs_deliver_vl_get_entry_by_name_u() argument
26 ret = afs_transfer_reply(call); in afs_deliver_vl_get_entry_by_name_u()
31 uvldb = call->buffer; in afs_deliver_vl_get_entry_by_name_u()
32 entry = call->ret_vldb; in afs_deliver_vl_get_entry_by_name_u()
115 struct afs_call *call; in afs_vl_get_entry_by_name_u() local
129 call = afs_alloc_flat_call(net, &afs_RXVLGetEntryByNameU, reqsz, in afs_vl_get_entry_by_name_u()
131 if (!call) { in afs_vl_get_entry_by_name_u()
136 call->key = vc->key; in afs_vl_get_entry_by_name_u()
137 call->ret_vldb = entry; in afs_vl_get_entry_by_name_u()
[all …]
|
| H A D | yfsclient.c | 138 static void yfs_check_req(struct afs_call *call, __be32 *bp) in yfs_check_req() argument
140 size_t len = (void *)bp - call->request; in yfs_check_req()
142 if (len > call->request_size) in yfs_check_req()
144 call->type->name, len, call->request_size); in yfs_check_req()
145 else if (len < call->request_size) in yfs_check_req()
147 call->type->name, len, call->request_size); in yfs_check_req()
174 struct afs_call *call, in xdr_decode_YFSFetchStatus() argument
220 afs_protocol_error(call, afs_eproto_bad_status); in xdr_decode_YFSFetchStatus()
228 struct afs_call *call, in xdr_decode_YFSCallBack() argument
235 cb_expiry = ktime_add(call->issue_time, xdr_to_u64(x->expiration_time) * 100); in xdr_decode_YFSCallBack()
[all …]
|
| H A D | fsclient.c | 55 struct afs_call *call, in xdr_decode_AFSFetchStatus() argument
60 bool inline_error = (call->operation_ID == afs_FS_InlineBulkStatus); in xdr_decode_AFSFetchStatus()
128 afs_protocol_error(call, afs_eproto_bad_status); in xdr_decode_AFSFetchStatus()
132 static time64_t xdr_decode_expiry(struct afs_call *call, u32 expiry) in xdr_decode_expiry() argument
134 return ktime_divns(call->issue_time, NSEC_PER_SEC) + expiry; in xdr_decode_expiry()
138 struct afs_call *call, in xdr_decode_AFSCallBack() argument
145 cb->expires_at = xdr_decode_expiry(call, ntohl(*bp++)); in xdr_decode_AFSCallBack()
238 static int afs_deliver_fs_fetch_status(struct afs_call *call) in afs_deliver_fs_fetch_status() argument
240 struct afs_operation *op = call->op; in afs_deliver_fs_fetch_status()
245 ret = afs_transfer_reply(call); in afs_deliver_fs_fetch_status()
[all …]
|
| /linux/include/trace/events/ |
| H A D | rxrpc.h | 53 EM(rxkad_abort_resp_call_ctr, "rxkad-resp-call-ctr") \
54 EM(rxkad_abort_resp_call_state, "rxkad-resp-call-state") \
88 EM(rxgk_abort_resp_call_ctr, "rxgk-resp-call-ctr") \
89 EM(rxgk_abort_resp_call_state, "rxgk-resp-call-state") \
107 EM(rxrpc_abort_call_improper_term, "call-improper-term") \
108 EM(rxrpc_abort_call_reset, "call-reset") \
109 EM(rxrpc_abort_call_sendmsg, "call-sendmsg") \
110 EM(rxrpc_abort_call_sock_release, "call-sock-rel") \
111 EM(rxrpc_abort_call_sock_release_tba, "call-sock-rel-tba") \
112 EM(rxrpc_abort_call_timeout, "call-timeout") \
[all …]
|
| /linux/tools/net/ynl/ |
| H A D | Makefile.deps | 19 CFLAGS_dev-energymodel:=$(call get_hdr_inc,_LINUX_DEV_ENERGYMODEL_H,dev_energymodel.h)
20 CFLAGS_devlink:=$(call get_hdr_inc,_LINUX_DEVLINK_H_,devlink.h)
21 CFLAGS_dpll:=$(call get_hdr_inc,_LINUX_DPLL_H,dpll.h)
22 CFLAGS_drm_ras:=$(call get_hdr_inc_drm,_LINUX_DRM_RAS_H,drm_ras.h)
23 CFLAGS_ethtool:=$(call get_hdr_inc,_LINUX_TYPELIMITS_H,typelimits.h) \
24 $(call get_hdr_inc,_LINUX_ETHTOOL_H,ethtool.h) \
25 $(call get_hdr_inc,_LINUX_ETHTOOL_NETLINK_H_,ethtool_netlink.h) \
26 $(call get_hdr_inc,_LINUX_ETHTOOL_NETLINK_GENERATED_H,ethtool_netlink_generated.h)
27 CFLAGS_handshake:=$(call get_hdr_inc,_LINUX_HANDSHAKE_H,handshake.h)
28 CFLAGS_lockd_netlink:=$(call get_hdr_in
[all...] |
| /linux/include/asm-generic/ |
| H A D | syscall.h | 3 * Access to user system call parameters and results
23 * syscall_get_nr - find what system call a task is executing
27 * If @task is executing a system call or is at system call
28 * tracing about to attempt one, returns the system call number.
29 * If @task is not executing a system call, i.e. it's blocked
33 * system call number can be meaningful. If the actual arch value
36 * It's only valid to call this when @task is known to be blocked.
41 * syscall_set_nr - change the system call a task is executing
44 * @nr: system call number
46 * Changes the system call number @task is about to execute.
[all …]
|
| /linux/tools/ |
| H A D | Makefile | 68 $(call descend,power/$@)
71 $(call descend,power/$@)
74 $(call descend,$@)
77 $(call descend,$@)
80 $(call descend,lib/api)
83 $(call descend,include/nolibc)
86 $(call descend,include/nolibc,$(patsubst nolibc_%,%,$@))
97 $(call descend,sched_ext)
100 $(call descend,testing/$@)
103 $(call descend,lib/$@)
[all …]
|
| /linux/include/trace/ |
| H A D | trace_custom_events.h | 62 #define DECLARE_CUSTOM_EVENT_CLASS(call, proto, args, tstruct, assign, print) \ argument
63 struct trace_custom_event_data_offsets_##call { \
77 #define DECLARE_CUSTOM_EVENT_CLASS(call, proto, args, tstruct, assign, print) \ argument
79 trace_custom_raw_output_##call(struct trace_iterator *iter, int flags, \
84 struct trace_custom_event_raw_##call *field; \
97 static struct trace_event_functions trace_custom_event_type_funcs_##call = { \
98 .trace = trace_custom_raw_output_##call, \
108 #define DECLARE_CUSTOM_EVENT_CLASS(call, proto, args, tstruct, func, print) \ argument
109 static struct trace_event_fields trace_custom_event_fields_##call[] = { \
120 #define DECLARE_CUSTOM_EVENT_CLASS(call, proto, args, tstruct, assign, print) \ argument
[all …]
|
| H A D | bpf_probe.h | 45 #define __BPF_DECLARE_TRACE(call, proto, args) \ argument
47 __bpf_trace_##call(void *__data, proto) \
53 #define DECLARE_EVENT_CLASS(call, proto, args, tstruct, assign, print) \ argument
54 __BPF_DECLARE_TRACE(call, PARAMS(proto), PARAMS(args))
56 #define __BPF_DECLARE_TRACE_SYSCALL(call, proto, args) \ argument
58 __bpf_trace_##call(void *__data, proto) \
65 #define DECLARE_EVENT_SYSCALL_CLASS(call, proto, args, tstruct, assign, print) \
66 __BPF_DECLARE_TRACE_SYSCALL(call, PARAMS(proto), PARAMS(args))
73 #define __DEFINE_EVENT(template, call, proto, args, size) \
74 static inline void bpf_test_probe_##call(voi
67 DECLARE_EVENT_SYSCALL_CLASS(call,proto,args,tstruct,assign,print) global() argument
75 __DEFINE_EVENT(template,call,proto,args,size) global() argument
96 __CHECK_WRITABLE_BUF_SIZE(call,proto,args,size) global() argument
108 DEFINE_EVENT_WRITABLE(template,call,proto,args,size) global() argument
113 DEFINE_EVENT(template,call,proto,args) global() argument
121 DECLARE_TRACE(call,proto,args) global() argument
126 DECLARE_TRACE_WRITABLE(call,proto,args,size) global() argument
[all...] |
| /linux/include/linux/firmware/intel/ |
| H A D | stratix10-smc.h | 14 * This file defines the Secure Monitor Call (SMC) message protocol used for
30 * FAST call executes atomic operations, returns when the requested operation
32 * STD call starts a operation which can be preempted by a non-secure
33 * interrupt. The call can return before the requested operation has
56 * Return values in INTEL_SIP_SMC_* call
86 * Sync call used by service driver at EL1 to request the FPGA in EL3 to
89 * Call register usage:
106 * Async call used by service driver at EL1 to provide FPGA configuration data
109 * Call register usage:
132 * Sync call use
[all...] |
| /linux/tools/perf/util/ |
| H A D | thread-stack.h | 3 * thread-stack.h: Synthesize a thread's stack using call / return events
24 * Call/Return flags.
26 * CALL_RETURN_NO_CALL: 'return' but no matching 'call'
27 * CALL_RETURN_NO_RETURN: 'call' but no matching 'return'
28 * CALL_RETURN_NON_CALL: a branch but not a 'call' to the start of a different
38 * struct call_return - paired call/return information.
39 * @thread: thread in which call/return occurred
40 * @comm: comm in which call/return occurred
41 * @cp: call path
42 * @call_time: timestamp of call (if known)
[all …]
|
| /linux/tools/testing/selftests/bpf/progs/ |
| H A D | verifier_spin_lock.c | 32 call %[bpf_map_lookup_elem]; \ in spin_lock_test1_success()
38 call %[bpf_spin_lock]; \ in spin_lock_test1_success()
42 call %[bpf_spin_unlock]; \ in spin_lock_test1_success()
65 call %[bpf_map_lookup_elem]; \ in lock_test2_direct_ld_st()
71 call %[bpf_spin_lock]; \ in lock_test2_direct_ld_st()
75 call %[bpf_spin_unlock]; \ in lock_test2_direct_ld_st()
99 call %[bpf_map_lookup_elem]; \ in __flag()
105 call %[bpf_spin_lock]; \ in __flag()
109 call %[bpf_spin_unlock]; \ in __flag()
133 call %[bpf_map_lookup_elem]; \ in __flag()
[all …]
|