2018-05-27 17:44:01 +00:00
|
|
|
#ifndef LLARP_HPP
|
|
|
|
#define LLARP_HPP
|
|
|
|
|
2019-01-13 16:30:07 +00:00
|
|
|
#include <util/types.hpp>
|
2019-04-08 12:01:52 +00:00
|
|
|
#include <ev/ev.hpp>
|
2018-12-12 02:52:51 +00:00
|
|
|
|
|
|
|
#include <iostream>
|
2018-12-11 00:53:11 +00:00
|
|
|
#include <memory>
|
2018-05-27 17:44:01 +00:00
|
|
|
#include <string>
|
|
|
|
#include <vector>
|
|
|
|
|
2019-01-11 00:12:43 +00:00
|
|
|
struct llarp_ev_loop;
|
|
|
|
struct llarp_nodedb;
|
|
|
|
struct llarp_nodedb_iter;
|
2019-01-13 16:30:07 +00:00
|
|
|
struct llarp_threadpool;
|
2018-12-10 16:26:46 +00:00
|
|
|
|
2018-05-27 17:44:01 +00:00
|
|
|
namespace llarp
|
|
|
|
{
|
2019-02-11 14:43:48 +00:00
|
|
|
struct Config;
|
2019-01-13 16:30:07 +00:00
|
|
|
struct Crypto;
|
2019-01-11 00:12:43 +00:00
|
|
|
class Logic;
|
2019-02-22 16:21:05 +00:00
|
|
|
struct AbstractRouter;
|
2019-01-11 00:12:43 +00:00
|
|
|
struct RouterContact;
|
|
|
|
|
2019-04-05 09:20:48 +00:00
|
|
|
namespace metrics
|
|
|
|
{
|
|
|
|
class DefaultManagerGuard;
|
|
|
|
class PublisherScheduler;
|
|
|
|
} // namespace metrics
|
|
|
|
|
|
|
|
namespace thread
|
|
|
|
{
|
|
|
|
class Scheduler;
|
|
|
|
}
|
|
|
|
|
2018-05-27 17:44:01 +00:00
|
|
|
struct Context
|
|
|
|
{
|
2019-04-05 09:20:48 +00:00
|
|
|
Context();
|
2018-05-27 17:44:01 +00:00
|
|
|
~Context();
|
|
|
|
|
2019-04-05 09:20:48 +00:00
|
|
|
// These come first, in this order.
|
|
|
|
// This ensures we get metric collection on shutdown
|
|
|
|
std::unique_ptr< thread::Scheduler > m_scheduler;
|
|
|
|
std::unique_ptr< metrics::DefaultManagerGuard > m_metricsManager;
|
|
|
|
std::unique_ptr< metrics::PublisherScheduler > m_metricsPublisher;
|
|
|
|
|
2019-04-07 17:55:14 +00:00
|
|
|
int num_nethreads = 1;
|
|
|
|
bool singleThreaded = false;
|
|
|
|
bool disableMetrics = false;
|
|
|
|
bool disableMetricLogs = false;
|
2019-04-05 09:20:48 +00:00
|
|
|
std::unique_ptr< Crypto > crypto;
|
|
|
|
std::unique_ptr< AbstractRouter > router;
|
2019-02-11 14:43:48 +00:00
|
|
|
std::unique_ptr< llarp_threadpool > worker;
|
2019-04-05 09:20:48 +00:00
|
|
|
std::unique_ptr< Logic > logic;
|
|
|
|
std::unique_ptr< Config > config;
|
2019-02-11 14:43:48 +00:00
|
|
|
std::unique_ptr< llarp_nodedb > nodedb;
|
2019-04-08 12:01:52 +00:00
|
|
|
llarp_ev_loop_ptr mainloop;
|
2018-09-17 12:02:09 +00:00
|
|
|
std::string nodedb_dir;
|
2018-05-27 17:44:01 +00:00
|
|
|
|
|
|
|
bool
|
|
|
|
LoadConfig(const std::string &fname);
|
|
|
|
|
|
|
|
void
|
|
|
|
Close();
|
|
|
|
|
2018-06-19 09:45:29 +00:00
|
|
|
int
|
|
|
|
LoadDatabase();
|
|
|
|
|
|
|
|
int
|
2019-01-11 00:12:43 +00:00
|
|
|
IterateDatabase(llarp_nodedb_iter &i);
|
2018-06-19 09:45:29 +00:00
|
|
|
|
|
|
|
bool
|
2018-09-24 13:10:36 +00:00
|
|
|
PutDatabase(struct llarp::RouterContact &rc);
|
2018-06-19 09:45:29 +00:00
|
|
|
|
2018-09-19 12:22:34 +00:00
|
|
|
llarp::RouterContact *
|
2018-06-21 11:11:55 +00:00
|
|
|
GetDatabase(const byte_t *pk);
|
|
|
|
|
2018-06-23 14:56:59 +00:00
|
|
|
int
|
|
|
|
Setup();
|
|
|
|
|
2018-05-27 17:44:01 +00:00
|
|
|
int
|
|
|
|
Run();
|
|
|
|
|
|
|
|
void
|
|
|
|
HandleSignal(int sig);
|
|
|
|
|
|
|
|
private:
|
2019-01-21 15:45:18 +00:00
|
|
|
void
|
|
|
|
SetPIDFile(const std::string &fname);
|
2019-01-18 13:24:33 +00:00
|
|
|
|
|
|
|
bool
|
|
|
|
WritePIDFile() const;
|
|
|
|
|
|
|
|
void
|
|
|
|
RemovePIDFile() const;
|
|
|
|
|
2018-12-24 16:09:05 +00:00
|
|
|
bool
|
|
|
|
Configure();
|
|
|
|
|
2018-05-27 17:44:01 +00:00
|
|
|
void
|
|
|
|
SigINT();
|
|
|
|
|
|
|
|
bool
|
|
|
|
ReloadConfig();
|
|
|
|
|
2019-02-11 14:43:48 +00:00
|
|
|
void
|
|
|
|
iter_config(const char *section, const char *key, const char *val);
|
2018-05-27 17:44:01 +00:00
|
|
|
|
|
|
|
void
|
|
|
|
progress();
|
|
|
|
|
2019-04-07 17:55:14 +00:00
|
|
|
void
|
|
|
|
setupMetrics();
|
|
|
|
|
2018-05-27 17:44:01 +00:00
|
|
|
std::string configfile;
|
2019-01-18 13:24:33 +00:00
|
|
|
std::string pidfile;
|
2018-05-27 17:44:01 +00:00
|
|
|
};
|
2018-07-09 03:34:29 +00:00
|
|
|
} // namespace llarp
|
2018-05-27 17:44:01 +00:00
|
|
|
|
|
|
|
#endif
|