diff --git a/common/workunit/wujobq.cpp b/common/workunit/wujobq.cpp index e97543f933a..71a40ebd882 100644 --- a/common/workunit/wujobq.cpp +++ b/common/workunit/wujobq.cpp @@ -1264,13 +1264,6 @@ class CJobQueue: public CJobQueueBase, implements IJobQueue } - IJobQueueItem *prioDequeue(int minprio,unsigned timeout=INFINITE) // minprio == MAX_INT - used cache priority - { - return dodequeue(minprio,timeout); - } - - - void placeonqueue(sQueueData &qd, IJobQueueItem *qitem,unsigned idx) // takes ownership of qitem { Owned qi = qitem; diff --git a/common/workunit/wujobq.hpp b/common/workunit/wujobq.hpp index 5a3cc35f095..efa74462aaf 100644 --- a/common/workunit/wujobq.hpp +++ b/common/workunit/wujobq.hpp @@ -110,7 +110,6 @@ interface IJobQueue: extends IJobQueueConst virtual void connect(bool validateitemsessions)=0; // must be called before dequeueing // validateitemsessions ensures that all queue items have running session virtual IJobQueueItem *dequeue(unsigned timeout=INFINITE)=0; - virtual IJobQueueItem *prioDequeue(int minprio,unsigned timeout=INFINITE)=0; virtual void disconnect()=0; // signal no longer wil be dequeing (optional - done automatically on release) virtual void getStats(unsigned &connected,unsigned &waiting, unsigned &enqueued)=0; // this not quick as validates clients still running virtual bool waitStatsChange(unsigned timeout)=0;