Subversion Repositories HomeAutomation

Rev

Rev 1914 | Rev 1940 | Go to most recent revision | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed

Rev 1914 Rev 1939
Line 37... Line 37...
37 
#include "can/Network.h"
 37 
#include "can/Network.h"
38 
#include "can/Monitor.h"
 38 
#include "can/Monitor.h"
39 
#include "can/CanDaemon.h"
 39 
#include "can/CanDaemon.h"
40 
#include "vm/Manager.h"
 40 
#include "vm/Manager.h"
41 
#include "storage/Manager.h"
 41 
#include "storage/Manager.h"
- 
 
 42 
#include "mbb/Manager.h"
42 
 
 43 
 
43 
#include "vm/plugin/System.h"
 44 
#include "vm/plugin/System.h"
44 
#include "vm/plugin/Timer.h"
 45 
#include "vm/plugin/Timer.h"
45 
#include "vm/plugin/Module.h"
 46 
#include "vm/plugin/Module.h"
46 
#include "vm/plugin/Node.h"
 47 
#include "vm/plugin/Node.h"
Line 64... Line 65...
64 
 
 65 
 
65 
int main(int argc, char **argv)
 66 
int main (int argc, char **argv)
66 
{
 67 
{
67 
    LOG.Info("\033[29;1mAtom Daemon, version " + std::string(VERSION) + " starting...\033[0m");
 68 
  LOG.Info ("\033[29;1mAtom Daemon, version " + std::string (VERSION) + " starting...\033[0m");
68 
    LOG.Info("\033[29;1mReleased under " + std::string(LICENSE) + ".\033[0m");
 69 
  LOG.Info ("\033[29;1mReleased under " + std::string (LICENSE) + ".\033[0m");
69 
    LOG.Info("Written by Mattias Runge 2010.");
 70 
  LOG.Info ("Written by Mattias Runge 2010-2012.");
70 
   
 71 
 
71 
    signal(SIGTERM, Handler);
 72 
  signal (SIGTERM, Handler);
72 
    signal(SIGINT, Handler);
 73 
  signal (SIGINT, Handler);
73 
    signal(SIGQUIT, Handler);
 74 
  signal (SIGQUIT, Handler);
74 
    signal(SIGABRT, Handler);
 75 
  signal (SIGABRT, Handler);
Line 105... Line 106...
105 
       
 106 
 
106 
        LOG.Info("Deamon mode entered successfully!");
 107 
    LOG.Info ("Deamon mode entered successfully!");
107 
    }
 108 
  }
108 
 
 109 
 
109 
    storage::Manager::Create();
 110 
  storage::Manager::Create();
- 
 
 111 
 
110 
    timer::Manager::Create();
 112 
  timer::Manager::Create();
111 
    broker::Manager::Create();
 113 
  broker::Manager::Create();
112 
    net::Manager::Create();
 114 
  net::Manager::Create();
113 
    can::Protocol::Create();
 115 
  can::Protocol::Create();
114 
    control::Manager::Create();
 116 
  control::Manager::Create();
115 
    vm::Manager::Create();
 117 
  vm::Manager::Create();
- 
 
 118 
 
- 
 
 119 
  if (config::Manager::Instance()->Exist ("MbbPort"))
- 
 
 120 
  {
- 
 
 121 
    mbb::Manager::Create (config::Manager::Instance()->GetAsInt ("MbbPort"));
- 
 
 122 
  }
116 
   
 123 
 
117 
    storage::Manager::Instance()->SetRootPath(config::Manager::Instance()->GetAsString("StoragePath"));
 124 
  storage::Manager::Instance()->SetRootPath (config::Manager::Instance()->GetAsString ("StoragePath"));
118 
   
 125 
 
119 
    can::Protocol::Instance()->Load(config::Manager::Instance()->GetAsString("ProtocolFile"));
 126 
  can::Protocol::Instance()->Load (config::Manager::Instance()->GetAsString ("ProtocolFile"));
120 
   
 127 
 
121 
    if (config::Manager::Instance()->Exist("MonitorPort"))
 128 
  if (config::Manager::Instance()->Exist ("MonitorPort"))
122 
    {
 129 
  {
123 
        subscribers.push_back(can::Monitor::Pointer(new can::Monitor(config::Manager::Instance()->GetAsInt("MonitorPort"))));  
 130 
    subscribers.push_back (can::Monitor::Pointer (new can::Monitor (config::Manager::Instance()->GetAsInt ("MonitorPort"))));
124 
    }
 131 
  }
125 
 
 132 
 
126 
    if (config::Manager::Instance()->Exist("DaemonPort"))
 133 
  if (config::Manager::Instance()->Exist ("DaemonPort"))
