Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(240)

Side by Side Diff: webrtc/rtc_base/socket_unittest.cc

Issue 2977953002: Partial Reland of Make the default ctor of rtc::Thread, protected (Closed)
Patch Set: Fix the same error elsewhere Created 3 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « webrtc/rtc_base/rtccertificategenerator_unittest.cc ('k') | webrtc/rtc_base/thread.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 /* 1 /*
2 * Copyright 2007 The WebRTC Project Authors. All rights reserved. 2 * Copyright 2007 The WebRTC Project Authors. All rights reserved.
3 * 3 *
4 * Use of this source code is governed by a BSD-style license 4 * Use of this source code is governed by a BSD-style license
5 * that can be found in the LICENSE file in the root of the source 5 * that can be found in the LICENSE file in the root of the source
6 * tree. An additional intellectual property rights grant can be found 6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may 7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree. 8 * be found in the AUTHORS file in the root of the source tree.
9 */ 9 */
10 10
(...skipping 663 matching lines...) Expand 10 before | Expand all | Expand 10 after
674 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress()); 674 EXPECT_EQ(client->GetRemoteAddress(), accepted->GetLocalAddress());
675 675
676 // Do an i/o operation, triggering an eventual callback. 676 // Do an i/o operation, triggering an eventual callback.
677 EXPECT_FALSE(sink.Check(accepted.get(), SSE_READ)); 677 EXPECT_FALSE(sink.Check(accepted.get(), SSE_READ));
678 char buf[1024] = {0}; 678 char buf[1024] = {0};
679 679
680 EXPECT_EQ(1024, client->Send(buf, 1024)); 680 EXPECT_EQ(1024, client->Send(buf, 1024));
681 EXPECT_FALSE(sink.Check(accepted.get(), SSE_READ)); 681 EXPECT_FALSE(sink.Check(accepted.get(), SSE_READ));
682 682
683 // Shouldn't signal when blocked in a thread Send, where process_io is false. 683 // Shouldn't signal when blocked in a thread Send, where process_io is false.
684 std::unique_ptr<Thread> thread(new Thread()); 684 std::unique_ptr<Thread> thread(Thread::CreateWithSocketServer());
685 thread->Start(); 685 thread->Start();
686 Sleeper sleeper; 686 Sleeper sleeper;
687 TypedMessageData<AsyncSocket*> data(client.get()); 687 TypedMessageData<AsyncSocket*> data(client.get());
688 thread->Send(RTC_FROM_HERE, &sleeper, 0, &data); 688 thread->Send(RTC_FROM_HERE, &sleeper, 0, &data);
689 EXPECT_FALSE(sink.Check(accepted.get(), SSE_READ)); 689 EXPECT_FALSE(sink.Check(accepted.get(), SSE_READ));
690 690
691 // But should signal when process_io is true. 691 // But should signal when process_io is true.
692 EXPECT_TRUE_WAIT((sink.Check(accepted.get(), SSE_READ)), kTimeout); 692 EXPECT_TRUE_WAIT((sink.Check(accepted.get(), SSE_READ)), kTimeout);
693 EXPECT_LT(0, accepted->Recv(buf, 1024, nullptr)); 693 EXPECT_LT(0, accepted->Recv(buf, 1024, nullptr));
694 } 694 }
(...skipping 342 matching lines...) Expand 10 before | Expand all | Expand 10 after
1037 socket->RecvFrom(buffer, 3, nullptr, &recv_timestamp_2); 1037 socket->RecvFrom(buffer, 3, nullptr, &recv_timestamp_2);
1038 1038
1039 int64_t system_time_diff = send_time_2 - send_time_1; 1039 int64_t system_time_diff = send_time_2 - send_time_1;
1040 int64_t recv_timestamp_diff = recv_timestamp_2 - recv_timestamp_1; 1040 int64_t recv_timestamp_diff = recv_timestamp_2 - recv_timestamp_1;
1041 // Compare against the system time at the point of sending, because 1041 // Compare against the system time at the point of sending, because
1042 // SleepMs may not sleep for exactly the requested time. 1042 // SleepMs may not sleep for exactly the requested time.
1043 EXPECT_NEAR(system_time_diff, recv_timestamp_diff, 10000); 1043 EXPECT_NEAR(system_time_diff, recv_timestamp_diff, 10000);
1044 } 1044 }
1045 1045
1046 } // namespace rtc 1046 } // namespace rtc
OLDNEW
« no previous file with comments | « webrtc/rtc_base/rtccertificategenerator_unittest.cc ('k') | webrtc/rtc_base/thread.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698