LXR linux/fs/ocfs2/cluster/tcp.h

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