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

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