~drizzle-pbxt/drizzle/drizzle-pbxt-2

 

#ifdef XT_TAB_ROW_USE_XSMUTEX

#define XT_TAB_ROW_LOCK_TYPE                    XTXSMutexRec

#define XT_TAB_ROW_FREE_LOCK(s, i)              xt_xsmutex_free(s, i)   

#define XT_TAB_ROW_READ_LOCK(i, s)              xt_xsmutex_slock(i, (s)->t_id)

#define XT_TAB_ROW_WRITE_LOCK(i, s)             xt_xsmutex_xlock(i, (s)->t_id)

#define XT_TAB_ROW_UNLOCK(i, s)                 xt_spinxslock_unlock(i, (s)->t_id)

#else

#define XT_TAB_ROW_LOCK_TYPE                    XTSpinLockRec

#define XT_TAB_ROW_FREE_LOCK(s, i)              xt_spinlock_free(s, i)  

#define XT_TAB_ROW_READ_LOCK(i, s)              xt_spinlock_lock(i)

#define XT_TAB_ROW_WRITE_LOCK(i, s)             xt_spinlock_lock(i)

        /* Values that belong in the header when flushed! */

        xtBool                                  tab_flush_pending;                                              /* TRUE if the table needs to be flushed */

        xtBool                                  tab_recovery_done;                                              /* TRUE if the table has been recovered */

        xtBool                                  tab_temporary;                                                  /* TRUE if this is a temporary table {TEMP-TABLES}. */

        off_t                                   tab_bytes_to_flush;                                             /* Number of bytes of the record/row files to flush. */

 

int                                     xt_use_table_by_id(struct XTThread *self, XTTableHPtr *tab, struct XTDatabase *db, xtTableID tab_id);

XTOpenTablePtr          xt_open_table(XTTableHPtr tab);

void                            xt_close_table(XTOpenTablePtr ot, xtBool flush, xtBool have_table_lock);

void                            xt_check_table(XTThreadPtr self, XTOpenTablePtr tab);

void                            xt_rename_table(struct XTThread *self, XTPathStrPtr old_name, XTPathStrPtr new_name);

 

void                            xt_tab_seq_reset(XTOpenTablePtr ot);

void                            xt_tab_seq_exit(XTOpenTablePtr ot);

xtBool                          xt_tab_seq_next(XTOpenTablePtr ot, xtWord1 *buffer, xtBool *eof);

 

xtBool                          xt_tab_new_record(XTOpenTablePtr ot, xtWord1 *buffer);

xtBool                          xt_tab_delete_record(XTOpenTablePtr ot, xtWord1 *buffer);

xtBool                          xt_tab_put_log_op_rec_data(XTOpenTablePtr ot, u_int status, xtRecordID free_rec_id, xtRecordID rec_id, size_t size, xtWord1 *buffer);

xtBool                          xt_tab_put_log_rec_data(XTOpenTablePtr ot, u_int status, xtRecordID free_rec_id, xtRecordID rec_id, size_t size, xtWord1 *buffer, xtOpSeqNo *op_seq);

xtBool                          xt_tab_get_rec_data(register XTOpenTablePtr ot, xtRecordID rec_id, size_t size, xtWord1 *buffer);

void                            xt_tab_set_index_error(XTTableHPtr tab);

 

inline off_t            xt_row_id_to_row_offset(register XTTableHPtr tab, xtRowID row_id)

{

        return (off_t) tab->tab_rows.tci_header_size + (off_t) (row_id - 1) * (off_t) tab->tab_rows.tci_rec_size;

        while (0)

 

#endif