Home
last modified time | relevance | path

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

1234567

/plugin/findologicxmlexport/vendor/hoa/protocol/Node/
H A 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/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Protocol/
H A DServerProtocolHandler.php59 protected $queue;
97 ServerQueue $queue,
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
48 protected $queue; global() variable in FreeDSx\\Ldap\\Protocol\\ServerProtocolHandler
81 __construct(ServerQueue $queue, RequestHandlerInterface $dispatcher, array $options = [], ServerProtocolHandlerFactory $protocolHandlerFactory = null, ServerBindHandlerFactory $bindHandlerFactory = null, ServerAuthorization $authorizer = null, ResponseFactory $responseFactory = null) global() argument
[all...]
H A DClientProtocolHandler.php56 protected $queue;
78 public function __construct(array $options, ClientQueue $queue = null, SocketPool $pool = null, ClientProtocolHandlerFactory $clientProtocolHandlerFactory = null)
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()
50 protected $queue; global() variable in FreeDSx\\Ldap\\Protocol\\ClientProtocolHandler
72 __construct(array $options, ClientQueue $queue = null, SocketPool $pool = null, ClientProtocolHandlerFactory $clientProtocolHandlerFactory = null) global() argument
178 protected function queue(): ClientQueue global() function in FreeDSx\\Ldap\\Protocol\\ClientProtocolHandler
[all...]
/plugin/authgooglesheets/vendor/guzzlehttp/guzzle/src/Handler/
H A DMockHandler.php17 private $queue = []; variable in GuzzleHttp\\Handler\\MockHandler
34 array $queue = null, argument
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);
140 $this->queue[] = $value;
175 return count($this->queue);
[all …]
/plugin/elasticsearch/vendor/react/promise/src/
H A 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/sql2wiki/action/
H A 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[
[all...]
/plugin/fastwiki/
H A Dpagecache.js10 var m_p1Queue = []; // Priority 1 queue. These can only be bumped by other p1 pages.
122 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[
[all...]
/plugin/creole/helper/
H A 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 &&
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;
181 for ( $q_index = 0 ; $q_index < count(self::$queue) ; $q_index++ ) {
182 if ( self::$queue [$q_index] != NULL &&
[all …]
/plugin/authgooglesheets/vendor/guzzlehttp/promises/src/
H A 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) {
H A DTaskQueue.php17 private $queue = []; variable in GuzzleHttp\\Promise\\TaskQueue
36 return !$this->queue;
41 $this->queue[] = $task;
46 while ($task = array_shift($this->queue)) {
H A DFulfilledPromise.php35 $queue = Utils::queue();
36 $p = new Promise([$queue, 'run']);
38 $queue->add(static function () use ($p, $value, $onFulfilled) {
H A DRejectedPromise.php35 $queue = Utils::queue();
37 $p = new Promise([$queue, 'run']);
38 $queue->add(static function () use ($p, $reason, $onRejected) {
/plugin/authgooglesheets/vendor/google/apiclient-services/src/CloudSearch/
H A DUnreserveItemsRequest.php31 public $queue; variable in Google\\Service\\CloudSearch\\UnreserveItemsRequest
64 public function setQueue($queue) argument
66 $this->queue = $queue;
73 return $this->queue;
H A DDeleteQueueItemsRequest.php31 public $queue; variable in Google\\Service\\CloudSearch\\DeleteQueueItemsRequest
64 public function setQueue($queue) argument
66 $this->queue = $queue;
73 return $this->queue;
H A DPollItemsRequest.php36 public $queue; variable in Google\\Service\\CloudSearch\\PollItemsRequest
87 public function setQueue($queue) argument
89 $this->queue = $queue;
96 return $this->queue;
H A DPushItem.php37 public $queue; variable in Google\\Service\\CloudSearch\\PushItem
94 public function setQueue($queue) argument
96 $this->queue = $queue;
103 return $this->queue;
H A DItem.php43 public $queue; variable in Google\\Service\\CloudSearch\\Item
140 public function setQueue($queue) argument
142 $this->queue = $queue;
149 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,
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)
111 processSaslChallenge(SaslBindRequest $request, ClientQueue $queue, BindResponse $saslResponse, MechanismInterface $mech) global() argument
142 sendRequestGetResponse(SaslBindRequest $request, ClientQueue $queue) global() argument
[all...]
H A DClientUnbindHandler.php35 $queue = $context->getQueue();
37 $queue->sendMessage($message);
38 $queue->close();
H A DClientBasicHandler.php56 $queue = $context->getQueue();
58 $queue->sendMessage($message);
60 return $queue->getMessage($message->getMessageId());
66 * @param ClientQueue $queue
72 public function handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options): ?LdapMessageResponse
55 handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options) global() argument
H A DClientSearchHandler.php59 * @param ClientQueue $queue
68 public function handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options): ?LdapMessageResponse
78 $messageFrom = $queue->getMessage($messageTo->getMessageId());
92 return parent::handleResponse($messageTo, $finalResponse, $queue, $options);
48 handleResponse(LdapMessageRequest $messageTo, LdapMessageResponse $messageFrom, ClientQueue $queue, array $options) global() argument
H A DMessageCreationTrait.php25 protected function makeRequest(LdapQueue $queue, RequestInterface $request, array $controls): LdapMessageRequest
28 $queue->generateId(),
24 makeRequest(LdapQueue $queue, RequestInterface $request, array $controls) global() argument
/plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Protocol/ServerProtocolHandler/
H A DServerStartTlsHandler.php50 * @param ServerQueue $queue
55 public function handleRequest(LdapMessageRequest $message, TokenInterface $token, RequestHandlerInterface $dispatcher, ServerQueue $queue, array $options): void
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();
45 handleRequest(LdapMessageRequest $message, TokenInterface $token, RequestHandlerInterface $dispatcher, ServerQueue $queue, array $options) global() argument
/plugin/diagramsnet/lib/plugins/
H A 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);
/plugin/jplayer/vendor/happyworm/jplayer/lib/
H A Dpopcorn.ie8.js18 queue: [], property in addEventListener.events
24 events[ eventName ].queue.push( callBack );
52 for ( i = listeners.queue.length - 1; i >= 0; i-- ) {
53 if ( callBack === listeners.queue[ i ] ) {
54 delete listeners.queue[ i ];
91 if ( listeners.queue.length ) {
92 while ( listeners.queue.length ) {
93 queuedListener = listeners.queue.shift();
109 listeners.queue.forEach(function( listener ) {
111 listeners.queue.splice( listeners.queue.indexOf( listener ), 1 );

1234567