Examples of com.sun.sgs.app.ResourceUnavailableException

com.sun.sgs.app.ResourceUnavailableException
Thrown when an operation fails because a resource, necessary for the operation, is unavailable.

      GetBindingForRemoveResults results = null;
      BindingKey nameKey = BindingKey.get(name);
      BindingKey nextNameKey = null;
      for (int i = 0; true; i++) {
    if (i > MAX_RANGE_LOCK_RETRIES) {
        throw new ResourceUnavailableException("Too many retries");
    }
    DbTransaction txn = env.beginTransaction(txnTimeout);
    boolean txnDone = false;
    String nextName;
    long oid;

View Full Code Here

  try {
      NextBoundNameResults results = null;
      BindingKey nextNameKey = null;
      for (int i = 0; true; i++) {
    if (i > MAX_RANGE_LOCK_RETRIES) {
        throw new ResourceUnavailableException("Too many retries");
    }
    DbTransaction txn = env.beginTransaction(txnTimeout);
    boolean txnDone = false;
    long oid;
    String nextName;

View Full Code Here

           nameKey.getName(), READ);
      long stop =
    addCheckOverflow(System.currentTimeMillis(), lockTimeout);
      for (int i = 0; true; i++) {
    if (i >= MAX_CACHE_RETRIES) {
        throw new ResourceUnavailableException("Too many retries");
    }
    /* Find cache entry for name or next higher name */
    BindingCacheEntry entry =
        cache.getCeilingBindingEntry(nameKey);
    if (entry == null) {

View Full Code Here

           nameKey.getName(), WRITE);
      long stop =
    addCheckOverflow(System.currentTimeMillis(), lockTimeout);
      for (int i = 0; true; i++) {
    if (i >= MAX_CACHE_RETRIES) {
        throw new ResourceUnavailableException("Too many retries");
    }
    /* Find cache entry for name or next higher name */
    BindingCacheEntry entry =
        cache.getCeilingBindingEntry(nameKey);
    if (entry == null) {

View Full Code Here

    private void addEvent(ChannelEvent event) {


  EventQueue eventQueue = eventQueueRef.get();


  if (!eventQueue.offer(event, this)) {
      throw new ResourceUnavailableException(
       "not enough resources to add channel event");
  }
    }

View Full Code Here

      sessionRef = dm.createReference(session);
  }


  public void validateSession(ClientSession session) {
      if (this.sessionRef == null) {
    throw new ResourceUnavailableException("sessionRef is null");
      } else {
    System.err.println(
        "ValidatingChannelListener.validateSession: session = " +
        session);
    ClientSession thisSession = sessionRef.get();

View Full Code Here

      sessionRef = dm.createReference(session);
  }


  public void validateSession(ClientSession session) {
      if (this.sessionRef == null) {
    throw new ResourceUnavailableException("sessionRef is null");
      } else {
    System.err.println(
        "ValidatingChannelListener.validateSession: session = " +
        session);
    ClientSession thisSession = sessionRef.get();

View Full Code Here

    private void addEvent(ChannelEvent event) {


  EventQueue eventQueue = eventQueueRef.get();


  if (!eventQueue.offer(event, this)) {
      throw new ResourceUnavailableException(
       "not enough resources to add channel event");
  }
    }

View Full Code Here

0 1 2

TOP

Related Classes of com.sun.sgs.app.ResourceUnavailableException

com.sun.sgs.impl.service.channel.ChannelImpl

com.sun.sgs.impl.service.data.store.cache.BasicCacheEntry

com.sun.sgs.impl.service.data.store.cache.CachingDataStore

com.sun.sgs.impl.service.data.store.cache.CachingDataStore$DowngradeBindingTask

com.sun.sgs.impl.service.data.store.cache.CachingDataStore$EvictBindingTask

com.sun.sgs.impl.service.data.store.cache.queue.UpdateQueue

com.sun.sgs.impl.service.data.store.cache.server.CachingDataStoreServerImpl

com.sun.sgs.impl.service.session.ClientSessionImpl

com.sun.sgs.test.impl.service.channel.TestChannelServiceImpl$ValidatingChannelListener

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.