Apollo
10.0
自动驾驶开放平台
dispatcher.cc
浏览该文件的文档.
1
/******************************************************************************
2
* Copyright 2018 The Apollo Authors. All Rights Reserved.
3
*
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
* you may not use this file except in compliance with the License.
6
* You may obtain a copy of the License at
7
*
8
* http://www.apache.org/licenses/LICENSE-2.0
9
*
10
* Unless required by applicable law or agreed to in writing, software
11
* distributed under the License is distributed on an "AS IS" BASIS,
12
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
* See the License for the specific language governing permissions and
14
* limitations under the License.
15
*****************************************************************************/
16
17
#include "
cyber/transport/dispatcher/dispatcher.h
"
18
19
namespace
apollo
{
20
namespace
cyber {
21
namespace
transport {
22
23
Dispatcher::Dispatcher
() : is_shutdown_(false) {}
24
25
Dispatcher::~Dispatcher
() {
Shutdown
(); }
26
27
void
Dispatcher::Shutdown
() {
28
is_shutdown_
.store(
true
);
29
ADEBUG
<<
"Shutdown"
;
30
}
31
32
bool
Dispatcher::HasChannel
(uint64_t channel_id) {
33
return
msg_listeners_
.
Has
(channel_id);
34
}
35
36
}
// namespace transport
37
}
// namespace cyber
38
}
// namespace apollo
apollo::cyber::base::AtomicHashMap::Has
bool Has(K key)
Definition
atomic_hash_map.h:46
apollo::cyber::transport::Dispatcher::is_shutdown_
std::atomic< bool > is_shutdown_
Definition
dispatcher.h:81
apollo::cyber::transport::Dispatcher::Shutdown
virtual void Shutdown()
Definition
dispatcher.cc:27
apollo::cyber::transport::Dispatcher::Dispatcher
Dispatcher()
Definition
dispatcher.cc:23
apollo::cyber::transport::Dispatcher::HasChannel
bool HasChannel(uint64_t channel_id)
Definition
dispatcher.cc:32
apollo::cyber::transport::Dispatcher::~Dispatcher
virtual ~Dispatcher()
Definition
dispatcher.cc:25
apollo::cyber::transport::Dispatcher::msg_listeners_
AtomicHashMap< uint64_t, ListenerHandlerBasePtr > msg_listeners_
Definition
dispatcher.h:83
dispatcher.h
ADEBUG
#define ADEBUG
Definition
log.h:41
apollo
class register implement
Definition
arena_queue.h:37
cyber
transport
dispatcher
dispatcher.cc