coffee/etl
1
0
Fork 0
mirror of https://github.com/ETLCPP/etl.git synced 2026-11-09 14:49:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

Minor changes

Browse Source
This commit is contained in:
John Wellbelove 2020-12-05 11:55:40 +00:00
parent 013598da60
commit fdcc2c00d3
4 changed files with 23 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
include/etl/ishared_message_processor.h → include/etl/shared_message_processor.h
View File

@ -38,13 +38,27 @@ namespace etl
//***************************************************************************
/// This is the base of all shared message processors.
//***************************************************************************
class ishared_message_processor
class shared_message_processor
{
public:
virtual ~ishared_message_processor() {}
shared_message_processor(imessage_router& router_)
: router(router_)
{
}
virtual ~shared_message_processor() {}
virtual void receive(etl::shared_message message) = 0;
virtual void receive(imessage_router& source, etl::shared_message message) = 0;
imessage_router& get_router() const
{
return router;
}
private:
imessage_router& router;
};
}

12
test/test_pool_message.cpp
View File

@ -36,7 +36,7 @@ SOFTWARE.
#include "etl/atomic.h"
#include "etl/queue.h"
#include "etl/ishared_message_processor.h"
#include "etl/shared_message_processor.h"
namespace
{
@ -71,10 +71,10 @@ namespace
};
//*************************************************************************
struct Processor : public etl::ishared_message_processor
struct Processor : public etl::shared_message_processor
{
Processor(etl::imessage_router& router_)
: router(router_)
Processor(Router& router_)
: shared_message_processor(router_)
{
}
@ -89,16 +89,14 @@ namespace
void receive(etl::imessage_router& source, etl::shared_message message)
{
}
void Process()
{
router.receive(smqueue.front().get_message());
get_router().receive(smqueue.front().get_message());
smqueue.pop();
}
etl::imessage_router& router;
etl::queue<etl::shared_message, 10> smqueue;
};

2
test/vs2019/etl.vcxproj
View File

@ -1083,7 +1083,7 @@
<ClInclude Include="..\..\include\etl\queue_spsc_locked.h" />
<ClInclude Include="..\..\include\etl\scaled_rounding.h" />
<ClInclude Include="..\..\include\etl\shared_message.h" />
<ClInclude Include="..\..\include\etl\ishared_message_processor.h" />
<ClInclude Include="..\..\include\etl\shared_message_processor.h" />
<ClInclude Include="..\..\include\etl\span.h" />
<ClInclude Include="..\..\include\etl\state_chart.h" />
<ClInclude Include="..\..\include\etl\math_constants.h" />

2
test/vs2019/etl.vcxproj.filters
View File

@ -864,7 +864,7 @@
<ClInclude Include="..\..\include\etl\message_pool.h">
<Filter>ETL\Frameworks</Filter>
</ClInclude>
<ClInclude Include="..\..\include\etl\ishared_message_processor.h">
<ClInclude Include="..\..\include\etl\shared_message_processor.h">
<Filter>ETL\Frameworks</Filter>
</ClInclude>
</ItemGroup>