~drizzle-trunk/drizzle/development

#define XT_SET_DISK_3(d, s) do { (*((xtWord2 *) &((d)[0])) = (xtWord2) (s)); *((xtWord1 *) &((d)[2])) = (xtWord1) (((xtWord4) (s)) >> 16); } while (0)

719

#define XT_SET_DISK_4(d, s) (*((xtWord4 *) &((d)[0])) = (xtWord4) (s))

720

#define XT_SET_DISK_6(d, s) do { *((xtWord4 *) &((d)[0])) = (xtWord4) (s); *((xtWord2 *) &((d)[4])) = (xtWord2) (((xtWord8) (s)) >> 32); } while (0)

721

#define XT_SET_DISK_8(d, s) (*((xtWord8 *) &((d)[0])) = (xtWord8) (s))

722

723

#define XT_GET_DISK_1(s) ((s)[0])

724

#define XT_GET_DISK_2(s) *((xtWord2 *) &((s)[0]))

725

#define XT_GET_DISK_3(s) ((xtWord4) *((xtWord2 *) &((s)[0])) | (((xtWord4) *((xtWord1 *) &((s)[2]))) << 16))

726

#define XT_GET_DISK_4(s) *((xtWord4 *) &((s)[0]))

727

#define XT_GET_DISK_6(s) ((xtWord8) *((xtWord4 *) &((s)[0])) | (((xtWord8) *((xtWord2 *) &((s)[4]))) << 32))

728

#define XT_GET_DISK_8(s) *((xtWord8 *) &((s)[0]))

729

730

#define XT_MOVE_DISK_1(d, s) ((d)[0] = (s)[0])

731

#define XT_MOVE_DISK_2(d, s) XT_COPY_DISK_2(d, s)

732

#define XT_MOVE_DISK_3(d, s) XT_COPY_DISK_3(d, s)

733

#define XT_MOVE_DISK_4(d, s) XT_COPY_DISK_4(d, s)

734

#define XT_MOVE_DISK_8(d, s) XT_COPY_DISK_8(d, s)

735

736

#define XT_COPY_DISK_1(d, s) (d)[0] = s

737

#define XT_COPY_DISK_2(d, s) (*((xtWord2 *) &((d)[0])) = (*((xtWord2 *) &((s)[0]))))

738

#define XT_COPY_DISK_3(d, s) do { *((xtWord2 *) &((d)[0])) = *((xtWord2 *) &((s)[0])); (d)[2] = (s)[2]; } while (0)

739

#define XT_COPY_DISK_4(d, s) (*((xtWord4 *) &((d)[0])) = (*((xtWord4 *) &((s)[0]))))

740

#define XT_COPY_DISK_6(d, s) do { *((xtWord4 *) &((d)[0])) = *((xtWord4 *) &((s)[0])); *((xtWord2 *) &((d)[4])) = *((xtWord2 *) &((s)[4])); } while (0)

741

#define XT_COPY_DISK_8(d, s) (*((xtWord8 *) &(d[0])) = (*((xtWord8 *) &((s)[0]))))

742

#define XT_COPY_DISK_10(d, s) memcpy(&((d)[0]), &((s)[0]), 10)

743

744

#define XT_SET_NULL_DISK_1(d) XT_SET_DISK_1(d, 0)

745

#define XT_SET_NULL_DISK_2(d) XT_SET_DISK_2(d, 0)

746

#define XT_SET_NULL_DISK_3(d) XT_SET_DISK_3(d, 0)

747

#define XT_SET_NULL_DISK_4(d) XT_SET_DISK_4(d, 0L)

748

#define XT_SET_NULL_DISK_6(d) XT_SET_DISK_6(d, 0LL)

749

#define XT_SET_NULL_DISK_8(d) XT_SET_DISK_8(d, 0LL)

750

751

#define XT_IS_NULL_DISK_1(d) (!(XT_GET_DISK_1(d)))

752

#define XT_IS_NULL_DISK_2(d) (!(XT_GET_DISK_2(d)))

753

#define XT_IS_NULL_DISK_3(d) (!(XT_GET_DISK_3(d)))

754

#define XT_IS_NULL_DISK_4(d) (!(XT_GET_DISK_4(d)))

755

#define XT_IS_NULL_DISK_8(d) (!(XT_GET_DISK_8(d)))

756

757

#define XT_EQ_DISK_4(d, s) (XT_GET_DISK_4(d) == XT_GET_DISK_4(s))

758

#define XT_EQ_DISK_8(d, s) (XT_GET_DISK_8(d) == XT_GET_DISK_8(s))

