MRPT  2.0.4
nodelets.cpp
Go to the documentation of this file.
1 /* +------------------------------------------------------------------------+
2  | Mobile Robot Programming Toolkit (MRPT) |
3  | https://www.mrpt.org/ |
4  | |
5  | Copyright (c) 2005-2020, Individual contributors, see AUTHORS file |
6  | See: https://www.mrpt.org/Authors - All rights reserved. |
7  | Released under BSD License. See: https://www.mrpt.org/License |
8  +------------------------------------------------------------------------+ */
9 
10 #include "comms-precomp.h" // Precompiled headers
11 
12 #include <mrpt/comms/nodelets.h>
13 
14 using namespace mrpt::comms;
15 
16 // ------- Subscriber --------------
18  std::function<void(const std::any&)>&& func,
19  std::function<void()>&& cleanup)
20  : m_func(std::move(func)), m_cleanup(std::move(cleanup))
21 {
22 }
23 
26  std::function<void(const std::any&)>&& func,
27  std::function<void()>&& cleanup)
28 {
29  return Ptr(new Subscriber(std::move(func), std::move(cleanup)));
30 }
31 
32 void Subscriber::pub(const std::any& a) { m_func(a); }
33 // ------- Topic --------------
34 Topic::Topic(std::function<void()>&& cleanup) : m_cleanup(std::move(cleanup)) {}
36 void Topic::publish(const std::any& any)
37 {
38  std::lock_guard<std::mutex> lock(m_mutex);
39  for (auto& sub : m_subs)
40  {
41  sub.lock()->pub(any);
42  }
43 }
44 
45 void Topic::cleanupSubscriber(std::list<std::weak_ptr<Subscriber>>::iterator it)
46 {
47  std::lock_guard<std::mutex> lock(m_mutex);
48  m_subs.erase(it);
49 }
50 
51 // -------------- TopicDirectory ---------------------
53 
54 void TopicDirectory::cleanupTopic(const std::string& key)
55 {
56  std::lock_guard<std::mutex> lock(m_mutex);
57  m_mapService.erase(m_mapService.find(key));
58 }
59 
mrpt::comms::Subscriber::m_cleanup
std::function< void()> m_cleanup
Definition: nodelets.h:48
mrpt::comms::TopicDirectory::create
static Ptr create()
Definition: nodelets.cpp:60
nodelets.h
mrpt::comms::TopicDirectory
The central directory of existing topics for pub/sub.
Definition: nodelets.h:108
mrpt::comms::Subscriber::Subscriber
Subscriber(std::function< void(const std::any &)> &&func, std::function< void()> &&cleanup)
Definition: nodelets.cpp:17
mrpt::comms::Topic::m_cleanup
std::function< void()> m_cleanup
Definition: nodelets.h:104
mrpt::comms::TopicDirectory::m_mapService
std::unordered_map< std::string, std::weak_ptr< Topic > > m_mapService
Definition: nodelets.h:139
mrpt::comms::Topic::m_mutex
std::mutex m_mutex
Definition: nodelets.h:102
mrpt::comms::Subscriber::Ptr
std::shared_ptr< Subscriber > Ptr
Definition: nodelets.h:37
mrpt::comms::TopicDirectory::TopicDirectory
TopicDirectory()
mrpt::comms::Topic::m_subs
std::list< std::weak_ptr< Subscriber > > m_subs
Definition: nodelets.h:103
mrpt::comms
Serial and networking devices and utilities.
Definition: CClientTCPSocket.h:21
mrpt::comms::Topic::~Topic
~Topic()
Definition: nodelets.cpp:35
mrpt::comms::Subscriber::~Subscriber
~Subscriber()
Definition: nodelets.cpp:24
mrpt::comms::TopicDirectory::m_mutex
std::mutex m_mutex
Definition: nodelets.h:138
mrpt::comms::Topic::Topic
Topic(std::function< void()> &&cleanup)
Definition: nodelets.cpp:34
mrpt::comms::Topic::publish
void publish(const std::any &any)
Definition: nodelets.cpp:36
mrpt::comms::TopicDirectory::cleanupTopic
void cleanupTopic(const std::string &key)
Definition: nodelets.cpp:54
mrpt::comms::Topic::cleanupSubscriber
void cleanupSubscriber(std::list< std::weak_ptr< Subscriber >>::iterator it)
Definition: nodelets.cpp:45
mrpt::comms::Subscriber::m_func
std::function< void(const std::any &)> m_func
Definition: nodelets.h:47
mrpt::comms::Subscriber::pub
void pub(const std::any &a)
Definition: nodelets.cpp:32
mrpt::comms::Subscriber::create
static Ptr create(std::function< void(const std::any &)> &&func, std::function< void()> &&cleanup)
Definition: nodelets.cpp:25
mrpt::comms::TopicDirectory::Ptr
std::shared_ptr< TopicDirectory > Ptr
Definition: nodelets.h:114
comms-precomp.h



Page generated by Doxygen 1.8.17 for MRPT 2.0.4 at Sun Jul 19 17:54:30 UTC 2020