Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 234) sorted by relevance

12345678910

/plugin/findologicxmlexport/vendor/hoa/protocol/Node/
DLibrary.php52 * @param string $queue Queue of the component (generally, a filename,
56 public function reach($queue = null) argument
59 return parent::reach($queue);
62 if (!empty($queue)) {
63 $head = $queue;
65 if (false !== $pos = strpos($queue, '/')) {
67 $queue = DIRECTORY_SEPARATOR . substr($queue, $pos + 1);
69 $queue = null;
75 $out[] = "\r" . $part . strtolower($head) . $queue;
78 $out[] = "\r" . dirname(dirname(dirname(dirname(__DIR__)))) . $queue;
[all …]
/plugin/asciidocjs/node_modules/asap/
Draw.js17 if (!queue.length) {
22 queue[queue.length] = task;
25 var queue = []; variable
45 while (index < queue.length) {
50 queue[currentIndex].call();
59 for (var scan = 0, newLength = queue.length - index; scan < newLength; scan++) {
60 queue[scan] = queue[scan + index];
62 queue.length -= index;
66 queue.length = 0;
Dbrowser-raw.js15 if (!queue.length) {
20 queue[queue.length] = task;
23 var queue = []; variable
47 while (index < queue.length) {
52 queue[currentIndex].call();
61 for (var scan = 0, newLength = queue.length - index; scan < newLength; scan++) {
62 queue[scan] = queue[scan + index];
64 queue.length -= index;
68 queue.length = 0;
/plugin/authgooglesheets/vendor/guzzlehttp/guzzle/src/Handler/
DMockHandler.php17 private $queue = []; variable in GuzzleHttp\\Handler\\MockHandler
27 * @param array $queue Array of responses, callables, or exceptions.
34 array $queue = null, argument
38 return HandlerStack::create(new self($queue, $onFulfilled, $onRejected));
46 * @param array $queue
51 array $queue = null, argument
58 if ($queue) {
59 call_user_func_array([$this, 'append'], $queue);
65 if (!$this->queue) {
75 $response = array_shift($this->queue);
[all …]
/plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Protocol/
H A DServerProtocolHandler.php59 protected $queue; variable in FreeDSx\\Ldap\\Protocol\\ServerProtocolHandler
97 ServerQueue $queue, argument
105 $this->queue = $queue;
128 while ($message = $this->queue->getMessage()) {
131 if (!$this->queue->isConnected()) {
138 $this->queue->sendMessage($this->responseFactory->getStandardResponse(
167 if ($this->queue->isConnected()) {
171 if ($this->queue->isConnected()) {
172 $this->queue->close();
188 $this->queue->close();
[all …]
H A DClientProtocolHandler.php56 protected $queue; variable in FreeDSx\\Ldap\\Protocol\\ClientProtocolHandler
78 …public function __construct(array $options, ClientQueue $queue = null, SocketPool $pool = null, Cl… argument
84 $this->queue = $queue;
155 $this->queue(),
165 $this->queue(),
173 $this->queue()->close();
195 return ($this->queue !== null && $this->queue->isConnected());
201 protected function queue(): ClientQueue function in FreeDSx\\Ldap\\Protocol\\ClientProtocolHandler
203 if ($this->queue === null) {
204 $this->queue = new ClientQueue($this->pool);
[all …]
/plugin/elasticsearch/vendor/react/promise/src/
DCancellationQueue.php8 private $queue = []; variable in React\\Promise\\CancellationQueue
26 $length = \array_push($this->queue, $cancellable);
35 for ($i = key($this->queue); isset($this->queue[$i]); $i++) {
36 $cancellable = $this->queue[$i];
46 unset($this->queue[$i]);
53 $this->queue = [];
/plugin/matrixnotifierwas/vendor/guzzlehttp/guzzle/src/Handler/
DMockHandler.php25 private $queue = []; variable in GuzzleHttp\\Handler\\MockHandler
51 * @param array|null $queue Array of responses, callables, or exceptions.
55 …public static function createWithMiddleware(array $queue = null, callable $onFulfilled = null, cal… argument
57 return HandlerStack::create(new self($queue, $onFulfilled, $onRejected));
69 …public function __construct(array $queue = null, callable $onFulfilled = null, callable $onRejecte… argument
74 if ($queue) {
76 $this->append(...array_values($queue));
82 if (!$this->queue) {
92 $response = \array_shift($this->queue);
161 $this->queue[] = $value;
[all …]
/plugin/fastwiki/
Dpagecache.js122 function _pushToFront(id, queue) { argument
123 var idx = queue.indexOf(id);
125 queue.splice(idx, 1);
126 queue.push(id);
129 function _addPage(id, queue, hash, data, maxSize, exclude) { argument
131 _pushToFront(id, queue);
133 if (queue.length > maxSize) {
135 for (var x=0; x<queue.length; x++) {
136 if (!exclude[queue[x]]) {
137 delete hash[queue[x]];
[all …]
/plugin/sql2wiki/action/
Dsqlite.php21 protected $queue = []; variable in action_plugin_sql2wiki_sqlite
24 if (!isset($this->queue[$db])) {
25 $this->queue[$db] = [];
29 $this->queue[$db] = true;
32 if (is_array($this->queue[$db])) {
33 $this->queue[$db][$query_name] = true;
39 $queue = $this->queue;
40 return array_filter($sql2wiki_data, function ($query) use ($queue) {
43 return isset($queue[$db]) && ($queue[$db] === true || isset($queue[$db][$query_name]));
48 $this->queue = [];
[all …]
/plugin/creole/helper/
Deventhandler.php112 protected static $queue = array(); variable in helper_plugin_creole_eventhandler
120 self::$queue = array();
153 $q_max = count(self::$queue);
156 if ( self::$queue[$q_index] != NULL &&
158 self::$callbacks [$cb_index]->ownEventMatches(self::$queue[$q_index]) ) {
160 … self::$callbacks [$cb_index]->execute(self::$queue [$q_index], $pos, $match, $handler);
166 self::$queue [] = $event;
172 for ( $q_index = 0 ; $q_index < count(self::$queue) ; $q_index++ ) {
173 if ( $event->equal(self::$queue [$q_index]) ) {
174 self::$queue [$q_index] = NULL;
[all …]
/plugin/matrixnotifierwas/vendor/guzzlehttp/promises/src/
DUtils.php24 public static function queue(TaskQueueInterface $assign = null): TaskQueueInterface function in GuzzleHttp\\Promise\\Utils
26 static $queue;
29 $queue = $assign;
30 } elseif (!$queue) {
31 $queue = new TaskQueue();
34 return $queue;
45 $queue = self::queue();
46 $promise = new Promise([$queue, 'run']);
47 $queue->add(function () use ($task, $promise): void {
DTaskQueue.php21 private $queue = []; variable in GuzzleHttp\\Promise\\TaskQueue
40 return !$this->queue;
45 $this->queue[] = $task;
50 while ($task = array_shift($this->queue)) {
/plugin/authgooglesheets/vendor/guzzlehttp/promises/src/
DUtils.php24 public static function queue(TaskQueueInterface $assign = null) function in GuzzleHttp\\Promise\\Utils
26 static $queue;
29 $queue = $assign;
30 } elseif (!$queue) {
31 $queue = new TaskQueue();
34 return $queue;
47 $queue = self::queue();
48 $promise = new Promise([$queue, 'run']);
49 $queue->add(function () use ($task, $promise) {
DTaskQueue.php17 private $queue = []; variable in GuzzleHttp\\Promise\\TaskQueue
36 return !$this->queue;
41 $this->queue[] = $task;
46 while ($task = array_shift($this->queue)) {
/plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Protocol/ServerProtocolHandler/
H A DServerStartTlsHandler.php50 * @param ServerQueue $queue
55 … TokenInterface $token, RequestHandlerInterface $dispatcher, ServerQueue $queue, array $options): … argument
59 … $queue->sendMessage(new LdapMessageResponse($message->getMessageId(), new ExtendedResponse(
67 if ($queue->isEncrypted()) {
68 … $queue->sendMessage(new LdapMessageResponse($message->getMessageId(), new ExtendedResponse(
76 $queue->sendMessage(new LdapMessageResponse($message->getMessageId(), new ExtendedResponse(
80 $queue->encrypt();
/plugin/authgooglesheets/vendor/google/apiclient-services/src/CloudSearch/
DUnreserveItemsRequest.php31 public $queue; variable in Google\\Service\\CloudSearch\\UnreserveItemsRequest
64 public function setQueue($queue) argument
66 $this->queue = $queue;
73 return $this->queue;
DDeleteQueueItemsRequest.php31 public $queue; variable in Google\\Service\\CloudSearch\\DeleteQueueItemsRequest
64 public function setQueue($queue) argument
66 $this->queue = $queue;
73 return $this->queue;
DPollItemsRequest.php36 public $queue; variable in Google\\Service\\CloudSearch\\PollItemsRequest
87 public function setQueue($queue) argument
89 $this->queue = $queue;
96 return $this->queue;
DPushItem.php37 public $queue; variable in Google\\Service\\CloudSearch\\PushItem
94 public function setQueue($queue) argument
96 $this->queue = $queue;
103 return $this->queue;
/plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Protocol/ClientProtocolHandler/
H A DClientSaslBindHandler.php82 $queue = $context->getQueue();
84 $queue->sendMessage($message);
87 $response = $queue->getMessage($message->getMessageId());
98 $response = $this->processSaslChallenge($request, $queue, $saslResponse, $mech);
144 * @param ClientQueue $queue
157 ClientQueue $queue, argument
167 $response = $this->sendRequestGetResponse($saslBind, $queue);
182 $queue->setMessageWrapper(new SaslMessageWrapper($mech->securityLayer(), $context));
190 * @param ClientQueue $queue
197 …protected function sendRequestGetResponse(SaslBindRequest $request, ClientQueue $queue): LdapMessa… argument
[all …]
/plugin/asciidocjs/node_modules/core-js/modules/
D_task.js12 var queue = {}; variable
18 if (queue.hasOwnProperty(id)) {
19 var fn = queue[id];
20 delete queue[id];
33 queue[++counter] = function () { function
41 delete queue[id];
/plugin/asciidocjs/node_modules/core-js/library/modules/
D_task.js12 var queue = {}; variable
18 if (queue.hasOwnProperty(id)) {
19 var fn = queue[id];
20 delete queue[id];
33 queue[++counter] = function () { function
41 delete queue[id];
/plugin/aichat/_test/
DTextSplitterTest.php174 $queue = self::getInaccessibleProperty($this->splitter, 'sentenceQueue');
175 $this->assertGreaterThanOrEqual(1, count($queue));
176 $this->assertContains('First sentence.', $queue);
180 $queue = self::getInaccessibleProperty($this->splitter, 'sentenceQueue');
181 $this->assertGreaterThan(1, $queue);
182 $this->assertContains('Second sentence.', $queue);
190 $queue = self::getInaccessibleProperty($this->splitter, 'sentenceQueue');
191 $this->assertLessThanOrEqual(2, count($queue));
/plugin/diagramsnet/lib/plugins/
Danonymize.js49 var queue = [];
65 queue.push({cell: cell, label: label});
68 for (var i = 0; i < queue.length; i++)
70 model.setValue(queue[i].cell, queue[i].label);

12345678910