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

Side by Side Diff: extensions/browser/api/cast_channel/cast_socket_service.cc

Issue 2891023002: [cast_channel] Make CastSocket not inherit from ApiResource (Closed)
Patch Set: resolve code review comments from Mark Created 3 years, 7 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
OLDNEW
(Empty)
1 // Copyright 2017 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "extensions/browser/api/cast_channel/cast_socket_service.h"
6
7 #include "base/memory/ptr_util.h"
8
9 namespace extensions {
10 namespace api {
11 namespace cast_channel {
12
13 int CastSocketRegistry::id_ = 0;
14
15 CastSocketRegistry::CastSocketRegistry() = default;
16
17 CastSocketRegistry::~CastSocketRegistry() {
18 DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
19 }
20
21 int CastSocketRegistry::AddSocket(std::unique_ptr<CastSocket> socket) {
22 DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
23 DCHECK(socket);
24 socket->set_id(++id_);
25 sockets_.insert(std::make_pair(id_, std::move(socket)));
26 return id_;
27 }
28
29 std::unique_ptr<CastSocket> CastSocketRegistry::RemoveSocket(int channel_id) {
30 DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
31 DCHECK(channel_id > 0);
32 auto socket_it = sockets_.find(channel_id);
33
34 std::unique_ptr<CastSocket> socket;
35 if (socket_it != sockets_.end()) {
36 socket = std::move(socket_it->second);
37 sockets_.erase(socket_it);
38 }
39 return socket;
40 }
41
42 CastSocket* CastSocketRegistry::GetSocket(int channel_id) const {
43 DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
44 DCHECK(channel_id > 0);
45 const auto& socket_it = sockets_.find(channel_id);
46 return socket_it == sockets_.end() ? nullptr : socket_it->second.get();
47 }
48
49 CastSocketService::CastSocketService() = default;
50 CastSocketService::~CastSocketService() = default;
51
52 CastSocketRegistry* CastSocketService::GetOrCreateSocketRegistry() {
53 DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
54 if (!sockets_)
55 sockets_.reset(new CastSocketRegistry());
56 return sockets_.get();
57 }
58
59 } // namespace cast_channel
60 } // namespace api
61 } // namespace extensions
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698