1*4882a593Smuzhiyun /* SPDX-License-Identifier: GPL-2.0-or-later */
2*4882a593Smuzhiyun /* -*- mode: c; c-basic-offset: 8; -*-
3*4882a593Smuzhiyun * vim: noexpandtab sw=8 ts=8 sts=0:
4*4882a593Smuzhiyun *
5*4882a593Smuzhiyun * tcp.h
6*4882a593Smuzhiyun *
7*4882a593Smuzhiyun * Function prototypes
8*4882a593Smuzhiyun *
9*4882a593Smuzhiyun * Copyright (C) 2004 Oracle. All rights reserved.
10*4882a593Smuzhiyun */
11*4882a593Smuzhiyun
12*4882a593Smuzhiyun #ifndef O2CLUSTER_TCP_H
13*4882a593Smuzhiyun #define O2CLUSTER_TCP_H
14*4882a593Smuzhiyun
15*4882a593Smuzhiyun #include <linux/socket.h>
16*4882a593Smuzhiyun #ifdef __KERNEL__
17*4882a593Smuzhiyun #include <net/sock.h>
18*4882a593Smuzhiyun #include <linux/tcp.h>
19*4882a593Smuzhiyun #else
20*4882a593Smuzhiyun #include <sys/socket.h>
21*4882a593Smuzhiyun #endif
22*4882a593Smuzhiyun #include <linux/inet.h>
23*4882a593Smuzhiyun #include <linux/in.h>
24*4882a593Smuzhiyun
25*4882a593Smuzhiyun struct o2net_msg
26*4882a593Smuzhiyun {
27*4882a593Smuzhiyun __be16 magic;
28*4882a593Smuzhiyun __be16 data_len;
29*4882a593Smuzhiyun __be16 msg_type;
30*4882a593Smuzhiyun __be16 pad1;
31*4882a593Smuzhiyun __be32 sys_status;
32*4882a593Smuzhiyun __be32 status;
33*4882a593Smuzhiyun __be32 key;
34*4882a593Smuzhiyun __be32 msg_num;
35*4882a593Smuzhiyun __u8 buf[];
36*4882a593Smuzhiyun };
37*4882a593Smuzhiyun
38*4882a593Smuzhiyun typedef int (o2net_msg_handler_func)(struct o2net_msg *msg, u32 len, void *data,
39*4882a593Smuzhiyun void **ret_data);
40*4882a593Smuzhiyun typedef void (o2net_post_msg_handler_func)(int status, void *data,
41*4882a593Smuzhiyun void *ret_data);
42*4882a593Smuzhiyun
43*4882a593Smuzhiyun #define O2NET_MAX_PAYLOAD_BYTES (4096 - sizeof(struct o2net_msg))
44*4882a593Smuzhiyun
45*4882a593Smuzhiyun /* same as hb delay, we're waiting for another node to recognize our hb */
46*4882a593Smuzhiyun #define O2NET_RECONNECT_DELAY_MS_DEFAULT 2000
47*4882a593Smuzhiyun
48*4882a593Smuzhiyun #define O2NET_KEEPALIVE_DELAY_MS_DEFAULT 2000
49*4882a593Smuzhiyun #define O2NET_IDLE_TIMEOUT_MS_DEFAULT 30000
50*4882a593Smuzhiyun
51*4882a593Smuzhiyun #define O2NET_TCP_USER_TIMEOUT 0x7fffffff
52*4882a593Smuzhiyun
53*4882a593Smuzhiyun /* TODO: figure this out.... */
o2net_link_down(int err,struct socket * sock)54*4882a593Smuzhiyun static inline int o2net_link_down(int err, struct socket *sock)
55*4882a593Smuzhiyun {
56*4882a593Smuzhiyun if (sock) {
57*4882a593Smuzhiyun if (sock->sk->sk_state != TCP_ESTABLISHED &&
58*4882a593Smuzhiyun sock->sk->sk_state != TCP_CLOSE_WAIT)
59*4882a593Smuzhiyun return 1;
60*4882a593Smuzhiyun }
61*4882a593Smuzhiyun
62*4882a593Smuzhiyun if (err >= 0)
63*4882a593Smuzhiyun return 0;
64*4882a593Smuzhiyun switch (err) {
65*4882a593Smuzhiyun /* ????????????????????????? */
66*4882a593Smuzhiyun case -ERESTARTSYS:
67*4882a593Smuzhiyun case -EBADF:
68*4882a593Smuzhiyun /* When the server has died, an ICMP port unreachable
69*4882a593Smuzhiyun * message prompts ECONNREFUSED. */
70*4882a593Smuzhiyun case -ECONNREFUSED:
71*4882a593Smuzhiyun case -ENOTCONN:
72*4882a593Smuzhiyun case -ECONNRESET:
73*4882a593Smuzhiyun case -EPIPE:
74*4882a593Smuzhiyun return 1;
75*4882a593Smuzhiyun }
76*4882a593Smuzhiyun return 0;
77*4882a593Smuzhiyun }
78*4882a593Smuzhiyun
79*4882a593Smuzhiyun enum {
80*4882a593Smuzhiyun O2NET_DRIVER_UNINITED,
81*4882a593Smuzhiyun O2NET_DRIVER_READY,
82*4882a593Smuzhiyun };
83*4882a593Smuzhiyun
84*4882a593Smuzhiyun int o2net_send_message(u32 msg_type, u32 key, void *data, u32 len,
85*4882a593Smuzhiyun u8 target_node, int *status);
86*4882a593Smuzhiyun int o2net_send_message_vec(u32 msg_type, u32 key, struct kvec *vec,
87*4882a593Smuzhiyun size_t veclen, u8 target_node, int *status);
88*4882a593Smuzhiyun
89*4882a593Smuzhiyun int o2net_register_handler(u32 msg_type, u32 key, u32 max_len,
90*4882a593Smuzhiyun o2net_msg_handler_func *func, void *data,
91*4882a593Smuzhiyun o2net_post_msg_handler_func *post_func,
92*4882a593Smuzhiyun struct list_head *unreg_list);
93*4882a593Smuzhiyun void o2net_unregister_handler_list(struct list_head *list);
94*4882a593Smuzhiyun
95*4882a593Smuzhiyun void o2net_fill_node_map(unsigned long *map, unsigned bytes);
96*4882a593Smuzhiyun
97*4882a593Smuzhiyun struct o2nm_node;
98*4882a593Smuzhiyun int o2net_register_hb_callbacks(void);
99*4882a593Smuzhiyun void o2net_unregister_hb_callbacks(void);
100*4882a593Smuzhiyun int o2net_start_listening(struct o2nm_node *node);
101*4882a593Smuzhiyun void o2net_stop_listening(struct o2nm_node *node);
102*4882a593Smuzhiyun void o2net_disconnect_node(struct o2nm_node *node);
103*4882a593Smuzhiyun int o2net_num_connected_peers(void);
104*4882a593Smuzhiyun
105*4882a593Smuzhiyun int o2net_init(void);
106*4882a593Smuzhiyun void o2net_exit(void);
107*4882a593Smuzhiyun
108*4882a593Smuzhiyun struct o2net_send_tracking;
109*4882a593Smuzhiyun struct o2net_sock_container;
110*4882a593Smuzhiyun
111*4882a593Smuzhiyun #ifdef CONFIG_DEBUG_FS
112*4882a593Smuzhiyun void o2net_debugfs_init(void);
113*4882a593Smuzhiyun void o2net_debugfs_exit(void);
114*4882a593Smuzhiyun void o2net_debug_add_nst(struct o2net_send_tracking *nst);
115*4882a593Smuzhiyun void o2net_debug_del_nst(struct o2net_send_tracking *nst);
116*4882a593Smuzhiyun void o2net_debug_add_sc(struct o2net_sock_container *sc);
117*4882a593Smuzhiyun void o2net_debug_del_sc(struct o2net_sock_container *sc);
118*4882a593Smuzhiyun #else
o2net_debugfs_init(void)119*4882a593Smuzhiyun static inline void o2net_debugfs_init(void)
120*4882a593Smuzhiyun {
121*4882a593Smuzhiyun }
o2net_debugfs_exit(void)122*4882a593Smuzhiyun static inline void o2net_debugfs_exit(void)
123*4882a593Smuzhiyun {
124*4882a593Smuzhiyun }
o2net_debug_add_nst(struct o2net_send_tracking * nst)125*4882a593Smuzhiyun static inline void o2net_debug_add_nst(struct o2net_send_tracking *nst)
126*4882a593Smuzhiyun {
127*4882a593Smuzhiyun }
o2net_debug_del_nst(struct o2net_send_tracking * nst)128*4882a593Smuzhiyun static inline void o2net_debug_del_nst(struct o2net_send_tracking *nst)
129*4882a593Smuzhiyun {
130*4882a593Smuzhiyun }
o2net_debug_add_sc(struct o2net_sock_container * sc)131*4882a593Smuzhiyun static inline void o2net_debug_add_sc(struct o2net_sock_container *sc)
132*4882a593Smuzhiyun {
133*4882a593Smuzhiyun }
o2net_debug_del_sc(struct o2net_sock_container * sc)134*4882a593Smuzhiyun static inline void o2net_debug_del_sc(struct o2net_sock_container *sc)
135*4882a593Smuzhiyun {
136*4882a593Smuzhiyun }
137*4882a593Smuzhiyun #endif /* CONFIG_DEBUG_FS */
138*4882a593Smuzhiyun
139*4882a593Smuzhiyun #endif /* O2CLUSTER_TCP_H */
140