exiddis/mysql-client/client-lib/eid_sequences.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_SEQUENCES__
#define __EID_SEQUENCES__
#include "config.h"
#include <cstdlib>
#include <iostream>
#include <sstream>
#include <ctime>
#include <memory>
#include <cstring>
#include <string>
#include <ctime>
#include <list>
#include <queue>

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

#include "eid_connection.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__*/

#include <map>

namespace eid {
    class SequencePack {
        public:
            SequencePack();
            SequencePack(const char* _seqName, int _bufferMin, int _bufferPack);

            ConnectionPack *clientPack;
            pthread_mutex_t clientMutex;

            std::queue<longlong> buffor;
            pthread_mutex_t bufforMutex; 
            int bufforMin; //change_to size_type
            int bufforPack;
    
            std::string seqName;
            int id;
            pthread_t thread;

            pthread_mutex_t updateBufforMutex;
            pthread_cond_t updateBufforCondition;
            int updateBufforPredicate;

            longlong getNext(int &error);
        private:

            struct UpdateBufforArgs {
                int *error;
                SequencePack* owner;
            };

            static void *updateBuffor(void *args);

            longlong buffor_get_next();

            void buffor_lock();
            void buffor_unlock();
    };

    longlong getNext(const char *seq, int &error);

    //static std::map<std::string, SequencePack*> name_to_seq;

    //Dodac znajdywanie sekcji :)

    template<class T, class E>
    T to_num(std::basic_string<E> str) {
            std::stringstream ss(str);
        T res;
            ss >> res;
        return res;
    };
}
#endif

---