/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/sun/misc/ |
H A D | RequestProcessor.java | 39 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 D | RequestProcessor.java | 39 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 D | http_rpc_engine.ts | 39 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 D | frontend.go | 58 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 D | frontend.go | 58 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 D | Job.py | 232 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 D | Job.py | 236 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 D | Job.py | 236 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 D | Job.py | 236 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 D | Job.py | 236 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 D | Job.py | 234 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 D | Job.py | 236 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 D | qtfilecopier.cpp | 109 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 D | HttpListenerTimeoutsElement.cs | 11 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 D | http_rpc_engine.ts | 41 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 D | job.cpp | 216 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 D | scheduler.go | 50 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 D | scheduler.go | 50 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 D | PluginPipeMock.java | 33 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 D | route_replies.cpp | 206 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 D | QMQueue.c | 400 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 D | ContentCache.as | 136 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 D | manager.go | 145 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 D | manager.go | 145 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 D | manager.go | 145 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
|