• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java HandshakeTimeoutException类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java DefaultFormBuilder类代码示例发布时间:2022-05-21
下一篇:
Java SpringBus类代码示例发布时间:2022-05-21
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap