23669027368

Committed 27 Mar 2026 09:50PM UTC coverage: 26.198% (+0.02%) from 26.176%

Build # 23669027368

Build Type

push

github

Committed by

reinder

Commit Message

Merge remote-tracking branch 'origin/master' into cbus

Coverage Stats

11 of 144 new or added lines in 34 files covered. (7.64%)

1 existing line in 1 file now uncovered.

8256 of 31514 relevant lines covered (26.2%)

182.55 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/server/src/hardware/protocol/z21/kernel.cpp

/**
 * server/src/hardware/protocol/z21/kernel.cpp
 *
 * This file is part of the traintastic source code.
 *
 * Copyright (C) 2019-2023 Reinder Feenstra
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation; either version 2
 * of the License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
 */

#include "kernel.hpp"
#include "messages.hpp"
#include "../xpressnet/messages.hpp"
#include "../../decoder/decoder.hpp"
#include "../../decoder/decoderchangeflags.hpp"
#include "../../input/inputcontroller.hpp"
#include "../../../utils/setthreadname.hpp"
#include "../../../core/eventloop.hpp"
#include "../../../log/log.hpp"
#include "../../../log/logmessageexception.hpp"

namespace Z21 {

Kernel::Kernel(std::string logId_)
  : KernelBase(std::move(logId_))
{
}

void Kernel::start()
{
  assert(m_ioHandler);
  assert(!m_started);

  m_thread = std::thread(
    [this]()
    {
      setThreadName("z21");
      boost::asio::executor_work_guard<decltype(m_ioContext.get_executor())> work{m_ioContext.get_executor()};
      m_ioContext.run();
    });

  boost::asio::post(m_ioContext, 
    [this]()
    {
      try
      {
        m_ioHandler->start();
      }
      catch(const LogMessageException& e)
      {
        EventLoop::call(
          [this, e]()
          {
            Log::log(logId, e.message(), e.args());
            error();
          });
        return;
      }

      onStart();

      started();
    });

#ifndef NDEBUG
  m_started = true;
#endif
}

void Kernel::stop()
{
  boost::asio::post(m_ioContext, 
    [this]()
    {
      onStop();

      m_ioHandler->stop();
    });

  m_ioContext.stop();

  m_thread.join();

#ifndef NDEBUG
  m_started = false;
#endif
}

void Kernel::setIOHandler(std::unique_ptr<IOHandler> handler)
{
  assert(handler);
  assert(!m_ioHandler);
  m_ioHandler = std::move(handler);
}

}

1	/**
2	* server/src/hardware/protocol/z21/kernel.cpp
3	*
4	* This file is part of the traintastic source code.
5	*
6	* Copyright (C) 2019-2023 Reinder Feenstra
7	*
8	* This program is free software; you can redistribute it and/or
9	* modify it under the terms of the GNU General Public License
10	* as published by the Free Software Foundation; either version 2
11	* of the License, or (at your option) any later version.
12	*
13	* This program is distributed in the hope that it will be useful,
14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16	* GNU General Public License for more details.
17	*
18	* You should have received a copy of the GNU General Public License
19	* along with this program; if not, write to the Free Software
20	* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
21	*/
22
23	#include "kernel.hpp"
24	#include "messages.hpp"
25	#include "../xpressnet/messages.hpp"
26	#include "../../decoder/decoder.hpp"
27	#include "../../decoder/decoderchangeflags.hpp"
28	#include "../../input/inputcontroller.hpp"
29	#include "../../../utils/setthreadname.hpp"
30	#include "../../../core/eventloop.hpp"
31	#include "../../../log/log.hpp"
32	#include "../../../log/logmessageexception.hpp"
33
34	namespace Z21 {
35
36	Kernel::Kernel(std::string logId_)	×
37	: KernelBase(std::move(logId_))	×
38	{
39	}	×
40
41	void Kernel::start()	×
42	{
43	assert(m_ioHandler);	×
44	assert(!m_started);	×
45
46	m_thread = std::thread(	×
47	[this]()	×
48	{
49	setThreadName("z21");	×
NEW 50	boost::asio::executor_work_guard<decltype(m_ioContext.get_executor())> work{m_ioContext.get_executor()};	×
51	m_ioContext.run();	×
52	});	×
53
NEW 54	boost::asio::post(m_ioContext,	×
55	[this]()	×
56	{
57	try
58	{
59	m_ioHandler->start();	×
60	}
61	catch(const LogMessageException& e)	×
62	{
63	EventLoop::call(	×
64	[this, e]()	×
65	{
66	Log::log(logId, e.message(), e.args());	×
67	error();	×
68	});	×
69	return;	×
70	}	×
71
72	onStart();	×
73
74	started();	×
75	});
76
77	#ifndef NDEBUG
78	m_started = true;	×
79	#endif
80	}	×
81
82	void Kernel::stop()	×
83	{
NEW 84	boost::asio::post(m_ioContext,	×
85	[this]()	×
86	{
87	onStop();	×
88
89	m_ioHandler->stop();	×
90	});	×
91
92	m_ioContext.stop();	×
93
94	m_thread.join();	×
95
96	#ifndef NDEBUG
97	m_started = false;	×
98	#endif
99	}	×
100
101	void Kernel::setIOHandler(std::unique_ptr<IOHandler> handler)	×
102	{
103	assert(handler);	×
104	assert(!m_ioHandler);	×
105	m_ioHandler = std::move(handler);	×
106	}	×
107
108	}

traintastic / traintastic / 23669027368

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous