Examples of DummyObject


Examples of edu.vt.rt.hyflow.core.tm.dtl2realtime.DummyObject

          //System.out.print("R-" + tid + " ");
          aborted = true;
          context.rollback();   
          if(earlierTxPresent) {
            //while(true) {
            DummyObject object = new DummyObject(threadID);

            synchronized(object) {
              SignalWaitingTxRequest.threadObjectMap.put(threadID, object);
              //System.out.println("Thread " + threadID + " Waiting ");
              SignalWaitingTxRequest.threadList.add(threadID);
               
              DTL2Directory.threadPhaseMap.put(thread_id, DTL2Directory.NOT_IN_COMMIT_PHASE);
              try
                Logger.debug("Thread " + threadID + " Waiting Again " );
                Timespec remainingTime = new Timespec();
                current.getTime();
                if(earlierDeadline(current, deadline) == DeadlineStatus.EARLIER) {
                  remainingTime.setTime(deadline);
                  remainingTime.subtract(current);

                  long milliSecRemaining = remainingTime.getSeconds()*1000 + remainingTime.getNanoseconds()/ 1000000;
                  object.wait(milliSecRemaining);
                  Logger.debug("Thread " + threadID + " Wait is over ");
                } else
                  Logger.debug("Thread " + threadID + " did not wait ");

              } catch(InterruptedException ex) {
View Full Code Here

Examples of org.apache.tuscany.sca.binding.corba.testing.hierarchy.DummyObject

        DynaCorbaRequest request = null;
        try {
            request = new DynaCorbaRequest(refObjectManager, "getDummyObject");
            request.setOutputType(DummyObject.class);
            DynaCorbaResponse response = request.invoke();
            DummyObject dummy = (DummyObject)response.getContent();
            DummyObject dummy2 = dummy.cloneObject();
            dummy2.cloneObject();
            assertNotSame(dummy.getLong(), dummy2.getLong());
        } catch (Exception e) {
            e.printStackTrace();
            fail();
        }
    }
View Full Code Here

Examples of org.apache.tuscany.sca.binding.corba.testing.hierarchy.DummyObject

        DynaCorbaRequest request = null;
        try {
            request = new DynaCorbaRequest(refObjectManager, "getDummyObject");
            request.setOutputType(DummyObject.class);
            DynaCorbaResponse response = request.invoke();
            DummyObject dummy = (DummyObject)response.getContent();
            DummyObject dummy2 = dummy.cloneObject();
            dummy2.cloneObject();
            assertNotSame(dummy.getLong(), dummy2.getLong());
        } catch (Exception e) {
            e.printStackTrace();
            fail();
        }
    }
View Full Code Here

Examples of org.apache.tuscany.sca.binding.corba.testing.hierarchy.DummyObject

        DynaCorbaRequest request = null;
        try {
            request = new DynaCorbaRequest(refObjectManager, "getDummyObject");
            request.setOutputType(DummyObject.class);
            DynaCorbaResponse response = request.invoke();
            DummyObject dummy = (DummyObject)response.getContent();
            DummyObject dummy2 = dummy.cloneObject();
            dummy2.cloneObject();
            assertNotSame(dummy.getLong(), dummy2.getLong());
        } catch (Exception e) {
            e.printStackTrace();
            fail();
        }
    }
View Full Code Here

Examples of org.apache.tuscany.sca.binding.corba.testing.hierarchy.DummyObject

        DynaCorbaRequest request = null;
        try {
            request = new DynaCorbaRequest(refObjectManager, "getDummyObject");
            request.setOutputType(DummyObject.class);
            DynaCorbaResponse response = request.invoke();
            DummyObject dummy = (DummyObject)response.getContent();
            DummyObject dummy2 = dummy.cloneObject();
            dummy2.cloneObject();
            assertNotSame(dummy.getLong(), dummy2.getLong());
        } catch (Exception e) {
            e.printStackTrace();
            fail();
        }
    }
View Full Code Here

Examples of org.apache.tuscany.sca.binding.corba.testing.hierarchy.DummyObject

        DynaCorbaRequest request = null;
        try {
            request = new DynaCorbaRequest(refObjectManager, "getDummyObject");
            request.setOutputType(DummyObject.class);
            DynaCorbaResponse response = request.invoke();
            DummyObject dummy = (DummyObject)response.getContent();
            DummyObject dummy2 = dummy.cloneObject();
            dummy2.cloneObject();
            assertNotSame(dummy.getLong(), dummy2.getLong());
        } catch (Exception e) {
            e.printStackTrace();
            fail();
        }
    }
View Full Code Here

Examples of org.directmemory.test.misc.DummyObject

    ICacheStore cache = new CacheStoreImpl(-1, cacheSize);
    cache.setSupervisor(supervisor);

    logger.debug("started");
      for (int i = 0; i < cacheSize / 1024 / 1.25; i++) {
        cache.put("test" + i, new DummyObject("test"+i, 1024));
//        DummyObject retrObj = (DummyObject)cache.retrieveObject("test"+i);
//        logger.debug(retrObj.getName());
      }
     
      Long finishedAt = Calendar.getInstance().getTimeInMillis();
View Full Code Here

Examples of org.directmemory.test.misc.DummyObject

    ICacheStore cache = new CacheStoreImpl(-1, cacheSize);
    cache.setSupervisor(supervisor);

    logger.debug("started");
      for (int i = 0; i < cacheSize / 1024; i++) {
        cache.put("test" + i, new DummyObject("test"+i, 1024));
      }
     
      Long finishedAt = Calendar.getInstance().getTimeInMillis();
   
      logger.debug("finished in " + (finishedAt - startedAt) + " msecs");
View Full Code Here

Examples of org.directmemory.test.misc.DummyObject

    return "key"+generator.nextInt(cacheSize/objectsSize);
  }

  public DummyObject randomObject() {
      String key = randomKey();
    DummyObject dummy = new DummyObject(key);
    dummy.PayLoad = new byte[objectsSize*generator.nextInt(5)];
    return dummy;
  }
View Full Code Here

Examples of org.directmemory.test.misc.DummyObject

 
  long lastOne = 0;
 
  public DummyObject nextObject() {
      String key = "key"+lastOne++;
    DummyObject dummy = new DummyObject(key);
    dummy.PayLoad = new byte[objectsSize];
    return dummy;
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.