/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutorTest.java | 29 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 D | SeriesTaskExecutorTest.java | 29 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 D | CoreTokenServiceGuiceModule.java | 38 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 D | CoreTokenAdapter.java | 34 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 D | jquery.js | 3987 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 D | TaskDispatcher.java | 16 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 D | MultimasterReplication.java | 77 * 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 D | MultimasterReplication.java | 108 * 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 D | MultimasterReplication.java | 75 * 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 D | MultimasterReplication.java | 77 * 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 D | MultimasterReplication.java | 108 * 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 D | MultimasterReplication.java | 109 /** 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 D | utilities.js | 333 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 D | UpgradeCTSMaxConnectionsConfigurationStep.java | 40 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
|
/forgerock/openam/openam-server-only/src/main/webapp/assets/lib/yui/utilities/ |
H A D | utilities.js | 333 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 D | SessionExpiryBatchHandlerTest.java | 30 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
|
/forgerock/openam/openam-upgrade/src/main/java/org/forgerock/openam/upgrade/steps/ |
H A D | UpgradeCTSMaxConnectionsConfigurationStep.java | 40 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 D | FractionalReplicationTest.java | 666 // 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 D | FractionalReplicationTest.java | 666 // 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 D | FractionalReplicationTest.java | 666 // 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 D | Importer.java | 1270 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 D | Importer.java | 1238 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 D | Importer.java | 1238 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 D | Importer.java | 1270 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 D | Importer.java | 1238 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...] |