]> git.uio.no Git - u/mrichter/AliRoot.git/blobdiff - SHUTTLE/DCSClient/AliDCSClient.h
adding warning in case result is outside of queried period
[u/mrichter/AliRoot.git] / SHUTTLE / DCSClient / AliDCSClient.h
index 399145263dace435cc8d326999c737fdc70e3370..1bd347e4200e7289c5b4a3ff19f999052718e662 100644 (file)
@@ -28,13 +28,12 @@ public:
                fgkTimeout = -3,             // Timeout
                fgkBadMessage = -4,          // Bad message
                fgkCommError = -5,           // Communication error
-               fgkServerError = -6          // Server error
+               fgkServerError = -6,         // Server error
+               fgkUnknownDP = -7            // unknown alias/DP error
        };
        
-       friend class AliShuttle;
-
        AliDCSClient(const char* host, Int_t port, UInt_t timeout = 5000,
-                        Int_t retries = 5);
+                        Int_t retries = 5, Int_t multiSplit = 100);
         virtual ~AliDCSClient();
 
 
@@ -51,6 +50,7 @@ public:
         AliDCSMessage::ErrorCode GetServerErrorCode() const
                 { return fServerErrorCode;}
 
+       Int_t GetResultErrorCode() const {return fResultErrorCode;}
         const TString& GetServerError() const {return fServerError;}
 
 
@@ -58,7 +58,6 @@ public:
 
         void Close();
 
-
         static const char* GetErrorString(Int_t code);
 
 private:
@@ -68,23 +67,24 @@ private:
        static const char* fgkBadMessageString;         // Bad message string
        static const char* fgkCommErrorString;          // Communication error string
        static const char* fgkServerErrorString;        // Server error string
+       static const char* fgkUnknownDPString;          // Unknown alias/DP string
 
        TSocket* fSocket;       // Pointer to the TCP socket client
        TString fHost;          // server host
        Int_t   fPort;          // server port
        UInt_t fTimeout;        // timeout parameter
        Int_t fRetries;         // number of retries
-       AliDCSMessage::ErrorCode fServerErrorCode;      // error code
+       Int_t   fMultiSplit; // number of datapoints that are queried at a time in a multi dp request, if set to 1 forces single requests 
+       AliDCSMessage::ErrorCode fServerErrorCode;      // server error code
        TString fServerError;   // server error string
+       
+       Int_t fResultErrorCode; // result error code
 
        Bool_t Connect();
 
        Int_t SendBuffer(const char* buffer, Int_t size);
-
        Int_t ReceiveBuffer(char* buffer, Int_t size);
-
        Int_t SendMessage(AliDCSMessage& message);
-
        Int_t ReceiveMessage(AliDCSMessage& message);
 
        Int_t GetValues(AliDCSMessage::RequestType requestType,
@@ -95,7 +95,7 @@ private:
                const TSeqCollection* list, UInt_t startTime, UInt_t endTime,
                Int_t startIndex, Int_t endIndex);
 
-       Int_t ReceiveValueSet(TObjArray* result);
+       Int_t ReceiveValueSet(TObjArray* result, Int_t& ownerIndex);
 
        AliDCSClient(const AliDCSClient& other);                // not implemented
        AliDCSClient& operator= (const AliDCSClient& other);    // not implemented