Package | Description |
---|---|
com.caucho.cloud.globalcache | |
com.caucho.distcache | |
com.caucho.distcache.cluster | |
com.caucho.env.distcache | |
com.caucho.memcached | |
com.caucho.server.distcache |
Modifier and Type | Method and Description |
---|---|
void |
GlobalCacheProxy.pushData(java.lang.String clusterId,
int pod,
java.lang.String key,
MnodeUpdate update,
StreamSource source,
ReplyCallback<java.lang.Boolean> cb) |
Modifier and Type | Method and Description |
---|---|
MnodeUpdate |
ExtCacheEntry.getRemoteUpdate() |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractCache.putIfNew(java.lang.Object key,
MnodeUpdate update,
java.io.InputStream is)
Puts a new item in the cache with a custom idle
timeout (used for sessions).
|
boolean |
ByteStreamCache.putIfNew(java.lang.Object key,
MnodeUpdate update,
java.io.InputStream is)
Updates the cache if the old value hash matches the current value.
|
Modifier and Type | Class and Description |
---|---|
class |
CachePut
Updates data for a cache
|
Modifier and Type | Method and Description |
---|---|
MnodeUpdate |
CacheMnodeActor.localPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
StreamSource source)
localPut updates the local copy based on a CachePut message
|
MnodeUpdate |
CacheMnodeLocalProxy.localPut(byte[] key,
byte[] cacheKey,
MnodeUpdate mnodeUpdate,
StreamSource dataSource) |
MnodeUpdate |
CacheMnodeTriadActor.triadPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
int requestLeaseOwner,
StreamSource source)
The CachePut updates a cache entry for a triad.
|
Modifier and Type | Method and Description |
---|---|
void |
CacheMnodeActor.compareAndPut(byte[] keyHash,
byte[] cacheHash,
long testValue,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime,
ReplyCallback<java.lang.Boolean> cb) |
void |
CacheMnodeLocalProxy.compareAndPut(byte[] key,
byte[] cacheKey,
long testValue,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime,
ReplyCallback<java.lang.Boolean> cb) |
boolean |
ClusterCacheEngine.compareAndPut(DistCacheEntry entry,
long testValue,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime) |
java.io.InputStream |
ClusterCacheEngine.getAndPut(DistCacheEntry entry,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime)
Sets a cache entry
|
java.io.InputStream |
CacheMnodeActor.getAndPut(DistCacheEntry entry,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime) |
java.io.InputStream |
CacheMnodeLocalProxy.getAndPut(DistCacheEntry entry,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime) |
MnodeUpdate |
CacheMnodeActor.localPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
StreamSource source)
localPut updates the local copy based on a CachePut message
|
MnodeUpdate |
CacheMnodeLocalProxy.localPut(byte[] key,
byte[] cacheKey,
MnodeUpdate mnodeUpdate,
StreamSource dataSource) |
void |
CacheMnodeProxy.localPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
StreamSource dataSource) |
void |
CacheMnodeActor.put(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate mnodeUpdate,
StreamSource dataSource) |
void |
CacheMnodeTriadActor.put(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
StreamSource dataSource) |
void |
CacheMnodeLocalProxy.put(byte[] key,
byte[] cacheKey,
MnodeUpdate mnodeUpdate,
StreamSource dataSource) |
void |
ClusterCacheEngine.put(HashKey key,
HashKey cacheKey,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime) |
boolean |
ClusterDataBacking.putLocalValue(MnodeEntry mnodeValue,
HashKey key,
HashKey cacheKey,
MnodeEntry oldEntryValue,
MnodeUpdate mnodeUpdate) |
void |
ClusterCacheEngine.remove(HashKey key,
HashKey cacheKey,
MnodeUpdate mnodeUpdate) |
protected boolean |
CacheMnodeActor.triadCompareAndPut(byte[] keyHash,
byte[] cacheHash,
long testHash,
MnodeUpdate update,
StreamSource source) |
boolean |
CacheMnodeTriadActor.triadCompareAndPut(byte[] keyHash,
byte[] cacheHash,
long testHash,
MnodeUpdate update,
StreamSource source)
The CachePut updates a cache entry for a triad.
|
void |
CacheMnodeProxy.triadCompareAndPut(byte[] keyHash,
byte[] cacheHash,
long testHash,
MnodeUpdate update,
StreamSource dataSource,
ReplyCallback<java.lang.Boolean> cb) |
protected CacheUpdateWithSource |
CacheMnodeActor.triadGetAndPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
StreamSource source) |
CacheUpdateWithSource |
CacheMnodeTriadActor.triadGetAndPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
StreamSource source)
The CachePut updates a cache entry for a triad.
|
void |
CacheMnodeProxy.triadGetAndPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
StreamSource dataSource,
ReplyCallback<CacheUpdateWithSource> cb) |
MnodeUpdate |
CacheMnodeTriadActor.triadPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
int requestLeaseOwner,
StreamSource source)
The CachePut updates a cache entry for a triad.
|
void |
CacheMnodeProxy.triadPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
int requestLeaseOwner,
StreamSource dataSource,
ReplyCallback<MnodeUpdate> putCallback) |
Modifier and Type | Method and Description |
---|---|
void |
CacheMnodeProxy.triadPut(byte[] keyHash,
byte[] cacheHash,
MnodeUpdate update,
int requestLeaseOwner,
StreamSource dataSource,
ReplyCallback<MnodeUpdate> putCallback) |
Constructor and Description |
---|
CachePut(MnodeUpdate mnodeUpdate,
StreamSource source)
Create a new CachePut message
|
Modifier and Type | Method and Description |
---|---|
void |
CacheClusterBacking.putCluster(HashKey key,
MnodeUpdate mnodeUpdate,
MnodeEntry mnodeValue) |
void |
AbstractCacheClusterBacking.putCluster(HashKey key,
MnodeUpdate mnodeUpdate,
MnodeEntry mnodeValue) |
boolean |
CacheDataBacking.putLocalValue(MnodeEntry mnodeValue,
HashKey key,
HashKey cacheKey,
MnodeEntry oldEntryValue,
MnodeUpdate mnodeUpdate)
Sets a cache entry
|
void |
CacheClusterBacking.removeCluster(HashKey key,
MnodeUpdate mnodeUpdate,
MnodeEntry mnodeValue) |
void |
AbstractCacheClusterBacking.removeCluster(HashKey key,
MnodeUpdate mnodeUpdate,
MnodeEntry mnodeValue) |
Modifier and Type | Method and Description |
---|---|
void |
MemcachedCacheEngine.put(HashKey hashKey,
HashKey cacheKey,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime) |
void |
MemcachedCacheEngine.remove(HashKey hashKey,
HashKey cacheKey,
MnodeUpdate mnodeUpdate) |
Modifier and Type | Class and Description |
---|---|
class |
CacheUpdateWithSource
Updates data for a cache
|
Modifier and Type | Field and Description |
---|---|
static MnodeUpdate |
MnodeUpdate.NULL |
Modifier and Type | Method and Description |
---|---|
static MnodeUpdate |
MnodeUpdate.createNull(long version,
CacheConfig config) |
static MnodeUpdate |
MnodeUpdate.createNull(long version,
MnodeValue oldValue) |
MnodeUpdate |
MnodeUpdate.createRemote()
Create an update that removes the local information for sending to a
remote server.
|
MnodeUpdate |
ExtCacheEntryFacade.getRemoteUpdate() |
MnodeUpdate |
MnodeEntry.getRemoteUpdate()
Creates an update with local data removed for remote update.
|
MnodeUpdate |
CacheStoreManager.localPut(byte[] keyHash,
MnodeUpdate update,
StreamSource source)
localPut updates the local copy based on a CachePut message
|
MnodeUpdate |
DistCacheEntry.localUpdate(MnodeUpdate update,
java.io.InputStream is) |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractCacheEngine.compareAndPut(DistCacheEntry entry,
long testValue,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime) |
boolean |
CacheEngine.compareAndPut(DistCacheEntry entry,
long testValue,
MnodeUpdate update,
long valueDataId,
long valueDataTime) |
protected boolean |
DistCacheEntry.compareAndPut(DistCacheEntry entry,
long testValue,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime,
java.lang.Object value,
CacheConfig config) |
boolean |
DistCacheEntry.compareAndPutLocal(long testValueHash,
MnodeUpdate update,
long valueDataId,
long valueDataTime,
java.lang.Object value) |
boolean |
DistCacheEntry.compareAndPutLocal(long testValue,
MnodeUpdate update,
StreamSource source) |
java.io.InputStream |
AbstractCacheEngine.getAndPut(DistCacheEntry entry,
MnodeUpdate mnodeValue,
long valueDataId,
long valueDataTime) |
java.io.InputStream |
CacheEngine.getAndPut(DistCacheEntry entry,
MnodeUpdate mnodeValue,
long valueDataId,
long valueDataTime) |
long |
DistCacheEntry.getAndPutLocal(DistCacheEntry entry,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime,
java.lang.Object value) |
DataStore.DataItem |
DistCacheEntry.getAndPutLocal(MnodeUpdate mnodeUpdate,
StreamSource source) |
MnodeUpdate |
CacheStoreManager.localPut(byte[] keyHash,
MnodeUpdate update,
StreamSource source)
localPut updates the local copy based on a CachePut message
|
MnodeUpdate |
DistCacheEntry.localUpdate(MnodeUpdate update,
java.io.InputStream is) |
void |
CacheBackupEngine.put(byte[] key,
byte[] cacheHash,
MnodeUpdate mnodeUpdate,
StreamSource valueStream) |
void |
AbstractCacheBackupEngine.put(byte[] key,
byte[] cacheHash,
MnodeUpdate mnodeUpdate,
StreamSource valueStream) |
void |
AbstractCacheEngine.put(HashKey key,
HashKey cacheKey,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime) |
void |
CacheEngine.put(HashKey key,
HashKey cacheKey,
MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime) |
boolean |
DistCacheEntry.putIfNew(MnodeUpdate update,
java.io.InputStream is)
Sets the value by an input stream
|
boolean |
CacheImpl.putIfNew(java.lang.Object key,
MnodeUpdate update,
java.io.InputStream is)
Updates the cache if the old version matches the current value.
|
boolean |
CacheDataBackingImpl.putLocalValue(MnodeEntry mnodeEntry,
HashKey key,
HashKey cacheKey,
MnodeEntry oldEntryEntry,
MnodeUpdate mnodeUpdate) |
MnodeEntry |
DistCacheEntry.putLocalValue(MnodeUpdate mnodeUpdate,
DataStore.DataItem valueData,
java.lang.Object value)
Sets a cache entry
|
MnodeValue |
DistCacheEntry.putLocalValue(MnodeUpdate mnodeUpdate,
java.io.InputStream is)
Sets a cache entry
|
MnodeEntry |
DistCacheEntry.putLocalValue(MnodeUpdate mnodeUpdate,
long valueDataId,
long valueDataTime,
java.lang.Object value)
Sets a cache entry
|
void |
CacheBackupEngine.remove(byte[] key,
byte[] cacheHash,
MnodeUpdate mnodeUpdate) |
void |
AbstractCacheBackupEngine.remove(byte[] key,
byte[] cacheHash,
MnodeUpdate mnodeUpdate) |
void |
AbstractCacheEngine.remove(HashKey key,
HashKey cacheKey,
MnodeUpdate mnodeUpdate) |
void |
CacheEngine.remove(HashKey key,
HashKey cacheKey,
MnodeUpdate mnodeUpdate) |
Constructor and Description |
---|
CacheUpdateWithSource(MnodeUpdate mnodeUpdate,
StreamSource source)
Create a new CachePut message
|
MnodeUpdate(MnodeUpdate update) |