759

760

#define XT_IS_FF_DISK_4(d) (XT_GET_DISK_4(d) == 0xFFFFFFFF)

761

#endif

762

763

#define XT_CMP_DISK_4(a, b) ((xtInt4) XT_GET_DISK_4(a) - (xtInt4) XT_GET_DISK_4(b))

764

#define XT_CMP_DISK_8(d, s) memcmp(&((d)[0]), &((s)[0]), 8)

765

//#define XT_CMP_DISK_8(d, s) (XT_CMP_DISK_4((d).h_number_4, (s).h_number_4) == 0 ? XT_CMP_DISK_4((d).h_file_4, (s).h_file_4) : XT_CMP_DISK_4((d).h_number_4, (s).h_number_4))

766

767

#define XT_SWAP_DISK_2(d, s) do { (d)[0] = (s)[1]; (d)[1] = (s)[0]; } while (0)

768

#define XT_SWAP_DISK_3(d, s) do { (d)[0] = (s)[2]; (d)[1] = (s)[1]; (d)[2] = (s)[0]; } while (0)

769

#define XT_SWAP_DISK_4(d, s) do { (d)[0] = (s)[3]; (d)[1] = (s)[2]; (d)[2] = (s)[1]; (d)[3] = (s)[0]; } while (0)

770

#define XT_SWAP_DISK_8(d, s) do { (d)[0] = (s)[7]; (d)[1] = (s)[6]; (d)[2] = (s)[5]; (d)[3] = (s)[4]; \

771

(d)[4] = (s)[3]; (d)[5] = (s)[2]; (d)[6] = (s)[1]; (d)[7] = (s)[0]; } while (0)

772

773

/* ----------------------------------------------------------------------

774

* GLOBAL APPLICATION TYPES & MACROS

775

776

777

struct XTThread;

778

779

typedef void (*XTFreeFunc)(struct XTThread *self, void *thunk, void *item);

780

typedef int (*XTCompareFunc)(struct XTThread *self, register const void *thunk, register const void *a, register const void *b);

781

782

/* Log ID and offset: */

783

#define xtLogID xtWord4

784

#define xtLogOffset off_t

785

786

#define xtDatabaseID xtWord4

787

#define xtTableID xtWord4

788

#define xtOpSeqNo xtWord4

789

#define xtXactID xtWord4

790

#define xtThreadID xtWord4

791

792

#ifdef DEBUG

793

//#define XT_USE_NODE_ID_STRUCT

794

#endif

795

796

#ifdef XT_USE_NODE_ID_STRUCT

797

typedef struct xtIndexNodeID {

798

xtWord4 x;

799

} xtIndexNodeID;

800

#define XT_NODE_TEMP xtWord4 xt_node_temp

801

#define XT_NODE_ID(a) (a).x

802

#define XT_RET_NODE_ID(a) *((xtIndexNodeID *) &(xt_node_temp = (a)))

803

#else

804

#define XT_NODE_TEMP

805

#define xtIndexNodeID xtWord4

806

#define XT_NODE_ID(a) a

807

#define XT_RET_NODE_ID(a) ((xtIndexNodeID) (a))

808

#endif

809

810

/* Row, Record ID and Record offsets: */

811

#define xtRowID xtWord4

812

#define xtRecordID xtWord4 /* NOTE: Record offset == header-size + record-id * record-size! */

813

#define xtRefID xtWord4 /* Must be big enough to contain a xtRowID and a xtRecordID! */

814

#define xtRecOffset off_t

815

#define xtDiskRecordID4 XTDiskValue4

816

#ifdef XT_WIN

817

#define xtProcID DWORD

818

#else

819

#define xtProcID pid_t

820

#endif

821

822

#define XT_ROW_ID_SIZE 4

823

#define XT_RECORD_ID_SIZE 4

824

#define XT_REF_ID_SIZE 4 /* max(XT_ROW_ID_SIZE, XT_RECORD_ID_SIZE) */

825

#define XT_RECORD_OFFS_SIZE 4

826

#define XT_RECORD_REF_SIZE (XT_RECORD_ID_SIZE + XT_ROW_ID_SIZE)

827

#define XT_CHECKSUM4_REC(x) (x)

828

829

#define XT_XACT_ID_SIZE 4

830

#define XT_CHECKSUM4_XACT(x) (x)

831

832

#ifdef XT_WIN

833

#define __FUNC__ __FUNCTION__

834

#elif defined(XT_SOLARIS)

835

#define __FUNC__ "__func__"

836

#else

837

#define __FUNC__ __PRETTY_FUNCTION__

