File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -241,9 +241,6 @@ bool noThreadsWaiting();
241241
242242void workerThread (GThreadData& td); // Thread function
243243
244- // check if a worker thread popped the data queue:
245- bool queuePopped (GPVec<BundleData>& bundleQueue, int prevCount);
246-
247244// prepare the next free bundle for loading
248245int waitForData (BundleData* bundles);
249246#endif
@@ -1355,15 +1352,6 @@ void workerThread(GThreadData& td) {
13551352 DBGPRINT2 (" ---->> Thread%d DONE.\n " , td.thread ->get_id ());
13561353}
13571354
1358- bool queuePopped (GPVec<BundleData>& bundleQueue, int prevCount) {
1359- int c;
1360- queueMutex.lock ();
1361- c=bundleQueue.Count ();
1362- queueMutex.unlock ();
1363- DBGPRINT3 (" ##> post-notification check: qlen is now %d (was %d)\n " , c, prevCount);
1364- return (c==0 || c<prevCount);
1365- }
1366-
13671355// prepare the next available bundle slot for loading
13681356int waitForData (BundleData* bundles) {
13691357 int bidx=-1 ;
You can’t perform that action at this time.
0 commit comments