| 1104 | } |
| 1105 | |
| 1106 | void ProcessThread() { |
| 1107 | for (;;) { |
| 1108 | if (!process_.WaitAndPop()) { |
| 1109 | EndFromProcessThread(); |
| 1110 | return; |
| 1111 | } |
| 1112 | if (!Process()) { |
| 1113 | return; |
| 1114 | } |
| 1115 | } |
| 1116 | } |
| 1117 | |
| 1118 | static void ProcessThreadWrapper(AsofJoinNode* node) { node->ProcessThread(); } |
| 1119 | #endif |
no test coverage detected