Searched refs:queue (Results 126 - 150 of 194) sorted by relevance

12345678

/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorTest.java29 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
83 // Capture the blocking queue that is provided to the mock processor
108 executor.execute("123", task); // First create fills the queue
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorTest.java29 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
83 // Capture the blocking queue that is provided to the mock processor
108 executor.execute("123", task); // First create fills the queue
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/
H A DCoreTokenServiceGuiceModule.java38 import org.forgerock.openam.cts.impl.queue.ResultHandlerFactory;
43 import org.forgerock.openam.cts.monitoring.impl.queue.MonitoredResultHandlerFactory;
155 * This is only utilised by the CTS asynchronous queue implementation, therefore
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/
H A DCoreTokenAdapter.java34 import org.forgerock.openam.cts.impl.queue.ResultHandlerFactory;
35 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
/forgerock/openam-v13/openam-authentication/deviceprint/scripts/src/main/resources/js/
H A Djquery.js3987 queue: function( elem, type, data ) {
3988 var queue;
3991 type = ( type || "fx" ) + "queue";
3992 queue = jQuery._data( elem, type );
3996 if ( !queue || jQuery.isArray(data) ) {
3997 queue = jQuery._data( elem, type, jQuery.makeArray(data) );
3999 queue.push( data );
4002 return queue || [];
4009 var queue = jQuery.queue( ele
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcher.java16 package org.forgerock.openam.cts.impl.queue;
100 * @see org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration#getQueueTimeout()
124 * @see org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration#getQueueTimeout()
130 * @throws CoreTokenException If there was a problem adding the task to the queue.
145 * @see org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration#getQueueTimeout()
151 * @throws CoreTokenException If there was a problem adding the task to the queue.
166 * @see org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration#getQueueTimeout()
182 * @see org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration#getQueueTimeout()
203 * Note: Because a query has no associated Token ID, this function will select a random queue to place the
209 * @see org.forgerock.openam.cts.impl.queue
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/
H A DMultimasterReplication.java77 * The queue of received update messages, to be treated by the ReplayThread
209 * @param queue The BlockingQueue that this domain will use.
217 BlockingQueue<UpdateToReplay> queue)
221 new LDAPReplicationDomain(configuration, queue);
215 createNewDomain( ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> queue) argument
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DMultimasterReplication.java108 * The queue of received update messages, to be treated by the ReplayThread
244 * @param queue The BlockingQueue that this domain will use.
252 BlockingQueue<UpdateToReplay> queue)
256 new LDAPReplicationDomain(configuration, queue, dsrsShutdownSync);
250 createNewDomain( ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> queue) argument
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DMultimasterReplication.java75 * The queue of received update messages, to be treated by the ReplayThread
204 * @param queue The BlockingQueue that this domain will use.
212 BlockingQueue<UpdateToReplay> queue)
216 new LDAPReplicationDomain(configuration, queue);
210 createNewDomain( ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> queue) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/
H A DMultimasterReplication.java77 * The queue of received update messages, to be treated by the ReplayThread
209 * @param queue The BlockingQueue that this domain will use.
217 BlockingQueue<UpdateToReplay> queue)
221 new LDAPReplicationDomain(configuration, queue);
215 createNewDomain( ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> queue) argument
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DMultimasterReplication.java108 * The queue of received update messages, to be treated by the ReplayThread
244 * @param queue The BlockingQueue that this domain will use.
252 BlockingQueue<UpdateToReplay> queue)
256 new LDAPReplicationDomain(configuration, queue, dsrsShutdownSync);
250 createNewDomain( ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> queue) argument
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DMultimasterReplication.java109 /** The queue of received update messages, to be treated by the ReplayThread threads. */
229 * @param queue The BlockingQueue that this domain will use.
237 BlockingQueue<UpdateToReplay> queue)
241 new LDAPReplicationDomain(configuration, queue, dsrsShutdownSync);
235 createNewDomain( ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> queue) argument
/forgerock/openam-v13/openam-server-only/src/main/webapp/assets/lib/yui/utilities/
H A Dutilities.js333 actualFrames+=1;};var onComplete=function(){var actual_duration=(new Date()-startTime)/1000;var data={duration:actual_duration,frames:actualFrames,fps:actualFrames/actual_duration};data.toString=function(){return('duration: '+data.duration+', frames: '+data.frames+', fps: '+data.fps);};isAnimated=false;actualFrames=0;this.onComplete.fire(data);};this._onStart=new YAHOO.util.CustomEvent('_start',this,true);this.onStart=new YAHOO.util.CustomEvent('start',this);this.onTween=new YAHOO.util.CustomEvent('tween',this);this._onTween=new YAHOO.util.CustomEvent('_tween',this,true);this.onComplete=new YAHOO.util.CustomEvent('complete',this);this._onComplete=new YAHOO.util.CustomEvent('_complete',this,true);this._onStart.subscribe(onStart);this._onTween.subscribe(onTween);this._onComplete.subscribe(onComplete);}};YAHOO.util.AnimMgr=new function(){var thread=null;var queue=[];var tweenCount=0;this.fps=1000;this.delay=1;this.registerElement=function(tween){queue[queue.length]=tween;tweenCount+=1;tween._onStart.fire();this.start();};this.unRegister=function(tween,index){tween._onComplete.fire();index=index||getIndex(tween);if(index==-1){return false;}
334 queue.splice(index,1);tweenCount-=1;if(tweenCount<=0){this.stop();}
335 return true;};this.start=function(){if(thread===null){thread=setInterval(this.run,this.delay);}};this.stop=function(tween){if(!tween){clearInterval(thread);for(var i=0,len=queue.length;i<len;++i){if(queue[0].isAnimated()){this.unRegister(queue[0],0);}}
336 queue=[];thread=null;tweenCount=0;}
337 else{this.unRegister(tween);}};this.run=function(){for(var i=0,len=queue.length;i<len;++i){var tween=queue[
[all...]
/forgerock/openam-v13/openam-upgrade/src/main/java/org/forgerock/openam/upgrade/steps/
H A DUpgradeCTSMaxConnectionsConfigurationStep.java40 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
/forgerock/openam/openam-server-only/src/main/webapp/assets/lib/yui/utilities/
H A Dutilities.js333 actualFrames+=1;};var onComplete=function(){var actual_duration=(new Date()-startTime)/1000;var data={duration:actual_duration,frames:actualFrames,fps:actualFrames/actual_duration};data.toString=function(){return('duration: '+data.duration+', frames: '+data.frames+', fps: '+data.fps);};isAnimated=false;actualFrames=0;this.onComplete.fire(data);};this._onStart=new YAHOO.util.CustomEvent('_start',this,true);this.onStart=new YAHOO.util.CustomEvent('start',this);this.onTween=new YAHOO.util.CustomEvent('tween',this);this._onTween=new YAHOO.util.CustomEvent('_tween',this,true);this.onComplete=new YAHOO.util.CustomEvent('complete',this);this._onComplete=new YAHOO.util.CustomEvent('_complete',this,true);this._onStart.subscribe(onStart);this._onTween.subscribe(onTween);this._onComplete.subscribe(onComplete);}};YAHOO.util.AnimMgr=new function(){var thread=null;var queue=[];var tweenCount=0;this.fps=1000;this.delay=1;this.registerElement=function(tween){queue[queue.length]=tween;tweenCount+=1;tween._onStart.fire();this.start();};this.unRegister=function(tween,index){tween._onComplete.fire();index=index||getIndex(tween);if(index==-1){return false;}
334 queue.splice(index,1);tweenCount-=1;if(tweenCount<=0){this.stop();}
335 return true;};this.start=function(){if(thread===null){thread=setInterval(this.run,this.delay);}};this.stop=function(tween){if(!tween){clearInterval(thread);for(var i=0,len=queue.length;i<len;++i){if(queue[0].isAnimated()){this.unRegister(queue[0],0);}}
336 queue=[];thread=null;tweenCount=0;}
337 else{this.unRegister(tween);}};this.run=function(){for(var i=0,len=queue.length;i<len;++i){var tween=queue[
[all...]
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/worker/process/
H A DSessionExpiryBatchHandlerTest.java30 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
/forgerock/openam/openam-upgrade/src/main/java/org/forgerock/openam/upgrade/steps/
H A DUpgradeCTSMaxConnectionsConfigurationStep.java40 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DFractionalReplicationTest.java666 // A blocking queue that is used to receive updates from
669 BlockingQueue<UpdateMsg> queue = new LinkedBlockingQueue<UpdateMsg>(); field in class:FractionalReplicationTest.FakeReplicationDomain
751 if (queue != null)
752 queue.add(updateMsg);
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DFractionalReplicationTest.java666 // A blocking queue that is used to receive updates from
669 BlockingQueue<UpdateMsg> queue = new LinkedBlockingQueue<UpdateMsg>(); field in class:FractionalReplicationTest.FakeReplicationDomain
751 if (queue != null)
752 queue.add(updateMsg);
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DFractionalReplicationTest.java666 // A blocking queue that is used to receive updates from
669 BlockingQueue<UpdateMsg> queue = new LinkedBlockingQueue<UpdateMsg>(); field in class:FractionalReplicationTest.FakeReplicationDomain
751 if (queue != null)
752 queue.add(updateMsg);
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1270 task.queue.add(indexBuffer);
2625 * read from a blocking queue private to each index.
2631 private final BlockingQueue<IndexOutputBuffer> queue; field in class:Importer.ScratchFileWriterTask
2644 public ScratchFileWriterTask(BlockingQueue<IndexOutputBuffer> queue, argument
2647 this.queue = queue;
2670 final IndexOutputBuffer indexBuffer = queue.take();
2673 if (!queue.isEmpty())
2675 queue.drainTo(l, DRAIN_TO);
2942 * task and corresponding queue i
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1238 task.queue.add(indexBuffer);
2591 * read from a blocking queue private to each index.
2597 private final BlockingQueue<IndexOutputBuffer> queue; field in class:Importer.ScratchFileWriterTask
2610 public ScratchFileWriterTask(BlockingQueue<IndexOutputBuffer> queue, argument
2613 this.queue = queue;
2636 final IndexOutputBuffer indexBuffer = queue.take();
2639 if (!queue.isEmpty())
2641 queue.drainTo(l, DRAIN_TO);
2908 * task and corresponding queue i
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1238 task.queue.add(indexBuffer);
2591 * read from a blocking queue private to each index.
2597 private final BlockingQueue<IndexOutputBuffer> queue; field in class:Importer.ScratchFileWriterTask
2610 public ScratchFileWriterTask(BlockingQueue<IndexOutputBuffer> queue, argument
2613 this.queue = queue;
2636 final IndexOutputBuffer indexBuffer = queue.take();
2639 if (!queue.isEmpty())
2641 queue.drainTo(l, DRAIN_TO);
2908 * task and corresponding queue i
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1270 task.queue.add(indexBuffer);
2625 * read from a blocking queue private to each index.
2631 private final BlockingQueue<IndexOutputBuffer> queue; field in class:Importer.ScratchFileWriterTask
2644 public ScratchFileWriterTask(BlockingQueue<IndexOutputBuffer> queue, argument
2647 this.queue = queue;
2670 final IndexOutputBuffer indexBuffer = queue.take();
2673 if (!queue.isEmpty())
2675 queue.drainTo(l, DRAIN_TO);
2942 * task and corresponding queue i
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1238 task.queue.add(indexBuffer);
2591 * read from a blocking queue private to each index.
2597 private final BlockingQueue<IndexOutputBuffer> queue; field in class:Importer.ScratchFileWriterTask
2610 public ScratchFileWriterTask(BlockingQueue<IndexOutputBuffer> queue, argument
2613 this.queue = queue;
2636 final IndexOutputBuffer indexBuffer = queue.take();
2639 if (!queue.isEmpty())
2641 queue.drainTo(l, DRAIN_TO);
2908 * task and corresponding queue i
[all...]

Completed in 116 milliseconds

12345678