Examples of com.sun.sgs.kernel.TransactionScheduler

com.sun.sgs.kernel.TransactionScheduler
This interface is used to schedule transactional tasks for immediate, delayed, or periodic execution. Transactional tasks are short-lived: typically on the order of a few 10s of milliseconds) and not longer than the value of the property {@code com.sun.sgs.txn.timeout}. All tasks run through an implementation of {@code TransactionScheduler} will runtransactionally, and may be re-tried in the event of failure.
Many methods will make a best effort to schedule a given task to run, but based on the policy of the implementation, the task and its owner, may be unable to accept the given task. In this case {@code TaskRejectedException}is thrown. To ensure that a task will be accepted, methods are provided to get a {@code TaskReservation}. This is especially useful for {@code Service}methods working within a transaction that need to ensure that a task will be accepted before they can commit.
If the result of running a task via the {@code reserveTask} or{@code scheduleTask} methods is an {@code Exception} which implements{@code ExceptionRetryStatus}, then its {@code shouldRetry} method iscalled to decide if the task should be re-tried. It is up to the scheduler implementation's policy to decide how and when tasks are re-run, but all failing tasks run through a {@code TransactionScheduler} that wish to bere-tried will eventually be re-run given available resources.
Note that re-try is handled slightly differently for {@code runTask}. See the documentation on that method for more details.

     * get them from two different test nodes.  This ensures that
     * our context is correct.
     */
    public void testContext() throws Exception {
        addNodes(null, 1);
        TransactionScheduler ts1 =
            serverNode.
                getSystemRegistry().getComponent(TransactionScheduler.class);
        TransactionScheduler ts2 =
            additionalNodes[0].
                getSystemRegistry().getComponent(TransactionScheduler.class);
        
        GetManagerTask task = new GetManagerTask();
        ts1.runTask(task, new DummyIdentity("first"));
        Object o1 = task.getManager();
        ts2.runTask(task, new DummyIdentity("second"));
        Object o2 = task.getManager();
        assertNotSame("expected different managers!", o1, o2);
        
        // Now reset to the first manager
        ts1.runTask(task, new DummyIdentity("first"));

View Full Code Here

        }
    }}, taskOwner);


      for (int i = 0; i < iterations; i++) {
    for (SgsTestNode node : nodes) {
        TransactionScheduler localTxnScheduler = 
      node.getSystemRegistry().
          getComponent(TransactionScheduler.class);
        Identity identity = node.getProxy().getCurrentOwner();
        localTxnScheduler.scheduleTask(
            new TestAbstractKernelRunnable() {
          public void run() {
        DataManager dataManager =
            AppContext.getDataManager();
        Counter counter;

View Full Code Here

  SgsTestNode node, final DummyClient client, final int numMessages,
  final int offset)
  throws Exception
    {
  System.err.println("sending messages to client [" + client.name + "]");
        TransactionScheduler transactionScheduler = 
            node.getSystemRegistry(). getComponent(TransactionScheduler.class);
  for (int i = 0; i < numMessages; i++) {
      final int x = i + offset;
      transactionScheduler.runTask(new TestAbstractKernelRunnable() {
    public void run() {
        ClientSession session = (ClientSession)
      AppContext.getDataManager().getBinding(client.name);
      ByteBuffer buf = ByteBuffer.allocate(4);
      buf.putInt(x).flip();

View Full Code Here

        }
    }}, taskOwner);


      for (int i = 0; i < iterations; i++) {
    for (SgsTestNode node : nodes) {
        TransactionScheduler localTxnScheduler = 
      node.getSystemRegistry().
          getComponent(TransactionScheduler.class);
        Identity identity = node.getProxy().getCurrentOwner();
        localTxnScheduler.scheduleTask(
            new TestAbstractKernelRunnable() {
          public void run() {
        DataManager dataManager =
            AppContext.getDataManager();
        Counter counter;

View Full Code Here

  SgsTestNode node, final DummyClient client, final int numMessages,
  final int offset)
  throws Exception
    {
  System.err.println("sending messages to client [" + client.name + "]");
        TransactionScheduler transactionScheduler = 
            node.getSystemRegistry(). getComponent(TransactionScheduler.class);
  for (int i = 0; i < numMessages; i++) {
      final int x = i + offset;
      transactionScheduler.runTask(new TestAbstractKernelRunnable() {
    public void run() {
        ClientSession session = (ClientSession)
      AppContext.getDataManager().getBinding(client.name);
      ByteBuffer buf = ByteBuffer.allocate(4);
      buf.putInt(x).flip();

View Full Code Here

            server.getWatchdogService().reportFailure(node.getNodeId(), 
                    WatchdogService.class.getName());


            // The server node that reported the remote 
            // failure should be unaffected
            TransactionScheduler sched = server.getSystemRegistry().
                    getComponent(TransactionScheduler.class);
            Identity own = server.getProxy().getCurrentOwner();
            sched.runTask(new TestAbstractKernelRunnable() {
                public void run() throws Exception {
                    assertTrue(server.getWatchdogService().isLocalNodeAlive());
                }
            }, own);


            try {
                // The node should have failed
                sched = node.getSystemRegistry().
                        getComponent(TransactionScheduler.class);
                own = node.getProxy().getCurrentOwner();
                sched.runTask(new TestAbstractKernelRunnable() {
                    public void run() throws Exception {
                        if (node.getWatchdogService().isLocalNodeAlive()) {
                            fail("Expected watchdogService.isLocalNodeAlive() " +
                                    "to return false");
                        }

View Full Code Here

0 1

TOP

Related Classes of com.sun.sgs.kernel.TransactionScheduler

com.sun.sgs.test.impl.kernel.TestKernelSetAccessCoordinator

com.sun.sgs.test.impl.kernel.TestKernelStartupContext$TestService

com.sun.sgs.test.impl.service.channel.AbstractChannelServiceTest

com.sun.sgs.test.impl.service.data.TestDataServicePerformance

com.sun.sgs.test.impl.service.session.TestClientSessionServiceImplv4

com.sun.sgs.test.impl.service.watchdog.TestWatchdogServiceImpl

com.sun.sgs.test.util.TestSgsTestNode

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.