* progress on spectra server

NPLib/Core/NPSpectraServer.cxx

@@ -63,7 +63,6 @@ NPL::SpectraServer::SpectraServer(){
 
 ///////////////////////////////////////////////////////////////////////////////
 void NPL::SpectraServer::CheckRequest(){
- /*FIXME
   if(m_Server && m_Monitor){
     m_Monitor->ResetInterrupt();
     TSocket* s = m_Monitor->Select();
@@ -71,7 +70,6 @@ void NPL::SpectraServer::CheckRequest(){
         HandleSocket(s);
     }
   }
-  */
 }
 
 ////////////////////////////////////////////////////////////////////////////////
@@ -104,7 +102,7 @@ void NPL::SpectraServer::HandleSocket(TSocket* s){
     }
 
     // send requested object back
-    static TMessage answer(kMESS_OBJECT);
+    static TMessage answer(kMESS_OBJECT|kMESS_ACK);
     answer.SetCompressionLevel(1);
     answer.Reset();
     TObject* h =NULL;

NPLib/Online/NPSpectraClient.cxx

@@ -90,7 +90,9 @@ bool NPL::SpectraClient::Sync(){
   }
 
   TMessage* message=NULL;
-  m_Sock->Send("RequestSpectra");
+  m_Sock->Send("RequestSpectra",kMESS_STRING|kMESS_ACK);
+  
+
 
   if(m_Sock->Recv(message)<=0){
     if(m_Sock){
@@ -187,7 +189,7 @@ TTree* NPL::SpectraClient::GetTree(){
   }
 
   TMessage* message=NULL;
-  m_Sock->Send("RequestTree",kMESS_STRING||kMESS_ACK);
+  m_Sock->Send("RequestTree",kMESS_STRING|kMESS_ACK);
 
   if(m_Sock->Recv(message)<=0){
     if(m_Sock){

NPLib/Utility/npspectra_test.cxx

@@ -6,11 +6,12 @@
 #include"NPSpectraServer.h"
 #include<cstdlib>
 #include<iostream>
+#include"RootOutput.h"
 
 int main(int argc , char** argv){
   // Root will not issue any BS warning message
   gErrorIgnoreLevel = 10000;
-
+  RootOutput::getInstance("testOnline.root","TestTree");
   NPL::SpectraServer* server = NPL::SpectraServer::getInstance();
 
   // Create two test spectrum
@@ -46,6 +47,7 @@ int main(int argc , char** argv){
     }
     
     server->CheckRequest(); 
+    usleep(1000);
     }
 
   return 0;