6 //#define GETNSTIMEODAY_SUPPORTED
8 #define _sdp_printk(func, line, level, sk, format, arg...) \
10 printk(level "%s:%d %p sdp_sock(%d:%d %d:%d): " format "\n", \
11 func, line, sk ? sdp_sk(sk) : NULL, \
12 curproc->p_pid, PCPU_GET(cpuid), \
13 (sk) && sdp_sk(sk) ? ntohs(sdp_sk(sk)->lport) : -1, \
14 (sk) && sdp_sk(sk) ? ntohs(sdp_sk(sk)->fport) : -1, ## arg); \
16 #define sdp_printk(level, sk, format, arg...) \
17 _sdp_printk(__func__, __LINE__, level, sk, format, ## arg)
18 #define sdp_warn(sk, format, arg...) \
19 sdp_printk(KERN_WARNING, sk, format , ## arg)
21 #define SDP_MODPARAM_SINT(var, def_val, msg) \
22 static int var = def_val; \
23 module_param_named(var, var, int, 0644); \
24 MODULE_PARM_DESC(var, msg " [" #def_val "]"); \
26 #define SDP_MODPARAM_INT(var, def_val, msg) \
28 module_param_named(var, var, int, 0644); \
29 MODULE_PARM_DESC(var, msg " [" #def_val "]"); \
42 unsigned long long time;
48 #define SDPPRF_LOG_SIZE 0x20000 /* must be a power of 2 */
50 extern struct sdpprf_log sdpprf_log[SDPPRF_LOG_SIZE];
51 extern int sdpprf_log_count;
53 #ifdef GETNSTIMEODAY_SUPPORTED
54 static inline unsigned long long current_nsec(void)
58 return tv.tv_sec * NSEC_PER_SEC + tv.tv_nsec;
61 #define current_nsec() jiffies_to_usecs(jiffies)
64 #define sdp_prf1(sk, s, format, arg...) ({ \
65 struct sdpprf_log *l = \
66 &sdpprf_log[sdpprf_log_count++ & (SDPPRF_LOG_SIZE - 1)]; \
68 l->idx = sdpprf_log_count - 1; \
69 l->pid = current->pid; \
70 l->sk_num = (sk) ? inet_sk(sk)->num : -1; \
71 l->sk_dport = (sk) ? ntohs(inet_sk(sk)->dport) : -1; \
72 l->cpu = smp_processor_id(); \
74 snprintf(l->msg, sizeof(l->msg) - 1, format, ## arg); \
75 l->time = current_nsec(); \
81 //#define sdp_prf(sk, s, format, arg...)
82 #define sdp_prf(sk, s, format, arg...) sdp_prf1(sk, s, format, ## arg)
85 #define sdp_prf1(sk, s, format, arg...)
86 #define sdp_prf(sk, s, format, arg...)
89 #ifdef CONFIG_INFINIBAND_SDP_DEBUG
90 extern int sdp_debug_level;
92 #define sdp_dbg(sk, format, arg...) \
94 if (sdp_debug_level > 0) \
95 sdp_printk(KERN_WARNING, sk, format , ## arg); \
98 #else /* CONFIG_INFINIBAND_SDP_DEBUG */
99 #define sdp_dbg(priv, format, arg...) \
100 do { (void) (priv); } while (0)
101 #define sock_ref(sk, msg, sock_op) sock_op(sk)
102 #endif /* CONFIG_INFINIBAND_SDP_DEBUG */
104 #ifdef CONFIG_INFINIBAND_SDP_DEBUG_DATA
106 extern int sdp_data_debug_level;
107 #define sdp_dbg_data(sk, format, arg...) \
109 if (sdp_data_debug_level & 0x2) \
110 sdp_printk(KERN_WARNING, sk, format , ## arg); \
112 #define SDP_DUMP_PACKET(sk, str, mb, h) \
114 if (sdp_data_debug_level & 0x1) \
115 dump_packet(sk, str, mb, h); \
118 #define sdp_dbg_data(priv, format, arg...)
119 #define SDP_DUMP_PACKET(sk, str, mb, h)
122 #define SOCK_REF_RESET "RESET"
123 #define SOCK_REF_ALIVE "ALIVE" /* sock_alloc -> destruct_sock */
124 #define SOCK_REF_CLONE "CLONE"
125 #define SOCK_REF_CMA "CMA" /* sdp_cma_handler() is expected to be invoked */
126 #define SOCK_REF_SEQ "SEQ" /* during proc read */
127 #define SOCK_REF_DREQ_TO "DREQ_TO" /* dreq timeout is pending */
128 #define SOCK_REF_ZCOPY "ZCOPY" /* zcopy send in process */
129 #define SOCK_REF_RDMA_RD "RDMA_RD" /* RDMA read in process */
131 #define sock_hold(sk, msg) sock_ref(sk, msg, sock_hold)
132 #define sock_put(sk, msg) sock_ref(sk, msg, sock_put)
133 #define __sock_put(sk, msg) sock_ref(sk, msg, __sock_put)
135 #define ENUM2STR(e) [e] = #e
137 static inline char *sdp_state_str(int state)
139 static char *state2str[] = {
140 ENUM2STR(TCPS_ESTABLISHED),
141 ENUM2STR(TCPS_SYN_SENT),
142 ENUM2STR(TCPS_SYN_RECEIVED),
143 ENUM2STR(TCPS_FIN_WAIT_1),
144 ENUM2STR(TCPS_FIN_WAIT_2),
145 ENUM2STR(TCPS_TIME_WAIT),
146 ENUM2STR(TCPS_CLOSED),
147 ENUM2STR(TCPS_CLOSE_WAIT),
148 ENUM2STR(TCPS_LAST_ACK),
149 ENUM2STR(TCPS_LISTEN),
150 ENUM2STR(TCPS_CLOSING),
153 if (state < 0 || state >= ARRAY_SIZE(state2str))
156 return state2str[state];
160 #ifdef CONFIG_INFINIBAND_SDP_DEBUG_DATA
161 void _dump_packet(const char *func, int line, struct socket *sk, char *str,
162 struct mbuf *mb, const struct sdp_bsdh *h);
163 #define dump_packet(sk, str, mb, h) \
164 _dump_packet(__func__, __LINE__, sk, str, mb, h)