本文整理汇总了Java中org.apache.catalina.tribes.io.ReplicationStream类的典型用法代码示例。如果您正苦于以下问题：Java ReplicationStream类的具体用法？Java ReplicationStream怎么用？Java ReplicationStream使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ReplicationStream类属于org.apache.catalina.tribes.io包，在下文中一共展示了ReplicationStream类的12个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: applyDiff
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
/**
* Applies a diff to an existing object.
* @param diff byte[]
* @param offset int
* @param length int
* @throws IOException
*/
@Override
public void applyDiff(byte[] diff, int offset, int length) throws IOException, ClassNotFoundException {
try {
lock();
ReplicationStream stream = ( (ClusterManager) getManager()).getReplicationStream(diff, offset, length);
ClassLoader contextLoader = Thread.currentThread().getContextClassLoader();
try {
ClassLoader[] loaders = getClassLoaders();
if (loaders != null && loaders.length > 0)
Thread.currentThread().setContextClassLoader(loaders[0]);
getDeltaRequest().readExternal(stream);
getDeltaRequest().execute(this, ((ClusterManager)getManager()).isNotifyListenersOnReplication());
stream.close();
} finally {
Thread.currentThread().setContextClassLoader(contextLoader);
}
}finally {
unlock();
}
}
开发者ID:liaokailin，项目名称:tomcat7，代码行数:28，代码来源:DeltaSession.java
示例2: applyDiff
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
/**
* Applies a diff to an existing object.
*
* @param diff
* byte[]
* @param offset
* int
* @param length
* int
* @throws IOException
*/
@Override
public void applyDiff(byte[] diff, int offset, int length) throws IOException, ClassNotFoundException {
try {
lock();
ReplicationStream stream = ((ClusterManager) getManager()).getReplicationStream(diff, offset, length);
ClassLoader contextLoader = Thread.currentThread().getContextClassLoader();
try {
ClassLoader[] loaders = getClassLoaders();
if (loaders != null && loaders.length > 0)
Thread.currentThread().setContextClassLoader(loaders[0]);
getDeltaRequest().readExternal(stream);
getDeltaRequest().execute(this, ((ClusterManager) getManager()).isNotifyListenersOnReplication());
stream.close();
} finally {
Thread.currentThread().setContextClassLoader(contextLoader);
}
} finally {
unlock();
}
}
开发者ID:how2j，项目名称:lazycat，代码行数:32，代码来源:DeltaSession.java
示例3: applyDiff
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
/**
* Applies a diff to an existing object.
* @param diff byte[]
* @param offset int
* @param length int
* @throws IOException
*/
@Override
public void applyDiff(byte[] diff, int offset, int length) throws IOException, ClassNotFoundException {
try {
lock();
ReplicationStream stream = ( (ClusterManager) getManager()).getReplicationStream(diff, offset, length);
ClassLoader contextLoader = Thread.currentThread().getContextClassLoader();
try {
ClassLoader[] loaders = getClassLoaders();
if (loaders != null && loaders.length > 0)
Thread.currentThread().setContextClassLoader(loaders[0]);
getDeltaRequest().readExternal(stream);
getDeltaRequest().execute(this, ((ClusterManager)getManager()).isNotifyListenersOnReplication());
} finally {
Thread.currentThread().setContextClassLoader(contextLoader);
}
}finally {
unlock();
}
}
开发者ID:deathspeeder，项目名称:class-guard，代码行数:27，代码来源:DeltaSession.java
示例4: deserializeSessionId
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
/**
* Load sessionID
* @throws IOException if an input/output error occurs
*/
protected String deserializeSessionId(byte[] data) throws IOException {
ReplicationStream ois = getReplicationStream(data);
String sessionId = ois.readUTF();
ois.close();
return sessionId;
}
开发者ID:liaokailin，项目名称:tomcat7，代码行数:11，代码来源:DeltaManager.java
示例5: deserializeDeltaRequest
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
/**
* Load Deltarequest from external node
* Load the Class at container classloader
* @see DeltaRequest#readExternal(java.io.ObjectInput)
* @param session
* @param data message data
* @return The request
* @throws ClassNotFoundException
* @throws IOException
*/
protected DeltaRequest deserializeDeltaRequest(DeltaSession session, byte[] data) throws ClassNotFoundException, IOException {
try {
session.lock();
ReplicationStream ois = getReplicationStream(data);
session.getDeltaRequest().readExternal(ois);
ois.close();
return session.getDeltaRequest();
}finally {
session.unlock();
}
}
开发者ID:liaokailin，项目名称:tomcat7，代码行数:22，代码来源:DeltaManager.java
示例6: deserializeSessionId
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
/**
* Load sessionID
*
* @throws IOException
* if an input/output error occurs
*/
protected String deserializeSessionId(byte[] data) throws IOException {
ReplicationStream ois = getReplicationStream(data);
String sessionId = ois.readUTF();
ois.close();
return sessionId;
}
开发者ID:how2j，项目名称:lazycat，代码行数:13，代码来源:DeltaManager.java
示例7: deserializeDeltaRequest
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
/**
* Load Deltarequest from external node Load the Class at container
* classloader
*
* @see DeltaRequest#readExternal(java.io.ObjectInput)
* @param session
* @param data
* message data
* @return The request
* @throws ClassNotFoundException
* @throws IOException
*/
protected DeltaRequest deserializeDeltaRequest(DeltaSession session, byte[] data)
throws ClassNotFoundException, IOException {
try {
session.lock();
ReplicationStream ois = getReplicationStream(data);
session.getDeltaRequest().readExternal(ois);
ois.close();
return session.getDeltaRequest();
} finally {
session.unlock();
}
}
开发者ID:how2j，项目名称:lazycat，代码行数:25，代码来源:DeltaManager.java
示例8: getReplicationStream
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
@Override
public ReplicationStream getReplicationStream(byte[] data) throws IOException {
return getReplicationStream(data,0,data.length);
}
开发者ID:liaokailin，项目名称:tomcat7，代码行数:5，代码来源:ClusterManagerBase.java
示例9: getReplicationStream
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
@Override
public ReplicationStream getReplicationStream(byte[] data) throws IOException {
return getReplicationStream(data, 0, data.length);
}
开发者ID:how2j，项目名称:lazycat，代码行数:5，代码来源:ClusterManagerBase.java
示例10: getReplicationStream
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
@Override
public ReplicationStream getReplicationStream(byte[] data, int offset, int length) throws IOException {
ByteArrayInputStream fis = new ByteArrayInputStream(data, offset, length);
return new ReplicationStream(fis, getClassLoaders());
}
开发者ID:deathspeeder，项目名称:class-guard，代码行数:6，代码来源:ClusterManagerBase.java
示例11: getReplicationStream
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
/**
* Open stream and use correct ClassLoader (Container), switching thread
* context class loader.
*
* @param data The data
* @return The object input stream
* @throws IOException An error occurred
*/
public ReplicationStream getReplicationStream(byte[] data) throws IOException;
开发者ID:liaokailin，项目名称:tomcat7，代码行数:10，代码来源:ClusterManager.java
示例12: getReplicationStream
import org.apache.catalina.tribes.io.ReplicationStream; //导入依赖的package包/类
/**
* Open stream and use correct ClassLoader (Container), switching thread
* context class loader.
*
* @param data
* The data
* @return The object input stream
* @throws IOException
* An error occurred
*/
public ReplicationStream getReplicationStream(byte[] data) throws IOException;
开发者ID:how2j，项目名称:lazycat，代码行数:12，代码来源:ClusterManager.java
注：本文中的org.apache.catalina.tribes.io.ReplicationStream类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论