Lines Matching refs:ch1
549 void ConnectAndDisconnectChannels(TestChannel* ch1, TestChannel* ch2);
639 TestChannel ch1(port1, port2);
641 EXPECT_EQ(0, ch1.complete_count());
645 ch1.Start();
647 ASSERT_EQ_WAIT(1, ch1.complete_count(), kTimeout);
651 ch1.CreateConnection();
652 ASSERT_TRUE(ch1.conn() != NULL);
653 EXPECT_TRUE_WAIT(ch1.conn()->connected(), kTimeout); // for TCP connect
654 ch1.Ping();
660 EXPECT_TRUE(ch1.remote_address().IsNil());
677 EXPECT_TRUE(ch1.remote_address().IsNil());
688 EXPECT_EQ(Connection::STATE_READABLE, ch1.conn()->read_state());
693 if (ch1.conn()->write_state() == Connection::STATE_WRITE_INIT) {
694 ch1.Ping();
695 EXPECT_EQ_WAIT(Connection::STATE_WRITABLE, ch1.conn()->write_state(),
701 EXPECT_TRUE(ch1.remote_address().IsNil());
706 ch1.Ping();
709 EXPECT_TRUE(ch1.remote_address().IsNil());
720 EXPECT_FALSE(ch1.remote_address().IsNil());
721 EXPECT_EQ(Connection::STATE_READ_INIT, ch1.conn()->read_state());
724 ch1.AcceptConnection();
725 ch1.Ping();
726 EXPECT_EQ_WAIT(Connection::STATE_WRITABLE, ch1.conn()->write_state(),
730 EXPECT_TRUE(ch1.remote_address().IsNil());
732 ch1.Ping();
734 EXPECT_TRUE(ch1.remote_address().IsNil());
740 ASSERT_TRUE(ch1.conn() != NULL);
743 EXPECT_EQ(Connection::STATE_READABLE, ch1.conn()->read_state());
744 EXPECT_EQ(Connection::STATE_WRITABLE, ch1.conn()->write_state());
748 EXPECT_NE(Connection::STATE_READABLE, ch1.conn()->read_state());
749 EXPECT_NE(Connection::STATE_WRITABLE, ch1.conn()->write_state());
755 ch1.Stop();
757 EXPECT_TRUE_WAIT(ch1.conn() == NULL, kTimeout);
761 void PortTest::ConnectAndDisconnectChannels(TestChannel* ch1,
764 ch1->Start();
768 ch1->CreateConnection();
769 EXPECT_TRUE_WAIT(ch1->conn()->connected(), kTimeout); // for TCP connect
770 ch1->Ping();
780 ch1->Stop();
2311 TestChannel ch1(port1, port2);
2315 ch1.Start();
2317 ASSERT_EQ_WAIT(1, ch1.complete_count(), kTimeout);
2321 ch1.CreateConnection();
2322 ASSERT_TRUE(ch1.conn() != NULL);
2323 EXPECT_EQ(Connection::STATE_WRITE_INIT, ch1.conn()->write_state());
2324 EXPECT_TRUE_WAIT(ch1.conn()->connected(), kTimeout); // for TCP connect
2325 ch1.Ping();
2332 EXPECT_EQ(SOCKET_ERROR, ch1.conn()->Send(data, data_size, options));
2337 EXPECT_EQ_WAIT(Connection::STATE_WRITABLE, ch1.conn()->write_state(),
2339 EXPECT_EQ(data_size, ch1.conn()->Send(data, data_size, options));
2345 ch1.Ping(i);
2348 ch1.conn()->UpdateState(unreliable_timeout_delay);
2349 EXPECT_EQ(Connection::STATE_WRITE_UNRELIABLE, ch1.conn()->write_state());
2352 EXPECT_EQ(data_size, ch1.conn()->Send(data, data_size, options));
2356 EXPECT_EQ_WAIT(Connection::STATE_WRITABLE, ch1.conn()->write_state(),
2362 ch1.Ping(unreliable_timeout_delay + i);
2364 ch1.conn()->UpdateState(unreliable_timeout_delay + CONNECTION_WRITE_TIMEOUT +
2366 EXPECT_EQ(Connection::STATE_WRITE_TIMEOUT, ch1.conn()->write_state());
2369 EXPECT_EQ(SOCKET_ERROR, ch1.conn()->Send(data, data_size, options));
2371 ch1.Stop();
2380 TestChannel ch1(port1, port2);
2384 ch1.Start();
2387 ch1.CreateConnection();
2388 ASSERT_TRUE(ch1.conn() != NULL);
2389 EXPECT_EQ(Connection::STATE_WRITE_INIT, ch1.conn()->write_state());
2393 ch1.Ping(i);
2395 ch1.conn()->UpdateState(CONNECTION_WRITE_TIMEOUT + 500u);
2396 EXPECT_EQ(Connection::STATE_WRITE_TIMEOUT, ch1.conn()->write_state());
2401 // In this test |ch1| behaves like FULL mode client and we have created
2412 TestChannel ch1(ice_full_port, ice_lite_port.get());
2413 ch1.SetIceMode(ICEMODE_FULL);
2416 ch1.Start();
2419 ASSERT_EQ_WAIT(1, ch1.complete_count(), kTimeout);
2422 ch1.CreateConnection();
2423 ASSERT_TRUE(ch1.conn() != NULL);
2424 EXPECT_EQ(Connection::STATE_WRITE_INIT, ch1.conn()->write_state());
2428 ch1.Ping();
2447 ch1.conn()->OnReadPacket(ice_lite_port->last_stun_buf()->Data(),
2451 EXPECT_EQ_WAIT(Connection::STATE_WRITABLE, ch1.conn()->write_state(),
2453 EXPECT_TRUE_WAIT(ch1.nominated(), kTimeout);
2459 ch1.Ping();
2463 ch1.Stop();
2480 TestChannel ch1(port1, port2);
2484 ConnectAndDisconnectChannels(&ch1, &ch2);
2512 TestChannel ch1(port1, port2);
2516 ConnectAndDisconnectChannels(&ch1, &ch2);
