complement-svn

[complement-svn] SF.net SVN: complement: [1746] trunk/complement/explore/lib/janus/samples/ point1/point1.cc

[<com...@us...>]

Revision: 1746
          http://complement.svn.sourceforge.net/complement/?rev=1746&view=rev
Author:   complement
Date:     2007-09-26 03:58:43 -0700 (Wed, 26 Sep 2007)

Log Message:
-----------
use cin for input; send message to group

Modified Paths:
--------------
    trunk/complement/explore/lib/janus/samples/point1/point1.cc

Modified: trunk/complement/explore/lib/janus/samples/point1/point1.cc
===================================================================
--- trunk/complement/explore/lib/janus/samples/point1/point1.cc	2007-09-25 14:28:38 UTC (rev 1745)
+++ trunk/complement/explore/lib/janus/samples/point1/point1.cc	2007-09-26 10:58:43 UTC (rev 1746)
@@ -7,10 +7,12 @@
 #include <mt/xmt.h>
 
 #include <iostream>
+#include <string>
 
 using namespace janus;
 using namespace std;
 using namespace xmt;
+using namespace stem;
 
 #define VS_LINE 0x1300
 
@@ -63,7 +65,7 @@
 
 void YaSample::vs_line( const stem::Event& ev )
 {
-  cerr << "Line here" << endl;
+  cerr << "Line here: '" << ev.value() << "'" << endl;
 }
 
 DEFINE_RESPONSE_TABLE( YaSample )
@@ -77,11 +79,26 @@
 
   YaSample sample;
 
-  condition cnd;
+  sample.JoinGroup( janus::vs_base::first_user_group );
 
-  cnd.set( false );
+  Event ev( VS_LINE );
+  ev.dest( janus::vs_base::first_user_group );
 
-  cnd.wait();  
+  string line;
 
+  while ( cin.good() ) {
+    cin >> line;
+    if ( !cin.fail() ) {
+      ev.value() = line;
+      sample.JaSend( ev );
+    }
+  }
+
+  // condition cnd;
+
+  // cnd.set( false );
+
+  // cnd.wait();  
+
   return 0;
 }


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.

[complement-svn] SF.net SVN: complement: [1749] trunk/complement/explore/lib/janus/samples/ point1/point1.cc

[<com...@us...>]

Revision: 1749
          http://complement.svn.sourceforge.net/complement/?rev=1749&view=rev
Author:   complement
Date:     2007-09-27 06:47:07 -0700 (Thu, 27 Sep 2007)

Log Message:
-----------
add trace and debug printing

Modified Paths:
--------------
    trunk/complement/explore/lib/janus/samples/point1/point1.cc

Modified: trunk/complement/explore/lib/janus/samples/point1/point1.cc
===================================================================
--- trunk/complement/explore/lib/janus/samples/point1/point1.cc	2007-09-27 13:42:40 UTC (rev 1748)
+++ trunk/complement/explore/lib/janus/samples/point1/point1.cc	2007-09-27 13:47:07 UTC (rev 1749)
@@ -4,6 +4,8 @@
 #include <janus/janus.h>
 #include <janus/vshostmgr.h>
 
+#include <stem/EvManager.h>
+
 #include <mt/xmt.h>
 
 #include <iostream>
@@ -56,11 +58,13 @@
 void YaSample::VSNewMember( const stem::Event_base<VSsync_rq>& ev )
 {
   // VTNewMember_data( ev, "" );
+  cerr << "new member" << endl;
   VTHandler::VSNewMember( ev );
 }
 
 void YaSample::VSOutMember( const stem::Event_base<VSsync_rq>& )
 {
+  cerr << "member out" << endl;
 }
 
 void YaSample::vs_line( const stem::Event& ev )
@@ -79,6 +83,13 @@
 
   YaSample sample;
 
+  sample.manager()->settrf( stem::EvManager::tracenet | stem::EvManager::tracedispatch | stem::EvManager::tracefault );
+  sample.manager()->settrs( &std::cerr );
+
+  sample.vtdispatcher()->settrf( janus::Janus::tracenet | janus::Janus::tracedispatch | janus::Janus::tracefault | janus::Janus::tracedelayed | janus::Janus::tracegroup );
+  sample.vtdispatcher()->settrs( &std::cerr );
+
+
   sample.JoinGroup( janus::vs_base::first_user_group );
 
   Event ev( VS_LINE );


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.

