Searched refs:ManagedQueue (Results 1 – 5 of 5) sorted by relevance
| /dports/www/gitea/gitea-1.16.5/modules/queue/ |
| H A D | manager.go | 27 Queues map[int64]*ManagedQueue
34 type ManagedQueue struct { struct
80 type ManagedQueueList []*ManagedQueue
104 Queues: make(map[int64]*ManagedQueue),
117 mq := &ManagedQueue{
211 go func(q *ManagedQueue) {
245 mqs := make([]*ManagedQueue, 0, len(m.Queues))
255 func (q *ManagedQueue) Workers() []*PoolWorkers { argument
324 func (q *ManagedQueue) IsEmpty() bool { argument
332 func (q *ManagedQueue) NumberOfWorkers() int { argument
[all …]
|
| /dports/net/zerotier/ZeroTierOne-1.8.3/node/ |
| H A D | Switch.hpp | 59 struct ManagedQueue;
117 dqr dodequeue(ManagedQueue *q, uint64_t now);
144 Switch::TXQueueEntry * CoDelDequeue(ManagedQueue *q, bool isNew, uint64_t now);
299 struct ManagedQueue struct in ZeroTier::Switch
301 ManagedQueue(int id) : in ManagedQueue() function
321 std::vector<ManagedQueue *> newQueues;
322 std::vector<ManagedQueue *> oldQueues;
323 std::vector<ManagedQueue *> inactiveQueues;
|
| H A D | Switch.cpp | 608 nqcb->inactiveQueues.push_back(new ManagedQueue(i)); in aqm_enqueue()
623 ManagedQueue *selectedQueue = nullptr; in aqm_enqueue()
655 ManagedQueue *selectedQueueToDropFrom = nullptr; in aqm_enqueue()
696 Switch::dqr Switch::dodequeue(ManagedQueue *q, uint64_t now) in dodequeue()
722 Switch::TXQueueEntry * Switch::CoDelDequeue(ManagedQueue *q, bool isNew, uint64_t now) in CoDelDequeue()
763 std::vector<ManagedQueue*> *currQueues = &((*nqcb).second->newQueues); in aqm_dequeue()
764 std::vector<ManagedQueue*> *oldQueues = &((*nqcb).second->oldQueues); in aqm_dequeue()
765 std::vector<ManagedQueue*> *inactiveQueues = &((*nqcb).second->inactiveQueues); in aqm_dequeue()
772 ManagedQueue *queueAtFrontOfList = currQueues->front(); in aqm_dequeue()
807 ManagedQueue *queueAtFrontOfList = currQueues->front(); in aqm_dequeue()
|
| /dports/audio/noson-app/noson-app-4.5.0/backend/NosonApp/ |
| H A D | player.h | 307 typedef RegisteredContent<Player> ManagedQueue; in my_facet()
308 Locked<ManagedQueue> m_queue; in my_facet()
315 static void unregisterContent(ManagedQueue& mq); in my_facet()
|
| H A D | player.cpp | 43 , m_queue(ManagedQueue(nullptr, "")) in Player()
1536 void Player::unregisterContent(ManagedQueue& mq) in unregisterContent()
|