dc44b3a09a
In the rxrpc_connection and rxrpc_call structs, there's one field to hold the abort code, no matter whether that value was generated locally to be sent or was received from the peer via an abort packet. Split the abort code fields in two for cleanliness sake and add an error field to hold the Linux error number to the rxrpc_call struct too (sometimes this is generated in a context where we can't return it to userspace directly). Furthermore, add a skb mark to indicate a packet that caused a local abort to be generated so that recvmsg() can pick up the correct abort code. A future addition will need to be to indicate to userspace the difference between aborts via a control message. Signed-off-by: David Howells <dhowells@redhat.com> Signed-off-by: David S. Miller <davem@davemloft.net>
54 lines
1.9 KiB
C
54 lines
1.9 KiB
C
/* RxRPC kernel service interface definitions
|
|
*
|
|
* Copyright (C) 2007 Red Hat, Inc. All Rights Reserved.
|
|
* Written by David Howells (dhowells@redhat.com)
|
|
*
|
|
* This program is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU General Public License
|
|
* as published by the Free Software Foundation; either version
|
|
* 2 of the License, or (at your option) any later version.
|
|
*/
|
|
|
|
#ifndef _NET_RXRPC_H
|
|
#define _NET_RXRPC_H
|
|
|
|
#include <linux/skbuff.h>
|
|
#include <linux/rxrpc.h>
|
|
|
|
struct rxrpc_call;
|
|
|
|
/*
|
|
* the mark applied to socket buffers that may be intercepted
|
|
*/
|
|
enum rxrpc_skb_mark {
|
|
RXRPC_SKB_MARK_DATA, /* data message */
|
|
RXRPC_SKB_MARK_FINAL_ACK, /* final ACK received message */
|
|
RXRPC_SKB_MARK_BUSY, /* server busy message */
|
|
RXRPC_SKB_MARK_REMOTE_ABORT, /* remote abort message */
|
|
RXRPC_SKB_MARK_LOCAL_ABORT, /* local abort message */
|
|
RXRPC_SKB_MARK_NET_ERROR, /* network error message */
|
|
RXRPC_SKB_MARK_LOCAL_ERROR, /* local error message */
|
|
RXRPC_SKB_MARK_NEW_CALL, /* local error message */
|
|
};
|
|
|
|
typedef void (*rxrpc_interceptor_t)(struct sock *, unsigned long,
|
|
struct sk_buff *);
|
|
void rxrpc_kernel_intercept_rx_messages(struct socket *, rxrpc_interceptor_t);
|
|
struct rxrpc_call *rxrpc_kernel_begin_call(struct socket *,
|
|
struct sockaddr_rxrpc *,
|
|
struct key *,
|
|
unsigned long,
|
|
gfp_t);
|
|
int rxrpc_kernel_send_data(struct rxrpc_call *, struct msghdr *, size_t);
|
|
void rxrpc_kernel_abort_call(struct rxrpc_call *, u32);
|
|
void rxrpc_kernel_end_call(struct rxrpc_call *);
|
|
bool rxrpc_kernel_is_data_last(struct sk_buff *);
|
|
u32 rxrpc_kernel_get_abort_code(struct sk_buff *);
|
|
int rxrpc_kernel_get_error_number(struct sk_buff *);
|
|
void rxrpc_kernel_data_delivered(struct sk_buff *);
|
|
void rxrpc_kernel_free_skb(struct sk_buff *);
|
|
struct rxrpc_call *rxrpc_kernel_accept_call(struct socket *, unsigned long);
|
|
int rxrpc_kernel_reject_call(struct socket *);
|
|
|
|
#endif /* _NET_RXRPC_H */
|