Package | Description |
---|---|
com.caucho.cloud.globalcache | |
com.caucho.distcache | |
com.caucho.distcache.cluster | |
com.caucho.distcache.jdbc | |
com.caucho.env.distcache | |
com.caucho.server.admin | |
com.caucho.server.deploy | |
com.caucho.server.distcache | |
com.caucho.server.repository | |
com.caucho.vfs |
Resin's Virtual File System.
|
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 |
---|---|
StreamSource |
ExtCacheEntry.getValueStream() |
Modifier and Type | Method and Description |
---|---|
DataStore.DataItem |
AbstractCache.saveData(StreamSource source,
int length) |
Modifier and Type | Method and Description |
---|---|
protected StreamSource |
ClusterCacheEngine.createDataSource(long valueIndex,
long valueDataTime) |
StreamSource |
DataPut.getData()
Returns the source
|
StreamSource |
CachePut.getStreamSource()
Returns the stream source
|
StreamSource |
DataPut.getStreamSource()
Returns the stream source
|
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) |
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) |
DataStore.DataItem |
ClusterDataBacking.saveData(StreamSource source,
int length) |
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) |
Constructor and Description |
---|
CachePut(MnodeUpdate mnodeUpdate,
StreamSource source)
Create a new CachePut message
|
CachePut(MnodeValue mnodeValue,
StreamSource source)
Create a new CachePut message
|
DataPut(byte[] value,
StreamSource data)
Create a new CachePut message
|
Modifier and Type | Method and Description |
---|---|
long |
JdbcDataStore.save(HashKey id,
StreamSource source,
int length)
Saves the data, returning true on success.
|
Modifier and Type | Method and Description |
---|---|
DataStore.DataItem |
CacheDataBacking.saveData(StreamSource source,
int length) |
Modifier and Type | Class and Description |
---|---|
class |
GitJarStreamSource
Stream source for Hessian serialization of large data
|
Modifier and Type | Method and Description |
---|---|
StreamSource |
PdfReportQueryReply.getPdf() |
Constructor and Description |
---|
PdfReportQueryReply(java.lang.String message,
java.lang.String fileName,
StreamSource pdf) |
Modifier and Type | Method and Description |
---|---|
StreamSource |
DeployActor.getFile(java.lang.String tag,
java.lang.String fileName)
Returns a file to the client.
|
StreamSource |
DeployActorProxy.getFile(java.lang.String tagName,
java.lang.String fileName) |
Modifier and Type | Method and Description |
---|---|
boolean |
DeployActor.sendFile(java.lang.String sha1,
StreamSource source)
Receives a file from the client.
|
void |
DeployActorProxy.sendFile(java.lang.String sha1,
StreamSource source,
QueryCallback callback) |
Modifier and Type | Class and Description |
---|---|
class |
DataStreamSource
Stream source for Hessian serialization of large data
|
Modifier and Type | Method and Description |
---|---|
StreamSource |
CacheUpdateWithSource.getStreamSource()
Returns the stream source
|
StreamSource |
ExtCacheEntryFacade.getValueStream()
Returns the value of the cache entry.
|
StreamSource |
DistCacheEntry.getValueStream()
Gets a cache entry as a stream
|
StreamSource |
LocalStoreManager.loadDataSource(byte[] keyHash,
byte[] cacheHash) |
Modifier and Type | Method and Description |
---|---|
boolean |
DistCacheEntry.compareAndPutLocal(long testValue,
MnodeUpdate update,
StreamSource source) |
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
|
void |
CacheBackupEngine.put(byte[] key,
byte[] cacheHash,
MnodeUpdate mnodeUpdate,
StreamSource valueStream) |
void |
AbstractCacheBackupEngine.put(byte[] key,
byte[] cacheHash,
MnodeUpdate mnodeUpdate,
StreamSource valueStream) |
DataStore.DataItem |
DataStore.save(StreamSource source,
int length)
Saves the data, returning true on success.
|
DataStore.DataItem |
CacheDataBackingImpl.saveData(StreamSource source,
int length) |
DataStore.DataItem |
CacheImpl.saveData(StreamSource source,
int length) |
LocalDataManager.DataItemLocal |
LocalDataManager.writeData(StreamSource source) |
Constructor and Description |
---|
CacheUpdateWithSource(MnodeUpdate mnodeUpdate,
StreamSource source)
Create a new CachePut message
|
CacheUpdateWithSource(MnodeValue mnodeValue,
StreamSource source,
int leaseOwner)
Create a new CachePut message
|
Modifier and Type | Class and Description |
---|---|
class |
GitStreamSource
Stream source for Hessian serialization of large data
|
Modifier and Type | Method and Description |
---|---|
StreamSource |
SendFile.getStreamSource() |
Modifier and Type | Method and Description |
---|---|
void |
RepositoryProxy.sendFile(java.lang.String sha1,
StreamSource source)
SendFile adds a git file to the repository
|
Constructor and Description |
---|
SendFile(java.lang.String sha1,
StreamSource source)
Creates a notification message
|
Modifier and Type | Class and Description |
---|---|
class |
InputStreamSource
Stream source for Hessian serialization of large data
|
Constructor and Description |
---|
StreamSource(StreamSource indirectSource)
Constructor allowing for dynamic opening.
|