File tree 1 file changed +1
-18
lines changed
1 file changed +1
-18
lines changed Original file line number Diff line number Diff line change @@ -432,25 +432,8 @@ void UserQuerySelect::submit() {
432
432
uberJobId++, _qMetaCzarId);
433
433
434
434
int chunksInUber = 0 ;
435
- // &&&czar::WorkerResource& wr = *workerIter;
436
435
deque<int >& dq = workerIter->second ;
437
- /* &&&
438
- auto& wChunkIdSet = wr.chunkIdSet;
439
- for(auto&& wcIter = wChunkIdSet.begin();
440
- wcIter != wChunkIdSet.end() && !chunksInQuery.empty() && chunksInUber < maxChunksPerUber;) {
441
-
442
- int chunkIdWorker = *wcIter;
443
- auto oldIter = wcIter;
444
- ++wcIter;
445
- wChunkIdSet.erase(oldIter);
446
- auto found = chunksInQuery.find(chunkIdWorker);
447
- if (found != chunksInQuery.end()) {
448
- uJob->addJob(found->second);
449
- ++chunksInUber;
450
- chunksInQuery.erase(found);
451
- }
452
- }
453
- */
436
+
454
437
while (!dq.empty () && !chunksInQuery.empty () && chunksInUber < maxChunksPerUber) {
455
438
int chunkIdWorker = dq.front ();
456
439
dq.pop_front ();
You can’t perform that action at this time.
0 commit comments