iframe-proxy | Sunbelt Computer Software

History

191 lines (157 loc) · 4.77 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

/* Main routine.

* Author: Steffen Vogel <post@steffenvogel.de>

* SPDX-FileCopyrightText: 2014-2023 Institute for Automation of Complex Power Systems, RWTH Aachen University

* SPDX-License-Identifier: Apache-2.0

#include <cstdlib>

#include <iomanip>

#include <iostream>

#include <unistd.h>

#include <villas/api.hpp>

#include <villas/api/request.hpp>

#include <villas/capabilities.hpp>

#include <villas/colors.hpp>

#include <villas/exceptions.hpp>

#include <villas/format.hpp>

#include <villas/hook.hpp>

#include <villas/kernel/kernel.hpp>

#include <villas/kernel/rt.hpp>

#include <villas/log.hpp>

#include <villas/memory.hpp>

#include <villas/node.hpp>

#include <villas/node/config.hpp>

#include <villas/path.hpp>

#include <villas/plugin.hpp>

#include <villas/super_node.hpp>

#include <villas/tool.hpp>

#include <villas/utils.hpp>

#include <villas/version.hpp>

#include <villas/web.hpp>

using namespace villas;

using namespace villas::node;

using namespace villas::plugin;

namespace villas {

namespace node {

namespace tools {

class Node : public Tool {

public:

Node(int argc, char *argv[]) : Tool(argc, argv, "node") {}

protected:

SuperNode sn;

std::string uri;

bool showCapabilities = false;

void handler(int signal, siginfo_t *sinfo, void *ctx) {

switch (signal) {

case SIGALRM:

logger->info("Reached timeout. Terminating...");

break;

default:

logger->info("Received {} signal. Terminating...", strsignal(signal));

}

sn.setState(State::STOPPING);

}

void usage() {

std::cout

<< "Usage: villas-node [OPTIONS] [CONFIG]" << std::endl

<< " OPTIONS is one or more of the following options:" << std::endl

<< " -h show this usage information" << std::endl

<< " -d LVL set logging level" << std::endl

<< " -C show capabilities in JSON format" << std::endl

<< " -V show the version of the tool" << std::endl

<< std::endl

<< " CONFIG is the path to an optional configuration file" << std::endl

<< " if omitted, VILLASnode will start without a configuration"

<< std::endl

<< " and wait for provisioning over the web interface."

<< std::endl

<< std::endl;

std::cout << "Supported node-types:" << std::endl;

for (auto p : registry->lookup<NodeFactory>()) {

if (!p->isHidden())

std::cout << " - " << std::left << std::setw(18) << p->getName()

<< p->getDescription() << std::endl;

}

std::cout << std::endl;

std::cout << "Supported IO formats:" << std::endl;

for (auto p : registry->lookup<FormatFactory>()) {

if (!p->isHidden())

std::cout << " - " << std::left << std::setw(18) << p->getName()

<< p->getDescription() << std::endl;

}

std::cout << std::endl;

#ifdef WITH_HOOKS

std::cout << "Supported hooks:" << std::endl;

for (auto p : registry->lookup<HookFactory>()) {

if (!p->isHidden())

std::cout << " - " << std::left << std::setw(18) << p->getName()

<< p->getDescription() << std::endl;

}

std::cout << std::endl;

#endif // WITH_HOOKS

#ifdef WITH_API

std::cout << "Supported API commands:" << std::endl;

for (auto p : registry->lookup<api::RequestFactory>()) {

if (!p->isHidden())

std::cout << " - " << std::left << std::setw(18) << p->getName()

<< p->getDescription() << std::endl;

}

std::cout << std::endl;

#endif // WITH_API

printCopyright();

}

void parse() {

// Parse optional command line arguments

int c;

while ((c = getopt(argc, argv, "hCVd:")) != -1) {

switch (c) {

case 'V':

printVersion();

exit(EXIT_SUCCESS);

case 'd':

Log::getInstance().setLevel(optarg);

break;

case 'C':

showCapabilities = true;

break;

case 'h':

case '?':

usage();

exit(c == '?' ? EXIT_FAILURE : EXIT_SUCCESS);

}

continue;

}

if (argc == optind + 1)

uri = argv[optind];

else if (argc != optind) {

usage();

exit(EXIT_FAILURE);

}

int main() { return showCapabilities ? capabilities() : daemon(); }

int capabilities() {

auto *json_caps = getCapabilities();

json_dumpf(json_caps, stdout, JSON_INDENT(4));

return 0;

}

int daemon() {

if (!uri.empty())

sn.parse(uri);

else

logger->warn("No configuration file specified. Starting unconfigured. "

"Use the API to configure this instance.");

sn.check();

sn.prepare();

sn.start();

sn.run();

sn.stop();

return 0;

}

};

} // namespace tools

} // namespace node

} // namespace villas

int main(int argc, char *argv[]) {

villas::node::tools::Node t(argc, argv);

return t.run();

}

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

villas-node.cpp

Latest commit

History

villas-node.cpp

File metadata and controls