basethread.h

Go to the documentation of this file.

#ifndef __BASETHREAD_H
#define __BASETHREAD_H

#include "thread_wrapper.h"
#include "sm_base.h"
#include "vol.h"
#include "logarchiver.h"
#include "xct.h"

#include <stdexcept>
#include <queue>

using namespace std;

class basethread_t : public thread_wrapper_t {
public:
    basethread_t();

    virtual ~basethread_t();

    bool finished;

    static void start_base();

    static void start_buffer();

    static void start_log(string logdir);

    // default archiver workspace size = 800MB
    static void start_archiver(string archdir, size_t wsize, size_t bsize);

    static void start_merger(string archdir);

    static void start_other();

    static void print_stats();

protected:
    void begin_xct();

    void commit_xct();

    virtual void before_run();

    virtual void after_run();

    static sm_options _options;

private:
    pthread_mutex_t running_mutex;

    xct_t* current_xct;
};

#endif // __BASETHREAD_H