Linux Kernel
3.7.1
|
#include <rxrpc/packet.h>
Go to the source code of this file.
Data Structures | |
struct | rxrpc_crypt |
struct | rxrpc_sock |
struct | rxrpc_skb_priv |
struct | rxrpc_security |
struct | rxrpc_local |
struct | rxrpc_peer |
struct | rxrpc_transport |
struct | rxrpc_conn_bundle |
struct | rxrpc_connection |
struct | rxrpc_call |
Macros | |
#define | CHECK_SLAB_OKAY(X) do {} while(0) |
#define | FCRYPT_BSIZE 8 |
#define | rxrpc_queue_work(WS) queue_work(rxrpc_workqueue, (WS)) |
#define | rxrpc_queue_delayed_work(WS, D) queue_delayed_work(rxrpc_workqueue, (WS), (D)) |
#define | rxrpc_queue_call(CALL) rxrpc_queue_work(&(CALL)->processor) |
#define | rxrpc_queue_conn(CONN) rxrpc_queue_work(&(CONN)->processor) |
#define | RXRPC_SOCK_EXCLUSIVE_CONN 1 /* exclusive connection for a client socket */ |
#define | RXRPC_SECURITY_MAX RXRPC_SECURITY_ENCRYPT |
#define | rxrpc_sk(__sk) container_of((__sk), struct rxrpc_sock, sk) |
#define | rxrpc_skb(__skb) ((struct rxrpc_skb_priv *) &(__skb)->cb) |
#define | RXRPC_RTT_CACHE_SIZE 32 |
#define | RXRPC_CONN_CHALLENGE 0 /* send challenge packet */ |
#define | RXRPC_CALL_RELEASED 0 /* call has been released - no more message to userspace */ |
#define | RXRPC_CALL_TERMINAL_MSG 1 /* call has given the socket its final message */ |
#define | RXRPC_CALL_RCVD_LAST 2 /* all packets received */ |
#define | RXRPC_CALL_RUN_RTIMER 3 /* Tx resend timer started */ |
#define | RXRPC_CALL_TX_SOFT_ACK 4 /* sent some soft ACKs */ |
#define | RXRPC_CALL_PROC_BUSY 5 /* the processor is busy */ |
#define | RXRPC_CALL_INIT_ACCEPT 6 /* acceptance was initiated */ |
#define | RXRPC_CALL_HAS_USERID 7 /* has a user ID attached */ |
#define | RXRPC_CALL_EXPECT_OOS 8 /* expect out of sequence packets */ |
#define | RXRPC_CALL_RCVD_ACKALL 0 /* ACKALL or reply received */ |
#define | RXRPC_CALL_RCVD_BUSY 1 /* busy packet received */ |
#define | RXRPC_CALL_RCVD_ABORT 2 /* abort packet received */ |
#define | RXRPC_CALL_RCVD_ERROR 3 /* network error received */ |
#define | RXRPC_CALL_ACK_FINAL 4 /* need to generate final ACK (and release call) */ |
#define | RXRPC_CALL_ACK 5 /* need to generate ACK */ |
#define | RXRPC_CALL_REJECT_BUSY 6 /* need to generate busy message */ |
#define | RXRPC_CALL_ABORT 7 /* need to generate abort */ |
#define | RXRPC_CALL_CONN_ABORT 8 /* local connection abort generated */ |
#define | RXRPC_CALL_RESEND_TIMER 9 /* Tx resend timer expired */ |
#define | RXRPC_CALL_RESEND 10 /* Tx resend required */ |
#define | RXRPC_CALL_DRAIN_RX_OOS 11 /* drain the Rx out of sequence queue */ |
#define | RXRPC_CALL_LIFE_TIMER 12 /* call's lifetimer ran out */ |
#define | RXRPC_CALL_ACCEPTED 13 /* incoming call accepted by userspace app */ |
#define | RXRPC_CALL_SECURED 14 /* incoming call's connection is now secure */ |
#define | RXRPC_CALL_POST_ACCEPT 15 /* need to post an "accept?" message to the app */ |
#define | RXRPC_CALL_RELEASE 16 /* need to release the call's resources */ |
#define | RXRPC_ACKR_WINDOW_ASZ DIV_ROUND_UP(RXRPC_MAXACKS, BITS_PER_LONG) |
#define | dbgprintk(FMT,...) printk("[%-6.6s] "FMT"\n", current->comm ,##__VA_ARGS__) |
#define | kenter(FMT,...) dbgprintk("==> %s("FMT")",__func__ ,##__VA_ARGS__) |
#define | kleave(FMT,...) dbgprintk("<== %s()"FMT"",__func__ ,##__VA_ARGS__) |
#define | kdebug(FMT,...) dbgprintk(" "FMT ,##__VA_ARGS__) |
#define | kproto(FMT,...) dbgprintk("### "FMT ,##__VA_ARGS__) |
#define | knet(FMT,...) dbgprintk("@@@ "FMT ,##__VA_ARGS__) |
#define | _enter(FMT,...) no_printk("==> %s("FMT")",__func__ ,##__VA_ARGS__) |
#define | _leave(FMT,...) no_printk("<== %s()"FMT"",__func__ ,##__VA_ARGS__) |
#define | _debug(FMT,...) no_printk(" "FMT ,##__VA_ARGS__) |
#define | _proto(FMT,...) no_printk("### "FMT ,##__VA_ARGS__) |
#define | _net(FMT,...) no_printk("@@@ "FMT ,##__VA_ARGS__) |
#define | ASSERT(X) |
#define | ASSERTCMP(X, OP, Y) |
#define | ASSERTIF(C, X) |
#define | ASSERTIFCMP(C, X, OP, Y) |
#define | rxrpc_new_skb(skb) __rxrpc_new_skb((skb), __func__) |
#define | rxrpc_kill_skb(skb) __rxrpc_kill_skb((skb), __func__) |
#define | rxrpc_free_skb(skb) __rxrpc_free_skb((skb), __func__) |
#define | rxrpc_get_local(LOCAL) __rxrpc_get_local((LOCAL), __func__) |
#define | rxrpc_get_call(CALL) |
#define | rxrpc_put_call(CALL) |
Enumerations | |
enum | { RXRPC_UNCONNECTED = 0, RXRPC_CLIENT_BOUND, RXRPC_CLIENT_CONNECTED, RXRPC_SERVER_BOUND, RXRPC_SERVER_LISTENING, RXRPC_CLOSE } |
enum | rxrpc_command { RXRPC_CMD_SEND_DATA, RXRPC_CMD_SEND_ABORT, RXRPC_CMD_ACCEPT, RXRPC_CMD_REJECT_BUSY } |
Variables | |
union { | |
u8 x [FCRYPT_BSIZE] | |
__be32 n [2] | |
}; | |
enum { ... } | __attribute__ |
atomic_t | rxrpc_n_skbs |
__be32 | rxrpc_epoch |
atomic_t | rxrpc_debug_id |
struct workqueue_struct * | rxrpc_workqueue |
struct kmem_cache * | rxrpc_call_jar |
struct list_head | rxrpc_calls |
rwlock_t | rxrpc_call_lock |
struct list_head | rxrpc_connections |
rwlock_t | rxrpc_connection_lock |
unsigned long | rxrpc_ack_timeout |
const char * | rxrpc_pkts [] |
rwlock_t | rxrpc_local_lock |
struct key_type | key_type_rxrpc |
struct key_type | key_type_rxrpc_s |
int | rxrpc_resend_timeout |
const char *const | rxrpc_call_states [] |
struct file_operations | rxrpc_call_seq_fops |
struct file_operations | rxrpc_connection_seq_fops |
unsigned int | rxrpc_debug |
#define _debug | ( | FMT, | |
... | |||
) | no_printk(" "FMT ,##__VA_ARGS__) |
Definition at line 654 of file ar-internal.h.
#define _enter | ( | FMT, | |
... | |||
) | no_printk("==> %s("FMT")",__func__ ,##__VA_ARGS__) |
Definition at line 652 of file ar-internal.h.
#define _leave | ( | FMT, | |
... | |||
) | no_printk("<== %s()"FMT"",__func__ ,##__VA_ARGS__) |
Definition at line 653 of file ar-internal.h.
#define _net | ( | FMT, | |
... | |||
) | no_printk("@@@ "FMT ,##__VA_ARGS__) |
Definition at line 656 of file ar-internal.h.
#define _proto | ( | FMT, | |
... | |||
) | no_printk("### "FMT ,##__VA_ARGS__) |
Definition at line 655 of file ar-internal.h.
#define ASSERT | ( | X | ) |
Definition at line 673 of file ar-internal.h.
Definition at line 695 of file ar-internal.h.
#define CHECK_SLAB_OKAY | ( | X | ) | do {} while(0) |
Definition at line 19 of file ar-internal.h.
#define dbgprintk | ( | FMT, | |
... | |||
) | printk("[%-6.6s] "FMT"\n", current->comm ,##__VA_ARGS__) |
Definition at line 597 of file ar-internal.h.
#define FCRYPT_BSIZE 8 |
Definition at line 22 of file ar-internal.h.
#define kdebug | ( | FMT, | |
... | |||
) | dbgprintk(" "FMT ,##__VA_ARGS__) |
Definition at line 602 of file ar-internal.h.
#define kenter | ( | FMT, | |
... | |||
) | dbgprintk("==> %s("FMT")",__func__ ,##__VA_ARGS__) |
Definition at line 600 of file ar-internal.h.
#define kleave | ( | FMT, | |
... | |||
) | dbgprintk("<== %s()"FMT"",__func__ ,##__VA_ARGS__) |
Definition at line 601 of file ar-internal.h.
#define knet | ( | FMT, | |
... | |||
) | dbgprintk("@@@ "FMT ,##__VA_ARGS__) |
Definition at line 604 of file ar-internal.h.
#define kproto | ( | FMT, | |
... | |||
) | dbgprintk("### "FMT ,##__VA_ARGS__) |
Definition at line 603 of file ar-internal.h.
#define RXRPC_ACKR_WINDOW_ASZ DIV_ROUND_UP(RXRPC_MAXACKS, BITS_PER_LONG) |
Definition at line 396 of file ar-internal.h.
#define RXRPC_CALL_ABORT 7 /* need to generate abort */ |
Definition at line 335 of file ar-internal.h.
Definition at line 341 of file ar-internal.h.
#define RXRPC_CALL_ACK 5 /* need to generate ACK */ |
Definition at line 333 of file ar-internal.h.
Definition at line 332 of file ar-internal.h.
#define RXRPC_CALL_CONN_ABORT 8 /* local connection abort generated */ |
Definition at line 336 of file ar-internal.h.
Definition at line 339 of file ar-internal.h.
Definition at line 326 of file ar-internal.h.
Definition at line 325 of file ar-internal.h.
#define RXRPC_CALL_INIT_ACCEPT 6 /* acceptance was initiated */ |
Definition at line 324 of file ar-internal.h.
Definition at line 340 of file ar-internal.h.
Definition at line 343 of file ar-internal.h.
Definition at line 323 of file ar-internal.h.
Definition at line 330 of file ar-internal.h.
#define RXRPC_CALL_RCVD_ACKALL 0 /* ACKALL or reply received */ |
Definition at line 328 of file ar-internal.h.
Definition at line 329 of file ar-internal.h.
#define RXRPC_CALL_RCVD_ERROR 3 /* network error received */ |
Definition at line 331 of file ar-internal.h.
#define RXRPC_CALL_RCVD_LAST 2 /* all packets received */ |
Definition at line 320 of file ar-internal.h.
Definition at line 334 of file ar-internal.h.
Definition at line 344 of file ar-internal.h.
Definition at line 318 of file ar-internal.h.
#define RXRPC_CALL_RESEND 10 /* Tx resend required */ |
Definition at line 338 of file ar-internal.h.
Definition at line 337 of file ar-internal.h.
Definition at line 321 of file ar-internal.h.
#define RXRPC_CALL_SECURED 14 /* incoming call's connection is now secure */ |
Definition at line 342 of file ar-internal.h.
Definition at line 319 of file ar-internal.h.
#define RXRPC_CALL_TX_SOFT_ACK 4 /* sent some soft ACKs */ |
Definition at line 322 of file ar-internal.h.
Definition at line 256 of file ar-internal.h.
Definition at line 758 of file ar-internal.h.
#define rxrpc_get_call | ( | CALL | ) |
Definition at line 776 of file ar-internal.h.
Definition at line 774 of file ar-internal.h.
Definition at line 745 of file ar-internal.h.
Definition at line 737 of file ar-internal.h.
#define rxrpc_put_call | ( | CALL | ) |
Definition at line 783 of file ar-internal.h.
#define rxrpc_queue_call | ( | CALL | ) | rxrpc_queue_work(&(CALL)->processor) |
Definition at line 34 of file ar-internal.h.
#define rxrpc_queue_conn | ( | CONN | ) | rxrpc_queue_work(&(CONN)->processor) |
Definition at line 35 of file ar-internal.h.
#define rxrpc_queue_delayed_work | ( | WS, | |
D | |||
) | queue_delayed_work(rxrpc_workqueue, (WS), (D)) |
Definition at line 31 of file ar-internal.h.
#define rxrpc_queue_work | ( | WS | ) | queue_work(rxrpc_workqueue, (WS)) |
Definition at line 30 of file ar-internal.h.
#define RXRPC_RTT_CACHE_SIZE 32 |
Definition at line 188 of file ar-internal.h.
#define RXRPC_SECURITY_MAX RXRPC_SECURITY_ENCRYPT |
Definition at line 70 of file ar-internal.h.
#define rxrpc_sk | ( | __sk | ) | container_of((__sk), struct rxrpc_sock, sk) |
Definition at line 76 of file ar-internal.h.
#define rxrpc_skb | ( | __skb | ) | ((struct rxrpc_skb_priv *) &(__skb)->cb) |
Definition at line 95 of file ar-internal.h.
#define RXRPC_SOCK_EXCLUSIVE_CONN 1 /* exclusive connection for a client socket */ |
Definition at line 67 of file ar-internal.h.
anonymous enum |
RXRPC_UNCONNECTED | |
RXRPC_CLIENT_BOUND | |
RXRPC_CLIENT_CONNECTED | |
RXRPC_SERVER_BOUND | |
RXRPC_SERVER_LISTENING | |
RXRPC_CLOSE |
Definition at line 40 of file ar-internal.h.
enum rxrpc_command |
Definition at line 97 of file ar-internal.h.
|
read |
Packet vector entry.
This data structure is used with netio_send_packet_vector() to send multiple packets with one NetIO call. The structure should be initialized by calling netio_pkt_vector_set(), rather than by setting the fields directly.
This structure is guaranteed to be a power of two in size, no bigger than one L2 cache line, and to be aligned modulo its size.
Reserved for use by the user application. When initialized with the netio_set_pkt_vector_entry() function, this field is guaranteed to be visible to readers only after all other fields are already visible. This way it can be used as a valid flag or generation counter.
Low 8 bits of the packet address to send. The high bits are acquired from the 'handle' field.
Number of bytes to transmit.
The raw handle from a netio_pkt_t. If this is NETIO_PKT_HANDLE_NONE, this vector entry will be skipped and no packet will be transmitted.
void __rxrpc_put_call | ( | struct rxrpc_call * | ) |
|
read |
Definition at line 319 of file ar-accept.c.
void rxrpc_accept_incoming_calls | ( | struct work_struct * | ) |
Definition at line 207 of file ar-accept.c.
void rxrpc_clear_conn_security | ( | struct rxrpc_connection * | ) |
Definition at line 252 of file ar-security.c.
int rxrpc_client_sendmsg | ( | struct kiocb * | , |
struct rxrpc_sock * | , | ||
struct rxrpc_transport * | , | ||
struct msghdr * | , | ||
size_t | |||
) |
Definition at line 129 of file ar-output.c.
int rxrpc_connect_call | ( | struct rxrpc_sock * | , |
struct rxrpc_transport * | , | ||
struct rxrpc_conn_bundle * | , | ||
struct rxrpc_call * | , | ||
gfp_t | |||
) |
Definition at line 423 of file ar-connection.c.
Definition at line 913 of file ar-connection.c.
Definition at line 289 of file ar-local.c.
Definition at line 270 of file ar-transport.c.
void rxrpc_fast_process_packet | ( | struct rxrpc_call * | , |
struct sk_buff * | |||
) |
Definition at line 319 of file ar-input.c.
|
read |
Definition at line 747 of file ar-connection.c.
|
read |
|
read |
|
read |
Definition at line 149 of file ar-transport.c.
|
read |
Definition at line 65 of file ar-connection.c.
|
read |
|
read |
|
read |
Definition at line 74 of file ar-transport.c.
|
read |
|
read |
Definition at line 616 of file ar-connection.c.
int rxrpc_init_client_conn_security | ( | struct rxrpc_connection * | ) |
Definition at line 124 of file ar-security.c.
int rxrpc_init_server_conn_security | ( | struct rxrpc_connection * | ) |
Definition at line 163 of file ar-security.c.
|
read |
Definition at line 130 of file ar-local.c.
Definition at line 100 of file ar-skbuff.c.
void rxrpc_process_call | ( | struct work_struct * | ) |
void rxrpc_process_connection | ( | struct work_struct * | ) |
Definition at line 258 of file ar-connevent.c.
void rxrpc_put_bundle | ( | struct rxrpc_transport * | , |
struct rxrpc_conn_bundle * | |||
) |
Definition at line 171 of file ar-connection.c.
void rxrpc_put_connection | ( | struct rxrpc_connection * | ) |
Definition at line 798 of file ar-connection.c.
void rxrpc_put_local | ( | struct rxrpc_local * | ) |
Definition at line 221 of file ar-local.c.
void rxrpc_put_peer | ( | struct rxrpc_peer * | ) |
void rxrpc_put_transport | ( | struct rxrpc_transport * | ) |
Definition at line 182 of file ar-transport.c.
Definition at line 44 of file ar-input.c.
Definition at line 46 of file ar-recvmsg.c.
int rxrpc_register_security | ( | struct rxrpc_security * | sec | ) |
rxrpc_register_security - register an RxRPC security handler : security module
register an RxRPC security handler for use by RxRPC
Definition at line 73 of file ar-security.c.
int rxrpc_reject_call | ( | struct rxrpc_sock * | ) |
Definition at line 413 of file ar-accept.c.
void rxrpc_reject_packet | ( | struct rxrpc_local * | , |
struct sk_buff * | |||
) |
Definition at line 315 of file ar-connevent.c.
void rxrpc_reject_packets | ( | struct work_struct * | ) |
Definition at line 331 of file ar-connevent.c.
void rxrpc_release_call | ( | struct rxrpc_call * | ) |
void rxrpc_release_calls_on_socket | ( | struct rxrpc_sock * | ) |
void rxrpc_remove_user_ID | ( | struct rxrpc_sock * | , |
struct rxrpc_call * | |||
) |
Definition at line 23 of file ar-recvmsg.c.
Definition at line 226 of file ar-security.c.
int rxrpc_send_packet | ( | struct rxrpc_transport * | , |
struct sk_buff * | |||
) |
Definition at line 335 of file ar-output.c.
Definition at line 274 of file ar-output.c.
void rxrpc_UDP_error_handler | ( | struct work_struct * | ) |
Definition at line 131 of file ar-error.c.
Definition at line 28 of file ar-error.c.
void rxrpc_unregister_security | ( | struct rxrpc_security * | sec | ) |
rxrpc_unregister_security - unregister an RxRPC security handler : security module
unregister an RxRPC security handler
Definition at line 107 of file ar-security.c.
Definition at line 240 of file ar-security.c.
union { ... } |
enum { ... } __attribute__ |
__be32 n[2] |
Definition at line 31 of file ar-internal.h.
unsigned long rxrpc_ack_timeout |
Definition at line 28 of file ar-input.c.
struct kmem_cache* rxrpc_call_jar |
rwlock_t rxrpc_call_lock |
struct file_operations rxrpc_call_seq_fops |
rwlock_t rxrpc_connection_lock |
struct file_operations rxrpc_connection_seq_fops |
unsigned int rxrpc_debug |
Definition at line 29 of file af_rxrpc.c.
atomic_t rxrpc_debug_id |
Definition at line 42 of file af_rxrpc.c.
__be32 rxrpc_epoch |
Definition at line 39 of file af_rxrpc.c.
rwlock_t rxrpc_local_lock |
atomic_t rxrpc_n_skbs |
Definition at line 45 of file af_rxrpc.c.
Definition at line 30 of file ar-input.c.
int rxrpc_resend_timeout |
Definition at line 21 of file ar-output.c.
struct workqueue_struct* rxrpc_workqueue |
Definition at line 47 of file af_rxrpc.c.
u8 x[FCRYPT_BSIZE] |
Definition at line 30 of file ar-internal.h.