diff --git a/storage/tokudb/ha_tokudb.cc b/storage/tokudb/ha_tokudb.cc index 91ea103675a..c502a1c222a 100644 --- a/storage/tokudb/ha_tokudb.cc +++ b/storage/tokudb/ha_tokudb.cc @@ -579,6 +579,9 @@ inline HA_TOKU_ISO_LEVEL tx_to_toku_iso(ulong tx_isolation) { if (tx_isolation == ISO_READ_UNCOMMITTED) { return hatoku_iso_read_uncommitted; } + else if (tx_isolation == ISO_READ_COMMITTED) { + return hatoku_iso_read_committed; + } else { return hatoku_iso_serializable; } @@ -588,6 +591,9 @@ inline u_int32_t toku_iso_to_txn_flag (HA_TOKU_ISO_LEVEL lvl) { if (lvl == hatoku_iso_read_uncommitted) { return DB_READ_UNCOMMITTED; } + else if (lvl == hatoku_iso_read_committed) { + return DB_READ_COMMITTED; + } else { return 0; } diff --git a/storage/tokudb/hatoku_defines.h b/storage/tokudb/hatoku_defines.h index 5eae3d7c356..af606794d95 100644 --- a/storage/tokudb/hatoku_defines.h +++ b/storage/tokudb/hatoku_defines.h @@ -79,6 +79,7 @@ inline unsigned int my_tid() { typedef enum { hatoku_iso_not_set = 0, hatoku_iso_read_uncommitted, + hatoku_iso_read_committed, hatoku_iso_serializable } HA_TOKU_ISO_LEVEL;