本文整理汇总了Java中com.esotericsoftware.kryonet.KryoNetException类的典型用法代码示例。如果您正苦于以下问题:Java KryoNetException类的具体用法?Java KryoNetException怎么用?Java KryoNetException使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
KryoNetException类属于com.esotericsoftware.kryonet包,在下文中一共展示了KryoNetException类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: next
import com.esotericsoftware.kryonet.KryoNetException; //导入依赖的package包/类
protected final Object next () {
try {
int total = 0;
while (total < chunk.length) {
int count = input.read(chunk, total, chunk.length - total);
if (count < 0) {
if (total == 0) return null;
byte[] partial = new byte[total];
System.arraycopy(chunk, 0, partial, 0, total);
return next(partial);
}
total += count;
}
} catch (IOException ex) {
throw new KryoNetException(ex);
}
return next(chunk);
}
开发者ID:HoratiusTang,项目名称:EsperDist,代码行数:19,代码来源:InputStreamSender.java
示例2: next
import com.esotericsoftware.kryonet.KryoNetException; //导入依赖的package包/类
protected final Object next() {
try {
int total = 0;
while (total < chunk.length) {
int count = input.read(chunk, total, chunk.length - total);
if (count < 0) {
if (total == 0)
return null;
byte[] partial = new byte[total];
System.arraycopy(chunk, 0, partial, 0, total);
return next(partial);
}
total += count;
}
} catch (IOException ex) {
throw new KryoNetException(ex);
}
return next(chunk);
}
开发者ID:MosaicOwl,项目名称:the-erder,代码行数:20,代码来源:InputStreamSender.java
示例3: next
import com.esotericsoftware.kryonet.KryoNetException; //导入依赖的package包/类
protected final Object next () {
try {
int total = 0;
while (total < chunk.length) {
int count = input.read(chunk, total, chunk.length - total);
if (count < 0) {
if (total == 0) return null;
byte[] partial = new byte[total];
System.arraycopy(chunk, 0, partial, 0, total);
return partial;
}
total += count;
}
} catch (IOException ex) {
throw new KryoNetException(ex);
}
return next(chunk);
}
开发者ID:matheus23,项目名称:RuinsOfRevenge,代码行数:19,代码来源:InputStreamSender.java
示例4: waitForResponse
import com.esotericsoftware.kryonet.KryoNetException; //导入依赖的package包/类
private Object waitForResponse (byte responseID) {
if (connection.getEndPoint().getUpdateThread() == Thread.currentThread())
throw new IllegalStateException("Cannot wait for an RMI response on the connection's update thread.");
long endTime = System.currentTimeMillis() + timeoutMillis;
while (true) {
long remaining = endTime - System.currentTimeMillis();
InvokeMethodResult invokeMethodResult;
synchronized (this) {
invokeMethodResult = responseTable[responseID];
}
if (invokeMethodResult != null) {
lastResponseID = null;
return invokeMethodResult.result;
} else {
if (remaining <= 0) throw new TimeoutException("Response timed out.");
lock.lock();
try {
responseCondition.await(remaining, TimeUnit.MILLISECONDS);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new KryoNetException(e);
} finally {
lock.unlock();
}
}
}
}
开发者ID:abejfehr,项目名称:magic-realm,代码行数:31,代码来源:ObjectSpace.java
示例5: waitForResponse
import com.esotericsoftware.kryonet.KryoNetException; //导入依赖的package包/类
private Object waitForResponse(byte responseID) {
if (connection.getEndPoint().getUpdateThread() == Thread
.currentThread())
throw new IllegalStateException(
"Cannot wait for an RMI response on the connection's update thread.");
long endTime = System.currentTimeMillis() + timeoutMillis;
while (true) {
long remaining = endTime - System.currentTimeMillis();
if (responseTable.containsKey(responseID)) {
InvokeMethodResult invokeMethodResult = responseTable
.get(responseID);
responseTable.remove(responseID);
lastResponseID = null;
return invokeMethodResult.result;
} else {
if (remaining <= 0)
throw new TimeoutException("Response timed out.");
lock.lock();
try {
responseCondition.await(remaining,
TimeUnit.MILLISECONDS);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new KryoNetException(e);
} finally {
lock.unlock();
}
}
}
}
开发者ID:MosaicOwl,项目名称:the-erder,代码行数:34,代码来源:ObjectSpace.java
示例6: write
import com.esotericsoftware.kryonet.KryoNetException; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public void write(Kryo kryo, Output output, Object object) {
Connection connection = (Connection) kryo.getContext().get(
"connection");
int id = getRegisteredID(connection, object);
if (id == Integer.MAX_VALUE)
throw new KryoNetException(
"Object not found in an ObjectSpace: " + object);
output.writeInt(id, true);
}
开发者ID:MosaicOwl,项目名称:the-erder,代码行数:11,代码来源:ObjectSpace.java
示例7: write
import com.esotericsoftware.kryonet.KryoNetException; //导入依赖的package包/类
public void write (Kryo kryo, Output output, Object object) {
Connection connection = (Connection)kryo.getContext().get("connection");
int id = getRegisteredID(connection, object);
if (id == Integer.MAX_VALUE) throw new KryoNetException("Object not found in an ObjectSpace: " + object);
output.writeInt(id, true);
}
开发者ID:abejfehr,项目名称:magic-realm,代码行数:7,代码来源:ObjectSpace.java
注:本文中的com.esotericsoftware.kryonet.KryoNetException类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论