/net/rxrpc/ |
H A D | ar-skbuff.c | 24 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 D | ar-error.c | 218 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 D | ar-proc.c | 50 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 D | ar-recvmsg.c | 20 * 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 D | ar-security.c | 226 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 D | ar-accept.c | 1 /* 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 D | ar-connevent.c | 31 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 D | ar-input.c | 38 * - 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 D | ar-call.c | 1 /* 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 D | ar-connection.c | 296 * 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 D | ar-output.c | 25 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 D | af_rxrpc.c | 256 * 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 D | ar-ack.c | 44 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 D | rxkad.c | 153 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 D | ar-internal.h | 83 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 D | af_ax25.c | 1041 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 D | compat.c | 800 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 D | af_rose.c | 244 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;
|