[complement-svn] SF.net SVN: complement: [1871] trunk/complement/explore/app/SMTP-tools/ smtp_server_ut/my_test.cc

[<oke...@us...>]

Revision: 1871
          http://complement.svn.sourceforge.net/complement/?rev=1871&view=rev
Author:   okechina
Date:     2008-05-05 07:11:27 -0700 (Mon, 05 May 2008)

Log Message:
-----------
Creating client-server dialog using streams for input/output

Modified Paths:
--------------
    trunk/complement/explore/app/SMTP-tools/smtp_server_ut/my_test.cc

Modified: trunk/complement/explore/app/SMTP-tools/smtp_server_ut/my_test.cc
===================================================================
--- trunk/complement/explore/app/SMTP-tools/smtp_server_ut/my_test.cc	2008-05-03 05:38:59 UTC (rev 1870)
+++ trunk/complement/explore/app/SMTP-tools/smtp_server_ut/my_test.cc	2008-05-05 14:11:27 UTC (rev 1871)
@@ -101,15 +101,39 @@
   ifstream in( fd2[0] );
   ofstream out( fd1[1] );
 #elif defined( __GNUC__ )
-  __gnu_cxx::stdio_filebuf _in_buf( fd2[0], std::ios_base::in );
+  __gnu_cxx::stdio_filebuf<char> _in_buf( fd2[0], std::ios_base::in );
   basic_istream<char> in( &_in_buf );
 
-  __gnu_cxx::stdio_filebuf _out_buf( fd1[1], std::ios_base::out );
-  basic_istream<char> in( &_out_buf );
+  __gnu_cxx::stdio_filebuf<char> _out_buf( fd1[1], std::ios_base::out );
+  basic_ostream<char> out( &_out_buf );
 #endif
 
+
+  string param, message, stout;
   while ( st != disconnect ) {
     if ( st != letter ) {
+      string str;
+      in >> str;
+      getline(in, param);
+      com = setCom(str);
+      change(st, com, param, stout);
+      write( fd1[1], stout.data(), stout.length() );
+//      out << stout;
+    } else {
+      getline( in, param );
+      if ( param != "." ) {
+        message += param + "\n";
+      } else {
+        st = hello;
+//        out << message;
+        message = "";
+      }
+    }
+  }
+
+
+/*  while ( st != disconnect ) {
+    if ( st != letter ) {
       bool full = false;
       stringstream st_stream;
       while (!full) {
@@ -127,14 +151,12 @@
         }
       };
       if (full) { 
-        cerr << st_stream.str();
         while (st_stream.good()) {
           string str;
           string param, stout;
           st_stream >> str;
           if (str != "") {
             getline (st_stream, param);
-            cerr << param;
 //          param.assign( str, com_length, str.size() );
 //          str.erase( com_length, str.size() - com_length + 1 );
             com = setCom( str );
@@ -167,9 +189,10 @@
       }
     }
   }
+*/
+  
   close(fd2[0]);
   close(fd1[1]);
-
   active = false;
   // cerr << "Server's loop may be here" << endl;
 }
@@ -180,7 +203,8 @@
 
   string s;
   string expected;
-
+  string result;
+   
   for ( tests_container_type::const_iterator i = tests.begin(); i != tests.end(); ++i ) {
     pipe( fd1 );
     pipe( fd2 );
@@ -189,11 +213,11 @@
     ifstream in( fd1[0] );
     ofstream out( fd2[1] );
 #elif defined( __GNUC__ )
-    __gnu_cxx::stdio_filebuf _in_buf( fd1[0], std::ios_base::in );
+    __gnu_cxx::stdio_filebuf<char> _in_buf( fd1[0], std::ios_base::in );
     basic_istream<char> in( &_in_buf );
 
-    __gnu_cxx::stdio_filebuf _out_buf( fd2[1], std::ios_base::out );
-    basic_istream<char> in( &_out_buf );
+    __gnu_cxx::stdio_filebuf<char> _out_buf( fd2[1], std::ios_base::out );
+    basic_ostream<char> out( &_out_buf );
 #endif
     char r_buffer[buf_size], w_buffer[buf_size];
 
@@ -204,12 +228,12 @@
 
     getline( in_tst, expected );
 
-    while ( in.good() ){
+    while ( in_tst.good() ){
       getline( in_tst, s ); 
       if ( !s.empty() ) {
         write( fd2[1], s.data(), s.length() );
         write( fd2[1], "\n", 1 );
-        int n = read( fd1[0], r_buffer, sizeof(r_buffer) );
+/*        int n = read( fd1[0], r_buffer, sizeof(r_buffer) );
         if ( n < 0 ) {                                      
           cerr << "Reading error\n";
           break;
@@ -220,24 +244,31 @@
           r_buffer[n] = '\0';
           cerr << "<< " << r_buffer;
         }
+        out << s << "\n";
+*/      cerr << s << "\n";
+//        do {
+          getline (in, result); 
+          cerr << result;
+//        } while (!result.empty());
+//        if (result.empty()) cerr << "Empty";
       }
     }
 
-    string str ("helo mail.ru\nmail from:se...@ma...\nrcpt to:cl...@ma...\nquit\n");
-    write( fd2[1], str.data(), str.length() );
+//    string str ("helo mail.ru\nmail from:se...@ma...\nrcpt to:cl...@ma...\nquit\n");
+//    write( fd2[1], str.data(), str.length() );
 
     close(fd2[1]);
     close(fd1[0]);
 
     t.join();
 
-    string result(r_buffer);
+//    string result(r_buffer);
     if ( expected.compare(0, 3, result, 0, 3) != 0 ) {
       cerr << expected << "!=" << result << " at " << *i << endl;
     }
         
     EXAM_CHECK( expected.compare(0, 3, result, 0, 3) == 0 );
-        
+  }      
 /*        strcpy (w_buffer, "help");
         write (fd2[1], w_buffer, sizeof(w_buffer));
         read (fd1[0], r_buffer, sizeof(r_buffer));
@@ -250,7 +281,6 @@
     
         cerr << "Client's text may be here" << endl;
 */
-  }
   // EXAM_CHECK( val == 1 );
   // std::tr2::basic_thread<0,0> t2( thread_func_int, 2 );
   // t2.join();


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