[complement-svn] SF.net SVN: complement: [1759] trunk/complement/explore/lib/janus/samples/ point1/point1.cc

[<com...@us...>]

Revision: 1759
          http://complement.svn.sourceforge.net/complement/?rev=1759&view=rev
Author:   complement
Date:     2007-10-08 04:06:51 -0700 (Mon, 08 Oct 2007)

Log Message:
-----------
debug

Modified Paths:
--------------
    trunk/complement/explore/lib/janus/samples/point1/point1.cc

Modified: trunk/complement/explore/lib/janus/samples/point1/point1.cc
===================================================================
--- trunk/complement/explore/lib/janus/samples/point1/point1.cc	2007-10-05 17:28:42 UTC (rev 1758)
+++ trunk/complement/explore/lib/janus/samples/point1/point1.cc	2007-10-08 11:06:51 UTC (rev 1759)
@@ -30,9 +30,11 @@
   private:
     void vs_line( const stem::Event& );
 
-    void VSNewMember( const stem::Event_base<VSsync_rq>& );
-    void VSOutMember( const stem::Event_base<VSsync_rq>& );
+    virtual void VSNewMember( const stem::Event_base<VSsync_rq>& );
+    virtual void VSOutMember( const stem::Event_base<VSsync_rq>& );
+    virtual void VSsync_time( const stem::Event_base<VSsync>& );
 
+
     DECLARE_RESPONSE_TABLE( YaSample, janus::VTHandler );
 };
 
@@ -67,6 +69,12 @@
   cerr << "member out" << endl;
 }
 
+void YaSample::VSsync_time( const stem::Event_base<VSsync>& ev )
+{
+  cout << "VSsync_time" << endl;
+  VTHandler::VSsync_time( ev );
+}
+
 void YaSample::vs_line( const stem::Event& ev )
 {
   cerr << "Line here: '" << ev.value() << "'" << endl;


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.

[complement-svn] SF.net SVN: complement: [1765] trunk/complement/explore/lib/janus/samples/ point1/point1.cc

[<com...@us...>]

Revision: 1765
          http://complement.svn.sourceforge.net/complement/?rev=1765&view=rev
Author:   complement
Date:     2007-10-09 06:14:54 -0700 (Tue, 09 Oct 2007)

Log Message:
-----------
removed debug print; use getline, to take line instead of word

Modified Paths:
--------------
    trunk/complement/explore/lib/janus/samples/point1/point1.cc

Modified: trunk/complement/explore/lib/janus/samples/point1/point1.cc
===================================================================
--- trunk/complement/explore/lib/janus/samples/point1/point1.cc	2007-10-09 13:10:09 UTC (rev 1764)
+++ trunk/complement/explore/lib/janus/samples/point1/point1.cc	2007-10-09 13:14:54 UTC (rev 1765)
@@ -91,11 +91,11 @@
 
   YaSample sample;
 
-  sample.manager()->settrf( stem::EvManager::tracenet | stem::EvManager::tracedispatch | stem::EvManager::tracefault );
-  sample.manager()->settrs( &std::cerr );
+  // sample.manager()->settrf( stem::EvManager::tracenet | stem::EvManager::tracedispatch | stem::EvManager::tracefault );
+  // sample.manager()->settrs( &std::cerr );
 
-  sample.vtdispatcher()->settrf( janus::Janus::tracenet | janus::Janus::tracedispatch | janus::Janus::tracefault | janus::Janus::tracedelayed | janus::Janus::tracegroup );
-  sample.vtdispatcher()->settrs( &std::cerr );
+  // sample.vtdispatcher()->settrf( janus::Janus::tracenet | janus::Janus::tracedispatch | janus::Janus::tracefault | janus::Janus::tracedelayed | janus::Janus::tracegroup );
+  // sample.vtdispatcher()->settrs( &std::cerr );
 
 
   sample.JoinGroup( janus::vs_base::first_user_group );
@@ -106,7 +106,7 @@
   string line;
 
   while ( cin.good() ) {
-    cin >> line;
+    getline( cin, line );
     if ( !cin.fail() ) {
       cerr << "local: " << line << endl;
       ev.value() = line;


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.