Commit dc303220 authored by Olivier Bertrand's avatar Olivier Bertrand

Merge branch 'ob-10.1' into 10.1

parents 3c6ba5b9 83455972
...@@ -19,3 +19,4 @@ json_java_3 : Need MongoDB running and its Java Driver installed ...@@ -19,3 +19,4 @@ json_java_3 : Need MongoDB running and its Java Driver installed
mongo_c : Need MongoDB running and its C Driver installed mongo_c : Need MongoDB running and its C Driver installed
mongo_java_2 : Need MongoDB running and its Java Driver installed mongo_java_2 : Need MongoDB running and its Java Driver installed
mongo_java_3 : Need MongoDB running and its Java Driver installed mongo_java_3 : Need MongoDB running and its Java Driver installed
tbl_thread : Bug MDEV-9844,10179,14214 03/01/2018 OB Option THREAD removed
/************* TabTbl C++ Program Source Code File (.CPP) **************/ /************* TabTbl C++ Program Source Code File (.CPP) **************/
/* PROGRAM NAME: TABTBL */ /* PROGRAM NAME: TABTBL */
/* ------------- */ /* ------------- */
/* Version 1.8 */ /* Version 1.9 */
/* */ /* */
/* COPYRIGHT: */ /* Author: Olivier BERTRAND 2008-2018 */
/* ---------- */
/* (C) Copyright to PlugDB Software Development 2008-2017 */
/* Author: Olivier BERTRAND */
/* */ /* */
/* WHAT THIS PROGRAM DOES: */ /* WHAT THIS PROGRAM DOES: */
/* ----------------------- */ /* ----------------------- */
...@@ -168,9 +165,14 @@ PTDB TBLDEF::GetTable(PGLOBAL g, MODE) ...@@ -168,9 +165,14 @@ PTDB TBLDEF::GetTable(PGLOBAL g, MODE)
{ {
if (Catfunc == FNC_COL) if (Catfunc == FNC_COL)
return new(g) TDBTBC(this); return new(g) TDBTBC(this);
else if (Thread) else if (Thread) {
#if defined(DEVELOPMENT)
return new(g) TDBTBM(this); return new(g) TDBTBM(this);
else #else
strcpy(g->Message, "Option THREAD is no more supported");
return NULL;
#endif // DEVELOPMENT
} else
return new(g) TDBTBL(this); return new(g) TDBTBL(this);
} // end of GetTable } // end of GetTable
...@@ -560,6 +562,7 @@ void TBTBLK::ReadColumn(PGLOBAL) ...@@ -560,6 +562,7 @@ void TBTBLK::ReadColumn(PGLOBAL)
} // end of ReadColumn } // end of ReadColumn
#if defined(DEVELOPMENT)
/* ------------------------- Class TDBTBM ---------------------------- */ /* ------------------------- Class TDBTBM ---------------------------- */
/***********************************************************************/ /***********************************************************************/
...@@ -865,5 +868,6 @@ int TDBTBM::ReadNextRemote(PGLOBAL g) ...@@ -865,5 +868,6 @@ int TDBTBM::ReadNextRemote(PGLOBAL g)
return RC_OK; return RC_OK;
} // end of ReadNextRemote } // end of ReadNextRemote
#endif // DEVELOPMENT
/* ------------------------------------------------------------------- */ /* ------------------------------------------------------------------- */
...@@ -11,29 +11,8 @@ ...@@ -11,29 +11,8 @@
typedef class TBLDEF *PTBLDEF; typedef class TBLDEF *PTBLDEF;
typedef class TDBTBL *PTDBTBL; typedef class TDBTBL *PTDBTBL;
typedef class TDBTBM *PTDBTBM;
typedef class MYSQLC *PMYC; typedef class MYSQLC *PMYC;
/***********************************************************************/
/* Defines the structures used for distributed TBM tables. */
/***********************************************************************/
typedef struct _TBMtable *PTBMT;
typedef struct _TBMtable {
PTBMT Next; // Points to next data table struct
PTABLE Tap; // Points to the sub table
PGLOBAL G; // Needed in thread routine
bool Complete; // TRUE when all results are read
bool Ready; // TRUE when results are there
int Rows; // Total number of rows read so far
int ProgCur; // Current pos
int ProgMax; // Max pos
int Rc; // Return code
THD *Thd;
pthread_attr_t attr; // ???
pthread_t Tid; // CheckOpen thread ID
} TBMT;
/***********************************************************************/ /***********************************************************************/
/* TBL table. */ /* TBL table. */
/***********************************************************************/ /***********************************************************************/
...@@ -123,7 +102,33 @@ class TBTBLK : public TIDBLK { ...@@ -123,7 +102,33 @@ class TBTBLK : public TIDBLK {
protected: protected:
// Must not have additional members // Must not have additional members
}; // end of class TBTBLK }; // end of class TBTBLK
#if defined(DEVELOPMENT)
/***********************************************************************/
/* This table type is buggy and removed until a fix is found. */
/***********************************************************************/
typedef class TDBTBM *PTDBTBM;
/***********************************************************************/
/* Defines the structures used for distributed TBM tables. */
/***********************************************************************/
typedef struct _TBMtable *PTBMT;
typedef struct _TBMtable {
PTBMT Next; // Points to next data table struct
PTABLE Tap; // Points to the sub table
PGLOBAL G; // Needed in thread routine
bool Complete; // TRUE when all results are read
bool Ready; // TRUE when results are there
int Rows; // Total number of rows read so far
int ProgCur; // Current pos
int ProgMax; // Max pos
int Rc; // Return code
THD *Thd;
pthread_attr_t attr; // ???
pthread_t Tid; // CheckOpen thread ID
} TBMT;
/***********************************************************************/ /***********************************************************************/
/* This is the TBM Access Method class declaration. */ /* This is the TBM Access Method class declaration. */
...@@ -160,3 +165,4 @@ class DllExport TDBTBM : public TDBTBL { ...@@ -160,3 +165,4 @@ class DllExport TDBTBM : public TDBTBL {
}; // end of class TDBTBM }; // end of class TDBTBM
pthread_handler_t ThreadOpen(void *p); pthread_handler_t ThreadOpen(void *p);
#endif // DEVELOPMENT
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment