summaryrefslogtreecommitdiff
path: root/yhttpd/src/wrap.cpp
blob: 251a575ff5320a8dd295a5095a8d057f035f346c (plain)
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
116
117
118
119
120
121
#ifndef WRAP_CPP
#define WRAP_CPP

#include "wrap.h"

using namespace std;


conf* wrap::CONF = NULL;
html* wrap::HTML = NULL;
#ifdef LOGGING
logd* wrap::LOGD = NULL;
#endif
#ifdef NCURSES
ncur* wrap::NCUR = NULL;
#endif
sock* wrap::SOCK = NULL;
stats* wrap::STAT = NULL;
timr* wrap::TIMR = NULL;
pool* wrap::POOL = NULL;
dynamic_wrap* wrap::WRAP = NULL;

void
wrap::system_message( string s_message )
{
#ifdef NCURSES
  if(NCUR)
  {
    NCUR->print( s_message );
  }

  else
  {
    cout << s_message << endl;
  }
#endif

#ifdef SERVMSG
  cout << s_message << endl;
#endif

#ifdef LOGGING

  LOGD->log_simple_line( s_message + "\n" );
#endif
}

void
wrap::init_wrapper(map<string,string>* p_main_loop_params)
{
  // Init the dynamic wrapper (is needed to pass all wrapped objects through a single pointer).
  WRAP = new dynamic_wrap;

  // Init the config manager.
  WRAP->CONF = CONF = new conf( CONFILE, p_main_loop_params );
  delete p_main_loop_params,

  // Init the statistic manager.
  WRAP->STAT = STAT = new stats;

  // Init the html-template manager.
  WRAP->HTML = HTML = new html;

#ifdef LOGGING
  // Init the system message logd
  WRAP->LOGD = LOGD = new logd( CONF->get_elem("httpd.logging.systemfile"),
                                CONF->get_elem("httpd.logging.systemlines") );
#endif

  // Init the socket manager.
  int i_port = tool::string2int( wrap::CONF->get_elem( "httpd.serverport" ) );

#ifndef OPENSSL

  WRAP->SOCK = SOCK = new sock;
#else

  WRAP->SOCK = SOCK = new sslsock;
#endif

  // create the server socket and set it up to accept connections.
  if(SOCK->_make_server_socket ( i_port ) <= 0)
  {
    system_message(SOCKER1);
    exit(-1);
  }

#ifdef NCURSES

  WRAP->NCUR = NCUR = new ncur; 	// init the ncurses admin interface.
  NCUR->run();				// run the thread

  // Wait until ncurses interface has been initialized.
  do
  {
    usleep(1000);
  }
  while ( ! NCUR->is_ready() );

  HTML->print_cached(0);
#else
#ifdef CLI

  cli* p_cli = new cli;
  p_cli->run();
#endif
#endif

  // Init the thread pool
  WRAP->POOL = POOL = new pool;


  // Init the system timer.
  WRAP->TIMR = TIMR = new timr;


  // Run threads
  TIMR->run();
}

#endif