aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--net/dccp/ccids/ccid3.c45
-rw-r--r--net/dccp/ccids/ccid3.h19
-rw-r--r--net/dccp/dccp.h8
3 files changed, 37 insertions, 35 deletions
diff --git a/net/dccp/ccids/ccid3.c b/net/dccp/ccids/ccid3.c
index cec23ad286de..2fa0c6d1fbee 100644
--- a/net/dccp/ccids/ccid3.c
+++ b/net/dccp/ccids/ccid3.c
@@ -75,14 +75,6 @@ static struct dccp_tx_hist *ccid3_tx_hist;
75static struct dccp_rx_hist *ccid3_rx_hist; 75static struct dccp_rx_hist *ccid3_rx_hist;
76static struct dccp_li_hist *ccid3_li_hist; 76static struct dccp_li_hist *ccid3_li_hist;
77 77
78/* TFRC sender states */
79enum ccid3_hc_tx_states {
80 TFRC_SSTATE_NO_SENT = 1,
81 TFRC_SSTATE_NO_FBACK,
82 TFRC_SSTATE_FBACK,
83 TFRC_SSTATE_TERM,
84};
85
86#ifdef CCID3_DEBUG 78#ifdef CCID3_DEBUG
87static const char *ccid3_tx_state_name(enum ccid3_hc_tx_states state) 79static const char *ccid3_tx_state_name(enum ccid3_hc_tx_states state)
88{ 80{
@@ -251,9 +243,8 @@ static void ccid3_hc_tx_no_feedback_timer(unsigned long data)
251 hctx->ccid3hctx_x)); 243 hctx->ccid3hctx_x));
252 break; 244 break;
253 default: 245 default:
254 printk(KERN_CRIT "%s: %s, sk=%p, Illegal state (%d)!\n", 246 DCCP_BUG("%s, sk=%p, Illegal state (%d)!", dccp_role(sk), sk,
255 __FUNCTION__, dccp_role(sk), sk, hctx->ccid3hctx_state); 247 hctx->ccid3hctx_state);
256 dump_stack();
257 goto out; 248 goto out;
258 } 249 }
259 250
@@ -329,9 +320,8 @@ static int ccid3_hc_tx_send_packet(struct sock *sk,
329 rc = delay > 0 ? delay : 0; 320 rc = delay > 0 ? delay : 0;
330 break; 321 break;
331 default: 322 default:
332 printk(KERN_CRIT "%s: %s, sk=%p, Illegal state (%d)!\n", 323 DCCP_BUG("%s, sk=%p, Illegal state (%d)!", dccp_role(sk), sk,
333 __FUNCTION__, dccp_role(sk), sk, hctx->ccid3hctx_state); 324 hctx->ccid3hctx_state);
334 dump_stack();
335 rc = -EINVAL; 325 rc = -EINVAL;
336 break; 326 break;
337 } 327 }
@@ -423,9 +413,8 @@ static void ccid3_hc_tx_packet_sent(struct sock *sk, int more, int len)
423 } 413 }
424 break; 414 break;
425 default: 415 default:
426 printk(KERN_CRIT "%s: %s, sk=%p, Illegal state (%d)!\n", 416 DCCP_BUG("%s, sk=%p, Illegal state (%d)!", dccp_role(sk), sk,
427 __FUNCTION__, dccp_role(sk), sk, hctx->ccid3hctx_state); 417 hctx->ccid3hctx_state);
428 dump_stack();
429 break; 418 break;
430 } 419 }
431} 420}
@@ -568,9 +557,8 @@ static void ccid3_hc_tx_packet_recv(struct sock *sk, struct sk_buff *skb)
568 hctx->ccid3hctx_idle = 1; 557 hctx->ccid3hctx_idle = 1;
569 break; 558 break;
570 default: 559 default:
571 printk(KERN_CRIT "%s: %s, sk=%p, Illegal state (%d)!\n", 560 DCCP_BUG("%s, sk=%p, Illegal state (%d)!", dccp_role(sk), sk,
572 __FUNCTION__, dccp_role(sk), sk, hctx->ccid3hctx_state); 561 hctx->ccid3hctx_state);
573 dump_stack();
574 break; 562 break;
575 } 563 }
576} 564}
@@ -688,13 +676,6 @@ static void ccid3_hc_tx_exit(struct sock *sk)
688 * RX Half Connection methods 676 * RX Half Connection methods
689 */ 677 */
690 678
691/* TFRC receiver states */
692enum ccid3_hc_rx_states {
693 TFRC_RSTATE_NO_DATA = 1,
694 TFRC_RSTATE_DATA,
695 TFRC_RSTATE_TERM = 127,
696};
697
698#ifdef CCID3_DEBUG 679#ifdef CCID3_DEBUG
699static const char *ccid3_rx_state_name(enum ccid3_hc_rx_states state) 680static const char *ccid3_rx_state_name(enum ccid3_hc_rx_states state)
700{ 681{
@@ -744,9 +725,8 @@ static void ccid3_hc_rx_send_feedback(struct sock *sk)
744 } 725 }
745 break; 726 break;
746 default: 727 default:
747 printk(KERN_CRIT "%s: %s, sk=%p, Illegal state (%d)!\n", 728 DCCP_BUG("%s, sk=%p, Illegal state (%d)!", dccp_role(sk), sk,
748 __FUNCTION__, dccp_role(sk), sk, hcrx->ccid3hcrx_state); 729 hcrx->ccid3hcrx_state);
749 dump_stack();
750 return; 730 return;
751 } 731 }
752 732
@@ -1088,9 +1068,8 @@ static void ccid3_hc_rx_packet_recv(struct sock *sk, struct sk_buff *skb)
1088 } 1068 }
1089 return; 1069 return;
1090 default: 1070 default:
1091 printk(KERN_CRIT "%s: %s, sk=%p, Illegal state (%d)!\n", 1071 DCCP_BUG("%s, sk=%p, Illegal state (%d)!", dccp_role(sk), sk,
1092 __FUNCTION__, dccp_role(sk), sk, hcrx->ccid3hcrx_state); 1072 hcrx->ccid3hcrx_state);
1093 dump_stack();
1094 return; 1073 return;
1095 } 1074 }
1096 1075
diff --git a/net/dccp/ccids/ccid3.h b/net/dccp/ccids/ccid3.h
index 0a2cb7536d26..c122e757eb7f 100644
--- a/net/dccp/ccids/ccid3.h
+++ b/net/dccp/ccids/ccid3.h
@@ -73,6 +73,14 @@ struct ccid3_options_received {
73 u32 ccid3or_receive_rate; 73 u32 ccid3or_receive_rate;
74}; 74};
75 75
76/* TFRC sender states */
77enum ccid3_hc_tx_states {
78 TFRC_SSTATE_NO_SENT = 1,
79 TFRC_SSTATE_NO_FBACK,
80 TFRC_SSTATE_FBACK,
81 TFRC_SSTATE_TERM,
82};
83
76/** struct ccid3_hc_tx_sock - CCID3 sender half connection sock 84/** struct ccid3_hc_tx_sock - CCID3 sender half connection sock
77 * 85 *
78 * @ccid3hctx_state - Sender state 86 * @ccid3hctx_state - Sender state
@@ -103,7 +111,7 @@ struct ccid3_hc_tx_sock {
103#define ccid3hctx_t_rto ccid3hctx_tfrc.tfrctx_rto 111#define ccid3hctx_t_rto ccid3hctx_tfrc.tfrctx_rto
104#define ccid3hctx_t_ipi ccid3hctx_tfrc.tfrctx_ipi 112#define ccid3hctx_t_ipi ccid3hctx_tfrc.tfrctx_ipi
105 u16 ccid3hctx_s; 113 u16 ccid3hctx_s;
106 u8 ccid3hctx_state; 114 enum ccid3_hc_tx_states ccid3hctx_state:8;
107 u8 ccid3hctx_last_win_count; 115 u8 ccid3hctx_last_win_count;
108 u8 ccid3hctx_idle; 116 u8 ccid3hctx_idle;
109 struct timeval ccid3hctx_t_last_win_count; 117 struct timeval ccid3hctx_t_last_win_count;
@@ -115,6 +123,13 @@ struct ccid3_hc_tx_sock {
115 struct ccid3_options_received ccid3hctx_options_received; 123 struct ccid3_options_received ccid3hctx_options_received;
116}; 124};
117 125
126/* TFRC receiver states */
127enum ccid3_hc_rx_states {
128 TFRC_RSTATE_NO_DATA = 1,
129 TFRC_RSTATE_DATA,
130 TFRC_RSTATE_TERM = 127,
131};
132
118struct ccid3_hc_rx_sock { 133struct ccid3_hc_rx_sock {
119 struct tfrc_rx_info ccid3hcrx_tfrc; 134 struct tfrc_rx_info ccid3hcrx_tfrc;
120#define ccid3hcrx_x_recv ccid3hcrx_tfrc.tfrcrx_x_recv 135#define ccid3hcrx_x_recv ccid3hcrx_tfrc.tfrcrx_x_recv
@@ -122,8 +137,8 @@ struct ccid3_hc_rx_sock {
122#define ccid3hcrx_p ccid3hcrx_tfrc.tfrcrx_p 137#define ccid3hcrx_p ccid3hcrx_tfrc.tfrcrx_p
123 u64 ccid3hcrx_seqno_nonloss:48, 138 u64 ccid3hcrx_seqno_nonloss:48,
124 ccid3hcrx_ccval_nonloss:4, 139 ccid3hcrx_ccval_nonloss:4,
125 ccid3hcrx_state:8,
126 ccid3hcrx_ccval_last_counter:4; 140 ccid3hcrx_ccval_last_counter:4;
141 enum ccid3_hc_rx_states ccid3hcrx_state:8;
127 u32 ccid3hcrx_bytes_recv; 142 u32 ccid3hcrx_bytes_recv;
128 struct timeval ccid3hcrx_tstamp_last_feedback; 143 struct timeval ccid3hcrx_tstamp_last_feedback;
129 struct timeval ccid3hcrx_tstamp_last_ack; 144 struct timeval ccid3hcrx_tstamp_last_ack;
diff --git a/net/dccp/dccp.h b/net/dccp/dccp.h
index 363fa520056e..ecb4e7bd1a84 100644
--- a/net/dccp/dccp.h
+++ b/net/dccp/dccp.h
@@ -18,6 +18,14 @@
18#include <net/tcp.h> 18#include <net/tcp.h>
19#include "ackvec.h" 19#include "ackvec.h"
20 20
21#define DCCP_CRIT(fmt, a...) LIMIT_NETDEBUG(KERN_CRIT fmt " at %s:%d/%s()\n", \
22 ##a, __FILE__, __LINE__, __FUNCTION__)
23#define DCCP_BUG(fmt, a...) do { DCCP_CRIT(fmt, ##a); dump_stack(); } while (0)
24#define DCCP_BUG_ON(cond) do { if (unlikely((cond) == 0)) \
25 DCCP_BUG("BUG: condition \"%s\" fails",\
26 __stringify((cond))); \
27 } while (0)
28
21#ifdef CONFIG_IP_DCCP_DEBUG 29#ifdef CONFIG_IP_DCCP_DEBUG
22extern int dccp_debug; 30extern int dccp_debug;
23 31