eive-obsw/mission/core/GenericFactory.cpp

126 lines
5.2 KiB
C++
Raw Normal View History

2020-11-20 18:10:39 +01:00
#include "GenericFactory.h"
2020-12-29 13:59:31 +01:00
2020-11-20 18:10:39 +01:00
#include <fsfw/events/EventManager.h>
#include <fsfw/health/HealthTable.h>
2021-07-15 01:25:32 +02:00
#include <fsfw/internalerror/InternalErrorReporter.h>
2020-11-20 18:10:39 +01:00
#include <fsfw/pus/CService200ModeCommanding.h>
2022-05-12 19:22:20 +02:00
#include <fsfw/pus/CService201HealthCommanding.h>
2020-11-20 18:10:39 +01:00
#include <fsfw/pus/Service17Test.h>
#include <fsfw/pus/Service1TelecommandVerification.h>
2021-03-04 18:29:28 +01:00
#include <fsfw/pus/Service20ParameterManagement.h>
2020-11-20 18:10:39 +01:00
#include <fsfw/pus/Service2DeviceAccess.h>
2022-01-17 15:58:27 +01:00
#include <fsfw/pus/Service3Housekeeping.h>
2020-11-20 18:10:39 +01:00
#include <fsfw/pus/Service5EventReporting.h>
#include <fsfw/pus/Service8FunctionManagement.h>
#include <fsfw/pus/Service9TimeManagement.h>
#include <fsfw/storagemanager/PoolManager.h>
#include <fsfw/tcdistribution/CCSDSDistributor.h>
#include <fsfw/tcdistribution/PUSDistributor.h>
#include <fsfw/timemanager/TimeStamper.h>
#include <mission/utility/TmFunnel.h>
2022-01-17 15:58:27 +01:00
2022-03-25 18:39:21 +01:00
#include "OBSWConfig.h"
2022-03-26 13:54:05 +01:00
#include "eive/definitions.h"
2022-01-17 15:58:27 +01:00
#include "objects/systemObjectList.h"
2022-03-25 18:39:21 +01:00
#include "tmtc/apid.h"
#include "tmtc/pusIds.h"
2020-11-20 18:10:39 +01:00
2021-09-28 14:58:12 +02:00
#if OBSW_ADD_TCPIP_BRIDGE == 1
2022-03-08 09:37:23 +01:00
#if OBSW_USE_TMTC_TCP_BRIDGE == 0
2021-09-28 14:58:12 +02:00
// UDP server includes
#include "fsfw/osal/common/UdpTcPollingTask.h"
2022-01-17 15:58:27 +01:00
#include "fsfw/osal/common/UdpTmTcBridge.h"
2021-09-28 14:58:12 +02:00
#else
// TCP server includes
#include "fsfw/osal/common/TcpTmTcBridge.h"
#include "fsfw/osal/common/TcpTmTcServer.h"
#endif
#endif
2020-12-29 13:59:31 +01:00
#if OBSW_ADD_TEST_CODE == 1
2021-09-28 14:58:12 +02:00
#include <test/testtasks/TestTask.h>
2020-11-25 16:17:16 +01:00
#endif
2020-11-20 18:10:39 +01:00
2022-03-26 14:08:34 +01:00
#ifndef OBSW_TM_TO_PTME
#define OBSW_TM_TO_PTME 0
#endif
2022-05-02 17:37:00 +02:00
void ObjectFactory::produceGenericObjects(HealthTableIF** healthTable_) {
2022-01-17 15:58:27 +01:00
// Framework objects
new EventManager(objects::EVENT_MANAGER);
2022-05-02 17:37:00 +02:00
auto healthTable = new HealthTable(objects::HEALTH_TABLE);
if (healthTable != nullptr) {
*healthTable_ = healthTable;
}
2022-01-17 15:58:27 +01:00
new InternalErrorReporter(objects::INTERNAL_ERROR_REPORTER);
new TimeStamper(objects::TIME_STAMPER);
{
PoolManager::LocalPoolConfig poolCfg = {{300, 16}, {300, 32}, {200, 64},
{200, 128}, {100, 1024}, {10, 2048}};
new PoolManager(objects::TC_STORE, poolCfg);
}
{
PoolManager::LocalPoolConfig poolCfg = {{300, 16}, {300, 32}, {100, 64},
{100, 128}, {100, 1024}, {10, 2048}};
new PoolManager(objects::TM_STORE, poolCfg);
}
{
PoolManager::LocalPoolConfig poolCfg = {{300, 16}, {200, 32}, {150, 64}, {150, 128},
{100, 256}, {50, 512}, {50, 1024}, {10, 2048}};
new PoolManager(objects::IPC_STORE, poolCfg);
}
new CCSDSDistributor(apid::EIVE_OBSW, objects::CCSDS_PACKET_DISTRIBUTOR);
new PUSDistributor(apid::EIVE_OBSW, objects::PUS_PACKET_DISTRIBUTOR,
objects::CCSDS_PACKET_DISTRIBUTOR);
2022-03-26 14:08:34 +01:00
uint8_t vc = 0;
#if OBSW_TM_TO_PTME == 1
vc = config::LIVE_TM;
#endif
2022-01-17 15:58:27 +01:00
// Every TM packet goes through this funnel
2022-03-26 14:08:34 +01:00
new TmFunnel(objects::TM_FUNNEL, 50, vc);
2022-01-17 15:58:27 +01:00
// PUS service stack
new Service1TelecommandVerification(objects::PUS_SERVICE_1_VERIFICATION, apid::EIVE_OBSW,
pus::PUS_SERVICE_1, objects::TM_FUNNEL, 20);
new Service2DeviceAccess(objects::PUS_SERVICE_2_DEVICE_ACCESS, apid::EIVE_OBSW,
pus::PUS_SERVICE_2, 3, 10);
new Service3Housekeeping(objects::PUS_SERVICE_3_HOUSEKEEPING, apid::EIVE_OBSW,
pus::PUS_SERVICE_3);
new Service5EventReporting(objects::PUS_SERVICE_5_EVENT_REPORTING, apid::EIVE_OBSW,
2022-02-22 20:17:15 +01:00
pus::PUS_SERVICE_5, 15, 45);
2022-01-17 15:58:27 +01:00
new Service8FunctionManagement(objects::PUS_SERVICE_8_FUNCTION_MGMT, apid::EIVE_OBSW,
pus::PUS_SERVICE_8, 3, 60);
new Service9TimeManagement(objects::PUS_SERVICE_9_TIME_MGMT, apid::EIVE_OBSW, pus::PUS_SERVICE_9);
new Service17Test(objects::PUS_SERVICE_17_TEST, apid::EIVE_OBSW, pus::PUS_SERVICE_17);
new Service20ParameterManagement(objects::PUS_SERVICE_20_PARAMETERS, apid::EIVE_OBSW,
pus::PUS_SERVICE_20);
new CService200ModeCommanding(objects::PUS_SERVICE_200_MODE_MGMT, apid::EIVE_OBSW,
2022-05-12 19:22:20 +02:00
pus::PUS_SERVICE_200, 8);
new CService201HealthCommanding(objects::PUS_SERVICE_201_HEALTH, apid::EIVE_OBSW,
pus::PUS_SERVICE_201);
2021-09-28 14:58:12 +02:00
#if OBSW_ADD_TCPIP_BRIDGE == 1
2022-03-08 09:37:23 +01:00
#if OBSW_USE_TMTC_TCP_BRIDGE == 0
2022-01-17 15:58:27 +01:00
auto tmtcBridge = new UdpTmTcBridge(objects::TMTC_BRIDGE, objects::CCSDS_PACKET_DISTRIBUTOR);
new UdpTcPollingTask(objects::TMTC_POLLING_TASK, objects::TMTC_BRIDGE);
sif::info << "Created UDP server for TMTC commanding with listener port "
<< udpBridge->getUdpPort() << std::endl;
2021-09-28 14:58:12 +02:00
#else
2022-01-17 15:58:27 +01:00
auto tmtcBridge = new TcpTmTcBridge(objects::TMTC_BRIDGE, objects::CCSDS_PACKET_DISTRIBUTOR);
auto tcpServer = new TcpTmTcServer(objects::TMTC_POLLING_TASK, objects::TMTC_BRIDGE);
// TCP is stream based. Use packet ID as start marker when parsing for space packets
tcpServer->setSpacePacketParsingOptions({common::PUS_PACKET_ID});
sif::info << "Created TCP server for TMTC commanding with listener port "
2021-09-28 14:58:12 +02:00
<< tcpServer->getTcpPort() << std::endl;
2022-04-26 10:37:25 +02:00
#if OBSW_TCP_SERVER_WIRETAPPING == 1
2022-03-27 13:07:18 +02:00
tcpServer->enableWiretapping(true);
2022-04-26 10:37:25 +02:00
#endif /* OBSW_TCP_SERVER_WIRETAPPING == 1 */
2021-09-28 14:58:12 +02:00
#endif /* OBSW_USE_TMTC_TCP_BRIDGE == 0 */
2022-01-17 15:58:27 +01:00
tmtcBridge->setMaxNumberOfPacketsStored(70);
2021-09-28 14:58:12 +02:00
#endif /* OBSW_ADD_TCPIP_BRIDGE == 1 */
2020-11-20 18:10:39 +01:00
}