838

#endif

839

840

/* ----------------------------------------------------------------------

841

* GLOBAL VARIABLES

842

843

844

extern bool pbxt_inited;

845

extern xtBool pbxt_ignore_case;

846

extern const char *pbxt_extensions[];

847

extern xtBool pbxt_crash_debug;

848

849

850

/* ----------------------------------------------------------------------

851

* DRIZZLE MAPPINGS VARIABLES

852

853

854

#ifdef DRIZZLED

855

/* Drizzle is stuck at this level: */

856

#define MYSQL_VERSION_ID 60005

857

858

#define TABLE_LIST TableList

859

#define TABLE Table

860

#define THD Session

861

#define MYSQL_THD Session *

862

#define THR_THD THR_Session

863

#define STRUCT_TABLE class drizzled::TableShare

864

#define TABLE_SHARE TableShare

865

#define GET_TABLE_SHARE(x) (x)

866

#define GET_TABLE_FIELDS(x) ((x)->getFields(true))

867

868

#define MYSQL_TYPE_STRING DRIZZLE_TYPE_VARCHAR

869

#define MYSQL_TYPE_VARCHAR DRIZZLE_TYPE_VARCHAR

870

#define MYSQL_TYPE_LONGLONG DRIZZLE_TYPE_LONGLONG

871

#define MYSQL_TYPE_BLOB DRIZZLE_TYPE_BLOB

872

#define MYSQL_TYPE_ENUM DRIZZLE_TYPE_ENUM

873

#define MYSQL_TYPE_LONG DRIZZLE_TYPE_LONG

874

#define MYSQL_PLUGIN_VAR_HEADER DRIZZLE_PLUGIN_VAR_HEADER

875

#define MYSQL_STORAGE_ENGINE_PLUGIN DRIZZLE_STORAGE_ENGINE_PLUGIN

876

#define MYSQL_INFORMATION_SCHEMA_PLUGIN DRIZZLE_INFORMATION_SCHEMA_PLUGIN

877

#define memcpy_fixed memcpy

878

#define bfill(m, len, ch) memset(m, ch, len)

879

880

#define mx_tmp_use_all_columns(x, y) (x)->use_all_columns(y)

881

#define mx_tmp_restore_column_map(x, y) (x)->restore_column_map(y)

882

883

#define MX_TABLE_TYPES_T StorageEngine::Table_flags

884

#define MX_UINT8_T uint8_t

885

#define MX_ULONG_T uint32_t

886

#define MX_ULONGLONG_T uint64_t

887

#define MX_LONGLONG_T uint64_t

888

#define MX_CHARSET_INFO struct drizzled::charset_info_st

889

#define MX_CONST_CHARSET_INFO const struct drizzled::charset_info_st

890

#define MX_CONST const

891

#include <boost/dynamic_bitset.hpp>

892

#define MX_BITMAP boost::dynamic_bitset<>

893

#define MX_BIT_SIZE() size()

894

#define MX_BIT_SET(x, y) (x)->set(y)

895

//#define MX_BIT_FAST_TEST_AND_SET(x, y) (x)->testAndSet(y)

896

#define MX_BIT_FAST_TEST_AND_SET(x, y) (x)->test(y)

897

898

#define my_bool bool

899

//#define int16 int16_t

900

//#define int32 int32_t

901

//#define uint16 uint16_t

902

//#define uint32 uint32_t

903

#define uchar unsigned char

904

#define longlong int64_t

905

#define ulonglong uint64_t

906

#define handler Cursor

907

908

#define HAVE_LONG_LONG

909

910

#define my_malloc(x, y) malloc(x)

911

#define my_free(x, y) free(x)

912

913

#define HA_CAN_SQL_HANDLER 0

914

#define HA_CAN_INSERT_DELAYED 0

915

#define HA_BINLOG_ROW_CAPABLE 0

916

#define HA_BINLOG_STMT_CAPABLE 0

917

#define HA_CACHE_TBL_TRANSACT 0

918

919

//#define max cmax

920

//#define min cmin

921

922

#define NullS NULL

923

924

#define thd_charset session_charset

925

#define thd_slave_thread session_slave_thread

926

#define thd_binlog_format session_binlog_format

927

#define thd_mark_transaction_to_rollback ::drizzled::mark_transaction_to_rollback

928

#define thd_ha_data session_ha_data

929

#define current_thd current_session

930

#define thd_sql_command(x) ((x)->getSqlCommand())

931

#define thd_test_options session_test_options

932

#define thd_killed session_killed

933

#define thd_tx_isolation(x) ((x)->getTxIsolation())

