本文整理汇总了Java中org.sdnplatform.sync.error.HandshakeTimeoutException类的典型用法代码示例。如果您正苦于以下问题：Java HandshakeTimeoutException类的具体用法？Java HandshakeTimeoutException怎么用？Java HandshakeTimeoutException使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
HandshakeTimeoutException类属于org.sdnplatform.sync.error包，在下文中一共展示了HandshakeTimeoutException类的4个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: exceptionCaught
import org.sdnplatform.sync.error.HandshakeTimeoutException; //导入依赖的package包/类
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
if (cause instanceof ReadTimeoutException) {
// read timeout
logger.error("[{}->{}] Disconnecting RPC node due to read timeout",
getLocalNodeIdString(), getRemoteNodeIdString());
ctx.channel().close();
} else if (cause instanceof HandshakeTimeoutException) {
// read timeout
logger.error("[{}->{}] Disconnecting RPC node due to " +
"handshake timeout",
getLocalNodeIdString(), getRemoteNodeIdString());
ctx.channel().close();
} else if (cause instanceof ConnectException ||
cause instanceof IOException) {
logger.debug("[{}->{}] {}: {}",
new Object[] {getLocalNodeIdString(),
getRemoteNodeIdString(),
cause.getClass().getName(),
cause.getMessage()});
} else {
logger.error("[{}->{}] An error occurred on RPC channel",
new Object[]{getLocalNodeIdString(),
getRemoteNodeIdString(),
cause});
ctx.channel().close();
}
}
开发者ID:xuraylei，项目名称:fresco_floodlight，代码行数:29，代码来源:AbstractRPCChannelHandler.java
示例2: exceptionCaught
import org.sdnplatform.sync.error.HandshakeTimeoutException; //导入依赖的package包/类
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
if (cause instanceof ReadTimeoutException) {
// read timeout
logger.error("[{}->{}] Disconnecting RPC node due to read timeout",
getLocalNodeIdString(), getRemoteNodeIdString());
ctx.channel().close();
} else if (cause instanceof HandshakeTimeoutException) {
// read timeout
logger.error("[{}->{}] Disconnecting RPC node due to " +
"handshake timeout",
getLocalNodeIdString(), getRemoteNodeIdString());
ctx.channel().close();
} else if (cause instanceof ConnectException ||
cause instanceof IOException) {
logger.debug("[{}->{}] {}: {}",
new Object[] {getLocalNodeIdString(),
getRemoteNodeIdString(),
cause.getClass().getName(),
cause.getMessage()});
} else {
logger.error("[{}->{}] An error occurred on RPC channel",
new Object[]{getLocalNodeIdString(),
getRemoteNodeIdString(),
cause});
ctx.channel().close();
}
}
开发者ID:zhenshengcai，项目名称:floodlight-hardware，代码行数:29，代码来源:AbstractRPCChannelHandler.java
示例3: exceptionCaught
import org.sdnplatform.sync.error.HandshakeTimeoutException; //导入依赖的package包/类
@Override
public void exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) throws Exception {
if (e.getCause() instanceof ReadTimeoutException) {
// read timeout
logger.error("[{}->{}] Disconnecting RPC node due to read timeout",
getLocalNodeIdString(), getRemoteNodeIdString());
ctx.getChannel().close();
} else if (e.getCause() instanceof HandshakeTimeoutException) {
// read timeout
logger.error("[{}->{}] Disconnecting RPC node due to " +
"handshake timeout",
getLocalNodeIdString(), getRemoteNodeIdString());
ctx.getChannel().close();
} else if (e.getCause() instanceof ConnectException ||
e.getCause() instanceof IOException) {
logger.debug("[{}->{}] {}: {}",
new Object[] {getLocalNodeIdString(),
getRemoteNodeIdString(),
e.getCause().getClass().getName(),
e.getCause().getMessage()});
} else {
logger.error("[{}->{}] An error occurred on RPC channel",
new Object[]{getLocalNodeIdString(),
getRemoteNodeIdString(),
e.getCause()});
ctx.getChannel().close();
}
}
开发者ID:rhoybeen，项目名称:floodlightLB，代码行数:30，代码来源:AbstractRPCChannelHandler.java
示例4: exceptionCaught
import org.sdnplatform.sync.error.HandshakeTimeoutException; //导入依赖的package包/类
@Override
@LogMessageDocs({
@LogMessageDoc(level="ERROR",
message="[{id}->{id}] Disconnecting client due to read timeout",
explanation="The connected client has failed to send any " +
"messages or respond to echo requests",
recommendation=LogMessageDoc.CHECK_CONTROLLER),
@LogMessageDoc(level="ERROR",
message="[{id}->{id}] Disconnecting RPC node due to " +
"handshake timeout",
explanation="The remote node did not complete the handshake",
recommendation=LogMessageDoc.CHECK_CONTROLLER),
@LogMessageDoc(level="ERROR",
message="[{id}->{id}] IOException: {message}",
explanation="There was an error communicating with the " +
"remote client",
recommendation=LogMessageDoc.GENERIC_ACTION),
@LogMessageDoc(level="ERROR",
message="[{id}->{id}] ConnectException: {message} {error}",
explanation="There was an error connecting to the " +
"remote node",
recommendation=LogMessageDoc.GENERIC_ACTION),
@LogMessageDoc(level="ERROR",
message="[{}->{}] An error occurred on RPC channel",
explanation="An error occurred processing the message",
recommendation=LogMessageDoc.GENERIC_ACTION),
})
public void exceptionCaught(ChannelHandlerContext ctx,
ExceptionEvent e) throws Exception {
if (e.getCause() instanceof ReadTimeoutException) {
// read timeout
logger.error("[{}->{}] Disconnecting RPC node due to read timeout",
getLocalNodeIdString(), getRemoteNodeIdString());
ctx.getChannel().close();
} else if (e.getCause() instanceof HandshakeTimeoutException) {
// read timeout
logger.error("[{}->{}] Disconnecting RPC node due to " +
"handshake timeout",
getLocalNodeIdString(), getRemoteNodeIdString());
ctx.getChannel().close();
} else if (e.getCause() instanceof ConnectException ||
e.getCause() instanceof IOException) {
logger.debug("[{}->{}] {}: {}",
new Object[] {getLocalNodeIdString(),
getRemoteNodeIdString(),
e.getCause().getClass().getName(),
e.getCause().getMessage()});
} else {
logger.error("[{}->{}] An error occurred on RPC channel",
new Object[]{getLocalNodeIdString(),
getRemoteNodeIdString(),
e.getCause()});
ctx.getChannel().close();
}
}
开发者ID:nsg-ethz，项目名称:iTAP-controller，代码行数:56，代码来源:AbstractRPCChannelHandler.java
注：本文中的org.sdnplatform.sync.error.HandshakeTimeoutException类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论