1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
/*
* Copyright (C) 2015 Tommi Maekitalo
*
*/
#ifndef TNTNETIMPL_H
#define TNTNETIMPL_H
#include <tnt/job.h>
#include <tnt/poller.h>
#include <tnt/dispatcher.h>
#include <tnt/maptarget.h>
#include <tnt/scopemanager.h>
#include <cxxtools/condition.h>
#include <cxxtools/mutex.h>
#include <cxxtools/refcounted.h>
#include <set>
#include <fstream>
namespace tnt
{
class Listener;
struct TntConfig;
class TntnetImpl : public cxxtools::RefCounted
{
friend class Worker;
typedef std::set<Listener*> listeners_type;
unsigned _minthreads;
unsigned _maxthreads;
Jobqueue _queue;
static bool _stop;
listeners_type _listeners;
static listeners_type _allListeners;
cxxtools::AttachedThread _pollerthread;
Poller _poller;
Dispatcher _dispatcher;
ScopeManager _scopemanager;
std::string _appname;
std::ofstream _accessLog;
cxxtools::Mutex _accessLogMutex;
void timerTask();
static cxxtools::Condition _timerStopCondition;
static cxxtools::Mutex _timeStopMutex;
// non copyable and assignable
TntnetImpl(const TntnetImpl&);
TntnetImpl& operator= (const TntnetImpl&);
public:
TntnetImpl();
void init(Tntnet& app, const TntConfig& config);
void listen(Tntnet& app, const std::string& ipaddr, unsigned short int port);
void sslListen(Tntnet& app,
const std::string& ipaddr, unsigned short int port,
const std::string& certificateFile, const std::string& keyFile,
int sslVerifyLevel, const std::string& sslCa);
void run();
static void shutdown();
static bool shouldStop() { return _stop; }
Jobqueue& getQueue() { return _queue; }
Poller& getPoller() { return _poller; }
const Dispatcher& getDispatcher() const { return _dispatcher; }
ScopeManager& getScopemanager() { return _scopemanager; }
unsigned getMinThreads() const { return _minthreads; }
void setMinThreads(unsigned n);
unsigned getMaxThreads() const { return _maxthreads; }
void setMaxThreads(unsigned n) { _maxthreads = n; }
Mapping& mapUrl(const std::string& url, const std::string& ci)
{ return _dispatcher.addUrlMapEntry(std::string(), url, Maptarget(ci)); }
Mapping& mapUrl(const std::string& url, const Compident& ci)
{ return _dispatcher.addUrlMapEntry(std::string(), url, Maptarget(ci)); }
void mapUrl(const std::string& url, const std::string& pathinfo, const std::string& ci)
{ _dispatcher.addUrlMapEntry(std::string(), url, Maptarget(ci)).setPathInfo(pathinfo); }
Mapping& mapUrl(const std::string& url, const Maptarget& ci)
{ return _dispatcher.addUrlMapEntry(std::string(), url, ci); }
Mapping& vMapUrl(const std::string& vhost, const std::string& url, const Maptarget& ci)
{ return _dispatcher.addUrlMapEntry(vhost, url, ci); }
void setAppName(const std::string& appname)
{ _appname = appname; }
const std::string& getAppName() const
{ return _appname; }
void setAccessLog(const std::string& logfile_path)
{ _accessLog.open(logfile_path.c_str(), std::ios::out | std::ios::app); }
};
}
#endif // TNTNETIMPL_H
|
