| /dports/www/chromium-legacy/chromium-88.0.4324.182/extensions/browser/updater/ |
| H A D | request_queue_impl.h | 21 RequestQueue<T>::RequestQueue( in RequestQueue() function
28 RequestQueue<T>::~RequestQueue() = default;
31 T* RequestQueue<T>::active_request() { in active_request()
36 int RequestQueue<T>::active_request_failure_count() { in active_request_failure_count()
54 void RequestQueue<T>::PushImpl( in PushImpl()
64 bool RequestQueue<T>::empty() const { in empty()
69 size_t RequestQueue<T>::size() const { in size()
79 void RequestQueue<T>::StartNextRequest() { in StartNextRequest()
129 typename RequestQueue<T>::iterator RequestQueue<T>::begin() { in begin()
134 typename RequestQueue<T>::iterator RequestQueue<T>::end() { in end()
[all …]
|
| H A D | request_queue.h | 38 class RequestQueue {
42 RequestQueue(const net::BackoffEntry::Policy* backoff_policy,
44 ~RequestQueue();
120 class RequestQueue<T>::iterator {
133 friend class RequestQueue<T>;
134 typedef base::circular_deque<typename RequestQueue<T>::Request> Container;
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/extensions/browser/updater/ |
| H A D | request_queue_impl.h | 21 RequestQueue<T>::RequestQueue( in RequestQueue() function
28 RequestQueue<T>::~RequestQueue() = default;
31 T* RequestQueue<T>::active_request() { in active_request()
36 int RequestQueue<T>::active_request_failure_count() { in active_request_failure_count()
54 void RequestQueue<T>::PushImpl( in PushImpl()
64 bool RequestQueue<T>::empty() const { in empty()
69 size_t RequestQueue<T>::size() const { in size()
79 void RequestQueue<T>::StartNextRequest() { in StartNextRequest()
130 typename RequestQueue<T>::iterator RequestQueue<T>::begin() { in begin()
135 typename RequestQueue<T>::iterator RequestQueue<T>::end() { in end()
[all …]
|
| H A D | request_queue.h | 38 class RequestQueue {
42 RequestQueue(const net::BackoffEntry::Policy* backoff_policy,
44 ~RequestQueue();
120 class RequestQueue<T>::iterator {
133 friend class RequestQueue<T>;
134 typedef base::circular_deque<typename RequestQueue<T>::Request> Container;
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/components/offline_pages/core/background/ |
| H A D | request_queue.cc | 40 RequestQueue::RequestQueue(std::unique_ptr<RequestQueueStore> store) in RequestQueue() function in offline_pages::RequestQueue
45 RequestQueue::~RequestQueue() {} in ~RequestQueue()
47 void RequestQueue::OnTaskQueueIsIdle() {} in OnTaskQueueIsIdle()
76 void RequestQueue::RemoveRequestsIf( in RemoveRequestsIf()
85 void RequestQueue::ChangeRequestsState( in ChangeRequestsState()
94 void RequestQueue::MarkAttemptStarted(int64_t request_id, in MarkAttemptStarted()
116 void RequestQueue::SetAutoFetchNotificationState( in SetAutoFetchNotificationState()
132 void RequestQueue::PickNextRequest( in PickNextRequest()
159 void RequestQueue::CleanupRequestQueue() { in CleanupRequestQueue()
167 void RequestQueue::Initialize() { in Initialize()
[all …]
|
| H A D | request_queue.h | 36 class RequestQueue : public TaskQueue::Delegate {
66 explicit RequestQueue(std::unique_ptr<RequestQueueStore> store);
67 ~RequestQueue() override;
170 base::WeakPtrFactory<RequestQueue> weak_ptr_factory_{this};
172 DISALLOW_COPY_AND_ASSIGN(RequestQueue);
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/offline_pages/core/background/ |
| H A D | request_queue.cc | 40 RequestQueue::RequestQueue(std::unique_ptr<RequestQueueStore> store) in RequestQueue() function in offline_pages::RequestQueue
45 RequestQueue::~RequestQueue() {} in ~RequestQueue()
47 void RequestQueue::OnTaskQueueIsIdle() {} in OnTaskQueueIsIdle()
76 void RequestQueue::RemoveRequestsIf( in RemoveRequestsIf()
85 void RequestQueue::ChangeRequestsState( in ChangeRequestsState()
94 void RequestQueue::MarkAttemptStarted(int64_t request_id, in MarkAttemptStarted()
116 void RequestQueue::SetAutoFetchNotificationState( in SetAutoFetchNotificationState()
132 void RequestQueue::PickNextRequest( in PickNextRequest()
159 void RequestQueue::CleanupRequestQueue() { in CleanupRequestQueue()
167 void RequestQueue::Initialize() { in Initialize()
[all …]
|
| H A D | request_queue.h | 36 class RequestQueue : public TaskQueue::Delegate {
66 explicit RequestQueue(std::unique_ptr<RequestQueueStore> store);
67 ~RequestQueue() override;
170 base::WeakPtrFactory<RequestQueue> weak_ptr_factory_{this};
172 DISALLOW_COPY_AND_ASSIGN(RequestQueue);
|
| /dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/fastcgi/src/ |
| H A D | request_queue.cc | 23 RequestQueue::RequestQueue() in RequestQueue() function in RequestQueue
30 RequestQueue::~RequestQueue() in ~RequestQueue()
37 RequestQueue::isQueueFull() in isQueueFull()
47 RequestQueue::getSize() in getSize()
53 RequestQueue::isQueueEmpty() in isQueueEmpty()
63 RequestQueue::addToQueue(ServerIntercept *intercept) in addToQueue()
75 RequestQueue::popFromQueue() in popFromQueue()
|
| /dports/editors/libreoffice/libreoffice-7.2.6.2/sd/source/ui/slidesorter/cache/ |
| H A D | SlsRequestQueue.cxx | 85 class RequestQueue::Container
94 RequestQueue::RequestQueue (const SharedCacheContext& rpCacheContext) in RequestQueue() function in sd::slidesorter::cache::RequestQueue
103 RequestQueue::~RequestQueue() in ~RequestQueue()
108 void RequestQueue::AddRequest ( in AddRequest()
145 void RequestQueue::PageInDestruction(const SdrPage& rPage) in PageInDestruction()
156 RequestQueue::RemoveRequest( in RemoveRequest()
192 void RequestQueue::ChangeClass ( in ChangeClass()
211 CacheKey RequestQueue::GetFront() in GetFront()
233 void RequestQueue::PopFront() in PopFront()
253 bool RequestQueue::IsEmpty() in IsEmpty()
[all …]
|
| /dports/editors/libreoffice6/libreoffice-6.4.7.2/sd/source/ui/slidesorter/cache/ |
| H A D | SlsRequestQueue.cxx | 79 class RequestQueue::Container
88 RequestQueue::RequestQueue (const SharedCacheContext& rpCacheContext) in RequestQueue() function in sd::slidesorter::cache::RequestQueue
97 RequestQueue::~RequestQueue() in ~RequestQueue()
102 void RequestQueue::AddRequest ( in AddRequest()
139 void RequestQueue::PageInDestruction(const SdrPage& rPage) in PageInDestruction()
150 RequestQueue::RemoveRequest( in RemoveRequest()
186 void RequestQueue::ChangeClass ( in ChangeClass()
205 CacheKey RequestQueue::GetFront() in GetFront()
227 void RequestQueue::PopFront() in PopFront()
247 bool RequestQueue::IsEmpty() in IsEmpty()
[all …]
|
| /dports/net-p2p/ctorrent/ctorrent-dnh3.3.2/ |
| H A D | btrequest.cpp | 24 RequestQueue::~RequestQueue() in ~RequestQueue()
29 RequestQueue::RequestQueue() in RequestQueue() function in RequestQueue
35 void RequestQueue::Empty() in Empty()
41 void RequestQueue::SetHead(PSLICE ps) in SetHead()
48 void RequestQueue::operator=(RequestQueue &rq) in operator =()
75 int RequestQueue::Copy(const RequestQueue *prq, size_t idx) in Copy()
105 int RequestQueue::CopyShuffle(const RequestQueue *prq, size_t idx) in CopyShuffle()
194 size_t RequestQueue::Qsize() const in Qsize()
222 int RequestQueue::LastSlice() const in LastSlice()
536 RequestQueue tmprq; in Pending()
[all …]
|
| H A D | btrequest.h | 19 class RequestQueue
26 RequestQueue();
27 ~RequestQueue();
41 void operator=(RequestQueue &rq);
42 int Copy(const RequestQueue *prq, size_t idx);
43 int CopyShuffle(const RequestQueue *prq, size_t idx);
82 int Pending(RequestQueue *prq);
83 size_t ReAssign(RequestQueue *prq, BitField &bf);
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/scheduler/queue/ |
| H A D | queue.go | 49 type RequestQueue struct { struct
64 q := &RequestQueue{
82 func (q *RequestQueue) EnqueueRequest(userID string, req Request, maxQueriers int, successFn func()… argument
114 func (q *RequestQueue) GetNextRequestForQuerier(ctx context.Context, last UserIndex, querierID stri… argument
164 func (q *RequestQueue) forgetDisconnectedQueriers(_ context.Context) error { argument
177 func (q *RequestQueue) stopping(_ error) error { argument
194 func (q *RequestQueue) RegisterQuerierConnection(querier string) { argument
202 func (q *RequestQueue) UnregisterQuerierConnection(querier string) { argument
210 func (q *RequestQueue) NotifyQuerierShutdown(querierID string) { argument
217 func (q *RequestQueue) QuerierDisconnecting() { argument
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/scheduler/queue/ |
| H A D | queue.go | 49 type RequestQueue struct { struct
64 q := &RequestQueue{
82 func (q *RequestQueue) EnqueueRequest(userID string, req Request, maxQueriers int, successFn func()… argument
114 func (q *RequestQueue) GetNextRequestForQuerier(ctx context.Context, last UserIndex, querierID stri… argument
164 func (q *RequestQueue) forgetDisconnectedQueriers(_ context.Context) error { argument
177 func (q *RequestQueue) stopping(_ error) error { argument
194 func (q *RequestQueue) RegisterQuerierConnection(querier string) { argument
202 func (q *RequestQueue) UnregisterQuerierConnection(querier string) { argument
210 func (q *RequestQueue) NotifyQuerierShutdown(querierID string) { argument
217 func (q *RequestQueue) QuerierDisconnecting() { argument
[all …]
|
| /dports/sysutils/signon-ui/signon-ui-075830f31096947fcea70802b8d3c142bccfbefa/src/ |
| H A D | service.cpp | 34 typedef QQueue<Request*> RequestQueue; typedef
76 RequestQueue &queueForWindowId(WId windowId);
78 void runQueue(RequestQueue &queue);
88 QMap<WId,RequestQueue> m_requests;
103 RequestQueue &ServicePrivate::queueForWindowId(WId windowId) in queueForWindowId()
106 RequestQueue queue; in queueForWindowId()
119 RequestQueue &queue = queueForWindowId(windowId); in enqueue()
129 void ServicePrivate::runQueue(RequestQueue &queue) in runQueue()
151 RequestQueue &queue = queueForWindowId(windowId); in onRequestCompleted()
178 foreach (RequestQueue queue, m_requests) { in cancelUiRequest()
|
| /dports/graphics/kphotoalbum/kphotoalbum-5.8.1/ImageManager/ |
| H A D | RequestQueue.cpp | 14 bool ImageManager::RequestQueue::addRequest(ImageRequest *request) in addRequest()
32 ImageManager::ImageRequest *ImageManager::RequestQueue::popNext() in popNext()
58 void ImageManager::RequestQueue::cancelRequests(ImageClientInterface *client, StopAction action) in cancelRequests()
87 bool ImageManager::RequestQueue::isRequestStillValid(ImageRequest *request) in isRequestStillValid()
92 void ImageManager::RequestQueue::removeRequest(ImageRequest *request) in removeRequest()
99 ImageManager::RequestQueue::RequestQueue() in RequestQueue() function in ImageManager::RequestQueue
|
| /dports/devel/ice37/ice-3.7.2/cpp/src/Glacier2/ |
| H A D | RequestQueue.cpp | 187 Glacier2::RequestQueue::RequestQueue(const RequestQueueThreadPtr& requestQueueThread, in RequestQueue() function in Glacier2::RequestQueue
193 _callback(newCallback_Object_ice_invoke(this, &RequestQueue::response, &RequestQueue::exception, in RequestQueue()
194 &RequestQueue::sent)), in RequestQueue()
195 …allback(newCallback_Connection_flushBatchRequests(this, &RequestQueue::exception, &RequestQueue::s… in RequestQueue()
202 Glacier2::RequestQueue::addRequest(const RequestPtr& request) in addRequest()
257 Glacier2::RequestQueue::flushRequests() in flushRequests()
302 Glacier2::RequestQueue::destroy() in destroy()
326 Glacier2::RequestQueue::flush() in flush()
382 Glacier2::RequestQueue::destroyInternal() in destroyInternal()
403 Glacier2::RequestQueue::exception(const Ice::Exception& ex, const RequestPtr& request) in exception()
[all …]
|
| /dports/devel/php-ice37/ice-3.7.2/cpp/src/Glacier2/ |
| H A D | RequestQueue.cpp | 187 Glacier2::RequestQueue::RequestQueue(const RequestQueueThreadPtr& requestQueueThread, in RequestQueue() function in Glacier2::RequestQueue
193 _callback(newCallback_Object_ice_invoke(this, &RequestQueue::response, &RequestQueue::exception, in RequestQueue()
194 &RequestQueue::sent)), in RequestQueue()
195 …allback(newCallback_Connection_flushBatchRequests(this, &RequestQueue::exception, &RequestQueue::s… in RequestQueue()
202 Glacier2::RequestQueue::addRequest(const RequestPtr& request) in addRequest()
257 Glacier2::RequestQueue::flushRequests() in flushRequests()
302 Glacier2::RequestQueue::destroy() in destroy()
326 Glacier2::RequestQueue::flush() in flush()
382 Glacier2::RequestQueue::destroyInternal() in destroyInternal()
403 Glacier2::RequestQueue::exception(const Ice::Exception& ex, const RequestPtr& request) in exception()
[all …]
|
| /dports/devel/py-ice37/ice-3.7.2/cpp/src/Glacier2/ |
| H A D | RequestQueue.cpp | 187 Glacier2::RequestQueue::RequestQueue(const RequestQueueThreadPtr& requestQueueThread, in RequestQueue() function in Glacier2::RequestQueue
193 _callback(newCallback_Object_ice_invoke(this, &RequestQueue::response, &RequestQueue::exception, in RequestQueue()
194 &RequestQueue::sent)), in RequestQueue()
195 …allback(newCallback_Connection_flushBatchRequests(this, &RequestQueue::exception, &RequestQueue::s… in RequestQueue()
202 Glacier2::RequestQueue::addRequest(const RequestPtr& request) in addRequest()
257 Glacier2::RequestQueue::flushRequests() in flushRequests()
302 Glacier2::RequestQueue::destroy() in destroy()
326 Glacier2::RequestQueue::flush() in flush()
382 Glacier2::RequestQueue::destroyInternal() in destroyInternal()
403 Glacier2::RequestQueue::exception(const Ice::Exception& ex, const RequestPtr& request) in exception()
[all …]
|
| /dports/net/ns3/ns-allinone-3.35/ns-3.35/src/aodv/model/ |
| H A D | aodv-rqueue.cc | 41 RequestQueue::GetSize () in GetSize()
48 RequestQueue::Enqueue (QueueEntry & entry) in Enqueue()
72 RequestQueue::DropPacketWithDst (Ipv4Address dst) in DropPacketWithDst()
90 RequestQueue::Dequeue (Ipv4Address dst, QueueEntry & entry) in Dequeue()
106 RequestQueue::Find (Ipv4Address dst) in Find()
138 RequestQueue::Purge () in Purge()
154 RequestQueue::Drop (QueueEntry en, std::string reason) in Drop()
|
| /dports/audio/sonic-visualiser/sonic-visualiser-4.0.1/svcore/data/fileio/ |
| H A D | FileReadThread.h | 61 typedef std::map<int, Request> RequestQueue; typedef
62 RequestQueue m_queue;
63 RequestQueue m_cancelledRequests;
64 RequestQueue m_readyRequests;
|
| /dports/graphics/ogre3d/ogre-1.11.6/OgreMain/src/ |
| H A D | OgreWorkQueue.cpp | 115 for (RequestQueue::iterator i = mRequestQueue.begin(); i != mRequestQueue.end(); ++i) in ~DefaultWorkQueueBase()
275 for (RequestQueue::iterator i = mProcessQueue.begin(); i != mProcessQueue.end(); ++i) in abortRequest()
287 for (RequestQueue::iterator i = mRequestQueue.begin(); i != mRequestQueue.end(); ++i) in abortRequest()
304 … for (RequestQueue::iterator i = mIdleRequestQueue.begin(); i != mIdleRequestQueue.end(); ++i) in abortRequest()
329 for (RequestQueue::iterator i = mRequestQueue.begin(); i != mRequestQueue.end(); ++i) in abortPendingRequest()
357 for (RequestQueue::iterator i = mProcessQueue.begin(); i != mProcessQueue.end(); ++i) in abortRequestsByChannel()
368 for (RequestQueue::iterator i = mRequestQueue.begin(); i != mRequestQueue.end(); ++i) in abortRequestsByChannel()
410 for (RequestQueue::iterator i = mRequestQueue.begin(); i != mRequestQueue.end(); ++i) in abortPendingRequestsByChannel()
435 for (RequestQueue::iterator i = mProcessQueue.begin(); i != mProcessQueue.end(); ++i) in abortAllRequests()
445 for (RequestQueue::iterator i = mRequestQueue.begin(); i != mRequestQueue.end(); ++i) in abortAllRequests()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.HttpListener/tests/ |
| H A D | HttpListenerTimeoutManagerTests.cs | 66 RequestQueue, enumerator
111 internal ushort RequestQueue; field
250 _listener.TimeoutManager.RequestQueue = new TimeSpan(0, 0, 300); in RequestQueue_SetTimeoutNoStart_GetReturnsNewValue()
251 int seconds = (int)GetServerTimeout(_listener, HTTP_TIMEOUT_TYPE.RequestQueue); in RequestQueue_SetTimeoutNoStart_GetReturnsNewValue()
253 Assert.Equal(seconds, _listener.TimeoutManager.RequestQueue.TotalSeconds); in RequestQueue_SetTimeoutNoStart_GetReturnsNewValue()
261 _listener.TimeoutManager.RequestQueue = new TimeSpan(0, 0, 300); in RequestQueue_SetTimeoutAfterStart_GetReturnsNewValue()
262 int seconds = (int)GetServerTimeout(_listener, HTTP_TIMEOUT_TYPE.RequestQueue); in RequestQueue_SetTimeoutAfterStart_GetReturnsNewValue()
264 Assert.Equal(seconds, _listener.TimeoutManager.RequestQueue.TotalSeconds); in RequestQueue_SetTimeoutAfterStart_GetReturnsNewValue()
356 timeouts[(uint)HTTP_TIMEOUT_TYPE.RequestQueue] = in GetServerTimeout()
357 timeoutinfo.RequestQueue; in GetServerTimeout()
[all …]
|
| /dports/net/libcharon/libCharon-4.8.0/Charon/Service/ |
| H A D | FileService.py | 4 import RequestQueue
28 self.__queue = RequestQueue.RequestQueue()
45 request = RequestQueue.Request(self, request_id, file_path, virtual_paths)
|