127 
    {
 134 
  {
128 
        subscribers.push_back(can::CanDaemon::Pointer(new can::CanDaemon(config::Manager::Instance()->GetAsInt("DaemonPort"))));  
 135 
    subscribers.push_back (can::CanDaemon::Pointer (new can::CanDaemon (config::Manager::Instance()->GetAsInt ("DaemonPort"))));
129 
    }
 136 
  }
Line 150... Line 157...
150 
       
 157 
 
151 
        for (uint n = 0; n < cannetworks.size(); n++)
 158 
    for (uint n = 0; n < cannetworks.size(); n++)
152 
        {
 159 
    {
153 
            subscribers.push_back(can::Network::Pointer(new can::Network(cannetworks[n])));            
 160 
      subscribers.push_back (can::Network::Pointer (new can::Network (cannetworks[n])));
154 
        }
 161 
    }
155 
    }
 162 
  }
156 
   
 163 
 
157 
    boost::mutex::scoped_lock guard(guard_mutex);
 164 
  boost::mutex::scoped_lock guard (guard_mutex);
- 
 
 165 
 
158 
    on_message_condition.wait(guard);
 166 
  on_message_condition.wait (guard);
159 
   
 167 
 
160 
    LOG.Info("Cleaning up...");
 168 
  LOG.Info ("Cleaning up...");
161 
   
 169 
 
162 
    CleanUp();
 170 
  CleanUp();
163 
   
 171 
 
164 
    LOG.Info("Thank you for using Atom. Goodbye!");
 172 
  LOG.Info ("Thank you for using Atom. Goodbye!");
165 
   
 173 
 
166 
    return EXIT_SUCCESS;
 174 
  return EXIT_SUCCESS;
167 
}
 175 
}
168 
 
 176 
 
169 
void CleanUp()
 177 
void CleanUp()
170 
{
 178 
{
- 
 
 179 
  net::Manager::Instance()->Stop();
- 
 
 180 
 
171 
    subscribers.clear();
 181 
  subscribers.clear();
172 
    config::Manager::Delete();
 182 
  config::Manager::Delete();
173 
    timer::Manager::Delete();
 183 
  timer::Manager::Delete();
174 
    control::Manager::Delete();
 184 
  control::Manager::Delete();
175 
    vm::Manager::Delete();
 185 
  mbb::Manager::Delete();
176 
    can::Protocol::Delete();
 186 
  can::Protocol::Delete();
177 
    broker::Manager::Delete();
 187 
  broker::Manager::Delete();
- 
 
 188 
  vm::Manager::Delete();
178 
    net::Manager::Delete();
 189 
  net::Manager::Delete();
179 
    storage::Manager::Delete();
 190 
  storage::Manager::Delete();
180 
}
 191 
}
181 
 
 192 
 
182 
void Handler(int status)
 193 
void Handler (int status)
183 
{
 194 
{
184 
    std::string signal_name = "Unknown";
 195 
  std::string signal_name = "Unknown";
185 
   
 196 
 
186 
    switch (status)
 197 
  switch (status)
187 
    {
 198 
  {
188 
        case SIGTERM:
 199 
    case SIGTERM:
189 
        {
 200 
    {
190 
            signal_name = "Terminate";
 201 
      signal_name = "Terminate";
191 
            break;
 202 
      break;
192 
        }  
 203 
    }
- 
 
 204 
 
193 
        case SIGINT:
 205 
    case SIGINT:
194 
        {
 206 
    {
195 
            signal_name = "Interupt";
 207 
      signal_name = "Interupt";
196 
            break;
 208 
      break;
197 
        }  
 209 
    }
- 
 
 210 
 
198 
        case SIGQUIT:
 211 
    case SIGQUIT:
199 
        {
 212 
    {
200 
            signal_name = "Quit";
 213 
      signal_name = "Quit";
201 
            break;
 214 
      break;
202 
        }  
 215 
    }
- 
 
 216 
 
203 
        case SIGABRT:
 217 
    case SIGABRT:
204 
        {
 218 
    {
205 
            signal_name = "Abort";
 219 
      signal_name = "Abort";
206 
            break;
 220 
      break;
207 
        }  
 221 
    }
- 
 
 222 
 
208 
        case SIGIO:
 223 
    case SIGIO:
209 
        {
 224 
    {
210 
            signal_name = "I/O";
 225 
      signal_name = "I/O";
211 
            break;
 226 
      break;
212 
        }  
 227 
    }
- 
 
 228 
 
213 
        case SIGPIPE:
 229 
    case SIGPIPE:
214 
        {
 230 
    {
215 
            signal_name = "Pipe";
 231 
      signal_name = "Pipe";
216 
            break;
 232 
      break;
217 
        }
 233 
    }
Line 222... Line 238...
222 
    if (status != SIGPIPE)
 238 
  if (status != SIGPIPE)
223 
    {
 239 
  {
224 
        on_message_condition.notify_all();
 240 
    on_message_condition.notify_all();
225 
    }
 241 
  }
226 
}
 242 
}
227 
 
 -