| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/ddlproc/ |
| H A D | ddlprocessor.cpp | 112 fQtc.postQueryTele(qts); in operator ()()
121 fQtc.postQueryTele(qts); in operator ()()
145 fQtc.postQueryTele(qts); in operator ()()
156 fQtc.postQueryTele(qts); in operator ()()
181 fQtc.postQueryTele(qts); in operator ()()
191 fQtc.postQueryTele(qts); in operator ()()
216 fQtc.postQueryTele(qts); in operator ()()
225 fQtc.postQueryTele(qts); in operator ()()
332 QueryTeleClient fQtc; member
683 handler.fQtc = fQtc; in process()
[all …]
|
| H A D | ddlprocessor.h | 98 querytele::QueryTeleClient fQtc; variable
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/ddlproc/ |
| H A D | ddlprocessor.cpp | 112 fQtc.postQueryTele(qts); in operator ()()
121 fQtc.postQueryTele(qts); in operator ()()
145 fQtc.postQueryTele(qts); in operator ()()
156 fQtc.postQueryTele(qts); in operator ()()
181 fQtc.postQueryTele(qts); in operator ()()
191 fQtc.postQueryTele(qts); in operator ()()
216 fQtc.postQueryTele(qts); in operator ()()
225 fQtc.postQueryTele(qts); in operator ()()
332 QueryTeleClient fQtc; member
683 handler.fQtc = fQtc; in process()
[all …]
|
| H A D | ddlprocessor.h | 98 querytele::QueryTeleClient fQtc; variable
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
| H A D | jobstep.h | 446 fQtc.postStepTele(sts); in postStepStartTele()
456 fQtc.postStepTele(sts); in postStepProgressTele()
464 fQtc.postStepTele(sts); in postStepSummaryTele()
501 querytele::QueryTeleClient fQtc; variable
|
| H A D | jobstep.cpp | 109 fQtc.serverParms(tsp); in JobStep()
|
| H A D | tuplehavingstep.cpp | 72 fQtc.stepParms().stepType = StepTeleStats::T_HVS; in TupleHavingStep()
|
| H A D | subquerystep.cpp | 67 fQtc.stepParms().stepType = StepTeleStats::T_SQS; in SubQueryStep()
|
| H A D | tuple-bps.cpp | 279 fQtc.stepParms().stepType = StepTeleStats::T_BPS; in TupleBPS()
364 fQtc.stepParms().stepType = StepTeleStats::T_BPS; in TupleBPS()
431 fQtc.stepParms().stepType = StepTeleStats::T_BPS; in TupleBPS()
496 fQtc.stepParms().stepType = StepTeleStats::T_BPS; in TupleBPS()
|
| H A D | tupleconstantstep.cpp | 89 fQtc.stepParms().stepType = StepTeleStats::T_TCS; in TupleConstantStep()
|
| H A D | pdictionaryscan.cpp | 208 fQtc.stepParms().stepType = StepTeleStats::T_DSS; in pDictionaryScan()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
| H A D | jobstep.h | 446 fQtc.postStepTele(sts); in postStepStartTele()
456 fQtc.postStepTele(sts); in postStepProgressTele()
464 fQtc.postStepTele(sts); in postStepSummaryTele()
501 querytele::QueryTeleClient fQtc; variable
|
| H A D | jobstep.cpp | 109 fQtc.serverParms(tsp); in JobStep()
|
| H A D | tuplehavingstep.cpp | 72 fQtc.stepParms().stepType = StepTeleStats::T_HVS; in TupleHavingStep()
|
| H A D | subquerystep.cpp | 67 fQtc.stepParms().stepType = StepTeleStats::T_SQS; in SubQueryStep()
|
| H A D | tuple-bps.cpp | 279 fQtc.stepParms().stepType = StepTeleStats::T_BPS; in TupleBPS()
364 fQtc.stepParms().stepType = StepTeleStats::T_BPS; in TupleBPS()
431 fQtc.stepParms().stepType = StepTeleStats::T_BPS; in TupleBPS()
496 fQtc.stepParms().stepType = StepTeleStats::T_BPS; in TupleBPS()
|
| H A D | tupleconstantstep.cpp | 89 fQtc.stepParms().stepType = StepTeleStats::T_TCS; in TupleConstantStep()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/dmlproc/ |
| H A D | dmlprocessor.h | 214 querytele::QueryTeleClient fQtc; variable
290 querytele::QueryTeleClient fQtc; variable
|
| H A D | dmlprocessor.cpp | 327 fQtc(qtc), in PackageHandler()
591 fQtc.postQueryTele(qts); in run()
934 fQtc.postQueryTele(qts); in run()
974 fQtc.postQueryTele(qts); in run()
995 fQtc.postQueryTele(qts); in run()
1033 fQtc.postQueryTele(qts); in run()
1053 fQtc.postQueryTele(qts); in run()
1291 fQtc.serverParms(QueryTeleServerParms(teleServerHost, teleServerPort)); in DMLProcessor()
1715 … fConcurrentSupport, maxDeleteRows, sessionID, txnid.id, fDbrm, fQtc, csc)); in operator ()()
1757 … fConcurrentSupport, maxDeleteRows, sessionID, 0, fDbrm, fQtc, csc)); in operator ()()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dmlproc/ |
| H A D | dmlprocessor.h | 214 querytele::QueryTeleClient fQtc; variable
290 querytele::QueryTeleClient fQtc; variable
|
| H A D | dmlprocessor.cpp | 327 fQtc(qtc), in PackageHandler()
591 fQtc.postQueryTele(qts); in run()
934 fQtc.postQueryTele(qts); in run()
974 fQtc.postQueryTele(qts); in run()
995 fQtc.postQueryTele(qts); in run()
1033 fQtc.postQueryTele(qts); in run()
1053 fQtc.postQueryTele(qts); in run()
1291 fQtc.serverParms(QueryTeleServerParms(teleServerHost, teleServerPort)); in DMLProcessor()
1715 … fConcurrentSupport, maxDeleteRows, sessionID, txnid.id, fDbrm, fQtc, csc)); in operator ()()
1757 … fConcurrentSupport, maxDeleteRows, sessionID, 0, fDbrm, fQtc, csc)); in operator ()()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/bulk/ |
| H A D | we_tableinfo.cpp | 146 fQtc.serverParms(QueryTeleServerParms(teleServerHost, teleServerPort)); in TableInfo()
287 fQtc.postImportTele(its); in readTableData()
303 fQtc.postImportTele(its); in readTableData()
338 fQtc.postImportTele(its); in readTableData()
440 fQtc.postImportTele(its); in readTableData()
456 fQtc.postImportTele(its); in readTableData()
495 fQtc.postImportTele(its); in readTableData()
594 fQtc.postImportTele(its); in readTableData()
595 fQtc.waitForQueues(); in readTableData()
|
| H A D | we_tableinfo.h | 169 querytele::QueryTeleClient fQtc; // Query Tele client variable
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/bulk/ |
| H A D | we_tableinfo.cpp | 146 fQtc.serverParms(QueryTeleServerParms(teleServerHost, teleServerPort)); in TableInfo()
287 fQtc.postImportTele(its); in readTableData()
303 fQtc.postImportTele(its); in readTableData()
338 fQtc.postImportTele(its); in readTableData()
440 fQtc.postImportTele(its); in readTableData()
456 fQtc.postImportTele(its); in readTableData()
495 fQtc.postImportTele(its); in readTableData()
594 fQtc.postImportTele(its); in readTableData()
595 fQtc.waitForQueues(); in readTableData()
|
| H A D | we_tableinfo.h | 169 querytele::QueryTeleClient fQtc; // Query Tele client variable
|