| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/querytele/ |
| H A D | querytele_types.h | 91 bool msg_type; member
132 QTType::type msg_type; variable
167 msg_type = val; in __set_msg_type()
319 if (!(msg_type == rhs.msg_type))
462 bool msg_type; member
492 STType::type msg_type; variable
516 msg_type = val; in __set_msg_type()
600 if (!(msg_type == rhs.msg_type))
685 bool msg_type; member
733 msg_type = val; in __set_msg_type()
[all …]
|
| H A D | queryteleclient.cpp | 46 switch (qts.msg_type) in qts2qt()
49 out.msg_type = QTType::QT_SUMMARY; in qts2qt()
53 out.msg_type = QTType::QT_PROGRESS; in qts2qt()
57 out.msg_type = QTType::QT_START; in qts2qt()
61 out.msg_type = QTType::QT_INVALID; in qts2qt()
101 switch (sts.msg_type) in sts2st()
104 out.msg_type = STType::ST_SUMMARY; in sts2st()
112 out.msg_type = STType::ST_START; in sts2st()
145 switch (its.msg_type) in its2it()
156 out.msg_type = ITType::IT_START; in its2it()
[all …]
|
| H A D | queryteleprotoimpl.cpp | 105 if (qtdata.msg_type == querytele::QTType::QT_SUMMARY) in log_query()
107 else if (qtdata.msg_type == querytele::QTType::QT_START) in log_query()
189 if (stdata.msg_type == querytele::STType::ST_SUMMARY) in log_step()
191 else if (stdata.msg_type == querytele::STType::ST_START) in log_step()
383 …Queue.queue.size() >= MaxQueueElems && stdata.msg_type != querytele::STType::ST_SUMMARY && stdata.… in enqStepTele()
390 stdata.msg_type != gLastStep.msg_type || in enqStepTele()
|
| H A D | serverdriver.cpp | 110 if (qt.msg_type == QTType::QT_SUMMARY) in postQuery()
112 else if (qt.msg_type == QTType::QT_START) in postQuery()
144 if (qt.msg_type == STType::ST_SUMMARY) in postStep()
146 else if (qt.msg_type == STType::ST_START) in postStep()
178 if (qt.msg_type == ITType::IT_SUMMARY) in postImport()
180 else if (qt.msg_type == ITType::IT_START) in postImport()
182 else if (qt.msg_type == ITType::IT_TERM) in postImport()
|
| H A D | tdriver.cpp | 40 qts.msg_type = QueryTeleStats::QT_START; in main()
49 sts.msg_type = StepTeleStats::ST_START; in main()
54 sts.msg_type = StepTeleStats::ST_PROGRESS; in main()
59 sts.msg_type = StepTeleStats::ST_SUMMARY; in main()
64 qts.msg_type = QueryTeleStats::QT_SUMMARY; in main()
|
| H A D | telestats.h | 44 msg_type(QT_INVALID), in QueryTeleStats()
68 QTType msg_type; member
123 msg_type(ST_INVALID), in StepTeleStats()
144 STType msg_type; member
175 msg_type(IT_INVALID), in ImportTeleStats()
185 ITType msg_type; member
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/writeengine/bulk/ |
| H A D | we_tableinfo.cpp | 279 its.msg_type = ImportTeleStats::IT_START; in readTableData()
300 its.msg_type = ImportTeleStats::IT_TERM; in readTableData()
335 its.msg_type = ImportTeleStats::IT_TERM; in readTableData()
437 its.msg_type = ImportTeleStats::IT_TERM; in readTableData()
448 its.msg_type = ImportTeleStats::IT_PROGRESS; in readTableData()
492 its.msg_type = ImportTeleStats::IT_TERM; in readTableData()
590 its.msg_type = ImportTeleStats::IT_SUMMARY; in readTableData()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/maria/ |
| H A D | ha_maria.cc | 409 static void _ma_check_print(HA_CHECK *param, const char* msg_type, in _ma_check_print() argument
412 if (msg_type == MA_CHECK_INFO) in _ma_check_print()
415 else if (msg_type == MA_CHECK_WARNING) in _ma_check_print()
425 static void _ma_check_print_msg(HA_CHECK *param, const char *msg_type, in _ma_check_print_msg() argument
440 DBUG_PRINT(msg_type, ("message: %s", msgbuf)); in _ma_check_print_msg()
444 _ma_check_print(param, msg_type, msgbuf); in _ma_check_print_msg()
452 if (msg_type == MA_CHECK_INFO) in _ma_check_print_msg()
454 else if (msg_type == MA_CHECK_WARNING) in _ma_check_print_msg()
458 _ma_check_print(param, msg_type, msgbuf); in _ma_check_print_msg()
474 protocol->store(msg_type, system_charset_info); in _ma_check_print_msg()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/myisam/ |
| H A D | ha_myisam.cc | 138 static void mi_check_print(HA_CHECK *param, const char* msg_type, in mi_check_print() argument
141 if (msg_type == MI_CHECK_INFO) in mi_check_print()
144 else if (msg_type == MI_CHECK_WARNING) in mi_check_print()
153 static void mi_check_print_msg(HA_CHECK *param, const char* msg_type, in mi_check_print_msg() argument
168 DBUG_PRINT(msg_type,("message: %s",msgbuf)); in mi_check_print_msg()
172 mi_check_print(param, msg_type, msgbuf); in mi_check_print_msg()
180 if (msg_type == MI_CHECK_INFO) in mi_check_print_msg()
182 else if (msg_type == MI_CHECK_WARNING) in mi_check_print_msg()
186 mi_check_print(param, msg_type, msgbuf); in mi_check_print_msg()
205 protocol->store(msg_type, system_charset_info); in mi_check_print_msg()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | roll.cc | 398 const enum ft_msg_type msg_type = (is_resetting_op in toku_commit_cmdupdatebroadcast() local
402 return do_insertion(msg_type, filenum, nullkey, 0, txn, oplsn, reset_root_xid_that_created); in toku_commit_cmdupdatebroadcast()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/sql/ |
| H A D | ha_partition.cc | 1399 const char* msg_type,
1404 const char* msg_type, in print_admin_msg() argument
1442 msg_type, msgbuf)); in print_admin_msg()
1446 protocol->store(msg_type, system_charset_info); in print_admin_msg()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dbcon/joblist/ |
| H A D | crossenginestep.cpp | 433 sts.msg_type = StepTeleStats::ST_START; in execute()
626 sts.msg_type = StepTeleStats::ST_SUMMARY; in execute()
|
| H A D | pdictionaryscan.cpp | 583 sts.msg_type = StepTeleStats::ST_START; in receivePrimitiveMessages()
693 sts.msg_type = StepTeleStats::ST_PROGRESS; in receivePrimitiveMessages()
827 sts.msg_type = StepTeleStats::ST_SUMMARY; in receivePrimitiveMessages()
|
| H A D | subquerystep.cpp | 378 sts.msg_type = StepTeleStats::ST_START; in execute()
455 sts.msg_type = StepTeleStats::ST_SUMMARY; in execute()
|
| H A D | tuple-bps.cpp | 2062 … if (fOid >= 3000 && threadID == 0 && sts.msg_type == StepTeleStats::ST_INVALID && size > 0) in receiveMultiPrimitiveMessages()
2064 sts.msg_type = StepTeleStats::ST_START; in receiveMultiPrimitiveMessages()
2367 sts.msg_type = StepTeleStats::ST_PROGRESS; in receiveMultiPrimitiveMessages()
2608 sts.msg_type = StepTeleStats::ST_SUMMARY; in receiveMultiPrimitiveMessages()
|
| H A D | tupleaggregatestep.cpp | 653 sts.msg_type = StepTeleStats::ST_SUMMARY; in nextBand_singleThread()
5163 sts.msg_type = StepTeleStats::ST_START; in aggregateRowGroups()
5294 sts.msg_type = StepTeleStats::ST_START; in threadedAggregateRowGroups()
5579 sts.msg_type = StepTeleStats::ST_SUMMARY; in doAggregate_singleThread()
5798 sts.msg_type = StepTeleStats::ST_SUMMARY; in doThreadedAggregate()
|
| H A D | tupleannexstep.cpp | 266 sts.msg_type = StepTeleStats::ST_START; in run()
369 sts.msg_type = StepTeleStats::ST_SUMMARY; in execute()
408 sts.msg_type = StepTeleStats::ST_START; in executeNoOrderBy()
514 sts.msg_type = StepTeleStats::ST_START; in executeNoOrderByWithDistinct()
631 sts.msg_type = StepTeleStats::ST_START; in executeWithOrderBy()
899 sts.msg_type = StepTeleStats::ST_SUMMARY; in finalizeParallelOrderByDistinct()
1094 sts.msg_type = StepTeleStats::ST_SUMMARY; in finalizeParallelOrderBy()
|
| H A D | tupleconstantstep.cpp | 411 sts.msg_type = StepTeleStats::ST_START; in execute()
451 sts.msg_type = StepTeleStats::ST_SUMMARY; in execute()
|
| H A D | tuplehashjoin.cpp | 632 sts.msg_type = StepTeleStats::ST_START; in hjRunner()
968 sts.msg_type = StepTeleStats::ST_SUMMARY; in hjRunner()
|
| H A D | tuplehavingstep.cpp | 276 sts.msg_type = StepTeleStats::ST_START; in execute()
319 sts.msg_type = StepTeleStats::ST_SUMMARY; in execute()
|
| H A D | tupleunion.cpp | 197 sts.msg_type = StepTeleStats::ST_START; in readInput()
312 sts.msg_type = StepTeleStats::ST_SUMMARY; in readInput()
|
| H A D | windowfunctionstep.cpp | 906 sts.msg_type = StepTeleStats::ST_START; in execute()
969 sts.msg_type = StepTeleStats::ST_SUMMARY; in execute()
1024 sts.msg_type = StepTeleStats::ST_SUMMARY; in execute()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/ddlproc/ |
| H A D | ddlprocessor.cpp | 104 qts.msg_type = QueryTeleStats::QT_START; in operator ()()
119 qts.msg_type = QueryTeleStats::QT_SUMMARY; in operator ()()
137 qts.msg_type = QueryTeleStats::QT_START; in operator ()()
154 qts.msg_type = QueryTeleStats::QT_SUMMARY; in operator ()()
173 qts.msg_type = QueryTeleStats::QT_START; in operator ()()
189 qts.msg_type = QueryTeleStats::QT_SUMMARY; in operator ()()
208 qts.msg_type = QueryTeleStats::QT_START; in operator ()()
223 qts.msg_type = QueryTeleStats::QT_SUMMARY; in operator ()()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/dmlproc/ |
| H A D | dmlprocessor.cpp | 583 qts.msg_type = QueryTeleStats::QT_START; in run()
922 qts.msg_type = QueryTeleStats::QT_SUMMARY; in run()
966 qts.msg_type = QueryTeleStats::QT_START; in run()
983 qts.msg_type = QueryTeleStats::QT_SUMMARY; in run()
1025 qts.msg_type = QueryTeleStats::QT_START; in run()
1041 qts.msg_type = QueryTeleStats::QT_SUMMARY; in run()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/exemgr/ |
| H A D | main.cpp | 703 qts.msg_type = querytele::QueryTeleStats::QT_START; in operator ()()
1220 qts.msg_type = querytele::QueryTeleStats::QT_SUMMARY; in operator ()()
|