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

Side by Side Diff: media/cast/test/utility/udp_proxy.cc

Issue 2023343002: Migrate WaitableEvent to enum-based constructor in media/ (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@WEvent_enums
Patch Set: Created 4 years, 6 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 | « media/cast/test/utility/in_process_receiver.cc ('k') | media/filters/blocking_url_protocol.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "media/cast/test/utility/udp_proxy.h" 5 #include "media/cast/test/utility/udp_proxy.h"
6 6
7 #include <math.h> 7 #include <math.h>
8 #include <stdlib.h> 8 #include <stdlib.h>
9 #include <utility> 9 #include <utility>
10 #include <vector> 10 #include <vector>
(...skipping 658 matching lines...) Expand 10 before | Expand all | Expand 10 after
669 : local_port_(local_port), 669 : local_port_(local_port),
670 destination_(destination), 670 destination_(destination),
671 destination_is_mutable_(destination.address().empty()), 671 destination_is_mutable_(destination.address().empty()),
672 proxy_thread_("media::cast::test::UdpProxy Thread"), 672 proxy_thread_("media::cast::test::UdpProxy Thread"),
673 to_dest_pipe_(std::move(to_dest_pipe)), 673 to_dest_pipe_(std::move(to_dest_pipe)),
674 from_dest_pipe_(std::move(from_dest_pipe)), 674 from_dest_pipe_(std::move(from_dest_pipe)),
675 blocked_(false), 675 blocked_(false),
676 weak_factory_(this) { 676 weak_factory_(this) {
677 proxy_thread_.StartWithOptions( 677 proxy_thread_.StartWithOptions(
678 base::Thread::Options(base::MessageLoop::TYPE_IO, 0)); 678 base::Thread::Options(base::MessageLoop::TYPE_IO, 0));
679 base::WaitableEvent start_event(false, false); 679 base::WaitableEvent start_event(
680 base::WaitableEvent::ResetPolicy::AUTOMATIC,
681 base::WaitableEvent::InitialState::NOT_SIGNALED);
680 proxy_thread_.task_runner()->PostTask( 682 proxy_thread_.task_runner()->PostTask(
681 FROM_HERE, 683 FROM_HERE,
682 base::Bind(&UDPProxyImpl::Start, 684 base::Bind(&UDPProxyImpl::Start,
683 base::Unretained(this), 685 base::Unretained(this),
684 base::Unretained(&start_event), 686 base::Unretained(&start_event),
685 net_log)); 687 net_log));
686 start_event.Wait(); 688 start_event.Wait();
687 } 689 }
688 690
689 ~UDPProxyImpl() final { 691 ~UDPProxyImpl() final {
690 base::WaitableEvent stop_event(false, false); 692 base::WaitableEvent stop_event(
693 base::WaitableEvent::ResetPolicy::AUTOMATIC,
694 base::WaitableEvent::InitialState::NOT_SIGNALED);
691 proxy_thread_.task_runner()->PostTask( 695 proxy_thread_.task_runner()->PostTask(
692 FROM_HERE, 696 FROM_HERE,
693 base::Bind(&UDPProxyImpl::Stop, 697 base::Bind(&UDPProxyImpl::Stop,
694 base::Unretained(this), 698 base::Unretained(this),
695 base::Unretained(&stop_event))); 699 base::Unretained(&stop_event)));
696 stop_event.Wait(); 700 stop_event.Wait();
697 proxy_thread_.Stop(); 701 proxy_thread_.Stop();
698 } 702 }
699 703
700 void Send(std::unique_ptr<Packet> packet, 704 void Send(std::unique_ptr<Packet> packet,
(...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after
849 net::NetLog* net_log) { 853 net::NetLog* net_log) {
850 std::unique_ptr<UDPProxy> ret( 854 std::unique_ptr<UDPProxy> ret(
851 new UDPProxyImpl(local_port, destination, std::move(to_dest_pipe), 855 new UDPProxyImpl(local_port, destination, std::move(to_dest_pipe),
852 std::move(from_dest_pipe), net_log)); 856 std::move(from_dest_pipe), net_log));
853 return ret; 857 return ret;
854 } 858 }
855 859
856 } // namespace test 860 } // namespace test
857 } // namespace cast 861 } // namespace cast
858 } // namespace media 862 } // namespace media
OLDNEW
« no previous file with comments | « media/cast/test/utility/in_process_receiver.cc ('k') | media/filters/blocking_url_protocol.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698