Lines Matching refs:fsq
35 gcomm::FairSendQueue fsq; in START_TEST() local
37 fsq.push_back(0, dg); in START_TEST()
38 ck_assert(fsq.front().len() == 2); in START_TEST()
39 ck_assert(get_header(fsq.front()) == 1); in START_TEST()
45 gcomm::FairSendQueue fsq; in START_TEST() local
47 fsq.push_back(0, dg); in START_TEST()
48 ck_assert(get_header(fsq.front()) == 1); in START_TEST()
49 ck_assert(get_header(fsq.back()) == 1); in START_TEST()
50 fsq.push_back(0, make_datagram(2)); in START_TEST()
51 ck_assert(get_header(fsq.front()) == 1); in START_TEST()
52 ck_assert(get_header(fsq.back()) == 2); in START_TEST()
58 gcomm::FairSendQueue fsq; in START_TEST() local
60 fsq.push_back(0, dg); in START_TEST()
61 ck_assert(get_header(fsq.front()) == 1); in START_TEST()
62 ck_assert(get_header(fsq.back()) == 1); in START_TEST()
63 fsq.push_back(1, make_datagram(2)); in START_TEST()
64 ck_assert(get_header(fsq.front()) == 1); in START_TEST()
65 ck_assert(get_header(fsq.back()) == 2); in START_TEST()
71 gcomm::FairSendQueue fsq; in START_TEST() local
72 ck_assert(fsq.empty()); in START_TEST()
73 fsq.push_back(0, make_datagram(1)); in START_TEST()
74 ck_assert(!fsq.empty()); in START_TEST()
80 gcomm::FairSendQueue fsq; in START_TEST() local
81 fsq.push_back(0, make_datagram(1)); in START_TEST()
82 ck_assert(fsq.size() == 1); in START_TEST()
83 fsq.push_back(1, make_datagram(2)); in START_TEST()
84 ck_assert(fsq.size() == 2); in START_TEST()
90 gcomm::FairSendQueue fsq; in START_TEST() local
91 fsq.push_back(0, make_datagram(1)); in START_TEST()
92 ck_assert(fsq.size() == 1); in START_TEST()
93 fsq.pop_front(); in START_TEST()
94 ck_assert(fsq.size() == 0); in START_TEST()
100 gcomm::FairSendQueue fsq; in START_TEST() local
101 fsq.push_back(0, make_datagram(1)); in START_TEST()
102 ck_assert(fsq.size() == 1); in START_TEST()
103 fsq.push_back(0, make_datagram(2)); in START_TEST()
104 ck_assert(fsq.size() == 2); in START_TEST()
105 ck_assert(get_header(fsq.front()) == 1); in START_TEST()
107 fsq.pop_front(); in START_TEST()
108 ck_assert(fsq.size() == 1); in START_TEST()
109 ck_assert(get_header(fsq.front()) == 2); in START_TEST()
115 gcomm::FairSendQueue fsq; in START_TEST() local
116 fsq.push_back(0, make_datagram(1)); in START_TEST()
117 ck_assert(fsq.size() == 1); in START_TEST()
118 fsq.push_back(1, make_datagram(2)); in START_TEST()
119 ck_assert(fsq.size() == 2); in START_TEST()
120 ck_assert(get_header(fsq.front()) == 1); in START_TEST()
122 fsq.pop_front(); in START_TEST()
123 ck_assert(fsq.size() == 1); in START_TEST()
124 ck_assert(get_header(fsq.front()) == 2); in START_TEST()
130 gcomm::FairSendQueue fsq; in START_TEST() local
131 fsq.push_back(0, make_datagram(1)); in START_TEST()
132 fsq.push_back(1, make_datagram(2)); in START_TEST()
133 fsq.push_back(0, make_datagram(3)); in START_TEST()
134 fsq.push_back(1, make_datagram(4)); in START_TEST()
136 ck_assert(get_header(fsq.front()) == 1); in START_TEST()
137 ck_assert(fsq.size() == 4); in START_TEST()
139 fsq.pop_front(); in START_TEST()
140 ck_assert(fsq.size() == 3); in START_TEST()
141 ck_assert(get_header(fsq.front()) == 2); in START_TEST()
142 fsq.pop_front(); in START_TEST()
143 ck_assert(fsq.size() == 2); in START_TEST()
144 ck_assert(get_header(fsq.front()) == 3); in START_TEST()
145 fsq.pop_front(); in START_TEST()
146 ck_assert(fsq.size() == 1); in START_TEST()
147 ck_assert(get_header(fsq.front()) == 4); in START_TEST()
148 fsq.pop_front(); in START_TEST()
149 ck_assert(fsq.empty()); in START_TEST()
155 gcomm::FairSendQueue fsq; in START_TEST() local
156 fsq.push_back(0, make_datagram(1)); in START_TEST()
157 ck_assert(fsq.queued_bytes() == 2); in START_TEST()
158 fsq.push_back(1, make_datagram(2)); in START_TEST()
159 ck_assert(fsq.queued_bytes() == 4); in START_TEST()
160 fsq.pop_front(); in START_TEST()
161 ck_assert(fsq.queued_bytes() == 2); in START_TEST()
162 fsq.pop_front(); in START_TEST()
163 ck_assert(fsq.queued_bytes() == 0); in START_TEST()