Home
last modified time | relevance | path

Searched refs:call (Results 1 - 25 of 1033) sorted by relevance

12345678910>>...42

/kernel/linux/linux-5.10/net/rxrpc/
H A Dcall_object.c2 /* RxRPC individual remote procedure call handling
50 struct rxrpc_call *call = from_timer(call, t, timer); in rxrpc_call_timer_expired() local
52 _enter("%d", call->debug_id); in rxrpc_call_timer_expired()
54 if (call->state < RXRPC_CALL_COMPLETE) { in rxrpc_call_timer_expired()
55 trace_rxrpc_timer(call, rxrpc_timer_expired, jiffies); in rxrpc_call_timer_expired()
56 __rxrpc_queue_call(call); in rxrpc_call_timer_expired()
58 rxrpc_put_call(call, rxrpc_call_put); in rxrpc_call_timer_expired()
62 void rxrpc_reduce_call_timer(struct rxrpc_call *call, in rxrpc_reduce_call_timer() argument
67 if (rxrpc_try_get_call(call, rxrpc_call_got_time in rxrpc_reduce_call_timer()
74 rxrpc_delete_call_timer(struct rxrpc_call *call) rxrpc_delete_call_timer() argument
89 struct rxrpc_call *call; rxrpc_find_call_by_user_ID() local
125 struct rxrpc_call *call; rxrpc_alloc_call() local
199 struct rxrpc_call *call; rxrpc_alloc_client_call() local
221 rxrpc_start_call_timer(struct rxrpc_call *call) rxrpc_start_call_timer() argument
255 rxrpc_put_call_slot(struct rxrpc_call *call) rxrpc_put_call_slot() argument
278 struct rxrpc_call *call, *xcall; global() variable
359 rxrpc_start_call_timer(call); global() variable
403 rxrpc_incoming_call(struct rxrpc_sock *rx, struct rxrpc_call *call, struct sk_buff *skb) rxrpc_incoming_call() argument
444 rxrpc_queue_call(struct rxrpc_call *call) rxrpc_queue_call() argument
462 __rxrpc_queue_call(struct rxrpc_call *call) __rxrpc_queue_call() argument
478 rxrpc_see_call(struct rxrpc_call *call) rxrpc_see_call() argument
489 rxrpc_try_get_call(struct rxrpc_call *call, enum rxrpc_call_trace op) rxrpc_try_get_call() argument
503 rxrpc_get_call(struct rxrpc_call *call, enum rxrpc_call_trace op) rxrpc_get_call() argument
515 rxrpc_cleanup_ring(struct rxrpc_call *call) rxrpc_cleanup_ring() argument
528 rxrpc_release_call(struct rxrpc_sock *rx, struct rxrpc_call *call) rxrpc_release_call() argument
593 struct rxrpc_call *call; rxrpc_release_calls_on_socket() local
621 rxrpc_put_call(struct rxrpc_call *call, enum rxrpc_call_trace op) rxrpc_put_call() argument
652 struct rxrpc_call *call = container_of(work, struct rxrpc_call, processor); rxrpc_destroy_call() local
671 struct rxrpc_call *call = container_of(rcu, struct rxrpc_call, rcu); rxrpc_rcu_destroy_call() local
685 rxrpc_cleanup_call(struct rxrpc_call *call) rxrpc_cleanup_call() argument
707 struct rxrpc_call *call; rxrpc_destroy_all_calls() local
[all...]
H A Drecvmsg.c20 * 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 (!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 in rxrpc_notify_socket()
64 __rxrpc_set_call_completion(struct rxrpc_call *call, enum rxrpc_call_completion compl, u32 abort_code, int error) __rxrpc_set_call_completion() argument
82 rxrpc_set_call_completion(struct rxrpc_call *call, enum rxrpc_call_completion compl, u32 abort_code, int error) rxrpc_set_call_completion() argument
100 __rxrpc_call_completed(struct rxrpc_call *call) __rxrpc_call_completed() argument
105 rxrpc_call_completed(struct rxrpc_call *call) rxrpc_call_completed() argument
120 __rxrpc_abort_call(const char *why, struct rxrpc_call *call, rxrpc_seq_t seq, u32 abort_code, int error) __rxrpc_abort_call() argument
129 rxrpc_abort_call(const char *why, struct rxrpc_call *call, rxrpc_seq_t seq, u32 abort_code, int error) rxrpc_abort_call() argument
143 rxrpc_recvmsg_term(struct rxrpc_call *call, struct msghdr *msg) rxrpc_recvmsg_term() argument
184 rxrpc_end_rx_phase(struct rxrpc_call *call, rxrpc_serial_t serial) rxrpc_end_rx_phase() argument
222 rxrpc_rotate_rx_window(struct rxrpc_call *call) rxrpc_rotate_rx_window() argument
278 rxrpc_verify_packet(struct rxrpc_call *call, struct sk_buff *skb, u8 annotation, unsigned int offset, unsigned int len) rxrpc_verify_packet() argument
314 rxrpc_locate_data(struct rxrpc_call *call, struct sk_buff *skb, u8 *_annotation, unsigned int *_offset, unsigned int *_len, bool *_last) rxrpc_locate_data() argument
354 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
489 struct rxrpc_call *call; rxrpc_recvmsg() local
684 rxrpc_kernel_recv_data(struct socket *sock, struct rxrpc_call *call, struct iov_iter *iter, bool want_more, u32 *_abort, u16 *_service) rxrpc_kernel_recv_data() argument
783 rxrpc_kernel_get_reply_time(struct socket *sock, struct rxrpc_call *call, ktime_t *_ts) rxrpc_kernel_get_reply_time() argument
[all...]
H A 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 in __rxrpc_propose_ACK()
136 rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, u32 serial, bool immediate, bool background, enum rxrpc_propose_ack_trace why) rxrpc_propose_ACK() argument
149 rxrpc_congestion_timeout(struct rxrpc_call *call) rxrpc_congestion_timeout() argument
157 rxrpc_resend(struct rxrpc_call *call, unsigned long now_j) rxrpc_resend() argument
289 struct rxrpc_call *call = rxrpc_process_call() local
[all...]
H A Dinput.c27 struct rxrpc_call *call, rxrpc_seq_t seq) in rxrpc_proto_abort()
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 in rxrpc_congestion_management()
26 rxrpc_proto_abort(const char *why, struct rxrpc_call *call, rxrpc_seq_t seq) rxrpc_proto_abort() argument
198 rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, struct rxrpc_ack_summary *summary) rxrpc_rotate_tx_window() argument
257 rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun, const char *abort_why) rxrpc_end_tx_phase() argument
303 rxrpc_receiving_reply(struct rxrpc_call *call) rxrpc_receiving_reply() argument
390 rxrpc_input_dup_data(struct rxrpc_call *call, rxrpc_seq_t seq, bool is_jumbo, bool *_jumbo_bad) rxrpc_input_dup_data() argument
411 rxrpc_input_data(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_data() argument
622 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
680 rxrpc_input_check_for_lost_ack(struct rxrpc_call *call) rxrpc_input_check_for_lost_ack() argument
713 rxrpc_input_ping_response(struct rxrpc_call *call, ktime_t resp_time, rxrpc_serial_t acked_serial, rxrpc_serial_t ack_serial) rxrpc_input_ping_response() argument
725 rxrpc_input_ackinfo(struct rxrpc_call *call, struct sk_buff *skb, struct rxrpc_ackinfo *ackinfo) rxrpc_input_ackinfo() argument
775 rxrpc_input_soft_acks(struct rxrpc_call *call, u8 *acks, rxrpc_seq_t seq, int nr_acks, struct rxrpc_ack_summary *summary) rxrpc_input_soft_acks() argument
821 rxrpc_is_ack_valid(struct rxrpc_call *call, rxrpc_seq_t first_pkt, rxrpc_seq_t prev_pkt) rxrpc_is_ack_valid() argument
851 rxrpc_input_ack(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_ack() argument
1005 rxrpc_input_ackall(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_ackall() argument
1023 rxrpc_input_abort(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_abort() argument
1047 rxrpc_input_call_packet(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_call_packet() argument
1106 rxrpc_input_implicit_end_call(struct rxrpc_sock *rx, struct rxrpc_connection *conn, struct rxrpc_call *call) rxrpc_input_implicit_end_call() argument
1219 struct rxrpc_call *call = NULL; rxrpc_input_packet() local
[all...]
H A Dsendmsg.c23 static bool rxrpc_check_tx_space(struct rxrpc_call *call, rxrpc_seq_t *_tx_win) in rxrpc_check_tx_space() argument
26 min_t(unsigned int, call->tx_winsize, in rxrpc_check_tx_space()
27 call->cong_cwnd + call->cong_extra); in rxrpc_check_tx_space()
28 rxrpc_seq_t tx_win = READ_ONCE(call->tx_hard_ack); in rxrpc_check_tx_space()
32 return call->tx_top - tx_win < win_size; in rxrpc_check_tx_space()
39 struct rxrpc_call *call, in rxrpc_wait_for_tx_window_intr()
44 if (rxrpc_check_tx_space(call, NULL)) in rxrpc_wait_for_tx_window_intr()
47 if (call->state >= RXRPC_CALL_COMPLETE) in rxrpc_wait_for_tx_window_intr()
48 return call in rxrpc_wait_for_tx_window_intr()
38 rxrpc_wait_for_tx_window_intr(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo) rxrpc_wait_for_tx_window_intr() argument
62 rxrpc_wait_for_tx_window_waitall(struct rxrpc_sock *rx, struct rxrpc_call *call) rxrpc_wait_for_tx_window_waitall() argument
103 rxrpc_wait_for_tx_window_nonintr(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo) rxrpc_wait_for_tx_window_nonintr() argument
124 rxrpc_wait_for_tx_window(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo, bool waitall) rxrpc_wait_for_tx_window() argument
160 rxrpc_instant_resend(struct rxrpc_call *call, int ix) rxrpc_instant_resend() argument
179 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
191 rxrpc_queue_packet(struct rxrpc_sock *rx, struct rxrpc_call *call, struct sk_buff *skb, bool last, rxrpc_notify_end_tx_t notify_end_tx) rxrpc_queue_packet() argument
287 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
626 struct rxrpc_call *call; global() variable
668 struct rxrpc_call *call; global() variable
809 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
863 rxrpc_kernel_abort_call(struct socket *sock, struct rxrpc_call *call, u32 abort_code, int error, const char *why) rxrpc_kernel_abort_call() argument
893 rxrpc_kernel_set_tx_length(struct socket *sock, struct rxrpc_call *call, s64 tx_total_len) rxrpc_kernel_set_tx_length() argument
[all...]
/kernel/linux/linux-5.10/fs/afs/
H A Dcmservice.c103 * route an incoming cache manager call
106 bool afs_cm_incoming_call(struct afs_call *call) in afs_cm_incoming_call() argument
108 _enter("{%u, CB.OP %u}", call->service_id, call->operation_ID); in afs_cm_incoming_call()
110 switch (call->operation_ID) { in afs_cm_incoming_call()
112 call->type = &afs_SRXCBCallBack; in afs_cm_incoming_call()
115 call->type = &afs_SRXCBInitCallBackState; in afs_cm_incoming_call()
118 call->type = &afs_SRXCBInitCallBackState3; in afs_cm_incoming_call()
121 call->type = &afs_SRXCBProbe; in afs_cm_incoming_call()
124 call in afs_cm_incoming_call()
143 afs_find_cm_server_by_peer(struct afs_call *call) afs_find_cm_server_by_peer() argument
164 afs_find_cm_server_by_uuid(struct afs_call *call, struct afs_uuid *uuid) afs_find_cm_server_by_uuid() argument
184 afs_cm_destructor(struct afs_call *call) afs_cm_destructor() argument
193 afs_abort_service_call(struct afs_call *call, u32 abort_code, int error, const char *why) afs_abort_service_call() argument
206 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_CallBack() local
230 afs_deliver_cb_callback(struct afs_call *call) afs_deliver_cb_callback() argument
331 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_InitCallBackState() local
345 afs_deliver_cb_init_call_back_state(struct afs_call *call) afs_deliver_cb_init_call_back_state() argument
364 afs_deliver_cb_init_call_back_state3(struct afs_call *call) afs_deliver_cb_init_call_back_state3() argument
428 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_Probe() local
439 afs_deliver_cb_probe(struct afs_call *call) afs_deliver_cb_probe() argument
461 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_ProbeUuid() local
478 afs_deliver_cb_probe_uuid(struct afs_call *call) afs_deliver_cb_probe_uuid() argument
537 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_TellMeAboutYourself() local
576 afs_deliver_cb_tell_me_about_yourself(struct afs_call *call) afs_deliver_cb_tell_me_about_yourself() argument
595 afs_deliver_yfs_cb_callback(struct afs_call *call) afs_deliver_yfs_cb_callback() argument
[all...]
H A Drxrpc.c26 /* asynchronous incoming call initial processing */
132 * Allocate a call.
138 struct afs_call *call; in afs_alloc_call() local
141 call = kzalloc(sizeof(*call), gfp); in afs_alloc_call()
142 if (!call) in afs_alloc_call()
145 call->type = type; in afs_alloc_call()
146 call->net = net; in afs_alloc_call()
147 call->debug_id = atomic_inc_return(&rxrpc_debug_id); in afs_alloc_call()
148 atomic_set(&call in afs_alloc_call()
163 afs_put_call(struct afs_call *call) afs_put_call() argument
198 afs_get_call(struct afs_call *call, enum afs_call_trace why) afs_get_call() argument
212 afs_queue_call_work(struct afs_call *call) afs_queue_call_work() argument
230 struct afs_call *call; afs_alloc_flat_call() local
264 afs_flat_call_destructor(struct afs_call *call) afs_flat_call_destructor() argument
279 afs_load_bvec(struct afs_call *call, struct msghdr *msg, struct bio_vec *bv, pgoff_t first, pgoff_t last, unsigned offset) afs_load_bvec() argument
315 struct afs_call *call = (struct afs_call *)call_user_ID; afs_notify_end_request_tx() local
323 afs_send_pages(struct afs_call *call, struct msghdr *msg) afs_send_pages() argument
360 afs_make_call(struct afs_addr_cursor *ac, struct afs_call *call, gfp_t gfp) afs_make_call() argument
505 afs_deliver_to_call(struct afs_call *call) afs_deliver_to_call() argument
604 afs_wait_for_call_to_complete(struct afs_call *call, struct afs_addr_cursor *ac) afs_wait_for_call_to_complete() argument
688 struct afs_call *call = (struct afs_call *)call_user_ID; afs_wake_up_call_waiter() local
700 struct afs_call *call = (struct afs_call *)call_user_ID; afs_wake_up_async_call() local
723 struct afs_call *call = container_of(work, struct afs_call, async_work); afs_process_async_call() local
738 struct afs_call *call = (struct afs_call *)user_call_ID; afs_rx_attach() local
750 struct afs_call *call = net->spare_incoming_call; afs_charge_preallocation() local
783 struct afs_call *call = (struct afs_call *)user_call_ID; afs_rx_discard_new_call() local
804 afs_deliver_cm_op_id(struct afs_call *call) afs_deliver_cm_op_id() argument
838 struct afs_call *call = (struct afs_call *)call_user_ID; afs_notify_end_reply_tx() local
846 afs_send_empty_reply(struct afs_call *call) afs_send_empty_reply() argument
882 afs_send_simple_reply(struct afs_call *call, const void *buf, size_t len) afs_send_simple_reply() argument
921 afs_extract_data(struct afs_call *call, bool want_more) afs_extract_data() argument
962 afs_protocol_error(struct afs_call *call, enum afs_eproto_cause cause) afs_protocol_error() argument
[all...]
H A Dvlclient.c15 * 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
27 ret = afs_transfer_reply(call); in afs_deliver_vl_get_entry_by_name_u()
32 uvldb = call->buffer; in afs_deliver_vl_get_entry_by_name_u()
33 entry = call->ret_vldb; in afs_deliver_vl_get_entry_by_name_u()
109 static void afs_destroy_vl_get_entry_by_name_u(struct afs_call *call) in afs_destroy_vl_get_entry_by_name_u() argument
111 kfree(call->ret_vldb); in afs_destroy_vl_get_entry_by_name_u()
112 afs_flat_call_destructor(call); in afs_destroy_vl_get_entry_by_name_u()
134 struct afs_call *call; in afs_vl_get_entry_by_name_u() local
148 call in afs_vl_get_entry_by_name_u()
181 afs_deliver_vl_get_addrs_u(struct afs_call *call) afs_deliver_vl_get_addrs_u() argument
248 afs_vl_get_addrs_u_destructor(struct afs_call *call) afs_vl_get_addrs_u_destructor() argument
273 struct afs_call *call; afs_vl_get_addrs_u() local
314 afs_deliver_vl_get_capabilities(struct afs_call *call) afs_deliver_vl_get_capabilities() argument
356 afs_destroy_vl_get_capabilities(struct afs_call *call) afs_destroy_vl_get_capabilities() argument
386 struct afs_call *call; afs_vl_get_capabilities() local
421 afs_deliver_yfsvl_get_endpoints(struct afs_call *call) afs_deliver_yfsvl_get_endpoints() argument
622 struct afs_call *call; afs_yfsvl_get_endpoints() local
652 afs_deliver_yfsvl_get_cell_name(struct afs_call *call) afs_deliver_yfsvl_get_cell_name() argument
711 afs_destroy_yfsvl_get_cell_name(struct afs_call *call) afs_destroy_yfsvl_get_cell_name() argument
736 struct afs_call *call; afs_yfsvl_get_cell_name() local
[all...]
H A Dfsclient.c54 struct afs_call *call, in xdr_decode_AFSFetchStatus()
59 bool inline_error = (call->operation_ID == afs_FS_InlineBulkStatus); in xdr_decode_AFSFetchStatus()
127 afs_protocol_error(call, afs_eproto_bad_status); in xdr_decode_AFSFetchStatus()
131 static time64_t xdr_decode_expiry(struct afs_call *call, u32 expiry) in xdr_decode_expiry() argument
133 return ktime_divns(call->issue_time, NSEC_PER_SEC) + expiry; in xdr_decode_expiry()
137 struct afs_call *call, in xdr_decode_AFSCallBack()
144 cb->expires_at = xdr_decode_expiry(call, ntohl(*bp++)); in xdr_decode_AFSCallBack()
237 static int afs_deliver_fs_fetch_status(struct afs_call *call) in afs_deliver_fs_fetch_status() argument
239 struct afs_operation *op = call->op; in afs_deliver_fs_fetch_status()
244 ret = afs_transfer_reply(call); in afs_deliver_fs_fetch_status()
53 xdr_decode_AFSFetchStatus(const __be32 **_bp, struct afs_call *call, struct afs_status_cb *scb) xdr_decode_AFSFetchStatus() argument
136 xdr_decode_AFSCallBack(const __be32 **_bp, struct afs_call *call, struct afs_status_cb *scb) xdr_decode_AFSCallBack() argument
274 struct afs_call *call; afs_fs_fetch_status() local
299 afs_deliver_fs_fetch_data(struct afs_call *call) afs_deliver_fs_fetch_data() argument
452 struct afs_call *call; afs_fs_fetch_data64() local
482 struct afs_call *call; afs_fs_fetch_data() local
513 afs_deliver_fs_create_vnode(struct afs_call *call) afs_deliver_fs_create_vnode() argument
554 struct afs_call *call; afs_fs_create_file() local
607 struct afs_call *call; afs_fs_make_dir() local
649 afs_deliver_fs_file_status_and_vol(struct afs_call *call) afs_deliver_fs_file_status_and_vol() argument
686 struct afs_call *call; afs_fs_remove_file() local
733 struct afs_call *call; afs_fs_remove_dir() local
769 afs_deliver_fs_link(struct afs_call *call) afs_deliver_fs_link() argument
811 struct afs_call *call; afs_fs_link() local
849 afs_deliver_fs_symlink(struct afs_call *call) afs_deliver_fs_symlink() argument
891 struct afs_call *call; afs_fs_symlink() local
944 afs_deliver_fs_rename(struct afs_call *call) afs_deliver_fs_rename() argument
987 struct afs_call *call; afs_fs_rename() local
1040 afs_deliver_fs_store_data(struct afs_call *call) afs_deliver_fs_store_data() argument
1086 struct afs_call *call; afs_fs_store_data64() local
1131 struct afs_call *call; afs_fs_store_data() local
1217 struct afs_call *call; afs_fs_setattr_size64() local
1259 struct afs_call *call; afs_fs_setattr_size() local
1300 struct afs_call *call; afs_fs_setattr() local
1332 afs_deliver_fs_get_volume_status(struct afs_call *call) afs_deliver_fs_get_volume_status() argument
1472 struct afs_call *call; afs_fs_get_volume_status() local
1494 afs_deliver_fs_xxxx_lock(struct afs_call *call) afs_deliver_fs_xxxx_lock() argument
1552 struct afs_call *call; afs_fs_set_lock() local
1579 struct afs_call *call; afs_fs_extend_lock() local
1605 struct afs_call *call; afs_fs_release_lock() local
1628 afs_deliver_fs_give_up_all_callbacks(struct afs_call *call) afs_deliver_fs_give_up_all_callbacks() argument
1651 struct afs_call *call; afs_fs_give_up_all_callbacks() local
1674 afs_deliver_fs_get_capabilities(struct afs_call *call) afs_deliver_fs_get_capabilities() argument
1737 struct afs_call *call; afs_fs_get_capabilities() local
1765 afs_deliver_fs_inline_bulk_status(struct afs_call *call) afs_deliver_fs_inline_bulk_status() argument
1893 afs_done_fs_inline_bulk_status(struct afs_call *call) afs_done_fs_inline_bulk_status() argument
1921 struct afs_call *call; afs_fs_inline_bulk_status() local
1962 afs_deliver_fs_fetch_acl(struct afs_call *call) afs_deliver_fs_fetch_acl() argument
2042 struct afs_call *call; afs_fs_fetch_acl() local
2079 struct afs_call *call; afs_fs_store_acl() local
[all...]
H A Dyfsclient.c145 static void yfs_check_req(struct afs_call *call, __be32 *bp) in yfs_check_req() argument
147 size_t len = (void *)bp - call->request; in yfs_check_req()
149 if (len > call->request_size) in yfs_check_req()
151 call->type->name, len, call->request_size); in yfs_check_req()
152 else if (len < call->request_size) in yfs_check_req()
154 call->type->name, len, call->request_size); in yfs_check_req()
181 struct afs_call *call, in xdr_decode_YFSFetchStatus()
227 afs_protocol_error(call, afs_eproto_bad_statu in xdr_decode_YFSFetchStatus()
180 xdr_decode_YFSFetchStatus(const __be32 **_bp, struct afs_call *call, struct afs_status_cb *scb) xdr_decode_YFSFetchStatus() argument
234 xdr_decode_YFSCallBack(const __be32 **_bp, struct afs_call *call, struct afs_status_cb *scb) xdr_decode_YFSCallBack() argument
335 yfs_deliver_status_and_volsync(struct afs_call *call) yfs_deliver_status_and_volsync() argument
356 yfs_deliver_fs_fetch_data64(struct afs_call *call) yfs_deliver_fs_fetch_data64() argument
501 struct afs_call *call; yfs_fs_fetch_data() local
534 yfs_deliver_fs_create_vnode(struct afs_call *call) yfs_deliver_fs_create_vnode() argument
577 struct afs_call *call; yfs_fs_create_file() local
627 struct afs_call *call; yfs_fs_make_dir() local
664 yfs_deliver_fs_remove_file2(struct afs_call *call) yfs_deliver_fs_remove_file2() argument
689 yfs_done_fs_remove_file2(struct afs_call *call) yfs_done_fs_remove_file2() argument
716 struct afs_call *call; yfs_fs_remove_file2() local
748 yfs_deliver_fs_remove(struct afs_call *call) yfs_deliver_fs_remove() argument
784 struct afs_call *call; yfs_fs_remove_file() local
828 struct afs_call *call; yfs_fs_remove_dir() local
858 yfs_deliver_fs_link(struct afs_call *call) yfs_deliver_fs_link() argument
898 struct afs_call *call; yfs_fs_link() local
931 yfs_deliver_fs_symlink(struct afs_call *call) yfs_deliver_fs_symlink() argument
973 struct afs_call *call; yfs_fs_symlink() local
1011 yfs_deliver_fs_rename(struct afs_call *call) yfs_deliver_fs_rename() argument
1055 struct afs_call *call; yfs_fs_rename() local
1103 struct afs_call *call; yfs_fs_store_data() local
1177 struct afs_call *call; yfs_fs_setattr_size() local
1216 struct afs_call *call; yfs_fs_setattr() local
1250 yfs_deliver_fs_get_volume_status(struct afs_call *call) yfs_deliver_fs_get_volume_status() argument
1391 struct afs_call *call; yfs_fs_get_volume_status() local
1455 struct afs_call *call; yfs_fs_set_lock() local
1487 struct afs_call *call; yfs_fs_extend_lock() local
1517 struct afs_call *call; yfs_fs_release_lock() local
1544 yfs_deliver_fs_fetch_status(struct afs_call *call) yfs_deliver_fs_fetch_status() argument
1581 struct afs_call *call; yfs_fs_fetch_status() local
1610 yfs_deliver_fs_inline_bulk_status(struct afs_call *call) yfs_deliver_fs_inline_bulk_status() argument
1756 struct afs_call *call; yfs_fs_inline_bulk_status() local
1790 yfs_deliver_fs_fetch_opaque_acl(struct afs_call *call) yfs_deliver_fs_fetch_opaque_acl() argument
1923 struct afs_call *call; yfs_fs_fetch_opaque_acl() local
1965 struct afs_call *call; yfs_fs_store_opaque_acl2() local
[all...]
/kernel/linux/linux-6.6/fs/afs/
H A Dcmservice.c105 * 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 in afs_cm_incoming_call()
145 afs_find_cm_server_by_peer(struct afs_call *call) afs_find_cm_server_by_peer() argument
166 afs_find_cm_server_by_uuid(struct afs_call *call, struct afs_uuid *uuid) afs_find_cm_server_by_uuid() argument
186 afs_cm_destructor(struct afs_call *call) afs_cm_destructor() argument
195 afs_abort_service_call(struct afs_call *call, u32 abort_code, int error, enum rxrpc_abort_reason why) afs_abort_service_call() argument
208 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_CallBack() local
232 afs_deliver_cb_callback(struct afs_call *call) afs_deliver_cb_callback() argument
335 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_InitCallBackState() local
349 afs_deliver_cb_init_call_back_state(struct afs_call *call) afs_deliver_cb_init_call_back_state() argument
368 afs_deliver_cb_init_call_back_state3(struct afs_call *call) afs_deliver_cb_init_call_back_state3() argument
433 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_Probe() local
444 afs_deliver_cb_probe(struct afs_call *call) afs_deliver_cb_probe() argument
466 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_ProbeUuid() local
483 afs_deliver_cb_probe_uuid(struct afs_call *call) afs_deliver_cb_probe_uuid() argument
543 struct afs_call *call = container_of(work, struct afs_call, work); SRXAFSCB_TellMeAboutYourself() local
582 afs_deliver_cb_tell_me_about_yourself(struct afs_call *call) afs_deliver_cb_tell_me_about_yourself() argument
601 afs_deliver_yfs_cb_callback(struct afs_call *call) afs_deliver_yfs_cb_callback() argument
[all...]
H A Drxrpc.c28 /* asynchronous incoming call initial processing */
134 * Allocate a call.
140 struct afs_call *call; in afs_alloc_call() local
143 call = kzalloc(sizeof(*call), gfp); in afs_alloc_call()
144 if (!call) in afs_alloc_call()
147 call->type = type; in afs_alloc_call()
148 call->net = net; in afs_alloc_call()
149 call->debug_id = atomic_inc_return(&rxrpc_debug_id); in afs_alloc_call()
150 refcount_set(&call in afs_alloc_call()
165 afs_put_call(struct afs_call *call) afs_put_call() argument
203 afs_get_call(struct afs_call *call, enum afs_call_trace why) afs_get_call() argument
219 afs_queue_call_work(struct afs_call *call) afs_queue_call_work() argument
237 struct afs_call *call; afs_alloc_flat_call() local
271 afs_flat_call_destructor(struct afs_call *call) afs_flat_call_destructor() argument
288 struct afs_call *call = (struct afs_call *)call_user_ID; afs_notify_end_request_tx() local
297 afs_make_call(struct afs_addr_cursor *ac, struct afs_call *call, gfp_t gfp) afs_make_call() argument
439 afs_log_error(struct afs_call *call, s32 remote_abort) afs_log_error() argument
471 afs_deliver_to_call(struct afs_call *call) afs_deliver_to_call() argument
576 afs_wait_for_call_to_complete(struct afs_call *call, struct afs_addr_cursor *ac) afs_wait_for_call_to_complete() argument
661 struct afs_call *call = (struct afs_call *)call_user_ID; afs_wake_up_call_waiter() local
673 struct afs_call *call = (struct afs_call *)call_user_ID; afs_wake_up_async_call() local
695 struct afs_call *call = container_of(work, struct afs_call, async_work); afs_process_async_call() local
710 struct afs_call *call = (struct afs_call *)user_call_ID; afs_rx_attach() local
722 struct afs_call *call = net->spare_incoming_call; afs_charge_preallocation() local
755 struct afs_call *call = (struct afs_call *)user_call_ID; afs_rx_discard_new_call() local
776 afs_deliver_cm_op_id(struct afs_call *call) afs_deliver_cm_op_id() argument
810 struct afs_call *call = (struct afs_call *)call_user_ID; afs_notify_end_reply_tx() local
818 afs_send_empty_reply(struct afs_call *call) afs_send_empty_reply() argument
855 afs_send_simple_reply(struct afs_call *call, const void *buf, size_t len) afs_send_simple_reply() argument
895 afs_extract_data(struct afs_call *call, bool want_more) afs_extract_data() argument
938 afs_protocol_error(struct afs_call *call, enum afs_eproto_cause cause) afs_protocol_error() argument
[all...]
H A Dvlclient.c15 * 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
27 ret = afs_transfer_reply(call); in afs_deliver_vl_get_entry_by_name_u()
32 uvldb = call->buffer; in afs_deliver_vl_get_entry_by_name_u()
33 entry = call->ret_vldb; in afs_deliver_vl_get_entry_by_name_u()
109 static void afs_destroy_vl_get_entry_by_name_u(struct afs_call *call) in afs_destroy_vl_get_entry_by_name_u() argument
111 kfree(call->ret_vldb); in afs_destroy_vl_get_entry_by_name_u()
112 afs_flat_call_destructor(call); in afs_destroy_vl_get_entry_by_name_u()
134 struct afs_call *call; in afs_vl_get_entry_by_name_u() local
148 call in afs_vl_get_entry_by_name_u()
181 afs_deliver_vl_get_addrs_u(struct afs_call *call) afs_deliver_vl_get_addrs_u() argument
248 afs_vl_get_addrs_u_destructor(struct afs_call *call) afs_vl_get_addrs_u_destructor() argument
273 struct afs_call *call; afs_vl_get_addrs_u() local
314 afs_deliver_vl_get_capabilities(struct afs_call *call) afs_deliver_vl_get_capabilities() argument
356 afs_destroy_vl_get_capabilities(struct afs_call *call) afs_destroy_vl_get_capabilities() argument
386 struct afs_call *call; afs_vl_get_capabilities() local
421 afs_deliver_yfsvl_get_endpoints(struct afs_call *call) afs_deliver_yfsvl_get_endpoints() argument
623 struct afs_call *call; afs_yfsvl_get_endpoints() local
653 afs_deliver_yfsvl_get_cell_name(struct afs_call *call) afs_deliver_yfsvl_get_cell_name() argument
712 afs_destroy_yfsvl_get_cell_name(struct afs_call *call) afs_destroy_yfsvl_get_cell_name() argument
737 struct afs_call *call; afs_yfsvl_get_cell_name() local
[all...]
H A Dfsclient.c55 struct afs_call *call, in xdr_decode_AFSFetchStatus()
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()
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()
54 xdr_decode_AFSFetchStatus(const __be32 **_bp, struct afs_call *call, struct afs_status_cb *scb) xdr_decode_AFSFetchStatus() argument
137 xdr_decode_AFSCallBack(const __be32 **_bp, struct afs_call *call, struct afs_status_cb *scb) xdr_decode_AFSCallBack() argument
275 struct afs_call *call; afs_fs_fetch_status() local
300 afs_deliver_fs_fetch_data(struct afs_call *call) afs_deliver_fs_fetch_data() argument
425 struct afs_call *call; afs_fs_fetch_data64() local
455 struct afs_call *call; afs_fs_fetch_data() local
486 afs_deliver_fs_create_vnode(struct afs_call *call) afs_deliver_fs_create_vnode() argument
527 struct afs_call *call; afs_fs_create_file() local
580 struct afs_call *call; afs_fs_make_dir() local
622 afs_deliver_fs_file_status_and_vol(struct afs_call *call) afs_deliver_fs_file_status_and_vol() argument
659 struct afs_call *call; afs_fs_remove_file() local
706 struct afs_call *call; afs_fs_remove_dir() local
742 afs_deliver_fs_link(struct afs_call *call) afs_deliver_fs_link() argument
784 struct afs_call *call; afs_fs_link() local
822 afs_deliver_fs_symlink(struct afs_call *call) afs_deliver_fs_symlink() argument
864 struct afs_call *call; afs_fs_symlink() local
917 afs_deliver_fs_rename(struct afs_call *call) afs_deliver_fs_rename() argument
960 struct afs_call *call; afs_fs_rename() local
1013 afs_deliver_fs_store_data(struct afs_call *call) afs_deliver_fs_store_data() argument
1058 struct afs_call *call; afs_fs_store_data64() local
1103 struct afs_call *call; afs_fs_store_data() local
1178 struct afs_call *call; afs_fs_setattr_size64() local
1220 struct afs_call *call; afs_fs_setattr_size() local
1261 struct afs_call *call; afs_fs_setattr() local
1293 afs_deliver_fs_get_volume_status(struct afs_call *call) afs_deliver_fs_get_volume_status() argument
1434 struct afs_call *call; afs_fs_get_volume_status() local
1456 afs_deliver_fs_xxxx_lock(struct afs_call *call) afs_deliver_fs_xxxx_lock() argument
1514 struct afs_call *call; afs_fs_set_lock() local
1541 struct afs_call *call; afs_fs_extend_lock() local
1567 struct afs_call *call; afs_fs_release_lock() local
1590 afs_deliver_fs_give_up_all_callbacks(struct afs_call *call) afs_deliver_fs_give_up_all_callbacks() argument
1613 struct afs_call *call; afs_fs_give_up_all_callbacks() local
1636 afs_deliver_fs_get_capabilities(struct afs_call *call) afs_deliver_fs_get_capabilities() argument
1712 struct afs_call *call; afs_fs_get_capabilities() local
1740 afs_deliver_fs_inline_bulk_status(struct afs_call *call) afs_deliver_fs_inline_bulk_status() argument
1869 afs_done_fs_inline_bulk_status(struct afs_call *call) afs_done_fs_inline_bulk_status() argument
1897 struct afs_call *call; afs_fs_inline_bulk_status() local
1938 afs_deliver_fs_fetch_acl(struct afs_call *call) afs_deliver_fs_fetch_acl() argument
2019 struct afs_call *call; afs_fs_fetch_acl() local
2056 struct afs_call *call; afs_fs_store_acl() local
[all...]
H A Dyfsclient.c138 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()
220 afs_protocol_error(call, afs_eproto_bad_statu in xdr_decode_YFSFetchStatus()
173 xdr_decode_YFSFetchStatus(const __be32 **_bp, struct afs_call *call, struct afs_status_cb *scb) xdr_decode_YFSFetchStatus() argument
227 xdr_decode_YFSCallBack(const __be32 **_bp, struct afs_call *call, struct afs_status_cb *scb) xdr_decode_YFSCallBack() argument
328 yfs_deliver_status_and_volsync(struct afs_call *call) yfs_deliver_status_and_volsync() argument
349 yfs_deliver_fs_fetch_data64(struct afs_call *call) yfs_deliver_fs_fetch_data64() argument
465 struct afs_call *call; yfs_fs_fetch_data() local
500 yfs_deliver_fs_create_vnode(struct afs_call *call) yfs_deliver_fs_create_vnode() argument
543 struct afs_call *call; yfs_fs_create_file() local
593 struct afs_call *call; yfs_fs_make_dir() local
630 yfs_deliver_fs_remove_file2(struct afs_call *call) yfs_deliver_fs_remove_file2() argument
655 yfs_done_fs_remove_file2(struct afs_call *call) yfs_done_fs_remove_file2() argument
682 struct afs_call *call; yfs_fs_remove_file2() local
714 yfs_deliver_fs_remove(struct afs_call *call) yfs_deliver_fs_remove() argument
750 struct afs_call *call; yfs_fs_remove_file() local
794 struct afs_call *call; yfs_fs_remove_dir() local
824 yfs_deliver_fs_link(struct afs_call *call) yfs_deliver_fs_link() argument
864 struct afs_call *call; yfs_fs_link() local
897 yfs_deliver_fs_symlink(struct afs_call *call) yfs_deliver_fs_symlink() argument
939 struct afs_call *call; yfs_fs_symlink() local
978 yfs_deliver_fs_rename(struct afs_call *call) yfs_deliver_fs_rename() argument
1022 struct afs_call *call; yfs_fs_rename() local
1070 struct afs_call *call; yfs_fs_store_data() local
1133 struct afs_call *call; yfs_fs_setattr_size() local
1172 struct afs_call *call; yfs_fs_setattr() local
1206 yfs_deliver_fs_get_volume_status(struct afs_call *call) yfs_deliver_fs_get_volume_status() argument
1347 struct afs_call *call; yfs_fs_get_volume_status() local
1411 struct afs_call *call; yfs_fs_set_lock() local
1443 struct afs_call *call; yfs_fs_extend_lock() local
1473 struct afs_call *call; yfs_fs_release_lock() local
1500 yfs_deliver_fs_fetch_status(struct afs_call *call) yfs_deliver_fs_fetch_status() argument
1537 struct afs_call *call; yfs_fs_fetch_status() local
1566 yfs_deliver_fs_inline_bulk_status(struct afs_call *call) yfs_deliver_fs_inline_bulk_status() argument
1712 struct afs_call *call; yfs_fs_inline_bulk_status() local
1746 yfs_deliver_fs_fetch_opaque_acl(struct afs_call *call) yfs_deliver_fs_fetch_opaque_acl() argument
1879 struct afs_call *call; yfs_fs_fetch_opaque_acl() local
1921 struct afs_call *call; yfs_fs_store_opaque_acl2() local
[all...]
/kernel/linux/linux-6.6/net/rxrpc/
H A 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 in rxrpc_propose_delay_ACK()
67 rxrpc_send_ACK(struct rxrpc_call *call, u8 ack_reason, rxrpc_serial_t serial, enum rxrpc_propose_ack_trace why) rxrpc_send_ACK() argument
104 rxrpc_congestion_timeout(struct rxrpc_call *call) rxrpc_congestion_timeout() argument
112 rxrpc_resend(struct rxrpc_call *call, struct sk_buff *ack_skb) rxrpc_resend() argument
258 rxrpc_begin_service_reply(struct rxrpc_call *call) rxrpc_begin_service_reply() argument
273 rxrpc_close_tx_phase(struct rxrpc_call *call) rxrpc_close_tx_phase() argument
289 rxrpc_tx_window_has_space(struct rxrpc_call *call) rxrpc_tx_window_has_space() argument
304 rxrpc_decant_prepared_tx(struct rxrpc_call *call) rxrpc_decant_prepared_tx() argument
333 rxrpc_transmit_some_data(struct rxrpc_call *call) rxrpc_transmit_some_data() argument
361 rxrpc_send_initial_ping(struct rxrpc_call *call) rxrpc_send_initial_ping() argument
373 rxrpc_input_call_event(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_call_event() argument
[all...]
H A Dcall_object.c2 /* RxRPC individual remote procedure call handling
46 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, in rxrpc_call_timer_expired() local
78 rxrpc_reduce_call_timer(struct rxrpc_call *call, unsigned long expire_at, unsigned long now, enum rxrpc_timer_trace why) rxrpc_reduce_call_timer() argument
98 struct rxrpc_call *call; rxrpc_find_call_by_user_ID() local
134 struct rxrpc_call *call; rxrpc_alloc_call() local
202 struct rxrpc_call *call; rxrpc_alloc_client_call() local
253 rxrpc_start_call_timer(struct rxrpc_call *call) rxrpc_start_call_timer() argument
288 rxrpc_put_call_slot(struct rxrpc_call *call) rxrpc_put_call_slot() argument
302 rxrpc_connect_call(struct rxrpc_call *call, gfp_t gfp) rxrpc_connect_call() argument
344 struct rxrpc_call *call, *xcall; global() variable
449 rxrpc_incoming_call(struct rxrpc_sock *rx, struct rxrpc_call *call, struct sk_buff *skb) rxrpc_incoming_call() argument
512 rxrpc_see_call(struct rxrpc_call *call, enum rxrpc_call_trace why) rxrpc_see_call() argument
521 rxrpc_try_get_call(struct rxrpc_call *call, enum rxrpc_call_trace why) rxrpc_try_get_call() argument
535 rxrpc_get_call(struct rxrpc_call *call, enum rxrpc_call_trace why) rxrpc_get_call() argument
546 rxrpc_cleanup_ring(struct rxrpc_call *call) rxrpc_cleanup_ring() argument
555 rxrpc_release_call(struct rxrpc_sock *rx, struct rxrpc_call *call) rxrpc_release_call() argument
612 struct rxrpc_call *call; rxrpc_release_calls_on_socket() local
641 rxrpc_put_call(struct rxrpc_call *call, enum rxrpc_call_trace why) rxrpc_put_call() argument
670 struct rxrpc_call *call = container_of(rcu, struct rxrpc_call, rcu); rxrpc_rcu_free_call() local
683 struct rxrpc_call *call = container_of(work, struct rxrpc_call, destroyer); rxrpc_destroy_call() local
713 rxrpc_cleanup_call(struct rxrpc_call *call) rxrpc_cleanup_call() argument
738 struct rxrpc_call *call; rxrpc_destroy_all_calls() local
[all...]
H A 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()
42 * Wait for a call t
45 rxrpc_wait_to_be_connected(struct rxrpc_call *call, long *timeo) rxrpc_wait_to_be_connected() argument
94 rxrpc_check_tx_space(struct rxrpc_call *call, rxrpc_seq_t *_tx_win) rxrpc_check_tx_space() argument
104 rxrpc_wait_for_tx_window_intr(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo) rxrpc_wait_for_tx_window_intr() argument
128 rxrpc_wait_for_tx_window_waitall(struct rxrpc_sock *rx, struct rxrpc_call *call) rxrpc_wait_for_tx_window_waitall() argument
168 rxrpc_wait_for_tx_window_nonintr(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo) rxrpc_wait_for_tx_window_nonintr() argument
189 rxrpc_wait_for_tx_window(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo, bool waitall) rxrpc_wait_for_tx_window() argument
226 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
238 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
277 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
575 struct rxrpc_call *call; global() variable
614 struct rxrpc_call *call; global() variable
755 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
792 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
818 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 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 in rxperf_set_call_complete()
110 rxperf_queue_call_work(struct rxperf_call *call) rxperf_queue_call_work() argument
118 struct rxperf_call *call = (struct rxperf_call *)call_user_ID; rxperf_notify_rx() local
126 struct rxperf_call *call = (struct rxperf_call *)user_call_ID; rxperf_rx_attach() local
144 struct rxperf_call *call; rxperf_charge_preallocation() local
245 rxperf_log_error(struct rxperf_call *call, s32 remote_abort) rxperf_log_error() argument
277 struct rxperf_call *call = container_of(work, struct rxperf_call, work); rxperf_deliver_to_call() local
354 rxperf_extract_data(struct rxperf_call *call, bool want_more) rxperf_extract_data() argument
388 rxperf_deliver_param_block(struct rxperf_call *call) rxperf_deliver_param_block() argument
436 rxperf_deliver_request(struct rxperf_call *call) rxperf_deliver_request() argument
494 rxperf_process_call(struct rxperf_call *call) rxperf_process_call() argument
[all...]
H A Dinput.c12 static void rxrpc_proto_abort(struct rxrpc_call *call, rxrpc_seq_t seq, in rxrpc_proto_abort() argument
15 rxrpc_abort_call(call, seq, RX_PROTOCOL_ERROR, -EBADMSG, why); in rxrpc_proto_abort()
21 static void rxrpc_congestion_management(struct rxrpc_call *call, in rxrpc_congestion_management() argument
27 unsigned int cumulative_acks = call->cong_cumul_acks; in rxrpc_congestion_management()
28 unsigned int cwnd = call->cong_cwnd; in rxrpc_congestion_management()
32 (call->tx_top - call->acks_hard_ack) - summary->nr_acks; in rxrpc_congestion_management()
34 if (test_and_clear_bit(RXRPC_CALL_RETRANS_TIMEOUT, &call->flags)) { in rxrpc_congestion_management()
36 call->cong_ssthresh = max_t(unsigned int, in rxrpc_congestion_management()
39 if (cwnd >= call in rxrpc_congestion_management()
179 rxrpc_congestion_degrade(struct rxrpc_call *call) rxrpc_congestion_degrade() argument
206 rxrpc_rotate_tx_window(struct rxrpc_call *call, rxrpc_seq_t to, struct rxrpc_ack_summary *summary) rxrpc_rotate_tx_window() argument
250 rxrpc_end_tx_phase(struct rxrpc_call *call, bool reply_begun, enum rxrpc_abort_reason abort_why) rxrpc_end_tx_phase() argument
288 rxrpc_receiving_reply(struct rxrpc_call *call) rxrpc_receiving_reply() argument
316 rxrpc_end_rx_phase(struct rxrpc_call *call, rxrpc_serial_t serial) rxrpc_end_rx_phase() argument
341 rxrpc_input_update_ack_window(struct rxrpc_call *call, rxrpc_seq_t window, rxrpc_seq_t wtop) rxrpc_input_update_ack_window() argument
351 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
368 rxrpc_input_data_one(struct rxrpc_call *call, struct sk_buff *skb, bool *_notify) rxrpc_input_data_one() argument
512 rxrpc_input_split_jumbo(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_split_jumbo() argument
567 rxrpc_input_data(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_data() argument
623 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
673 rxrpc_input_ackinfo(struct rxrpc_call *call, struct sk_buff *skb, struct rxrpc_ackinfo *ackinfo) rxrpc_input_ackinfo() argument
711 rxrpc_input_check_prev_ack(struct rxrpc_call *call, struct rxrpc_ack_summary *summary, rxrpc_seq_t seq) rxrpc_input_check_prev_ack() argument
754 rxrpc_input_soft_acks(struct rxrpc_call *call, struct rxrpc_ack_summary *summary, struct sk_buff *skb, rxrpc_seq_t seq, rxrpc_seq_t since) rxrpc_input_soft_acks() argument
805 rxrpc_is_ack_valid(struct rxrpc_call *call, rxrpc_seq_t first_pkt, rxrpc_seq_t prev_pkt) rxrpc_is_ack_valid() argument
835 rxrpc_input_ack(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_ack() argument
1011 rxrpc_input_ackall(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_ackall() argument
1022 rxrpc_input_abort(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_abort() argument
1035 rxrpc_input_call_packet(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_input_call_packet() argument
1090 rxrpc_implicit_end_call(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_implicit_end_call() argument
[all...]
H A Drecvmsg.c20 * 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 (!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 in rxrpc_notify_socket()
64 rxrpc_recvmsg_term(struct rxrpc_call *call, struct msghdr *msg) rxrpc_recvmsg_term() argument
106 rxrpc_rotate_rx_window(struct rxrpc_call *call) rxrpc_rotate_rx_window() argument
148 rxrpc_verify_data(struct rxrpc_call *call, struct sk_buff *skb) rxrpc_verify_data() argument
163 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
281 struct rxrpc_call *call; rxrpc_recvmsg() local
489 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 Dcall_state.c11 * 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()
28 rxrpc_notify_socket(call); in rxrpc_set_call_completion()
35 rxrpc_call_completed(struct rxrpc_call *call) rxrpc_call_completed() argument
43 rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq, u32 abort_code, int error, enum rxrpc_abort_reason why) rxrpc_abort_call() argument
60 rxrpc_prefail_call(struct rxrpc_call *call, enum rxrpc_call_completion compl, int error) rxrpc_prefail_call() argument
[all...]
H A 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()
62 * lets the far side know we're still interested in this call and helps keep
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()
81 rxrpc_fill_out_ack(struct rxrpc_connection *conn, struct rxrpc_call *call, struct rxrpc_txbuf *txb, u16 *_rwind) rxrpc_fill_out_ack() argument
144 rxrpc_begin_rtt_probe(struct rxrpc_call *call, rxrpc_serial_t serial, enum rxrpc_rtt_tx_trace why) rxrpc_begin_rtt_probe() argument
173 rxrpc_cancel_rtt_probe(struct rxrpc_call *call, rxrpc_serial_t serial, int rtt_slot) rxrpc_cancel_rtt_probe() argument
187 rxrpc_send_ack_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) rxrpc_send_ack_packet() argument
260 rxrpc_send_abort_packet(struct rxrpc_call *call) rxrpc_send_abort_packet() argument
324 rxrpc_send_data_packet(struct rxrpc_call *call, struct rxrpc_txbuf *txb) rxrpc_send_data_packet() argument
698 rxrpc_instant_resend(struct rxrpc_call *call, struct rxrpc_txbuf *txb) rxrpc_instant_resend() argument
708 rxrpc_transmit_one(struct rxrpc_call *call, struct rxrpc_txbuf *txb) rxrpc_transmit_one() argument
[all...]
/kernel/linux/linux-6.6/include/trace/
H A Dtrace_events.h8 * struct trace_event_raw_<call> {
101 * struct trace_event_data_offsets_<call> {
115 #define DECLARE_EVENT_CLASS(call, proto, args, tstruct, assign, print) \
116 struct trace_event_data_offsets_##call { \
141 * trace_raw_output_<call>(struct trace_iterator *iter, int flags)
144 * struct trace_event_raw_<call> *field; <-- defined in stage 1
153 * if (entry->type != event_<call>->event.type) {
161 * return trace_output_call(iter, <call>, <TP_printk> "\n");
187 #define DECLARE_EVENT_CLASS(call, proto, args, tstruct, assign, print) \
189 trace_raw_output_##call(struc
[all...]
/kernel/linux/linux-6.6/tools/
H A DMakefile67 $(call descend,power/$@)
70 $(call descend,power/$@)
73 $(call descend,$@)
76 $(call descend,$@)
79 $(call descend,lib/api)
82 $(call descend,include/nolibc)
85 $(call descend,include/nolibc,$(patsubst nolibc_%,%,$@))
96 $(call descend,testing/$@)
99 $(call descend,lib/$@)
102 $(call descen
[all...]

Completed in 15 milliseconds

12345678910>>...42