25#ifndef GOBY_MIDDLEWARE_APPLICATION_INTERFACE_H
26#define GOBY_MIDDLEWARE_APPLICATION_INTERFACE_H
34#include <boost/format.hpp>
52template <
typename App>
61template <
typename App,
62 typename Configurator = middleware::ProtobufConfigurator<typename App::ConfigType>>
63int run(
int argc,
char* argv[])
65 return run<App>(Configurator(argc, argv));
93 virtual void run() = 0;
107 void quit(
int return_value = 0)
110 return_value_ = return_value;
122 throw(
goby::Exception(
"No lat_origin and lon_origin defined for requested UTMGeodesy"));
128 std::string
app_name() {
return app3_base_configuration_->name(); }
134 template <
typename App>
135 friend int ::goby::run(
140 void configure_logger();
141 void configure_glog_file();
142 void check_rotate_glog_file();
146 static std::unique_ptr<Config> app_cfg_;
147 static std::unique_ptr<protobuf::AppConfig> app3_base_configuration_;
153 static std::unique_ptr<std::ofstream> fout_;
157 std::unique_ptr<goby::util::UTMGeodesy> geodesy_;
163template <
typename Config>
168template <
typename Config>
169std::unique_ptr<goby::middleware::protobuf::AppConfig>
177 if (app3_base_configuration_->has_geodesy())
179 app3_base_configuration_->geodesy().lon_origin_with_units()});
181 if (!app3_base_configuration_->IsInitialized())
184 glog.
is_debug2() &&
glog <<
"Application: constructed with PID: " << getpid() << std::endl;
185 glog.
is_debug1() &&
glog <<
"App name is " << app3_base_configuration_->name() << std::endl;
186 glog.
is_debug2() &&
glog <<
"Configuration is: " << app_cfg_->DebugString() << std::endl;
196 app3_base_configuration_->glog_config().tty_verbosity()),
199 if (app3_base_configuration_->glog_config().show_gui())
202 if (app3_base_configuration_->glog_config().has_file_log())
203 configure_glog_file();
205 if (app3_base_configuration_->glog_config().show_dccl_log())
212 if (app3_base_configuration_->glog_config().has_file_log() &&
213 app3_base_configuration_->glog_config().file_log().has_log_rotate_sec() &&
217 configure_glog_file();
223 const auto& file_log = app3_base_configuration_->glog_config().file_log();
224 std::string file_format_str;
226 std::string file_name_format = file_log.file_name();
228 if (!file_log.has_file_name() && file_log.omit().file_timestamp())
229 file_name_format =
"%2%.txt";
231 if (file_log.has_file_dir() && !file_log.file_dir().empty())
233 auto file_dir = file_log.file_dir();
234 if (file_dir.back() !=
'/')
236 file_format_str = file_dir + file_name_format;
240 file_format_str = file_name_format;
243 boost::format file_format(file_format_str);
245 if (!file_log.omit().file_timestamp())
247 if (file_format_str.find(
"%1") == std::string::npos)
249 glog <<
"file_name string must contain \"%1%\" which is expanded to the current "
250 "application start time (e.g. 20190201T184925), unless omit.file_timestamp "
251 "== true. Erroneous file_name is: "
252 << file_format_str << std::endl;
255 file_format.exceptions(boost::io::all_error_bits ^
256 (boost::io::too_many_args_bit | boost::io::too_few_args_bit));
258 std::string file_name =
262 fout_.reset(
new std::ofstream(file_name.c_str()));
264 if (!fout_->is_open())
265 glog.
is_die() &&
glog <<
"cannot write glog output to requested file: " << file_name
268 if (!file_log.omit().latest_symlink())
270 std::string file_symlink =
271 (file_format %
"latest" % app3_base_configuration_->name()).
str();
272 remove(file_symlink.c_str());
273 int result = symlink(realpath(file_name.c_str(), NULL), file_symlink.c_str());
276 glog <<
"Cannot create symlink to latest file. Continuing onwards anyway"
282 if (file_log.has_log_rotate_sec())
283 next_log_rotate_time_ =
287template <
typename Config>
297 sigset_t signal_mask;
298 sigemptyset(&signal_mask);
299 sigaddset(&signal_mask, SIGWINCH);
300 pthread_sigmask(SIG_BLOCK, &signal_mask, NULL);
302 this->pre_initialize();
304 this->post_initialize();
309 this->check_rotate_glog_file();
311 this->pre_finalize();
313 this->post_finalize();
314 return return_value_;
317template <
typename App>
320 int return_value = 0;
336 std::cout << cfgtor.
str() << std::endl;
341 App::app_cfg_.reset(
new typename App::ConfigType(cfgtor.
cfg()));
342 App::app3_base_configuration_.reset(
346 if (App::app3_base_configuration_->simulation().time().use_sim_time())
350 App::app3_base_configuration_->simulation().time().warp_factor();
351 if (App::app3_base_configuration_->simulation().time().has_reference_microtime())
353 std::chrono::system_clock::time_point(std::chrono::microseconds(
354 App::app3_base_configuration_->simulation().time().reference_microtime()));
359 return_value = app.__run();
361 catch (std::exception& e)
364 std::cerr <<
"Application:: uncaught exception: " << e.what() << std::endl;
simple exception class for goby applications
Base class for Goby applications. Generally you will want to use SingleThreadApplication or MultiThre...
const util::UTMGeodesy & geodesy()
Accesses the geodetic conversion tool if lat_origin and lon_origin were provided.
virtual void pre_finalize()
Called just before finalize.
virtual void post_initialize()
Called just after initialize.
virtual void initialize()
Perform any initialize tasks that couldn't be done in the constructor.
virtual void pre_initialize()
Called just before initialize.
virtual void run()=0
Runs continuously until quit() is called.
bool has_geodesy()
Returns if the geodesy tool is configured with a datum.
virtual void finalize()
Perform any final cleanup actions just before the destructor is called.
void quit(int return_value=0)
Requests a clean exit.
void configure_geodesy(goby::util::UTMGeodesy::LatLonPoint datum)
virtual void post_finalize()
Called just after finalize.
const Config & app_cfg()
Accesses configuration object passed at launch.
indicates a problem with the runtime command line or .cfg file configuration (or –help was given)
Defines the interface to a "configurator", a class that can read command line parameters (argc,...
virtual void validate() const
Override to validate the configuration.
virtual void handle_config_error(middleware::ConfigException &e) const
Override to customize how ConfigException errors are handled.
virtual const protobuf::AppConfig & app_configuration() const
Subset of the configuration used to configure the Application itself.
const Config & cfg() const
The configuration object produced from the command line parameters.
virtual std::string str() const =0
Override to output the configuration object as a string.
void remove_stream(std::ostream *os=nullptr)
void set_name(const std::string &s)
Set the name of the application that the logger is serving.
void add_stream(logger::Verbosity verbosity=logger::VERBOSE, std::ostream *os=nullptr)
Attach a stream object (e.g. std::cout, std::ofstream, ...) to the logger with desired verbosity.
std::string str(TimeType value=SystemClock::now< TimeType >())
Returns the provided time (or current time if omitted) as a human-readable string.
std::string file_str(TimeType value=SystemClock::now< TimeType >())
Returns the provided time (or current time if omitted) as an ISO string suitable for file names (no s...
The global namespace for the Goby project.
util::FlexOstream glog
Access the Goby logger through this object.
int run(const goby::middleware::ConfiguratorInterface< typename App::ConfigType > &cfgtor)
Run a Goby application using the provided Configurator.
static void setup_dlog()
Enable dlog output to glog using same verbosity settings as glog.
static bool using_sim_time
Enables simulation time if true (if false, none of the remaining parameters are used)
static std::chrono::system_clock::time_point reference_time
Reference time when calculating SystemClock::now(). If this is unset, the default is 1 January of the...
static int warp_factor
Warp factor to speed up (or slow time) the time values returned by SteadyClock::now() and SystemClock...
std::chrono::time_point< SteadyClock > time_point
static time_point now() noexcept
Returns the current steady time unless SimulatorSettings::using_sim_time == true in which case a simu...