nextMessage removed from client
[u/mrichter/AliRoot.git] / SHUTTLE / DCSClient / AliDCSClient.h
CommitLineData
73abe331 1#ifndef ALI_DCS_CLIENT_H
2#define ALI_DCS_CLIENT_H
3
4/* Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
5 * See cxx source for full Copyright notice */
6
7/* $Id$ */
8
9//
10// This class represents the AliDCSClient.
11// The client used for data retrieval from DCS server.
58bc3020 12// For more info see AliDCSClient.cxx
73abe331 13//
14
15#include "AliDCSMessage.h"
16
d477ad88 17class TObjArray;
58bc3020 18class TSocket;
73abe331 19class TMap;
a038aa70 20class TCollection;
73abe331 21
22class AliDCSClient: public TObject {
23public:
2bb7b766 24
eba76848 25 enum {
26 fgkBadState=-1, // Bad state
27 fgkInvalidParameter = -2, // Invalid parameter
28 fgkTimeout = -3, // Timeout
29 fgkBadMessage = -4, // Bad message
30 fgkCommError = -5, // Communication error
31 fgkServerError = -6 // Server error
32 };
33
b41b252a 34//// friend class AliShuttle;
2bb7b766 35
73abe331 36 AliDCSClient(const char* host, Int_t port, UInt_t timeout = 5000,
b41b252a 37 Int_t retries = 5, Int_t multiSplit = 100);
73abe331 38 virtual ~AliDCSClient();
39
40
41 Int_t GetDPValues(const char* dpName, UInt_t startTime, UInt_t endTime,
2bb7b766 42 TObjArray* result);
73abe331 43
44 Int_t GetAliasValues(const char* alias, UInt_t startTime,
2bb7b766 45 UInt_t endTime, TObjArray* result);
73abe331 46
a038aa70 47 TMap* GetDPValues(const TSeqCollection* dpList, UInt_t startTime, UInt_t endTime, Int_t startIndex = 0, Int_t endIndex = -1);
73abe331 48
a038aa70 49 TMap* GetAliasValues(const TSeqCollection* aliasList, UInt_t startTime, UInt_t endTime, Int_t startIndex = 0, Int_t endIndex = -1);
73abe331 50
58bc3020 51 AliDCSMessage::ErrorCode GetServerErrorCode() const
bee83158 52 { return fServerErrorCode;}
73abe331 53
1790d4b7 54 Int_t GetResultErrorCode() const {return fResultErrorCode;}
bee83158 55 const TString& GetServerError() const {return fServerError;}
73abe331 56
57
58 Bool_t IsConnected();
59
60 void Close();
61
73abe331 62 static const char* GetErrorString(Int_t code);
63
64private:
58bc3020 65 static const char* fgkBadStateString; // Bad state string
66 static const char* fgkInvalidParameterString; // Invalid parameter string
67 static const char* fgkTimeoutString; // Timeout string
68 static const char* fgkBadMessageString; // Bad message string
69 static const char* fgkCommErrorString; // Communication error string
70 static const char* fgkServerErrorString; // Server error string
71
58bc3020 72 TSocket* fSocket; // Pointer to the TCP socket client
bee83158 73 TString fHost; // server host
74 Int_t fPort; // server port
58bc3020 75 UInt_t fTimeout; // timeout parameter
58bc3020 76 Int_t fRetries; // number of retries
b41b252a 77 Int_t fMultiSplit; // number of datapoints that are queried at a time in a multi dp request, if set to 1 forces single requests
1790d4b7 78 AliDCSMessage::ErrorCode fServerErrorCode; // server error code
58bc3020 79 TString fServerError; // server error string
1790d4b7 80
81 Int_t fResultErrorCode; // result error code
73abe331 82
bee83158 83 Bool_t Connect();
73abe331 84
85 Int_t SendBuffer(const char* buffer, Int_t size);
73abe331 86 Int_t ReceiveBuffer(char* buffer, Int_t size);
73abe331 87 Int_t SendMessage(AliDCSMessage& message);
2bb7b766 88 Int_t ReceiveMessage(AliDCSMessage& message);
73abe331 89
90 Int_t GetValues(AliDCSMessage::RequestType requestType,
91 const char* requestString, UInt_t startTime, UInt_t endTime,
2bb7b766 92 TObjArray* result);
93
a038aa70 94 TMap* GetValues(AliDCSMessage::RequestType requestType,
95 const TSeqCollection* list, UInt_t startTime, UInt_t endTime,
96 Int_t startIndex, Int_t endIndex);
73abe331 97
4e3d5771 98 Int_t ReceiveValueSet(TObjArray* result, Int_t& ownerIndex);
73abe331 99
bee83158 100 AliDCSClient(const AliDCSClient& other); // not implemented
101 AliDCSClient& operator= (const AliDCSClient& other); // not implemented
73abe331 102
103 ClassDef(AliDCSClient, 0);
104};
105
106#endif