| 1193 | } |
| 1194 | |
| 1195 | std::string blockingReasonToString(BlockingReason reason) { |
| 1196 | switch (reason) { |
| 1197 | case BlockingReason::kNotBlocked: |
| 1198 | return "kNotBlocked"; |
| 1199 | case BlockingReason::kWaitForConsumer: |
| 1200 | return "kWaitForConsumer"; |
| 1201 | case BlockingReason::kWaitForSplit: |
| 1202 | return "kWaitForSplit"; |
| 1203 | case BlockingReason::kWaitForProducer: |
| 1204 | return "kWaitForProducer"; |
| 1205 | case BlockingReason::kWaitForJoinBuild: |
| 1206 | return "kWaitForJoinBuild"; |
| 1207 | case BlockingReason::kWaitForJoinProbe: |
| 1208 | return "kWaitForJoinProbe"; |
| 1209 | case BlockingReason::kWaitForMergeJoinRightSide: |
| 1210 | return "kWaitForMergeJoinRightSide"; |
| 1211 | case BlockingReason::kWaitForMemory: |
| 1212 | return "kWaitForMemory"; |
| 1213 | case BlockingReason::kWaitForConnector: |
| 1214 | return "kWaitForConnector"; |
| 1215 | case BlockingReason::kWaitForSpill: |
| 1216 | return "kWaitForSpill"; |
| 1217 | case BlockingReason::kYield: |
| 1218 | return "kYield"; |
| 1219 | case BlockingReason::kWaitForData: |
| 1220 | return "kWaitForData"; |
| 1221 | case BlockingReason::kWaitForArbitration: |
| 1222 | return "kWaitForArbitration"; |
| 1223 | case BlockingReason::kWaitForScanScaleUp: |
| 1224 | return "kWaitForScanScaleUp"; |
| 1225 | case BlockingReason::kWaitForIndexLookup: |
| 1226 | return "kWaitForIndexLookup"; |
| 1227 | default: |
| 1228 | BOLT_UNREACHABLE( |
| 1229 | fmt::format("Unknown blocking reason {}", static_cast<int>(reason))); |
| 1230 | } |
| 1231 | BOLT_UNREACHABLE(); |
| 1232 | return ""; |
| 1233 | } |
| 1234 | |
| 1235 | DriverThreadContext* driverThreadContext() { |
| 1236 | return driverThreadCtx; |
no outgoing calls
no test coverage detected