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

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

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

com.sun.sgs.impl.service.data.store.cache.CachingDataStore
Provides an implementation of {@link DataStore} that caches data on thelocal node and communicates with a {@link CachingDataStoreServer}. The caching data store requires the use of an access coordinator that performs pessimistic locking, such as {@link LockingAccessCoordinator}.
The {@link #CachingDataStore constructor} supports the followingconfiguration properties:

Property: {@value #CALLBACK_PORT_PROPERTY}
Default: {@value #DEFAULT_CALLBACK_PORT}
The network port used to accept callback requests. The value must be a non-negative number less than 65536. If the value specified is 0, then an anonymous port will be chosen.

Property: {@value #EVICTION_BATCH_SIZE_PROPERTY}
Default: {@value #DEFAULT_EVICTION_BATCH_SIZE}
The number of entries to consider when selecting a single candidate for eviction. The value must be greater than 0 and no larger than the cache size.

Property: {@value #EVICTION_RESERVE_SIZE_PROPERTY}
Default: {@value #DEFAULT_EVICTION_RESERVE_SIZE}
The number of cache entries to hold in reserve for use while searching for eviction candidates. The value must be greater than 0 and no larger than the cache size.

Property: {@value #LOCK_TIMEOUT_PROPERTY}
Default: {@value #DEFAULT_LOCK_TIMEOUT_PROPORTION} times the transaction timeout.
The maximum amount of time in milliseconds that an attempt to obtain a lock will be allowed to continue before being aborted. The value must be greater than 0, and should be less than the transaction timeout.

Property: {@value #MAX_RETRY_PROPERTY}
Default: {@value #DEFAULT_MAX_RETRY}
The number of milliseconds to continue retrying I/O operations before determining that the failure is permanent. The value must be non-negative.

Property: {@value #NUM_LOCKS_PROPERTY}
Default: {@value #DEFAULT_NUM_LOCKS}
The number of locks used by the cache. The value must be greater than 0. The number of cache locks controls the amount of concurrency.

Property: {@value #RETRY_WAIT_PROPERTY}
Default: {@value #DEFAULT_RETRY_WAIT}
The number of milliseconds to wait before retrying a failed I/O operation. The value must be non-negative.

Property: {@value #SERVER_HOST_PROPERTY}
Default: the value of the {@value com.sun.sgs.impl.kernel.StandardProperties#SERVER_HOST} property, if present, or localhost if this node is starting the server
The name of the host running the {@code CachingDataStoreServer}.

Property: {@value com.sun.sgs.impl.service.data.store.cache.server.CachingDataStoreServerImpl#SERVER_PORT_PROPERTY}
Default: {@value com.sun.sgs.impl.service.data.store.cache.server.CachingDataStoreServerImpl#DEFAULT_SERVER_PORT}
The network port used to make server requests. The value must be a non-negative number less than 65536. The value 0 can only be specified if the {@link StandardProperties#NODE_TYPE} property is not appNode and means that an anonymous port will be chosen for running the server.

Property: {@value #CACHE_SIZE_PROPERTY}
Default: {@value #DEFAULT_CACHE_SIZE}
The maximum number of entries, including name bindings and objects, that can be stored in the cache. The value must be no smaller than {@value #MIN_CACHE_SIZE}.

Property: {@value #UPDATE_QUEUE_SIZE_PROPERTY}
Default: {@value #DEFAULT_UPDATE_QUEUE_SIZE}
The maximum number of commit requests that can be queued waiting to send to the server. The value must be greater than 0 and no more than 5000

This class uses the {@link Logger} named {@code com.sun.sgs.impl.service.data.store.cache.CachingDataStore} to loginformation at the following logging levels:
- {@link Level#SEVERE SEVERE} - Initialization failures
- {@link Level#CONFIG CONFIG} - Constructor properties, data storeheaders
- {@link Level#FINE FINE} - Allocating blocks of object IDs
- {@link Level#FINER FINER} - Transaction operations, class infooperations, and node shutdown
- {@link Level#FINEST FINEST} - Name and object operations
Operations that throw {@link TransactionAbortedException} will instead logthe failure to the {@code Logger} named {@code com.sun.sgs.impl.service.data.store.cache.CachingDataStore.abort}, to make it easier to debug concurrency conflicts.

      Field serverPortField =
    DataStoreClient.class.getDeclaredField("serverPort");
      serverPortField.setAccessible(true);
      return (Integer) serverPortField.get(dsClient);
  } else if (dataStore instanceof CachingDataStore) {
      CachingDataStore cachingDataStore = (CachingDataStore) dataStore;
      Field localServerField =
    CachingDataStore.class.getDeclaredField("localServer");
      localServerField.setAccessible(true);
      CachingDataStoreServerImpl server = (CachingDataStoreServerImpl)
    localServerField.get(cachingDataStore);

View Full Code Here


    /** Create a {@link CachingDataStore}. */
    @Override
    protected DataStore createDataStore(Properties props) throws Exception {
  DataStore store = new DataStoreProfileProducer(
      new CachingDataStore(props, systemRegistry, txnProxy),
      DummyProfileCoordinator.getCollector());
  DummyProfileCoordinator.startProfiling();
  store.ready();
  return store;
    }

View Full Code Here

  props.setProperty(NODE_TYPE, nodeType);
  props.setProperty(SERVER_HOST_PROPERTY, host);
  props.setProperty(SERVER_PORT_PROPERTY, String.valueOf(port));
  props.setProperty(DIRECTORY_PROPERTY, directory);
  DataStore store = new DataStoreProfileProducer(
      new CachingDataStore(props, env.systemRegistry, txnProxy),
      DummyProfileCoordinator.getCollector());
  DummyProfileCoordinator.startProfiling();
  return store;
    }

View Full Code Here

TOP

Related Classes of com.sun.sgs.impl.service.data.store.cache.CachingDataStore

com.sun.sgs.impl.service.data.store.BindingValue

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

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

com.sun.sgs.impl.service.data.store.cache.server.CachingDataStoreServer.NextObjectResults

com.sun.sgs.impl.service.data.store.cache.server.CachingDataStoreServer.RegisterNodeResult

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

com.sun.sgs.impl.sharedutil.PropertiesWrapper

com.sun.sgs.impl.util.ShouldRetryIo

com.sun.sgs.kernel.KernelRunnable

com.sun.sgs.kernel.NodeType

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.