934

#define thd_in_lock_tables session_in_lock_tables

935

#define thd_tablespace_op(x) ((x)->doingTablespaceOperation())

936

#define thd_alloc session_alloc

937

#define thd_make_lex_string session_make_lex_string

938

#define column_bitmaps_signal()

939

940

#define my_pthread_setspecific_ptr(T, V) pthread_setspecific(T, (void*) (V))

941

942

/* TODO: This is dangerous! */

943

#define mysql_real_data_home ::drizzled::getDataHomeCatalog().file_string().c_str()

944

945

#define mi_int4store(T,A) { uint32_t def_temp= (uint32_t) (A);\

946

((unsigned char*) (T))[3]= (unsigned char) (def_temp);\

947

((unsigned char*) (T))[2]= (unsigned char) (def_temp >> 8);\

948

((unsigned char*) (T))[1]= (unsigned char) (def_temp >> 16);\

949

((unsigned char*) (T))[0]= (unsigned char) (def_temp >> 24); }

950

951

#define mi_uint4korr(A) ((uint32_t) (((uint32_t) (((const unsigned char*) (A))[3])) +\

952

(((uint32_t) (((const unsigned char*) (A))[2])) << 8) +\

953

(((uint32_t) (((const unsigned char*) (A))[1])) << 16) +\

954

(((uint32_t) (((const unsigned char*) (A))[0])) << 24)))

955

956

class PBXTStorageEngine;

957

typedef PBXTStorageEngine handlerton;

958

namespace drizzled {

959

class Session;

960

}

961

962

#define RECORD_0 getInsertRecord()

963

#define TABLE_RECORD_0 getTable()->getInsertRecord()

964

#define TABLE_FIELDS table->getFields()

965

#define MYSQL_LOCK(x) x.lock

966

#define MYSQL_UNLOCK(x) x.unlock

967

#define MYSQL_INIT_LOCK(x, y) x.init(y)

968

#define MYSQL_FREE_LOCK(x) x.deinit()

969

970

#else // DRIZZLED

971

972

/* The MySQL case: */

973

#if MYSQL_VERSION_ID >= 50404

974

#define STRUCT_TABLE struct TABLE

975

#else

976

#define STRUCT_TABLE struct st_table

977

#endif

978

#define GET_TABLE_SHARE(x) (x)->s

979

#define GET_TABLE_FIELDS(x) (x)->field

980

#if MYSQL_VERSION_ID >= 60009

981

#define storage_media default_storage_media

982

#endif

983

984

#define mx_tmp_use_all_columns dbug_tmp_use_all_columns

985

#define mx_tmp_restore_column_map(x, y) dbug_tmp_restore_column_map((x)->read_set, y)

986

#define MX_BIT_FAST_TEST_AND_SET(x, y) bitmap_fast_test_and_set(x, y)

987

988

#define MX_TABLE_TYPES_T ulonglong

989

#define MX_UINT8_T uint8

990

#define MX_ULONG_T ulong

991

#define MX_ULONGLONG_T ulonglong

992

#define MX_LONGLONG_T longlong

993

#define MX_CHARSET_INFO struct charset_info_st

994

#ifdef MARIADB_BASE_VERSION

995

#define MX_CONST_CHARSET_INFO const struct charset_info_st

996

#else

997

#define MX_CONST_CHARSET_INFO struct charset_info_st

998

#endif

999

#define MX_CONST

1000

#define MX_BITMAP MY_BITMAP

1001

#define MX_BIT_SIZE() n_bits

1002

#define MX_BIT_SET(x, y) bitmap_set_bit(x, y)

1003

1004

#define RECORD_0 record[0]

1005

#define TABLE_RECORD_0 table->record[0]

1006

#define TABLE_FIELDS table->field

1007

#define MYSQL_LOCK(x) pthread_mutex_lock(&x)

1008

#define MYSQL_UNLOCK(x) pthread_mutex_unlock(&x)

1009

#define MYSQL_INIT_LOCK(x, y) thr_lock_data_init(y, &x, NULL);

1010

#define MYSQL_FREE_LOCK(x) thr_lock_delete(&x)

1011

1012

#endif // DRIZZLED

1013

1014

#define MX_BIT_IS_SUBSET(x, y) x->is_subset_of(y)

1015

1016

#ifndef XT_SCAN_CORE_DEFINED

1017

#define XT_SCAN_CORE_DEFINED

1018

xtBool xt_mm_scan_core(void);

1019

#endif

1020

1021

//#define DEBUG_LOCK_QUEUE

1022

1023

#endif

Older »