WebSVN – HomeAutomation – Diff – /branches/atomV2/PcSoftware/AtomV2/src/Atom.cpp


//============================================================================
// Name        : Atom.cpp
// Author      : Mattias Runge
// Version     : 2.0
// Copyright   : GPL
//============================================================================
 
#include <iostream>
#include <istream>
#include <ostream>
#include <string>
#include <fstream>
#include <iterator>
 
#include <stdio.h>
 
#include "version.h"
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/foreach.hpp>
#include <boost/program_options.hpp>
#include "broker/Broker.h"
#include "message/Message.h"
#include "subscribers/monitor/Monitor.h"
#include "subscribers/cannet/CanNet.h"
#include "xml/Node.h"
#include "thread/Thread.h"
#include "utils/BitBuffer.h"
#include "net/UdpServer.h"
#include "xml/Node.h"
#include "protocol/Protocol.h"
#include "log/Logger.h"
 
namespace po = boost::program_options;
 
#define foreach         BOOST_FOREACH
#define reverse_foreach BOOST_REVERSE_FOREACH
using namespace std;
 
 
using namespace atom;
 
int main(int argc, char* argv[])
{
    log::Logger LOG;
    LOG.setName("Main");
 
    LOG.info("Atom (" + string(AutoVersion::FULLVERSION_STRING) + " " + string(AutoVersion::STATUS) + ")");
    LOG.info("Written by Mattias Runge 2009");
 
 
 
    Protocol::pointer protocol = Protocol::getInstance();
    protocol->load("../../Configuration/protocol.xml");
    cout << protocol->getRootNode().toString() << endl;
 
 
    broker::Broker::pointer broker = broker::Broker::getInstance();
 
    subscribers::Monitor::pointer monitorSubscriber(new subscribers::Monitor(broker));
    subscribers::CanNet::pointer canNetSubscriber(new subscribers::CanNet(broker, "192.168.1.250", 1100));
 
 
    sleep(10000000);
 
 
    return 0;
    //udpSubscriber->write(utils::BitBuffer(startPacket));
 
 
    cout << "ABC123" << endl;
 
    return 0;
    /*sleep(1);
 
        messagebroker::Message message("");
 
 
        message.data = "test1";
        broker.put(message);
 
        message.setOrigin(monitorSubscriber);
        message.data = "test2";
        broker.put(message);
        sleep(1);
        delete monitorSubscriber;
 
        message.data = "test3";
        broker.put(message);
        sleep(1);
        delete udpSubscriber;
 
 
        try
        {
            // Declare a group of options that will be
            // allowed only on command line
            po::options_description generic("Generic options");
            generic.add_options()   ("version,v", "print version string")
                                    ("help", "produce help message");
 
            // Declare a group of options that will be
            // allowed both on command line and in
            // config file
            po::options_description config("Configuration");
            config.add_options()("optimization", po::value<int>()->default_value(10), "optimization level")
                                ("include-path,I", po::value<vector<string> >()->composing(), "include path");
 
            // Hidden options, will be allowed both on command line and
            // in config file, but will not be shown to the user.
            po::options_description hidden("Hidden options");
            hidden.add_options()("input-file", po::value<vector<string> >(), "input file");
 
            po::options_description cmdline_options;
            cmdline_options.add(generic).add(config).add(hidden);
 
            po::options_description config_file_options;
            config_file_options.add(config).add(hidden);
 
            po::options_description visible("Allowed options");
            visible.add(generic).add(config);
 
            po::positional_options_description p;
            p.add("input-file", -1);
 
            po::variables_map vm;
            store(po::command_line_parser(argc, argv).options(cmdline_options).positional(p).run(), vm);
 
            ifstream ifs("multiple_sources.cfg");
            store(parse_config_file(ifs, config_file_options), vm);
            notify(vm);
 
            if (vm.count("help"))
            {
                cout << visible << "\n";
                return 0;
            }
 
            if (vm.count("version"))
            {
                cout << "Multiple sources example, version 1.0\n";
                return 0;
            }
 
            if (vm.count("include-path"))
            {
                //cout << "Include paths are: " << vm["include-path"].as<vector<string>>() << "\n";
            }
 
            if (vm.count("input-file"))
            {
                //cout << "Input files are: " << vm["input-file"].as<vector<string>>() << "\n";
            }
 
            //cout << "Optimization level is " << opt << "\n";
 
    */
    /*if (argc != 3)
    {
        std::cout << "Usage: async_client <server> <path>\n";
        std::cout << "Example:\n";
        std::cout << "  async_client www.boost.org /LICENSE_1_0.txt\n";
        return 1;
    }
 
    boost::asio::io_service io_service;
    client c(io_service, argv[1], argv[2]);
    io_service.run();*/
    /*
             std::string hello( "Hello, world!" );
 
            foreach( char ch, hello )
            {
                std::cout << ch;
            }
 
        }
        catch (std::exception& e)
        {
            std::cout << "Exception: " << e.what() << "\n";
        }
    */
    return 0;
}
 

