Lines Matching refs:stream_index
247 bool DualStreamTest::EqualTimestamp(int stream_index, int position) {
248 if (timestamp_dual_[stream_index][position]
249 != timestamp_ref_[stream_index][position]) {
255 int DualStreamTest::EqualPayloadLength(int stream_index, int position) {
257 payload_len_dual_[stream_index][position]
258 - payload_len_ref_[stream_index][position]);
261 bool DualStreamTest::EqualPayloadData(int stream_index, int position) {
263 payload_len_dual_[stream_index][position]
264 == payload_len_ref_[stream_index][position]);
266 for (int n = 0; n < payload_len_dual_[stream_index][position]; n++) {
267 if (payload_data_dual_[stream_index][offset + n]
268 != payload_data_ref_[stream_index][offset + n]) {
276 for (int stream_index = 0; stream_index < kMaxNumStreams; stream_index++) {
277 int my_tolerance = stream_index == kPrimary ? 0 : tolerance;
279 if (payload_ref_is_stored_[stream_index][position] == 1
280 && payload_dual_is_stored_[stream_index][position] == 1) {
282 if (start_in_sync || stream_index == 0)
283 EXPECT_TRUE(EqualTimestamp(stream_index, position));
284 EXPECT_LE(EqualPayloadLength(stream_index, position), my_tolerance);
286 EXPECT_TRUE(EqualPayloadData(stream_index, position));
287 num_compared_payloads_[stream_index]++;
288 payload_ref_is_stored_[stream_index][position] = 0;
289 payload_dual_is_stored_[stream_index][position] = 0;
301 int stream_index;
314 stream_index = kPrimary;
318 stream_index = kSecondary;
323 num_received_payloads_dual_[stream_index]++;
324 if (payload_dual_is_stored_[stream_index][0] == 0) {
326 } else if (payload_dual_is_stored_[stream_index][1] == 0) {
332 timestamp_dual_[stream_index][position] = timestamp
334 payload_len_dual_[stream_index][position] = fragmentation
337 &payload_data_dual_[stream_index][position * MAX_PAYLOAD_SIZE_BYTE],
340 payload_dual_is_stored_[stream_index][position] = 1;
342 if (received_payload_[stream_index]) {
343 int t = timestamp_dual_[stream_index][position]
344 - last_timestamp_[stream_index];
345 if ((stream_index == kPrimary) && (t != primary_encoder_.pacsize)) {
349 if ((stream_index == kSecondary) && (t != secondary_encoder_.pacsize)) {
354 received_payload_[stream_index] = true;
356 last_timestamp_[stream_index] = timestamp_dual_[stream_index][position];
364 stream_index = kPrimary;
366 stream_index = kSecondary;
371 num_received_payloads_ref_[stream_index]++;
372 if (payload_ref_is_stored_[stream_index][0] == 0) {
374 } else if (payload_ref_is_stored_[stream_index][1] == 0) {
380 timestamp_ref_[stream_index][position] = timestamp;
381 payload_len_ref_[stream_index][position] = payload_size;
382 memcpy(&payload_data_ref_[stream_index][position * MAX_PAYLOAD_SIZE_BYTE],
384 payload_ref_is_stored_[stream_index][position] = 1;
