exiddis/mysql-client/client-lib/eid_connection.h

 /*
 *  Copyright 2009 DreamLab Onet.pl Sp. z o.o.
  Licensed  under  the  Apache  License,  Version  2.0  (the  "License");
 you  may  not  use  this  file  except  in  compliance with the License.
 You may obtain a copy of the License at

      http://www.apache.org/licenses/LICENSE-2.0

 Unless  required  by applicable  law or  agreed to in writing,  software
 distributed  under the  License is  distributed  on  an " AS IS"  BASIS,
 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 See  the License  for the specific  language  governing  permissions and
 limitations under the License.

      Authors:  Kamil Kraszewski  <kraszewski(dot)kamil(at)gmail(dot)com>
                Piotr Zaborski  <piotr(dot)zaborski(at)uj(dot)edu(dot)pl>
 *
 */

#ifndef __EID_CONNECTION__
#define __EID_CONNECTION__
#include "config.h"

#include <ulxmlrpcpp/ulxmlrpcpp.h>
#include <ulxmlrpcpp/ulxr_tcpip_connection.h>
#include <ulxmlrpcpp/ulxr_ssl_connection.h>
#include <ulxmlrpcpp/ulxr_http_protocol.h>
#include <ulxmlrpcpp/ulxr_requester.h>
#include <ulxmlrpcpp/ulxr_value.h>
#include <ulxmlrpcpp/ulxr_except.h>
#include <ulxmlrpcpp/ulxr_log4j.h>

#include <cstdlib>
#include <iostream>
#include <sstream>
#include <ctime>
#include <memory>
#include <cstring>
#include <string>
#include <ctime>
#include <list>
#include <queue>
#include <map>

#include <pthread.h>
#include <errno.h>

#include "eid_errno.h"
#include "eid_signal.h"

//#ifdef __WIN__
//typedef unsigned __int64 ulonglong;           /* Microsofts 64 bit types */
//typedef __int64 longlong;
//#else
typedef unsigned long long ulonglong;
typedef long long longlong;
//#endif /*__WIN__*/

namespace eid {

    extern const char *seqHost;
    extern const int seqPort;

    extern const char *EXTERNAL_GET_NEXT_COMMAND;
    extern const char *EXTERNAL_FAST_GET_NEXT_COMMAND;
    extern const char *EXTERNAL_GET_LOCATION_COMMAND;

    struct RespPack {
        longlong* tab;
        int added;
        int id;
        int outCode;
    };

    class ConnectionPack {
        public:
            int port;
            char* host;

            ulxr::TcpIpConnection *conn;
            ulxr::HttpProtocol *prot;
            ulxr::Requester *client;

            ConnectionPack();
            ConnectionPack(const char * _host, int _port); 
            ~ConnectionPack();

            static int getNextValues(ConnectionPack** pCp, const char *seqName, int numNext, RespPack &out);
            static int getNextValues(ConnectionPack** pCp, int seqId, int numNext, RespPack &out);
        private:
            
            static ConnectionPack* getConnection(const char* seqName);
            static ConnectionPack* getConnection(const char* host, int port);

            static int parseResp(ConnectionPack** pCp, ulxr::Value& resp, RespPack &out);
            static int getValuesFromArray(ulxr::Array &ar, RespPack &out);
            static int getNextValuesCore(ConnectionPack** pCp, const char *seqName, const int id, ulxr::MethodCall& mc, RespPack &out);
    };

    template<class T, class E>
    T toNumber(std::basic_string<E> str) {
        std::stringstream ss(str);
        T res;
        ss >> res;
        return res;
    };
    
    static ConnectionPack *masterPack;
    static std::list<ConnectionPack*> connectionPacks;
}
#endif

---