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

Java AcceptState类代码示例

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

本文整理汇总了Java中org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState的典型用法代码示例。如果您正苦于以下问题:Java AcceptState类的具体用法?Java AcceptState怎么用?Java AcceptState使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



AcceptState类属于org.apache.hadoop.oncrpc.RpcAcceptedReply包,在下文中一共展示了AcceptState类的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: messageReceived

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e)
    throws Exception {
  RpcInfo info = (RpcInfo) e.getMessage();
  RpcCall call = (RpcCall) info.header();
  
  SocketAddress remoteAddress = info.remoteAddress();
  if (LOG.isTraceEnabled()) {
    LOG.trace(program + " procedure #" + call.getProcedure());
  }
  
  if (this.progNumber != call.getProgram()) {
    LOG.warn("Invalid RPC call program " + call.getProgram());
    sendAcceptedReply(call, remoteAddress, AcceptState.PROG_UNAVAIL, ctx);
    return;
  }

  int ver = call.getVersion();
  if (ver < lowProgVersion || ver > highProgVersion) {
    LOG.warn("Invalid RPC call version " + ver);
    sendAcceptedReply(call, remoteAddress, AcceptState.PROG_MISMATCH, ctx);
    return;
  }
  
  handleInternal(ctx, info);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:27,代码来源:RpcProgram.java


示例2: sendAcceptedReply

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
private void sendAcceptedReply(RpcCall call, SocketAddress remoteAddress,
    AcceptState acceptState, ChannelHandlerContext ctx) {
  RpcAcceptedReply reply = RpcAcceptedReply.getInstance(call.getXid(),
      acceptState, Verifier.VERIFIER_NONE);

  XDR out = new XDR();
  reply.write(out);
  if (acceptState == AcceptState.PROG_MISMATCH) {
    out.writeInt(lowProgVersion);
    out.writeInt(highProgVersion);
  }
  ChannelBuffer b = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap()
      .buffer());
  RpcResponse rsp = new RpcResponse(b, remoteAddress);
  RpcUtil.sendRpcResponse(ctx, rsp);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:17,代码来源:RpcProgram.java


示例3: handle

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
private void handle(RpcAcceptedReply acceptedReply, XDR xdr) {
  AcceptState acceptState = acceptedReply.getAcceptState();
  assert (acceptState == AcceptState.SUCCESS);
  boolean answer = xdr.readBoolean();
  if (answer != true) {
    LOG.warn("Portmap mapping registration failed, accept state:"
        + acceptState);
  }
  LOG.info("Portmap mapping registration succeeded");
}
 
开发者ID:naver,项目名称:hadoop,代码行数:11,代码来源:RegistrationClient.java


示例4: testAcceptState

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Test
public void testAcceptState() {
  assertEquals(AcceptState.SUCCESS, AcceptState.fromValue(0));
  assertEquals(AcceptState.PROG_UNAVAIL, AcceptState.fromValue(1));
  assertEquals(AcceptState.PROG_MISMATCH, AcceptState.fromValue(2));
  assertEquals(AcceptState.PROC_UNAVAIL, AcceptState.fromValue(3));
  assertEquals(AcceptState.GARBAGE_ARGS, AcceptState.fromValue(4));
  assertEquals(AcceptState.SYSTEM_ERR, AcceptState.fromValue(5));
}
 
开发者ID:naver,项目名称:hadoop,代码行数:10,代码来源:TestRpcAcceptedReply.java


示例5: testConstructor

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Test
public void testConstructor() {
  Verifier verifier = new VerifierNone();
  RpcAcceptedReply reply = new RpcAcceptedReply(0, 
      ReplyState.MSG_ACCEPTED, verifier, AcceptState.SUCCESS);
  assertEquals(0, reply.getXid());
  assertEquals(RpcMessage.Type.RPC_REPLY, reply.getMessageType());
  assertEquals(ReplyState.MSG_ACCEPTED, reply.getState());
  assertEquals(verifier, reply.getVerifier());
  assertEquals(AcceptState.SUCCESS, reply.getAcceptState());
}
 
开发者ID:naver,项目名称:hadoop,代码行数:12,代码来源:TestRpcAcceptedReply.java


示例6: programVersionMismatch

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
private XDR programVersionMismatch(XDR out, RpcCall call) {
  LOG.warn("Invalid RPC call version " + call.getVersion());
  RpcAcceptedReply.voidReply(out, call.getXid(), AcceptState.PROG_MISMATCH);
  out.writeInt(lowProgVersion);
  out.writeInt(highProgVersion);
  return out;
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:8,代码来源:RpcProgram.java


示例7: testConstructor

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Test
public void testConstructor() {
  RpcAuthInfo verifier = new RpcAuthInfo(AuthFlavor.AUTH_NONE, new byte[0]);
  RpcAcceptedReply reply = new RpcAcceptedReply(0, RpcMessage.RPC_REPLY,
      ReplyState.MSG_ACCEPTED, verifier, AcceptState.SUCCESS);
  assertEquals(0, reply.getXid());
  assertEquals(RpcMessage.RPC_REPLY, reply.getMessageType());
  assertEquals(ReplyState.MSG_ACCEPTED, reply.getState());
  assertEquals(verifier, reply.getVerifier());
  assertEquals(AcceptState.SUCCESS, reply.getAcceptState());
}
 
开发者ID:ict-carch,项目名称:hadoop-plus,代码行数:12,代码来源:TestRpcAcceptedReply.java


示例8: testAcceptStateFromInvalidValue

import org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState; //导入依赖的package包/类
@Test(expected = IndexOutOfBoundsException.class)
public void testAcceptStateFromInvalidValue() {
  AcceptState.fromValue(6);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:5,代码来源:TestRpcAcceptedReply.java



注:本文中的org.apache.hadoop.oncrpc.RpcAcceptedReply.AcceptState类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

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

请发表评论

全部评论

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

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

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

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

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