trunk/src/ha_tritonn.h

#ifdef USE_PRAGMA_INTERFACE
#pragma interface                       /* gcc class implementation */
#endif

#include <senna/senna.h>

typedef struct st_tritonn_db {
  char *db_name;
  uint db_name_length;
  sen_db *db;
  st_tritonn_db *next;
} TRITONN_DB;

/** @brief
  TRITONN_SHARE is a structure that will be shared among all open handlers.
  This implements the minimum of what you will probably need.
*/
typedef struct st_tritonn_share {
  char *table_name;
  char *short_name;
  uint table_name_length,use_count;
  pthread_mutex_t mutex;
  THR_LOCK lock;
} TRITONN_SHARE;

class ha_tritonn: public handler
{
  THR_LOCK_DATA lock;      // MySQL lock
  TRITONN_SHARE *share;   // Shared lock info
  sen_ctx *ctx;

public:
  /* constructor */
  ha_tritonn(handlerton *hton, TABLE_SHARE *table_arg);
  /* destructor */
  ~ha_tritonn();
  /* engine name */
  const char *table_type() const;
  /* index type in string for specified number */
  const char *index_type(uint inx) const;
  /* file extantion for storage */
  const char **bas_ext() const;

  // see $MYSQL_SRC/sql/handler.h "bits in table_flags"
  ulonglong table_flags() const;

  // see $MYSQL_SRC/sql/handler.h, "bits in index_flags"
  ulong index_flags(uint inx, uint part, bool all_parts) const;

  /* add index */
  int add_index(TABLE *table_arg, KEY *key_info, uint num_of_keys);

  /* drop index */
  int prepare_drop_index(TABLE *table_arg, uint *key_num, uint num_of_keys);
  int final_drop_index(TABLE *table_arg);

  /* open table */
  int open(const char *name, int mode, uint test_if_locked);
  /* close table */
  int close(void);

  int rnd_init(bool scan);                                      // required
  int rnd_next(uchar *buf);                                     // required
  int rnd_pos(uchar *buf, uchar *pos);                          // required
  void position(const uchar *record);                           // required
  int info(uint);                                               // required
  int create(const char *name, TABLE *form,
             HA_CREATE_INFO *create_info);                      // required
  const COND *cond_push(const COND *cond);                      // condition pushdown
  THR_LOCK_DATA **store_lock(THD *thd, THR_LOCK_DATA **to,
                             enum thr_lock_type lock_type);     // required
  uint max_supported_keys() const;
  uint max_supported_key_length() const;
  uint max_supported_key_part_length() const;
  int write_row(uchar *buf);
};

#ifdef DEBUG_TRITONN
#define DBTN printf("[DBTN] %s#%s:%d\n",__FUNCTION__,__FILE__,__LINE__)
#define DBTN2(x) printf("[DBTN2] %s#%s:%d msg=%s\n",__FUNCTION__,__FILE__,__LINE__,x)
#else
#define DBTN
#define DBTN2(x)
#endif