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

12

/net/rxrpc/
H A Dar-call.c1 /* RxRPC individual remote procedure call handling
22 * Maximum lifetime of a call (in jiffies).
27 * Time till dead call expires after last use (in jiffies).
103 * Add a call to the hashtable
105 static void rxrpc_call_hash_add(struct rxrpc_call *call) argument
111 switch (call->proto) {
113 addr_size = sizeof(call->peer_ip.ipv4_addr);
116 addr_size = sizeof(call->peer_ip.ipv6_addr);
121 key = rxrpc_call_hashfunc(call->in_clientflag, call
137 rxrpc_call_hash_del(struct rxrpc_call *call) argument
162 struct rxrpc_call *call = NULL; local
204 struct rxrpc_call *call; local
257 struct rxrpc_call *call; local
322 struct rxrpc_call *call, *candidate; local
420 struct rxrpc_call *call, *candidate; local
577 struct rxrpc_call *call; local
613 rxrpc_release_call(struct rxrpc_call *call) argument
741 struct rxrpc_call *call = (struct rxrpc_call *) _call; local
755 rxrpc_mark_call_released(struct rxrpc_call *call) argument
782 struct rxrpc_call *call; local
811 __rxrpc_put_call(struct rxrpc_call *call) argument
830 rxrpc_cleanup_call(struct rxrpc_call *call) argument
899 struct rxrpc_call *call = local
921 struct rxrpc_call *call; local
970 struct rxrpc_call *call = (struct rxrpc_call *) _call; local
990 struct rxrpc_call *call = (struct rxrpc_call *) _call; local
1007 struct rxrpc_call *call = (struct rxrpc_call *) _call; local
[all...]
H A Dar-skbuff.c24 static void rxrpc_request_final_ACK(struct rxrpc_call *call) argument
26 /* the call may be aborted before we have a chance to ACK it */
27 write_lock(&call->state_lock);
29 switch (call->state) {
31 call->state = RXRPC_CALL_CLIENT_FINAL_ACK;
34 /* get an extra ref on the call for the final-ACK generator to
36 rxrpc_get_call(call);
37 set_bit(RXRPC_CALL_ACK_FINAL, &call->events);
38 if (try_to_del_timer_sync(&call->ack_timer) >= 0)
39 rxrpc_queue_call(call);
54 rxrpc_hard_ACK_data(struct rxrpc_call *call, struct rxrpc_skb_priv *sp) argument
108 struct rxrpc_call *call = sp->call; local
[all...]
H A Dar-ack.c93 void __rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, argument
102 call->debug_id, rxrpc_acks(ack_reason), ntohl(serial),
105 if (prior < rxrpc_ack_priority[call->ackr_reason]) {
113 if (prior == rxrpc_ack_priority[call->ackr_reason]) {
115 call->ackr_serial = serial;
121 call->ackr_reason = ack_reason;
122 call->ackr_serial = serial;
154 if (!timer_pending(&call->ack_timer) ||
155 time_after(call->ack_timer.expires, expiry))
156 mod_timer(&call
172 rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, __be32 serial, bool immediate) argument
187 rxrpc_set_resend(struct rxrpc_call *call, u8 resend, unsigned long resend_at) argument
215 rxrpc_resend(struct rxrpc_call *call) argument
285 rxrpc_resend_timer(struct rxrpc_call *call) argument
336 rxrpc_process_soft_ACKs(struct rxrpc_call *call, struct rxrpc_ackpacket *ack, struct sk_buff *skb) argument
424 rxrpc_rotate_tx_window(struct rxrpc_call *call, u32 hard) argument
452 rxrpc_clear_tx_window(struct rxrpc_call *call) argument
460 rxrpc_drain_rx_oos_queue(struct rxrpc_call *call) argument
516 rxrpc_insert_oos_packet(struct rxrpc_call *call, struct sk_buff *skb) argument
568 rxrpc_zap_tx_window(struct rxrpc_call *call) argument
598 rxrpc_extract_ackinfo(struct rxrpc_call *call, struct sk_buff *skb, unsigned int latest, int nAcks) argument
630 rxrpc_process_rx_queue(struct rxrpc_call *call, u32 *_abort_code) argument
826 rxrpc_post_message(struct rxrpc_call *call, u32 mark, u32 error, bool fatal) argument
879 struct rxrpc_call *call = local
[all...]
H A Dar-input.c36 * - the caller must hold a lock on call->lock
42 int rxrpc_queue_rcv_skb(struct rxrpc_call *call, struct sk_buff *skb, argument
46 struct rxrpc_sock *rx = call->socket;
55 ASSERTCMP(sp->call, ==, call);
57 /* if we've already posted the terminal message for a call, then we
59 if (test_bit(RXRPC_CALL_TERMINAL_MSG, &call->flags)) {
61 ASSERTCMP(call->state, >=, RXRPC_CALL_COMPLETE);
63 sp->call = NULL;
64 rxrpc_put_call(call);
134 rxrpc_fast_process_data(struct rxrpc_call *call, struct sk_buff *skb, u32 seq) argument
280 rxrpc_assume_implicit_ackall(struct rxrpc_call *call, u32 serial) argument
310 rxrpc_fast_process_packet(struct rxrpc_call *call, struct sk_buff *skb) argument
450 rxrpc_process_jumbo_packet(struct rxrpc_call *call, struct sk_buff *jumbo) argument
519 rxrpc_post_packet_to_call(struct rxrpc_call *call, struct sk_buff *skb) argument
720 struct rxrpc_call *call; local
[all...]
H A Dar-output.c28 struct rxrpc_call *call,
106 * abort a call, sending an ABORT packet to the peer
108 static void rxrpc_send_abort(struct rxrpc_call *call, u32 abort_code) argument
110 write_lock_bh(&call->state_lock);
112 if (call->state <= RXRPC_CALL_COMPLETE) {
113 call->state = RXRPC_CALL_LOCALLY_ABORTED;
114 call->abort_code = abort_code;
115 set_bit(RXRPC_CALL_ABORT, &call->events);
116 del_timer_sync(&call->resend_timer);
117 del_timer_sync(&call
138 struct rxrpc_call *call; local
213 rxrpc_kernel_send_data(struct rxrpc_call *call, struct msghdr *msg, size_t len) argument
255 rxrpc_kernel_abort_call(struct rxrpc_call *call, u32 abort_code) argument
281 struct rxrpc_call *call; local
402 rxrpc_wait_for_tx_window(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo) argument
440 rxrpc_instant_resend(struct rxrpc_call *call) argument
456 rxrpc_queue_packet(struct rxrpc_call *call, struct sk_buff *skb, bool last) argument
526 rxrpc_send_data(struct kiocb *iocb, struct rxrpc_sock *rx, struct rxrpc_call *call, struct msghdr *msg, size_t len) argument
[all...]
H A Dar-accept.c1 /* incoming call handling
70 * accept an incoming call that needs peer, transport and/or connection setting
82 struct rxrpc_call *call; local
123 call = rxrpc_incoming_call(rx, conn, &sp->hdr, GFP_NOIO);
125 if (IS_ERR(call)) {
126 _debug("no call");
127 ret = PTR_ERR(call);
131 /* attach the call to the socket */
137 if (!test_and_set_bit(RXRPC_CALL_INIT_ACCEPT, &call->flags)) {
138 rxrpc_get_call(call);
322 struct rxrpc_call *call; local
415 struct rxrpc_call *call; local
483 struct rxrpc_call *call; local
[all...]
H A Dar-recvmsg.c20 * removal a call's user ID from the socket tree to make the user ID available
21 * again and so that it won't be seen again in association with that call
23 void rxrpc_remove_user_ID(struct rxrpc_sock *rx, struct rxrpc_call *call) argument
25 _debug("RELEASE CALL %d", call->debug_id);
27 if (test_bit(RXRPC_CALL_HAS_USERID, &call->flags)) {
29 rb_erase(&call->sock_node, &call->socket->calls);
30 clear_bit(RXRPC_CALL_HAS_USERID, &call->flags);
34 read_lock_bh(&call->state_lock);
35 if (!test_bit(RXRPC_CALL_RELEASED, &call
50 struct rxrpc_call *call = NULL, *continue_call = NULL; local
365 struct rxrpc_call *call = sp->call; local
[all...]
H A Dar-proc.c50 struct rxrpc_call *call; local
61 call = list_entry(v, struct rxrpc_call, link);
62 trans = call->conn->trans;
77 ntohs(call->conn->service_id),
78 ntohl(call->conn->cid),
79 ntohl(call->call_id),
80 call->conn->in_clientflag ? "Svc" : "Clt",
81 atomic_read(&call->usage),
82 rxrpc_call_states[call->state],
83 call
[all...]
H A Dar-connevent.c31 struct rxrpc_call *call; local
39 call = rb_entry(p, struct rxrpc_call, conn_node);
40 write_lock(&call->state_lock);
41 if (call->state <= RXRPC_CALL_COMPLETE) {
42 call->state = state;
43 call->abort_code = abort_code;
45 set_bit(RXRPC_CALL_CONN_ABORT, &call->events);
47 set_bit(RXRPC_CALL_RCVD_ABORT, &call->events);
48 rxrpc_queue_call(call);
50 write_unlock(&call
129 rxrpc_call_is_secure(struct rxrpc_call *call) argument
[all...]
H A Dar-error.c207 struct rxrpc_call *call, *_n; local
214 list_for_each_entry_safe(call, _n, &trans->peer->error_targets,
216 write_lock(&call->state_lock);
217 if (call->state != RXRPC_CALL_COMPLETE &&
218 call->state < RXRPC_CALL_NETWORK_ERROR) {
219 call->state = RXRPC_CALL_NETWORK_ERROR;
220 set_bit(RXRPC_CALL_RCVD_ERROR, &call->events);
221 rxrpc_queue_call(call);
223 write_unlock(&call->state_lock);
224 list_del_init(&call
[all...]
H A Dar-security.c226 int rxrpc_secure_packet(const struct rxrpc_call *call, argument
231 if (call->conn->security)
232 return call->conn->security->secure_packet(
233 call, skb, data_size, sechdr);
240 int rxrpc_verify_packet(const struct rxrpc_call *call, struct sk_buff *skb, argument
243 if (call->conn->security)
244 return call->conn->security->verify_packet(
245 call, skb, _abort_code);
H A Drxkad.c153 static int rxkad_secure_packet_auth(const struct rxrpc_call *call, argument
180 desc.tfm = call->conn->cipher;
197 static int rxkad_secure_packet_encrypt(const struct rxrpc_call *call, argument
224 token = call->conn->key->payload.data;
226 desc.tfm = call->conn->cipher;
239 len = data_size + call->conn->size_align - 1;
240 len &= ~(call->conn->size_align - 1);
253 static int rxkad_secure_packet(const struct rxrpc_call *call, argument
272 call->debug_id, key_serial(call
327 rxkad_verify_packet_auth(const struct rxrpc_call *call, struct sk_buff *skb, u32 *_abort_code) argument
401 rxkad_verify_packet_encrypt(const struct rxrpc_call *call, struct sk_buff *skb, u32 *_abort_code) argument
486 rxkad_verify_packet(const struct rxrpc_call *call, struct sk_buff *skb, u32 *_abort_code) argument
[all...]
H A DMakefile9 ar-call.o \
H A Dar-connection.c300 * add a call to a connection's call-by-ID tree
303 struct rxrpc_call *call)
311 call_id = call->call_id;
326 rb_link_node(&call->conn_node, parent, p);
327 rb_insert_color(&call->conn_node, &conn->calls);
333 * connect a call on an exclusive connection
338 struct rxrpc_call *call,
393 * call to it
404 conn->channels[chan] = call;
302 rxrpc_add_call_ID_to_conn(struct rxrpc_connection *conn, struct rxrpc_call *call) argument
335 rxrpc_connect_exclusive(struct rxrpc_sock *rx, struct rxrpc_transport *trans, __be16 service_id, struct rxrpc_call *call, gfp_t gfp) argument
429 rxrpc_connect_call(struct rxrpc_sock *rx, struct rxrpc_transport *trans, struct rxrpc_conn_bundle *bundle, struct rxrpc_call *call, gfp_t gfp) argument
[all...]
H A Daf_rxrpc.c256 * rxrpc_kernel_begin_call - Allow a kernel service to begin a call
257 * @sock: The socket on which to make the call
262 * Allow a kernel service to begin a call on the nominated socket. This just
264 * call IDs as appropriate. The call to be used is returned.
277 struct rxrpc_call *call; local
289 call = ERR_CAST(trans);
296 call = ERR_PTR(-ENOTCONN);
313 call = ERR_CAST(bundle);
317 call
337 rxrpc_kernel_end_call(struct rxrpc_call *call) argument
[all...]
H A Dar-internal.h83 struct rxrpc_call *call; /* call with which associated */ member in struct:rxrpc_skb_priv
100 RXRPC_CMD_ACCEPT, /* [server] accept incoming call */
101 RXRPC_CMD_REJECT_BUSY, /* [server] reject a call as busy */
153 struct work_struct acceptor; /* incoming call processor */
274 unsigned int call_counter; /* call ID counter */
294 * RxRPC call definition
298 struct rxrpc_connection *conn; /* connection carrying call */
300 struct timer_list lifetimer; /* lifetime remaining on call */
304 struct work_struct destroyer; /* call destroye
418 rxrpc_abort_call(struct rxrpc_call *call, u32 abort_code) argument
[all...]
/net/ax25/
H A Dax25_uid.c84 if (ax25cmp(&sax->sax25_call, &ax25_uid->call) == 0) {
113 ax25_uid->call = sax->sax25_call;
128 if (ax25cmp(&sax->sax25_call, &ax25_uid->call) == 0)
180 ax2asc(buf, &pt->call));
/net/netfilter/
H A Dnfnetlink_acct.c374 [NFNL_MSG_ACCT_NEW] = { .call = nfnl_acct_new,
377 [NFNL_MSG_ACCT_GET] = { .call = nfnl_acct_get,
380 [NFNL_MSG_ACCT_GET_CTRZERO] = { .call = nfnl_acct_get,
383 [NFNL_MSG_ACCT_DEL] = { .call = nfnl_acct_del,
H A Dnfnetlink_cttimeout.c517 [IPCTNL_MSG_TIMEOUT_NEW] = { .call = cttimeout_new_timeout,
520 [IPCTNL_MSG_TIMEOUT_GET] = { .call = cttimeout_get_timeout,
523 [IPCTNL_MSG_TIMEOUT_DELETE] = { .call = cttimeout_del_timeout,
526 [IPCTNL_MSG_TIMEOUT_DEFAULT_SET]= { .call = cttimeout_default_set,
529 [IPCTNL_MSG_TIMEOUT_DEFAULT_GET]= { .call = cttimeout_default_get,
H A Dxt_osf.c139 .call = xt_osf_add_callback,
144 .call = xt_osf_remove_callback,
H A Dnfnetlink_cthelper.c625 [NFNL_MSG_CTHELPER_NEW] = { .call = nfnl_cthelper_new,
628 [NFNL_MSG_CTHELPER_GET] = { .call = nfnl_cthelper_get,
631 [NFNL_MSG_CTHELPER_DEL] = { .call = nfnl_cthelper_del,
H A Dnfnetlink.c214 else if (nc->call)
215 err = nc->call(net->nfnl, skb, nlh,
H A Dnf_conntrack_netlink.c3103 [IPCTNL_MSG_CT_NEW] = { .call = ctnetlink_new_conntrack,
3106 [IPCTNL_MSG_CT_GET] = { .call = ctnetlink_get_conntrack,
3109 [IPCTNL_MSG_CT_DELETE] = { .call = ctnetlink_del_conntrack,
3112 [IPCTNL_MSG_CT_GET_CTRZERO] = { .call = ctnetlink_get_conntrack,
3115 [IPCTNL_MSG_CT_GET_STATS_CPU] = { .call = ctnetlink_stat_ct_cpu },
3116 [IPCTNL_MSG_CT_GET_STATS] = { .call = ctnetlink_stat_ct },
3117 [IPCTNL_MSG_CT_GET_DYING] = { .call = ctnetlink_get_ct_dying },
3118 [IPCTNL_MSG_CT_GET_UNCONFIRMED] = { .call = ctnetlink_get_ct_unconfirmed },
3122 [IPCTNL_MSG_EXP_GET] = { .call = ctnetlink_get_expect,
3125 [IPCTNL_MSG_EXP_NEW] = { .call
[all...]
/net/netfilter/ipset/
H A Dip_set_core.c646 * Routines to call by external subsystems, which do not
647 * call nfnl_lock for us.
956 /* Must call it without holding any lock */
977 * External systems (i.e. xt_set) must call
1759 .call = ip_set_none,
1763 .call = ip_set_create,
1768 .call = ip_set_destroy,
1773 .call = ip_set_flush,
1778 .call = ip_set_rename,
1783 .call
[all...]
/net/
H A Dcompat.c799 COMPAT_SYSCALL_DEFINE2(socketcall, int, call, u32 __user *, args)
805 if (call < SYS_SOCKET || call > SYS_SENDMMSG)
807 if (copy_from_user(a, args, nas[call]))
812 switch (call) {

Completed in 263 milliseconds

12