From 1081fcb6efac31ead884a131e8ebb567d9382be7 Mon Sep 17 00:00:00 2001
From: Peter Thorson <github@zaphoyd.com>
Date: Wed, 24 Apr 2013 06:56:59 -0500
Subject: [PATCH] tests with iostream_server

---
 examples/iostream_server/iostream_server.cpp | 35 +++++++++++++++++---
 1 file changed, 31 insertions(+), 4 deletions(-)

diff --git a/examples/iostream_server/iostream_server.cpp b/examples/iostream_server/iostream_server.cpp
index 1cf949cd09..726b4a471a 100644
--- a/examples/iostream_server/iostream_server.cpp
+++ b/examples/iostream_server/iostream_server.cpp
@@ -5,6 +5,8 @@
 #include <iostream>
 #include <fstream>
 
+#include <unistd.h>
+
 typedef websocketpp::server<websocketpp::config::core> server;
 
 using websocketpp::lib::placeholders::_1;
@@ -35,8 +37,8 @@ int main() {
 	try {        
         // Clear logging because we are using std out for data
         // TODO: fix when we can log to files
-        //s.clear_error_channels(websocketpp::log::elevel::all);
-        //s.clear_access_channels(websocketpp::log::alevel::all);
+        s.set_error_channels(websocketpp::log::elevel::all);
+        s.set_access_channels(websocketpp::log::alevel::all);
         
         
         log.open("output.log");
@@ -54,17 +56,42 @@ int main() {
         
         con->start();
         
-        std::cin >> *con;
+        //std::cin >> *con;
         
-        log << "ready done" << std::endl;
+        //log << "ready done" << std::endl;
+        
+        std::string temp;
+        while(std::cin >> temp) {
+            con->readsome(temp.data(),temp.size());
+            std::cout << temp;
+            std::cout.flush();
+        }
         
         /*char buf[512];
         size_t bytes_read;
+        size_t bytes_processed;
+        
         while(std::cin) {
             bytes_read = std::cin.readsome(buf,512);
             
+            if (bytes_read > 0) {
+                std::cout << "read " << bytes_read << " bytes " 
+                          << websocketpp::utility::to_hex(buf,bytes_read) 
+                          << std::endl;
+            }
             
+            bytes_processed = 0;
+            while (bytes_processed < bytes_read) {
+                std::cout << "foo" << std::endl;
+                bytes_processed += con->readsome(buf+bytes_processed,
+                                                 bytes_read-bytes_processed);
+                std::cout << "bar" << std::endl;
+                sleep(1);
+            }
+            
+            sleep(1);
         }*/
+        std::cout << "end" << std::endl;
         
     } catch (const std::exception & e) {
         std::cout << e.what() << std::endl;