1*4882a593Smuzhiyun /* SPDX-License-Identifier: GPL-2.0 */ 2*4882a593Smuzhiyun /* 3*4882a593Smuzhiyun * linux/include/linux/sunrpc/xprtsock.h 4*4882a593Smuzhiyun * 5*4882a593Smuzhiyun * Declarations for the RPC transport socket provider. 6*4882a593Smuzhiyun */ 7*4882a593Smuzhiyun 8*4882a593Smuzhiyun #ifndef _LINUX_SUNRPC_XPRTSOCK_H 9*4882a593Smuzhiyun #define _LINUX_SUNRPC_XPRTSOCK_H 10*4882a593Smuzhiyun 11*4882a593Smuzhiyun int init_socket_xprt(void); 12*4882a593Smuzhiyun void cleanup_socket_xprt(void); 13*4882a593Smuzhiyun unsigned short get_srcport(struct rpc_xprt *); 14*4882a593Smuzhiyun 15*4882a593Smuzhiyun #define RPC_MIN_RESVPORT (1U) 16*4882a593Smuzhiyun #define RPC_MAX_RESVPORT (65535U) 17*4882a593Smuzhiyun #define RPC_DEF_MIN_RESVPORT (665U) 18*4882a593Smuzhiyun #define RPC_DEF_MAX_RESVPORT (1023U) 19*4882a593Smuzhiyun 20*4882a593Smuzhiyun struct sock_xprt { 21*4882a593Smuzhiyun struct rpc_xprt xprt; 22*4882a593Smuzhiyun 23*4882a593Smuzhiyun /* 24*4882a593Smuzhiyun * Network layer 25*4882a593Smuzhiyun */ 26*4882a593Smuzhiyun struct socket * sock; 27*4882a593Smuzhiyun struct sock * inet; 28*4882a593Smuzhiyun struct file * file; 29*4882a593Smuzhiyun 30*4882a593Smuzhiyun /* 31*4882a593Smuzhiyun * State of TCP reply receive 32*4882a593Smuzhiyun */ 33*4882a593Smuzhiyun struct { 34*4882a593Smuzhiyun struct { 35*4882a593Smuzhiyun __be32 fraghdr, 36*4882a593Smuzhiyun xid, 37*4882a593Smuzhiyun calldir; 38*4882a593Smuzhiyun } __attribute__((packed)); 39*4882a593Smuzhiyun 40*4882a593Smuzhiyun u32 offset, 41*4882a593Smuzhiyun len; 42*4882a593Smuzhiyun 43*4882a593Smuzhiyun unsigned long copied; 44*4882a593Smuzhiyun } recv; 45*4882a593Smuzhiyun 46*4882a593Smuzhiyun /* 47*4882a593Smuzhiyun * State of TCP transmit queue 48*4882a593Smuzhiyun */ 49*4882a593Smuzhiyun struct { 50*4882a593Smuzhiyun u32 offset; 51*4882a593Smuzhiyun } xmit; 52*4882a593Smuzhiyun 53*4882a593Smuzhiyun /* 54*4882a593Smuzhiyun * Connection of transports 55*4882a593Smuzhiyun */ 56*4882a593Smuzhiyun unsigned long sock_state; 57*4882a593Smuzhiyun struct delayed_work connect_worker; 58*4882a593Smuzhiyun struct work_struct error_worker; 59*4882a593Smuzhiyun struct work_struct recv_worker; 60*4882a593Smuzhiyun struct mutex recv_mutex; 61*4882a593Smuzhiyun struct sockaddr_storage srcaddr; 62*4882a593Smuzhiyun unsigned short srcport; 63*4882a593Smuzhiyun int xprt_err; 64*4882a593Smuzhiyun 65*4882a593Smuzhiyun /* 66*4882a593Smuzhiyun * UDP socket buffer size parameters 67*4882a593Smuzhiyun */ 68*4882a593Smuzhiyun size_t rcvsize, 69*4882a593Smuzhiyun sndsize; 70*4882a593Smuzhiyun 71*4882a593Smuzhiyun struct rpc_timeout tcp_timeout; 72*4882a593Smuzhiyun 73*4882a593Smuzhiyun /* 74*4882a593Smuzhiyun * Saved socket callback addresses 75*4882a593Smuzhiyun */ 76*4882a593Smuzhiyun void (*old_data_ready)(struct sock *); 77*4882a593Smuzhiyun void (*old_state_change)(struct sock *); 78*4882a593Smuzhiyun void (*old_write_space)(struct sock *); 79*4882a593Smuzhiyun void (*old_error_report)(struct sock *); 80*4882a593Smuzhiyun }; 81*4882a593Smuzhiyun 82*4882a593Smuzhiyun /* 83*4882a593Smuzhiyun * TCP RPC flags 84*4882a593Smuzhiyun */ 85*4882a593Smuzhiyun #define XPRT_SOCK_CONNECTING 1U 86*4882a593Smuzhiyun #define XPRT_SOCK_DATA_READY (2) 87*4882a593Smuzhiyun #define XPRT_SOCK_UPD_TIMEOUT (3) 88*4882a593Smuzhiyun #define XPRT_SOCK_WAKE_ERROR (4) 89*4882a593Smuzhiyun #define XPRT_SOCK_WAKE_WRITE (5) 90*4882a593Smuzhiyun #define XPRT_SOCK_WAKE_PENDING (6) 91*4882a593Smuzhiyun #define XPRT_SOCK_WAKE_DISCONNECT (7) 92*4882a593Smuzhiyun #define XPRT_SOCK_CONNECT_SENT (8) 93*4882a593Smuzhiyun 94*4882a593Smuzhiyun #endif /* _LINUX_SUNRPC_XPRTSOCK_H */ 95