Now there is a simplest form of IPC using zeroc ice. More stuff is coming.
diff --git a/daemon/daemon.cc b/daemon/daemon.cc
index ba1fecc..fad4017 100644
--- a/daemon/daemon.cc
+++ b/daemon/daemon.cc
@@ -21,60 +21,97 @@
#include "db-helper.h"
#include <iostream>
+#include <Ice/Service.h>
+#include <Ice/Identity.h>
+
+#include "notify-i.h"
using namespace std;
using namespace boost;
+using namespace ChronoshareClient;
typedef boost::error_info<struct tag_errmsg, std::string> errmsg_info_str;
+class MyService : public Ice::Service
+{
+protected:
+ virtual bool start (int, char*[], int&)
+ {
+ _adapter = communicator ()->createObjectAdapterWithEndpoints ("ChronoShare", "default -p 55436");
+
+ Ice::Identity identity;
+ identity.name="NotifyDaemon";
+ NotifyPtr servant=new NotifyI;
+
+ _adapter->add (servant, identity);
+
+ _adapter->activate();
+ // status = EXIT_SUCCESS;
+ return true;
+ }
+
+private:
+ Ice::ObjectAdapterPtr _adapter;
+};
int
main (int argc, char **argv)
{
+ int status = 0;
+
try
{
DbHelper db ("./");
- HashPtr hash = db.RememberStateInStateLog ();
- // should be empty
- cout << "Hash: [" << *hash << "]" << endl;
+ MyService svc;
+ status = svc.main (argc, argv);
- //
- db.UpdateDeviceSeqno ("Alex", 1);
- hash = db.RememberStateInStateLog ();
- cout << "Hash: [" << *hash << "]" << endl;
+ // HashPtr hash = db.RememberStateInStateLog ();
+ // // should be empty
+ // cout << "Hash: [" << *hash << "]" << endl;
- db.UpdateDeviceSeqno ("Alex", 2);
- hash = db.RememberStateInStateLog ();
- cout << "Hash: [" << *hash << "]" << endl;
+ // //
+ // db.UpdateDeviceSeqno ("Alex", 1);
+ // hash = db.RememberStateInStateLog ();
+ // cout << "Hash: [" << *hash << "]" << endl;
- db.UpdateDeviceSeqno ("Alex", 2);
- hash = db.RememberStateInStateLog ();
- cout << "Hash: [" << *hash << "]" << endl;
+ // db.UpdateDeviceSeqno ("Alex", 2);
+ // hash = db.RememberStateInStateLog ();
+ // cout << "Hash: [" << *hash << "]" << endl;
- db.UpdateDeviceSeqno ("Alex", 1);
- hash = db.RememberStateInStateLog ();
- cout << "Hash: [" << *hash << "]" << endl;
+ // db.UpdateDeviceSeqno ("Alex", 2);
+ // hash = db.RememberStateInStateLog ();
+ // cout << "Hash: [" << *hash << "]" << endl;
- db.FindStateDifferences ("00", "ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52");
- db.FindStateDifferences ("ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52", "00");
- db.FindStateDifferences ("869c38c6dffe8911ced320aecc6d9244904d13d3e8cd21081311f2129b4557ce",
- "ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52");
- db.FindStateDifferences ("ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52",
- "869c38c6dffe8911ced320aecc6d9244904d13d3e8cd21081311f2129b4557ce");
+ // db.UpdateDeviceSeqno ("Alex", 1);
+ // hash = db.RememberStateInStateLog ();
+ // cout << "Hash: [" << *hash << "]" << endl;
- db.UpdateDeviceSeqno ("Bob", 1);
- hash = db.RememberStateInStateLog ();
- cout << "Hash: [" << *hash << "]" << endl;
+ // db.FindStateDifferences ("00", "ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52");
+ // db.FindStateDifferences ("ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52", "00");
+ // db.FindStateDifferences ("869c38c6dffe8911ced320aecc6d9244904d13d3e8cd21081311f2129b4557ce",
+ // "ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52");
+ // db.FindStateDifferences ("ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52",
+ // "869c38c6dffe8911ced320aecc6d9244904d13d3e8cd21081311f2129b4557ce");
- db.FindStateDifferences ("00", "48f4d95b503b9a79c2d5939fa67722b13fc01db861fc501d09efd0a38dbafab8");
- db.FindStateDifferences ("ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52",
- "48f4d95b503b9a79c2d5939fa67722b13fc01db861fc501d09efd0a38dbafab8");
+ // db.UpdateDeviceSeqno ("Bob", 1);
+ // hash = db.RememberStateInStateLog ();
+ // cout << "Hash: [" << *hash << "]" << endl;
+
+ // db.FindStateDifferences ("00", "48f4d95b503b9a79c2d5939fa67722b13fc01db861fc501d09efd0a38dbafab8");
+ // db.FindStateDifferences ("ec0a9941fa726e1fb8f34ecdbd8e3faa75dc9dba22e6a2ea1d8482aae5fdfb52",
+ // "48f4d95b503b9a79c2d5939fa67722b13fc01db861fc501d09efd0a38dbafab8");
+ }
+ catch (const Ice::Exception& e)
+ {
+ cerr << e << endl;
+ status = 1;
}
catch (const boost::exception &e)
{
cout << "ERRORR: " << *get_error_info<errmsg_info_str> (e) << endl;
+ status = 1;
}
- return 0;
+ return status;
}