Skip to content

Commit

Permalink
Renamed auto connector to device watchdog.
Browse files Browse the repository at this point in the history
  • Loading branch information
carsten0x51h committed Feb 29, 2024
1 parent 25a947e commit c924874
Show file tree
Hide file tree
Showing 4 changed files with 24 additions and 24 deletions.
4 changes: 2 additions & 2 deletions source/indi-device-watchdog/CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,8 @@ set(sources
indi_driver_restart_manager.cpp
indi_client.cpp
indi_client.h
indi_auto_connector.cpp
indi_auto_connector.h
indi_device_watchdog.cpp
indi_device_watchdog.h
main.cpp
)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,9 +34,9 @@

#include "wait_for.h"

#include "indi_auto_connector.h"
#include "indi_device_watchdog.h"

IndiAutoConnectorT::IndiAutoConnectorT(const std::string & hostname, int port, const std::vector<DeviceDataT> & devicesToMonitor) : hostname_(hostname), port_(port) {
IndiDeviceWatchdogT::IndiDeviceWatchdogT(const std::string & hostname, int port, const std::vector<DeviceDataT> & devicesToMonitor) : hostname_(hostname), port_(port) {
using namespace std::chrono_literals;

resetIndiClient();
Expand All @@ -48,7 +48,7 @@ IndiAutoConnectorT::IndiAutoConnectorT(const std::string & hostname, int port, c

}

IndiAutoConnectorT::~IndiAutoConnectorT() {
IndiDeviceWatchdogT::~IndiDeviceWatchdogT() {

serverConnectionFailedListenerConnection_.disconnect();
//serverConnectionStateChangedConnection_.disconnect();
Expand All @@ -62,7 +62,7 @@ IndiAutoConnectorT::~IndiAutoConnectorT() {
}


void IndiAutoConnectorT::resetIndiClient() {
void IndiDeviceWatchdogT::resetIndiClient() {

serverConnectionFailedListenerConnection_.disconnect();
//serverConnectionStateChangedConnection_.disconnect();
Expand Down Expand Up @@ -116,7 +116,7 @@ void IndiAutoConnectorT::resetIndiClient() {
});
}

INDI::BaseDevice IndiAutoConnectorT::getBaseDeviceFromProperty(INDI::Property property) {
INDI::BaseDevice IndiDeviceWatchdogT::getBaseDeviceFromProperty(INDI::Property property) {
#if INDI_MAJOR_VERSION < 2
return *property.getBaseDevice();
#else
Expand All @@ -125,7 +125,7 @@ INDI::BaseDevice IndiAutoConnectorT::getBaseDeviceFromProperty(INDI::Property pr
}


void IndiAutoConnectorT::addIndiDevice(INDI::BaseDevice indiBaseDevice) {
void IndiDeviceWatchdogT::addIndiDevice(INDI::BaseDevice indiBaseDevice) {
std::string indiDeviceName = indiBaseDevice.getDeviceName();

std::cerr << "addIndiDevice: " << indiDeviceName << std::endl;
Expand All @@ -145,7 +145,7 @@ void IndiAutoConnectorT::addIndiDevice(INDI::BaseDevice indiBaseDevice) {



void IndiAutoConnectorT::removeIndiDevice(INDI::BaseDevice indiBaseDevice) {
void IndiDeviceWatchdogT::removeIndiDevice(INDI::BaseDevice indiBaseDevice) {
std::string indiDeviceName = indiBaseDevice.getDeviceName();

std::cerr << "removeIndiDevice: " << indiDeviceName << std::endl;
Expand All @@ -162,7 +162,7 @@ void IndiAutoConnectorT::removeIndiDevice(INDI::BaseDevice indiBaseDevice) {
}
}

void IndiAutoConnectorT::propertyRemoved(INDI::Property property) {
void IndiDeviceWatchdogT::propertyRemoved(INDI::Property property) {

if (! std::strcmp(property.getName(), "CONNECTION")) {
std::cerr << "propertyRemoved..." << std::endl;
Expand All @@ -183,7 +183,7 @@ void IndiAutoConnectorT::propertyRemoved(INDI::Property property) {
}


void IndiAutoConnectorT::propertyUpdated(INDI::Property /*property*/) {
void IndiDeviceWatchdogT::propertyUpdated(INDI::Property /*property*/) {

// if (! std::strcmp(property.getName(), "CONNECTION")) {

Expand All @@ -204,7 +204,7 @@ void IndiAutoConnectorT::propertyUpdated(INDI::Property /*property*/) {
}


bool IndiAutoConnectorT::requestIndiDriverRestart(DeviceDataT & deviceData) {
bool IndiDeviceWatchdogT::requestIndiDriverRestart(DeviceDataT & deviceData) {
std::string driverName = deviceData.getIndiDeviceDriverName();

bool restarted = indiDriverRestartManager_.requestRestart(driverName);
Expand All @@ -215,7 +215,7 @@ bool IndiAutoConnectorT::requestIndiDriverRestart(DeviceDataT & deviceData) {
}


bool IndiAutoConnectorT::isDeviceValid(INDI::BaseDevice indiBaseDevice) {
bool IndiDeviceWatchdogT::isDeviceValid(INDI::BaseDevice indiBaseDevice) {
#if INDI_MAJOR_VERSION < 2
return (indiBaseDevice.getDeviceName() != nullptr);
#else
Expand All @@ -229,7 +229,7 @@ bool IndiAutoConnectorT::isDeviceValid(INDI::BaseDevice indiBaseDevice) {
* --> Actually an updated from the INDI server will be sent once the property has
* changed successfully. Only then the connect was successful.
*/
bool IndiAutoConnectorT::requestConnectionStateChange(INDI::BaseDevice indiBaseDevice, bool connect) {
bool IndiDeviceWatchdogT::requestConnectionStateChange(INDI::BaseDevice indiBaseDevice, bool connect) {

std::cerr << "Sending INDI device " << (connect ? "connect" : " disconnect") << " request for device ' '" << indiBaseDevice.getDeviceName() << "'..." << std::endl;

Expand Down Expand Up @@ -271,12 +271,12 @@ bool IndiAutoConnectorT::requestConnectionStateChange(INDI::BaseDevice indiBaseD
}


bool IndiAutoConnectorT::fileExists(const std::string & pathToFile) const {
bool IndiDeviceWatchdogT::fileExists(const std::string & pathToFile) const {
return std::filesystem::exists(pathToFile);
}


bool IndiAutoConnectorT::isIndiDeviceConnected(INDI::BaseDevice indiBaseDevice) {
bool IndiDeviceWatchdogT::isIndiDeviceConnected(INDI::BaseDevice indiBaseDevice) {

#if INDI_MAJOR_VERSION < 2
ISwitchVectorProperty* connectionSwitchVec = indiBaseDevice.getSwitch("CONNECTION");
Expand All @@ -288,7 +288,7 @@ bool IndiAutoConnectorT::isIndiDeviceConnected(INDI::BaseDevice indiBaseDevice)
}


bool IndiAutoConnectorT::handleDeviceConnection(DeviceDataT & deviceData) {
bool IndiDeviceWatchdogT::handleDeviceConnection(DeviceDataT & deviceData) {
std::string indiDeviceName = deviceData.getIndiDeviceName();

bool indiDeviceConnected = isIndiDeviceConnected(deviceData.getIndiBaseDevice());
Expand Down Expand Up @@ -338,7 +338,7 @@ bool IndiAutoConnectorT::handleDeviceConnection(DeviceDataT & deviceData) {
}


void IndiAutoConnectorT::run() {
void IndiDeviceWatchdogT::run() {
using namespace std::chrono_literals;


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@
/**
* TODO: Idea: Rename to IndiDeviceWatchdogT
*/
class IndiAutoConnectorT {
class IndiDeviceWatchdogT {
private:
std::string hostname_;
int port_;
Expand Down Expand Up @@ -80,8 +80,8 @@ class IndiAutoConnectorT {


public:
IndiAutoConnectorT(const std::string & hostname, int port, const std::vector<DeviceDataT> & devicesToMonitor);
~IndiAutoConnectorT();
IndiDeviceWatchdogT(const std::string & hostname, int port, const std::vector<DeviceDataT> & devicesToMonitor);
~IndiDeviceWatchdogT();

void run();
};
Expand Down
6 changes: 3 additions & 3 deletions source/indi-device-watchdog/main.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
#include <boost/program_options.hpp>

#include "indi_device_watchdog/indi_device_watchdog-version.h"
#include "indi_auto_connector.h"
#include "indi_device_watchdog.h"
#include "device_data_persistance.h"

std::string composeStartupMessage() {
Expand Down Expand Up @@ -85,9 +85,9 @@ int main(int argc, char *argv[]) {
std::string indiHostname = vm["hostname"].as<std::string>();
int indiPort = vm["port"].as<int>();

IndiAutoConnectorT indiAutoConnector(indiHostname, indiPort, devicesToMonitor);
IndiDeviceWatchdogT indiDeviceWatchdog(indiHostname, indiPort, devicesToMonitor);

indiAutoConnector.run();
indiDeviceWatchdog.run();

return 0;
}

0 comments on commit c924874

Please sign in to comment.