Rev 1317	Rev 1318
1	//============================================================================	1	//============================================================================
2	// Name : Atom.cpp	2	// Name : Atom.cpp
3	// Author : Mattias Runge	3	// Author : Mattias Runge
4	// Version : 2.0	4	// Version : 2.0
5	// Copyright : GPL	5	// Copyright : GPL
6	//============================================================================	6	//============================================================================
7		7
8	#include <iostream>	8	#include <iostream>
9	#include <istream>	9	#include <istream>
10	#include <ostream>	10	#include <ostream>
11	#include <string>	11	#include <string>
12	#include <fstream>	12	#include <fstream>
13	#include <iterator>	13	#include <iterator>
14		14
15	#include <stdio.h>	15	#include <stdio.h>
16		16
17	#include "version.h"	17	#include "version.h"
18	#include <boost/asio.hpp>	18	#include <boost/asio.hpp>
19	#include <boost/bind.hpp>	19	#include <boost/bind.hpp>
20	#include <boost/foreach.hpp>	20	#include <boost/foreach.hpp>
21	#include <boost/program_options.hpp>	21	#include <boost/program_options.hpp>
22	#include "broker/Broker.h"	22	#include "broker/Broker.h"
23	#include "message/Message.h"	23	#include "message/Message.h"
24	#include "subscribers/monitor/Monitor.h"	24	#include "subscribers/monitor/Monitor.h"
25	#include "subscribers/cannet/CanNet.h"	25	#include "subscribers/cannet/CanNet.h"
26	#include "xml/Node.h"	26	#include "xml/Node.h"
27	#include "thread/Thread.h"	27	#include "thread/Thread.h"
28	#include "utils/BitBuffer.h"	28	#include "utils/BitBuffer.h"
29	#include "net/UdpServer.h"	29	#include "net/UdpServer.h"
30	#include "xml/Node.h"	30	#include "xml/Node.h"
31	#include "protocol/Protocol.h"	31	#include "protocol/Protocol.h"
32	#include "log/Logger.h"	32	#include "log/Logger.h"
33		33
34	namespace po = boost::program_options;	34	namespace po = boost::program_options;
35		35
36	#define foreach BOOST_FOREACH	36	#define foreach BOOST_FOREACH
37	#define reverse_foreach BOOST_REVERSE_FOREACH	37	#define reverse_foreach BOOST_REVERSE_FOREACH
38	using namespace std;	38	using namespace std;
39		39
40		40
41	using namespace atom;	41	using namespace atom;
42		42
43	int main(int argc, char* argv[])	43	int main(int argc, char* argv[])
44	{	44	{
45	log::Logger LOG;	45	log::Logger LOG;
46	LOG.setName("Main");	46	LOG.setName("Main");
47		47
48	LOG.info("Atom (" + string(AutoVersion::FULLVERSION_STRING) + " " + string(AutoVersion::STATUS) + ")");	48	LOG.info("Atom (" + string(AutoVersion::FULLVERSION_STRING) + " " + string(AutoVersion::STATUS) + ")");
49	LOG.info("Written by Mattias Runge 2009");	49	LOG.info("Written by Mattias Runge 2009");
-		50
50		51
51		52
52	Protocol::pointer protocol = Protocol::getInstance();	53	Protocol::pointer protocol = Protocol::getInstance();
53	protocol->load("../../Configuration/protocol.xml");	54	protocol->load("../../Configuration/protocol.xml");
54	cout << protocol->getRootNode().toString() << endl;	55	cout << protocol->getRootNode().toString() << endl;
55		56
56		57
57	broker::Broker::pointer broker = broker::Broker::getInstance();	58	broker::Broker::pointer broker = broker::Broker::getInstance();
58		59
59	subscribers::Monitor::pointer monitorSubscriber(new subscribers::Monitor(broker));	60	subscribers::Monitor::pointer monitorSubscriber(new subscribers::Monitor(broker));
60	subscribers::CanNet::pointer canNetSubscriber(new subscribers::CanNet(broker, "192.168.1.250", 1100));	61	subscribers::CanNet::pointer canNetSubscriber(new subscribers::CanNet(broker, "192.168.1.250", 1100));
61		62
62		63
63	sleep(10000000);	64	sleep(10000000);
64		65
65		66
66	return 0;	67	return 0;
67	//udpSubscriber->write(utils::BitBuffer(startPacket));	68	//udpSubscriber->write(utils::BitBuffer(startPacket));
68		69
69		70
70	cout << "ABC123" << endl;	71	cout << "ABC123" << endl;
71		72
72	return 0;	73	return 0;
73	/*sleep(1);	74	/*sleep(1);
74		75
75	messagebroker::Message message("");	76	messagebroker::Message message("");
76		77
77		78
78	message.data = "test1";	79	message.data = "test1";
79	broker.put(message);	80	broker.put(message);
80		81
81	message.setOrigin(monitorSubscriber);	82	message.setOrigin(monitorSubscriber);
82	message.data = "test2";	83	message.data = "test2";
83	broker.put(message);	84	broker.put(message);
84	sleep(1);	85	sleep(1);
85	delete monitorSubscriber;	86	delete monitorSubscriber;
86		87
87	message.data = "test3";	88	message.data = "test3";
88	broker.put(message);	89	broker.put(message);
89	sleep(1);	90	sleep(1);
90	delete udpSubscriber;	91	delete udpSubscriber;
91		92
92		93
93	try	94	try
94	{	95	{
95	// Declare a group of options that will be	96	// Declare a group of options that will be
96	// allowed only on command line	97	// allowed only on command line
97	po::options_description generic("Generic options");	98	po::options_description generic("Generic options");
98	generic.add_options() ("version,v", "print version string")	99	generic.add_options() ("version,v", "print version string")
99	("help", "produce help message");	100	("help", "produce help message");
100		101
101	// Declare a group of options that will be	102	// Declare a group of options that will be
102	// allowed both on command line and in	103	// allowed both on command line and in
103	// config file	104	// config file
104	po::options_description config("Configuration");	105	po::options_description config("Configuration");
105	config.add_options()("optimization", po::value<int>()->default_value(10), "optimization level")	106	config.add_options()("optimization", po::value<int>()->default_value(10), "optimization level")
106	("include-path,I", po::value<vector<string> >()->composing(), "include path");	107	("include-path,I", po::value<vector<string> >()->composing(), "include path");
107		108
108	// Hidden options, will be allowed both on command line and	109	// Hidden options, will be allowed both on command line and
109	// in config file, but will not be shown to the user.	110	// in config file, but will not be shown to the user.
110	po::options_description hidden("Hidden options");	111	po::options_description hidden("Hidden options");
111	hidden.add_options()("input-file", po::value<vector<string> >(), "input file");	112	hidden.add_options()("input-file", po::value<vector<string> >(), "input file");
112		113
113	po::options_description cmdline_options;	114	po::options_description cmdline_options;
114	cmdline_options.add(generic).add(config).add(hidden);	115	cmdline_options.add(generic).add(config).add(hidden);
115		116
116	po::options_description config_file_options;	117	po::options_description config_file_options;
117	config_file_options.add(config).add(hidden);	118	config_file_options.add(config).add(hidden);
118		119
119	po::options_description visible("Allowed options");	120	po::options_description visible("Allowed options");
120	visible.add(generic).add(config);	121	visible.add(generic).add(config);
121		122
122	po::positional_options_description p;	123	po::positional_options_description p;
123	p.add("input-file", -1);	124	p.add("input-file", -1);
124		125
125	po::variables_map vm;	126	po::variables_map vm;
126	store(po::command_line_parser(argc, argv).options(cmdline_options).positional(p).run(), vm);	127	store(po::command_line_parser(argc, argv).options(cmdline_options).positional(p).run(), vm);
127		128
128	ifstream ifs("multiple_sources.cfg");	129	ifstream ifs("multiple_sources.cfg");
129	store(parse_config_file(ifs, config_file_options), vm);	130	store(parse_config_file(ifs, config_file_options), vm);
130	notify(vm);	131	notify(vm);
131		132
132	if (vm.count("help"))	133	if (vm.count("help"))
133	{	134	{
134	cout << visible << "\n";	135	cout << visible << "\n";
135	return 0;	136	return 0;
136	}	137	}
137		138
138	if (vm.count("version"))	139	if (vm.count("version"))
139	{	140	{
140	cout << "Multiple sources example, version 1.0\n";	141	cout << "Multiple sources example, version 1.0\n";
141	return 0;	142	return 0;
142	}	143	}
143		144
144	if (vm.count("include-path"))	145	if (vm.count("include-path"))
145	{	146	{
146	//cout << "Include paths are: " << vm["include-path"].as<vector<string>>() << "\n";	147	//cout << "Include paths are: " << vm["include-path"].as<vector<string>>() << "\n";
147	}	148	}
148		149
149	if (vm.count("input-file"))	150	if (vm.count("input-file"))
150	{	151	{
151	//cout << "Input files are: " << vm["input-file"].as<vector<string>>() << "\n";	152	//cout << "Input files are: " << vm["input-file"].as<vector<string>>() << "\n";
152	}	153	}
153		154
154	//cout << "Optimization level is " << opt << "\n";	155	//cout << "Optimization level is " << opt << "\n";
155		156
156	*/	157	*/
157	/*if (argc != 3)	158	/*if (argc != 3)
158	{	159	{
159	std::cout << "Usage: async_client <server> <path>\n";	160	std::cout << "Usage: async_client <server> <path>\n";
160	std::cout << "Example:\n";	161	std::cout << "Example:\n";
161	std::cout << " async_client www.boost.org /LICENSE_1_0.txt\n";	162	std::cout << " async_client www.boost.org /LICENSE_1_0.txt\n";
162	return 1;	163	return 1;
163	}	164	}
164		165
165	boost::asio::io_service io_service;	166	boost::asio::io_service io_service;
166	client c(io_service, argv[1], argv[2]);	167	client c(io_service, argv[1], argv[2]);
167	io_service.run();*/	168	io_service.run();*/
168	/*	169	/*
169	std::string hello( "Hello, world!" );	170	std::string hello( "Hello, world!" );
170		171
171	foreach( char ch, hello )	172	foreach( char ch, hello )
172	{	173	{
173	std::cout << ch;	174	std::cout << ch;
174	}	175	}
175		176
176	}	177	}
177	catch (std::exception& e)	178	catch (std::exception& e)
178	{	179	{
179	std::cout << "Exception: " << e.what() << "\n";	180	std::cout << "Exception: " << e.what() << "\n";
180	}	181	}
181	*/	182	*/
182	return 0;	183	return 0;
183	}	184	}
184		185

Subversion Repositories HomeAutomation

(root)/branches/atomV2/PcSoftware/AtomV2/src/Atom.cpp @ 1318 – Rev 1317 → 1318