Home
last modified time | relevance | path

Searched refs:requestQueue (Results 1 – 25 of 50) sorted by relevance

12

/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/sun/misc/
H A DRequestProcessor.java39 private static Queue<Request> requestQueue; field in RequestProcessor
48 requestQueue.enqueue(req); in postRequest()
58 Request req = requestQueue.dequeue(); in run()
91 if (requestQueue == null) { in lazyInitialize()
92 requestQueue = new Queue<Request>(); in lazyInitialize()
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/sun/misc/
H A DRequestProcessor.java39 private static Queue<Request> requestQueue; field in RequestProcessor
48 requestQueue.enqueue(req); in postRequest()
58 Request req = requestQueue.dequeue(); in run()
91 if (requestQueue == null) { in lazyInitialize()
92 requestQueue = new Queue<Request>(); in lazyInitialize()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/perfetto/ui/src/common/
H A Dhttp_rpc_engine.ts39 private requestQueue = new Array<QueuedRequest>(); property in HttpRpcEngine
65 this.requestQueue.push({methodName, reqData: data, resp});
66 if (this.requestQueue.length === 1) {
73 if (this.requestQueue.length === 0) {
76 const req = this.requestQueue[0];
94 const pendingReq = assertExists(this.requestQueue.shift());
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/frontend/v1/
H A Dfrontend.go58 requestQueue *queue.RequestQueue member
103 …f.requestQueue = queue.NewRequestQueue(cfg.MaxOutstandingPerTenant, cfg.QuerierForgetDelay, f.queu…
107 f.subservices, err = services.NewManager(f.requestQueue, f.activeUsers)
115 }, f.requestQueue.GetConnectedQuerierWorkersMetric)
198 f.requestQueue.RegisterQuerierConnection(querierID)
199 defer f.requestQueue.UnregisterQuerierConnection(querierID)
206 f.requestQueue.QuerierDisconnecting()
212 …reqWrapper, idx, err := f.requestQueue.GetNextRequestForQuerier(server.Context(), lastUserIndex, q…
290 f.requestQueue.NotifyQuerierShutdown(req.GetClientID())
334 err = f.requestQueue.EnqueueRequest(joinedTenantID, req, maxQueriers, nil)
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/frontend/v1/
H A Dfrontend.go58 requestQueue *queue.RequestQueue member
103 …f.requestQueue = queue.NewRequestQueue(cfg.MaxOutstandingPerTenant, cfg.QuerierForgetDelay, f.queu…
107 f.subservices, err = services.NewManager(f.requestQueue, f.activeUsers)
115 }, f.requestQueue.GetConnectedQuerierWorkersMetric)
198 f.requestQueue.RegisterQuerierConnection(querierID)
199 defer f.requestQueue.UnregisterQuerierConnection(querierID)
206 f.requestQueue.QuerierDisconnecting()
212 …reqWrapper, idx, err := f.requestQueue.GetNextRequestForQuerier(server.Context(), lastUserIndex, q…
290 f.requestQueue.NotifyQuerierShutdown(req.GetClientID())
334 err = f.requestQueue.EnqueueRequest(joinedTenantID, req, maxQueriers, nil)
[all …]
/dports/devel/scons/SCons-4.2.0/SCons/
H A DJob.py232 def __init__(self, requestQueue, resultsQueue, interrupted): argument
235 self.requestQueue = requestQueue
242 task = self.requestQueue.get()
272 self.requestQueue = queue.Queue(0)
291 worker = Worker(self.requestQueue, self.resultsQueue, interrupted)
299 self.requestQueue.put(task)
318 self.requestQueue.put(None)
/dports/science/apbs/apbs-pdb2pqr-apbs-1.5-102-g500c1473/pdb2pqr/scons/scons-local-2.3.3/SCons/
H A DJob.py236 def __init__(self, requestQueue, resultsQueue, interrupted): argument
239 self.requestQueue = requestQueue
246 task = self.requestQueue.get()
276 self.requestQueue = queue.Queue(0)
295 worker = Worker(self.requestQueue, self.resultsQueue, interrupted)
303 self.requestQueue.put(task)
322 self.requestQueue.put(None)
/dports/graphics/photivo/photivo/scons-local-2.2.0/SCons/
H A DJob.py236 def __init__(self, requestQueue, resultsQueue, interrupted): argument
239 self.requestQueue = requestQueue
246 task = self.requestQueue.get()
276 self.requestQueue = queue.Queue(0)
295 worker = Worker(self.requestQueue, self.resultsQueue, interrupted)
303 self.requestQueue.put(task)
322 self.requestQueue.put(None)
/dports/devel/nuitka/Nuitka-0.6.17/nuitka/build/inline_copy/lib/scons-2.3.2/SCons/
H A DJob.py236 def __init__(self, requestQueue, resultsQueue, interrupted): argument
239 self.requestQueue = requestQueue
246 task = self.requestQueue.get()
276 self.requestQueue = queue.Queue(0)
295 worker = Worker(self.requestQueue, self.resultsQueue, interrupted)
303 self.requestQueue.put(task)
322 self.requestQueue.put(None)
/dports/devel/nuitka/Nuitka-0.6.17/nuitka/build/inline_copy/lib/scons-3.1.2/SCons/
H A DJob.py236 def __init__(self, requestQueue, resultsQueue, interrupted): argument
239 self.requestQueue = requestQueue
246 task = self.requestQueue.get()
276 self.requestQueue = queue.Queue(0)
295 worker = Worker(self.requestQueue, self.resultsQueue, interrupted)
303 self.requestQueue.put(task)
322 self.requestQueue.put(None)
/dports/graphics/py-pivy/pivy-0.6.6/scons/scons-local-1.2.0.d20090919/SCons/
H A DJob.py234 def __init__(self, requestQueue, resultsQueue, interrupted): argument
237 self.requestQueue = requestQueue
244 task = self.requestQueue.get()
274 self.requestQueue = Queue.Queue(0)
293 worker = Worker(self.requestQueue, self.resultsQueue, interrupted)
303 self.requestQueue.put(task)
322 self.requestQueue.put(None)
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/scons-2.5.0/scons-local-2.5.0/SCons/
H A DJob.py236 def __init__(self, requestQueue, resultsQueue, interrupted): argument
239 self.requestQueue = requestQueue
246 task = self.requestQueue.get()
276 self.requestQueue = queue.Queue(0)
295 worker = Worker(self.requestQueue, self.resultsQueue, interrupted)
303 self.requestQueue.put(task)
322 self.requestQueue.put(None)
/dports/x11-fm/qtfm/qtfm-6.2.1/libfm/qtcopydialog/
H A Dqtfilecopier.cpp109 if (requestQueue.empty()) in isCanceled()
115 if (requestQueue.empty()) in isMoveError()
124 if (requestQueue.empty()) in setMoveError()
170 QMap<int, Request> requestQueue; member in QtCopyThread
240 requestQueue[id] = r; in copy()
250 requestQueue[it.key()] = r; in copy()
259 if (it != requestQueue.end()) { in cancelChildRequests()
271 if (it != requestQueue.end()) { in overwriteChildRequests()
732 requestQueue.remove(id); in renameChildren()
760 requestQueue.remove(childId); in cancelChildren()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/net/System/Net/Configuration/
H A DHttpListenerTimeoutsElement.cs11 private static readonly ConfigurationProperty requestQueue; field in System.Net.Configuration.HttpListenerTimeoutsElement
20 requestQueue = CreateTimeSpanProperty(ConfigurationStrings.RequestQueue); in HttpListenerTimeoutsElement()
30 properties.Add(requestQueue); in HttpListenerTimeoutsElement()
57 get { return (TimeSpan)this[requestQueue]; }
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/ui/src/common/
H A Dhttp_rpc_engine.ts41 private requestQueue = new Array<QueuedRequest>(); property in HttpRpcEngine
85 this.requestQueue.push(req);
132 if (this.pendingRequest === undefined && this.requestQueue.length > 0) {
133 this.beginFetch(this.requestQueue.shift()!);
/dports/net/libkgapi/libkgapi-21.12.3/src/core/
H A Djob.cpp216 if (requestQueue.isEmpty()) { in _k_replyReceived()
239 if (requestQueue.isEmpty()) { in _k_replyReceived()
300 qCDebug(KGAPIDebug) << requestQueue.length() << "requests in requestQueue."; in _k_replyReceived()
301 if (requestQueue.isEmpty()) { in _k_replyReceived()
313 if (requestQueue.isEmpty()) { in _k_dispatchTimeout()
318 const Request r = requestQueue.dequeue(); in _k_dispatchTimeout()
344 if (requestQueue.isEmpty()) { in _k_dispatchTimeout()
486 d->requestQueue.clear(); in emitFinished()
513 d->requestQueue.enqueue(r_); in enqueueRequest()
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/cortexproject/cortex/pkg/scheduler/
H A Dscheduler.go50 requestQueue *queue.RequestQueue member
114 …s.requestQueue = queue.NewRequestQueue(cfg.MaxOutstandingPerTenant, cfg.QuerierForgetDelay, s.queu…
124 }, s.requestQueue.GetConnectedQuerierWorkersMetric)
133 s.subservices, err = services.NewManager(s.requestQueue, s.activeUsers)
310 return s.requestQueue.EnqueueRequest(userID, req, maxQueriers, func() {
341 s.requestQueue.RegisterQuerierConnection(querierID)
342 defer s.requestQueue.UnregisterQuerierConnection(querierID)
349 s.requestQueue.QuerierDisconnecting()
356 …req, idx, err := s.requestQueue.GetNextRequestForQuerier(querier.Context(), lastUserIndex, querier…
397 s.requestQueue.NotifyQuerierShutdown(req.GetQuerierID())
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/pkg/scheduler/
H A Dscheduler.go50 requestQueue *queue.RequestQueue member
114 …s.requestQueue = queue.NewRequestQueue(cfg.MaxOutstandingPerTenant, cfg.QuerierForgetDelay, s.queu…
124 }, s.requestQueue.GetConnectedQuerierWorkersMetric)
133 s.subservices, err = services.NewManager(s.requestQueue, s.activeUsers)
310 return s.requestQueue.EnqueueRequest(userID, req, maxQueriers, func() {
341 s.requestQueue.RegisterQuerierConnection(querierID)
342 defer s.requestQueue.UnregisterQuerierConnection(querierID)
349 s.requestQueue.QuerierDisconnecting()
356 …req, idx, err := s.requestQueue.GetNextRequestForQuerier(querier.Context(), lastUserIndex, querier…
397 s.requestQueue.NotifyQuerierShutdown(req.GetQuerierID())
/dports/java/icedtea-web/icedtea-web-1.6.2/tests/test-extensions/sun/applet/mock/
H A DPluginPipeMock.java33 private BlockingQueue<String> requestQueue = new LinkedBlockingQueue<String>(); field in PluginPipeMock
45 return requestQueue.take(); in getNextRequest()
111 requestQueue.put(lineBuffer.toString()); in write()
/dports/irc/znc/znc-1.8.2/modules/
H A Droute_replies.cpp206 typedef std::map<CClient*, std::vector<struct queued_req>> requestQueue; typedef
221 requestQueue::iterator it; in ~CRouteRepliesMod()
249 requestQueue::iterator it; in OnClientDisconnect()
400 requestQueue::iterator it; in SendRequest()
447 requestQueue m_vsPending;
/dports/misc/rump/buildrump.sh-b914579/src/sys/dev/pci/n8/QMgr/
H A DQMQueue.c400 API_Request_p = (API_Request_t *)queue_p->requestQueue[queue_p->apiReadIdx]; in QMgrCheckQueue()
479 queue_p->requestQueue[queue_p->apiReadIdx] = NULL; in QMgrCheckQueue()
482 queue_p->requestQueue[queue_p->apiReadIdx]; in QMgrCheckQueue()
604 if (queue_p->requestQueue[requestIndex] == NULL) in N8_QMgrQueue()
606 queue_p->requestQueue[requestIndex] = &API_req_p->qr; in N8_QMgrQueue()
789 (API_Request_t *)queue_p->requestQueue[queue_p->apiReadIdx]; in QMgrCmdError()
/dports/devel/flex-sdk/flex-sdk-4.6.0.23201/frameworks/projects/spark/src/spark/core/
H A DContentCache.as136 protected var requestQueue:LinkedList = new LinkedList();
550 requestQueue.insertAfter(node, current);
552 requestQueue.insertBefore(node, current);
555 requestQueue.push(node);
560 requestQueue.push(node);
618 requestQueue = new LinkedList();
627 var current:QueueEntryNode = requestQueue.tail as QueueEntryNode;
640 requestQueue.remove(candidate);
649 requestQueue.unshift(current);
683 requestQueue.unshift(activeNode);
[all …]
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/netsync/
H A Dmanager.go145 requestQueue []*wire.InvVect member
1143 state.requestQueue = append(state.requestQueue, iv)
1192 requestQueue := state.requestQueue
1193 for len(requestQueue) != 0 {
1194 iv := requestQueue[0]
1195 requestQueue[0] = nil
1196 requestQueue = requestQueue[1:]
1242 state.requestQueue = requestQueue
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/netsync/
H A Dmanager.go145 requestQueue []*wire.InvVect member
1143 state.requestQueue = append(state.requestQueue, iv)
1192 requestQueue := state.requestQueue
1193 for len(requestQueue) != 0 {
1194 iv := requestQueue[0]
1195 requestQueue[0] = nil
1196 requestQueue = requestQueue[1:]
1242 state.requestQueue = requestQueue
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/netsync/
H A Dmanager.go145 requestQueue []*wire.InvVect member
1143 state.requestQueue = append(state.requestQueue, iv)
1192 requestQueue := state.requestQueue
1193 for len(requestQueue) != 0 {
1194 iv := requestQueue[0]
1195 requestQueue[0] = nil
1196 requestQueue = requestQueue[1:]
1242 state.requestQueue = requestQueue

12