Searched defs:call (Results 1 - 18 of 18) sorted by relevance

/net/rxrpc/
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
103 struct rxrpc_call *call = sp->call; local
[all...]
H A Dar-error.c218 struct rxrpc_call *call, *_n; local
225 list_for_each_entry_safe(call, _n, &trans->peer->error_targets,
227 write_lock(&call->state_lock);
228 if (call->state != RXRPC_CALL_COMPLETE &&
229 call->state < RXRPC_CALL_NETWORK_ERROR) {
230 call->state = RXRPC_CALL_NETWORK_ERROR;
231 set_bit(RXRPC_CALL_RCVD_ERROR, &call->events);
232 rxrpc_queue_call(call);
234 write_unlock(&call->state_lock);
235 list_del_init(&call
[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-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
380 struct rxrpc_call *call = sp->call; local
[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 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-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-input.c38 * - the caller must hold a lock on call->lock
44 int rxrpc_queue_rcv_skb(struct rxrpc_call *call, struct sk_buff *skb, argument
48 struct rxrpc_sock *rx = call->socket;
57 ASSERTCMP(sp->call, ==, call);
59 /* if we've already posted the terminal message for a call, then we
61 if (test_bit(RXRPC_CALL_TERMINAL_MSG, &call->flags)) {
63 ASSERTCMP(call->state, >=, RXRPC_CALL_COMPLETE);
65 sp->call = NULL;
66 rxrpc_put_call(call);
143 rxrpc_fast_process_data(struct rxrpc_call *call, struct sk_buff *skb, u32 seq) argument
289 rxrpc_assume_implicit_ackall(struct rxrpc_call *call, u32 serial) argument
319 rxrpc_fast_process_packet(struct rxrpc_call *call, struct sk_buff *skb) argument
460 rxrpc_process_jumbo_packet(struct rxrpc_call *call, struct sk_buff *jumbo) argument
533 struct rxrpc_call *call; local
[all...]
H A Dar-call.c1 /* RxRPC individual remote procedure call handling
51 * allocate a new call
55 struct rxrpc_call *call; local
57 call = kmem_cache_zalloc(rxrpc_call_jar, gfp);
58 if (!call)
61 call->acks_winsz = 16;
62 call->acks_window = kmalloc(call->acks_winsz * sizeof(unsigned long),
64 if (!call->acks_window) {
65 kmem_cache_free(rxrpc_call_jar, call);
108 struct rxrpc_call *call; local
153 struct rxrpc_call *call, *candidate; local
251 struct rxrpc_call *call, *candidate; local
383 struct rxrpc_call *call; local
419 rxrpc_release_call(struct rxrpc_call *call) argument
547 struct rxrpc_call *call = (struct rxrpc_call *) _call; local
561 rxrpc_mark_call_released(struct rxrpc_call *call) argument
588 struct rxrpc_call *call; local
617 __rxrpc_put_call(struct rxrpc_call *call) argument
636 rxrpc_cleanup_call(struct rxrpc_call *call) argument
702 struct rxrpc_call *call = local
724 struct rxrpc_call *call; local
773 struct rxrpc_call *call = (struct rxrpc_call *) _call; local
793 struct rxrpc_call *call = (struct rxrpc_call *) _call; local
810 struct rxrpc_call *call = (struct rxrpc_call *) _call; local
[all...]
H A Dar-connection.c296 * add a call to a connection's call-by-ID tree
299 struct rxrpc_call *call)
307 call_id = call->call_id;
322 rb_link_node(&call->conn_node, parent, p);
323 rb_insert_color(&call->conn_node, &conn->calls);
329 * connect a call on an exclusive connection
334 struct rxrpc_call *call,
387 * call to it
398 conn->channels[chan] = call;
298 rxrpc_add_call_ID_to_conn(struct rxrpc_connection *conn, struct rxrpc_call *call) argument
331 rxrpc_connect_exclusive(struct rxrpc_sock *rx, struct rxrpc_transport *trans, __be16 service_id, struct rxrpc_call *call, gfp_t gfp) argument
423 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 Dar-output.c25 struct rxrpc_call *call,
103 * abort a call, sending an ABORT packet to the peer
105 static void rxrpc_send_abort(struct rxrpc_call *call, u32 abort_code) argument
107 write_lock_bh(&call->state_lock);
109 if (call->state <= RXRPC_CALL_COMPLETE) {
110 call->state = RXRPC_CALL_LOCALLY_ABORTED;
111 call->abort_code = abort_code;
112 set_bit(RXRPC_CALL_ABORT, &call->events);
113 del_timer_sync(&call->resend_timer);
114 del_timer_sync(&call
135 struct rxrpc_call *call; local
210 rxrpc_kernel_send_data(struct rxrpc_call *call, struct msghdr *msg, size_t len) argument
252 rxrpc_kernel_abort_call(struct rxrpc_call *call, u32 abort_code) argument
278 struct rxrpc_call *call; local
399 rxrpc_wait_for_tx_window(struct rxrpc_sock *rx, struct rxrpc_call *call, long *timeo) argument
437 rxrpc_instant_resend(struct rxrpc_call *call) argument
453 rxrpc_queue_packet(struct rxrpc_call *call, struct sk_buff *skb, bool last) argument
523 rxrpc_send_data(struct kiocb *iocb, struct rxrpc_sock *rx, struct rxrpc_call *call, struct msghdr *msg, size_t len) 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-ack.c44 void __rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, argument
53 call->debug_id, rxrpc_acks[ack_reason], ntohl(serial),
56 if (prior < rxrpc_ack_priority[call->ackr_reason]) {
64 if (prior == rxrpc_ack_priority[call->ackr_reason]) {
66 call->ackr_serial = serial;
72 call->ackr_reason = ack_reason;
73 call->ackr_serial = serial;
78 call->ack_timer.expires = jiffies + rxrpc_ack_timeout * HZ;
79 add_timer(&call->ack_timer);
106 if (!timer_pending(&call
124 rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, __be32 serial, bool immediate) argument
139 rxrpc_set_resend(struct rxrpc_call *call, u8 resend, unsigned long resend_at) argument
167 rxrpc_resend(struct rxrpc_call *call) argument
237 rxrpc_resend_timer(struct rxrpc_call *call) argument
288 rxrpc_process_soft_ACKs(struct rxrpc_call *call, struct rxrpc_ackpacket *ack, struct sk_buff *skb) argument
376 rxrpc_rotate_tx_window(struct rxrpc_call *call, u32 hard) argument
404 rxrpc_clear_tx_window(struct rxrpc_call *call) argument
412 rxrpc_drain_rx_oos_queue(struct rxrpc_call *call) argument
468 rxrpc_insert_oos_packet(struct rxrpc_call *call, struct sk_buff *skb) argument
520 rxrpc_zap_tx_window(struct rxrpc_call *call) argument
550 rxrpc_extract_ackinfo(struct rxrpc_call *call, struct sk_buff *skb, unsigned int latest, int nAcks) argument
582 rxrpc_process_rx_queue(struct rxrpc_call *call, u32 *_abort_code) argument
778 rxrpc_post_message(struct rxrpc_call *call, u32 mark, u32 error, bool fatal) argument
831 struct rxrpc_call *call = local
[all...]
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 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
407 rxrpc_abort_call(struct rxrpc_call *call, u32 abort_code) argument
[all...]
/net/ax25/
H A Daf_ax25.c1041 ax25_address call; local
1059 call = user->call;
1065 call = addr->fsa_ax25.sax25_call;
1076 ax25->source_addr = call;
1716 case SIOCAX25ADDUID: /* Add a uid to the uid/call map table */
1717 case SIOCAX25DELUID: /* Delete a uid from the uid/call map table */
/net/
H A Dcompat.c800 asmlinkage long compat_sys_socketcall(int call, u32 __user *args) argument
806 if (call < SYS_SOCKET || call > SYS_SENDMMSG)
808 if (copy_from_user(a, args, nas[call]))
813 switch (call) {
/net/rose/
H A Daf_rose.c244 static struct sock *rose_find_listener(rose_address *addr, ax25_address *call) argument
253 !ax25cmp(&rose->source_call, call) &&
687 rose->source_call = user->call;
793 rose->source_call = user->call;

Completed in 213 milliseconds