| 87 | Ready.Signal(); |
| 88 | } |
| 89 | void GetResults(TVector<TVector<char>>* res) { |
| 90 | Ready.Reset(); |
| 91 | if (AtomicGet(QueryCount) != AtomicGet(ResultCount)) |
| 92 | Ready.Wait(); |
| 93 | if (res) |
| 94 | res->swap(Results); |
| 95 | Results.resize(0); |
| 96 | AtomicSet(QueryCount, 0); |
| 97 | AtomicSet(ResultCount, 0); |
| 98 | } |
| 99 | }; |
| 100 | ////////////////////////////////////////////////////////////////////////// |
| 101 | TGUID TRemoteQueryProcessor::SendQuery(int compId, const char* query, TVector<char>* cmdData, IRemoteQueryResponseNotify* proc, int resId) { |