s

BoundedBuffer.cpp

@@ -19,4 +19,3 @@ string BoundedBuffer::pop(){
 	empty->V();
     return item;
 }
-    

BoundedBuffer.h

@@ -32,6 +32,8 @@ public:
     
     void set_b(int b){ b_val = b;}
 
+    int get_val(){ return b_val; }
+    
     void push(string item);
             
     string pop();

dataserver.cpp

@@ -158,6 +158,7 @@ void handle_process_loop(RequestChannel & _channel) {
     cout << "New request is " << request << endl;
 
     if (request.compare("quit") == 0) {
+      cout << "\nquit\n";
       _channel.cwrite("bye");
       usleep(10000);          // give the other end a bit of time.
       break;                  // break out of the loop;

simpleclient.cpp

@@ -109,8 +109,8 @@ int main(int argc, char * argv[]) {
 
         string channel_name;
         for(int i=0; i < w; i++){
-            channel_name = chan.send_request("newthread");
+            channel_name = chan.send_request("newthrread");
-            cout << "Chan: " << channel_name << endl;
+            cout << "\nChan: " << channel_name << endl;
             RequestChannel* worker_ret = new RequestChannel(channel_name, RequestChannel::CLIENT_SIDE);
             Worker_Thread(argv, worker_ret);
         }
@@ -135,7 +135,7 @@ void* Worker_Thread(char* arg[], RequestChannel* chan){
     //control chan("control", RequestChannel::CLIENT_SIDE);
     //string channel_name = control.send_request("newthread");
     //RequestChannel * channel_ret = new RequestChannel(channel_name, RequestChannel::CLIENT_SIDE);
-    while(true){
+    while(Request_Buffer->get_val() != 0){
         
         
         string req = Request_Buffer->pop();