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

Java RpcUtil类代码示例

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

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



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

示例1: setPipelineFactory

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
@Override
protected ChannelPipelineFactory setPipelineFactory() {
  this.pipelineFactory = new ChannelPipelineFactory() {
    @Override
    public ChannelPipeline getPipeline() {
      return Channels.pipeline(
          RpcUtil.constructRpcFrameDecoder(),
          new WriteHandler(request));
    }
  };
  return this.pipelineFactory;
}
开发者ID:naver，项目名称:hadoop，代码行数:13，代码来源:TestOutOfOrderWrite.java


示例2: start

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
void start(final int idleTimeMilliSeconds, final SocketAddress tcpAddress,
    final SocketAddress udpAddress) {

  tcpServer = new ServerBootstrap(new NioServerSocketChannelFactory(
      Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));
  tcpServer.setPipelineFactory(new ChannelPipelineFactory() {
    private final HashedWheelTimer timer = new HashedWheelTimer();
    private final IdleStateHandler idleStateHandler = new IdleStateHandler(
        timer, 0, 0, idleTimeMilliSeconds, TimeUnit.MILLISECONDS);

    @Override
    public ChannelPipeline getPipeline() throws Exception {
      return Channels.pipeline(RpcUtil.constructRpcFrameDecoder(),
          RpcUtil.STAGE_RPC_MESSAGE_PARSER, idleStateHandler, handler,
          RpcUtil.STAGE_RPC_TCP_RESPONSE);
    }
  });

  udpServer = new ConnectionlessBootstrap(new NioDatagramChannelFactory(
      Executors.newCachedThreadPool()));

  udpServer.setPipeline(Channels.pipeline(RpcUtil.STAGE_RPC_MESSAGE_PARSER,
      handler, RpcUtil.STAGE_RPC_UDP_RESPONSE));

  tcpChannel = tcpServer.bind(tcpAddress);
  udpChannel = udpServer.bind(udpAddress);
  allChannels.add(tcpChannel);
  allChannels.add(udpChannel);

  LOG.info("Portmap server started at tcp://" + tcpChannel.getLocalAddress()
      + ", udp://" + udpChannel.getLocalAddress());
}
开发者ID:naver，项目名称:hadoop，代码行数:33，代码来源:Portmap.java


示例3: messageReceived

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e)
    throws Exception {

  RpcInfo info = (RpcInfo) e.getMessage();
  RpcCall rpcCall = (RpcCall) info.header();
  final int portmapProc = rpcCall.getProcedure();
  int xid = rpcCall.getXid();
  XDR in = new XDR(info.data().toByteBuffer().asReadOnlyBuffer(),
      XDR.State.READING);
  XDR out = new XDR();

  if (portmapProc == PMAPPROC_NULL) {
    out = nullOp(xid, in, out);
  } else if (portmapProc == PMAPPROC_SET) {
    out = set(xid, in, out);
  } else if (portmapProc == PMAPPROC_UNSET) {
    out = unset(xid, in, out);
  } else if (portmapProc == PMAPPROC_DUMP) {
    out = dump(xid, in, out);
  } else if (portmapProc == PMAPPROC_GETPORT) {
    out = getport(xid, in, out);
  } else if (portmapProc == PMAPPROC_GETVERSADDR) {
    out = getport(xid, in, out);
  } else {
    LOG.info("PortmapHandler unknown rpc procedure=" + portmapProc);
    RpcAcceptedReply reply = RpcAcceptedReply.getInstance(xid,
        RpcAcceptedReply.AcceptState.PROC_UNAVAIL, new VerifierNone());
    reply.write(out);
  }

  ChannelBuffer buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap()
      .buffer());
  RpcResponse rsp = new RpcResponse(buf, info.remoteAddress());
  RpcUtil.sendRpcResponse(ctx, rsp);
}
开发者ID:naver，项目名称:hadoop，代码行数:37，代码来源:RpcProgramPortmap.java


示例4: create

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
public static XDR create(PortmapMapping mapping, boolean set) {
  XDR request = new XDR();
  int procedure = set ? RpcProgramPortmap.PMAPPROC_SET
      : RpcProgramPortmap.PMAPPROC_UNSET;
  RpcCall call = RpcCall.getInstance(
      RpcUtil.getNewXid(String.valueOf(RpcProgramPortmap.PROGRAM)),
      RpcProgramPortmap.PROGRAM, RpcProgramPortmap.VERSION, procedure,
      new CredentialsNone(), new VerifierNone());
  call.write(request);
  return mapping.serialize(request);
}
开发者ID:naver，项目名称:hadoop，代码行数:12，代码来源:PortmapRequest.java


示例5: create

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
public static XDR create(PortmapMapping mapping) {
  XDR request = new XDR();
  RpcCall.write(request,
      RpcUtil.getNewXid(String.valueOf(RpcProgramPortmap.PROGRAM)),
      RpcProgramPortmap.PROGRAM, RpcProgramPortmap.VERSION,
      Procedure.PMAPPROC_SET.getValue());
  request.writeInt(AuthFlavor.AUTH_NONE.getValue());
  request.writeInt(0);
  request.writeInt(0);
  request.writeInt(0);
  return mapping.serialize(request);
}
开发者ID:ict-carch，项目名称:hadoop-plus，代码行数:13，代码来源:PortmapRequest.java


示例6: handleInternal

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
@Override
public void handleInternal(ChannelHandlerContext ctx, RpcInfo info) {
  RpcCall rpcCall = (RpcCall) info.header();
  final MNTPROC mntproc = MNTPROC.fromValue(rpcCall.getProcedure());
  int xid = rpcCall.getXid();
  byte[] data = new byte[info.data().readableBytes()];
  info.data().readBytes(data);
  XDR xdr = new XDR(data);
  XDR out = new XDR();
  InetAddress client =
      ((InetSocketAddress) info.remoteAddress()).getAddress();

  if (mntproc == MNTPROC.NULL) {
    out = nullOp(out, xid, client);
  } else if (mntproc == MNTPROC.MNT) {
    out = mnt(xdr, out, xid, client);
  } else if (mntproc == MNTPROC.DUMP) {
    out = dump(out, xid, client);
  } else if (mntproc == MNTPROC.UMNT) {
    out = umnt(xdr, out, xid, client);
  } else if (mntproc == MNTPROC.UMNTALL) {
    umntall(out, xid, client);
  } else if (mntproc == MNTPROC.EXPORT) {
    // Currently only support one NFS export 
    List<NfsExports> hostsMatchers = new ArrayList<NfsExports>();
    hostsMatchers.add(hostsMatcher);
    out = MountResponse.writeExportList(out, xid, exports, hostsMatchers);
  } else {
    // Invalid procedure
    RpcAcceptedReply
        .getInstance(xid, RpcAcceptedReply.AcceptState.PROC_UNAVAIL,
            new VerifierNone()).write(out);
  }
  ChannelBuffer buf =
      ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer());
  RpcResponse rsp = new RpcResponse(buf, info.remoteAddress());
  RpcUtil.sendRpcResponse(ctx, rsp);
}
开发者ID:hopshadoop，项目名称:hops，代码行数:39，代码来源:RpcProgramMountd.java


示例7: setPipelineFactory

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
@Override
protected ChannelPipelineFactory setPipelineFactory() {
  this.pipelineFactory = new ChannelPipelineFactory() {
    @Override
    public ChannelPipeline getPipeline() {
      return Channels.pipeline(RpcUtil.constructRpcFrameDecoder(),
          new WriteHandler(request));
    }
  };
  return this.pipelineFactory;
}
开发者ID:hopshadoop，项目名称:hops，代码行数:12，代码来源:TestOutOfOrderWrite.java


示例8: handleInternal

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
@Override
public void handleInternal(ChannelHandlerContext ctx, RpcInfo info) {
  RpcCall rpcCall = (RpcCall) info.header();
  final MNTPROC mntproc = MNTPROC.fromValue(rpcCall.getProcedure());
  int xid = rpcCall.getXid();
  byte[] data = new byte[info.data().readableBytes()];
  info.data().readBytes(data);
  XDR xdr = new XDR(data);
  XDR out = new XDR();
  InetAddress client = ((InetSocketAddress) info.remoteAddress()).getAddress();

  if (mntproc == MNTPROC.NULL) {
    out = nullOp(out, xid, client);
  } else if (mntproc == MNTPROC.MNT) {
    out = mnt(xdr, out, xid, client);
  } else if (mntproc == MNTPROC.DUMP) {
    out = dump(out, xid, client);
  } else if (mntproc == MNTPROC.UMNT) {      
    out = umnt(xdr, out, xid, client);
  } else if (mntproc == MNTPROC.UMNTALL) {
    umntall(out, xid, client);
  } else if (mntproc == MNTPROC.EXPORT) {
    // Currently only support one NFS export "/"
    List<NfsExports> hostsMatchers = new ArrayList<NfsExports>();
    hostsMatchers.add(hostsMatcher);
    out = MountResponse.writeExportList(out, xid, exports, hostsMatchers);
  } else {
    // Invalid procedure
    RpcAcceptedReply.getInstance(xid,
        RpcAcceptedReply.AcceptState.PROC_UNAVAIL, new VerifierNone()).write(
        out);
  }  
  ChannelBuffer buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer());
  RpcResponse rsp = new RpcResponse(buf, info.remoteAddress());
  RpcUtil.sendRpcResponse(ctx, rsp);
}
开发者ID:chendave，项目名称:hadoop-TCP，代码行数:37，代码来源:RpcProgramMountd.java


示例9: setPipelineFactory

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
@Override
protected ChannelPipelineFactory setPipelineFactory() {
  this.pipelineFactory = new ChannelPipelineFactory() {
    public ChannelPipeline getPipeline() {
      return Channels.pipeline(
          RpcUtil.constructRpcFrameDecoder(),
          new WriteHandler(request));
    }
  };
  return this.pipelineFactory;
}
开发者ID:chendave，项目名称:hadoop-TCP，代码行数:12，代码来源:TestOutOfOrderWrite.java


示例10: handleInternal

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
@Override
public void handleInternal(ChannelHandlerContext ctx, RpcInfo info) {
  RpcCall rpcCall = (RpcCall) info.header();
  final Procedure portmapProc = Procedure.fromValue(rpcCall.getProcedure());
  int xid = rpcCall.getXid();
  byte[] data = new byte[info.data().readableBytes()];
  info.data().readBytes(data);
  XDR in = new XDR(data);
  XDR out = new XDR();

  if (portmapProc == Procedure.PMAPPROC_NULL) {
    out = nullOp(xid, in, out);
  } else if (portmapProc == Procedure.PMAPPROC_SET) {
    out = set(xid, in, out);
  } else if (portmapProc == Procedure.PMAPPROC_UNSET) {
    out = unset(xid, in, out);
  } else if (portmapProc == Procedure.PMAPPROC_DUMP) {
    out = dump(xid, in, out);
  } else if (portmapProc == Procedure.PMAPPROC_GETPORT) {
    out = getport(xid, in, out);
  } else if (portmapProc == Procedure.PMAPPROC_GETVERSADDR) {
    out = getport(xid, in, out);
  } else {
    LOG.info("PortmapHandler unknown rpc procedure=" + portmapProc);
    RpcAcceptedReply reply = RpcAcceptedReply.getInstance(xid,
        RpcAcceptedReply.AcceptState.PROC_UNAVAIL, new VerifierNone());
    reply.write(out);
  }

  ChannelBuffer buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer());
  RpcResponse rsp = new RpcResponse(buf, info.remoteAddress());
  RpcUtil.sendRpcResponse(ctx, rsp);
}
开发者ID:chendave，项目名称:hadoop-TCP，代码行数:34，代码来源:RpcProgramPortmap.java


示例11: create

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
public static XDR create(PortmapMapping mapping) {
  XDR request = new XDR();
  RpcCall call = RpcCall.getInstance(
      RpcUtil.getNewXid(String.valueOf(RpcProgramPortmap.PROGRAM)),
      RpcProgramPortmap.PROGRAM, RpcProgramPortmap.VERSION,
      Procedure.PMAPPROC_SET.getValue(), new CredentialsNone(),
      new VerifierNone());
  call.write(request);
  return mapping.serialize(request);
}
开发者ID:chendave，项目名称:hadoop-TCP，代码行数:11，代码来源:PortmapRequest.java


示例12: handleInternal

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
@Override
public void handleInternal(ChannelHandlerContext ctx, RpcInfo info) {
  RpcCall rpcCall = (RpcCall) info.header();
  final MNTPROC mntproc = MNTPROC.fromValue(rpcCall.getProcedure());
  int xid = rpcCall.getXid();
  byte[] data = new byte[info.data().readableBytes()];
  info.data().readBytes(data);
  XDR xdr = new XDR(data);
  XDR out = new XDR();
  InetAddress client = ((InetSocketAddress) info.remoteAddress()).getAddress();

  if (mntproc == MNTPROC.NULL) {
    out = nullOp(out, xid, client);
  } else if (mntproc == MNTPROC.MNT) {
    out = mnt(xdr, out, xid, client);
  } else if (mntproc == MNTPROC.DUMP) {
    out = dump(out, xid, client);
  } else if (mntproc == MNTPROC.UMNT) {      
    out = umnt(xdr, out, xid, client);
  } else if (mntproc == MNTPROC.UMNTALL) {
    umntall(out, xid, client);
  } else if (mntproc == MNTPROC.EXPORT) {
    // Currently only support one NFS export 
    List<NfsExports> hostsMatchers = new ArrayList<NfsExports>();
    hostsMatchers.add(hostsMatcher);
    out = MountResponse.writeExportList(out, xid, exports, hostsMatchers);
  } else {
    // Invalid procedure
    RpcAcceptedReply.getInstance(xid,
        RpcAcceptedReply.AcceptState.PROC_UNAVAIL, new VerifierNone()).write(
        out);
  }  
  ChannelBuffer buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer());
  RpcResponse rsp = new RpcResponse(buf, info.remoteAddress());
  RpcUtil.sendRpcResponse(ctx, rsp);
}
开发者ID:Seagate，项目名称:hadoop-on-lustre2，代码行数:37，代码来源:RpcProgramMountd.java


示例13: handleInternal

import org.apache.hadoop.oncrpc.RpcUtil; //导入依赖的package包/类
@Override
public void handleInternal(ChannelHandlerContext ctx, RpcInfo info) {
  RpcCall rpcCall = (RpcCall) info.header();
  final MNTPROC mntproc = MNTPROC.fromValue(rpcCall.getProcedure());
  int xid = rpcCall.getXid();
  byte[] data = new byte[info.data().readableBytes()];
  info.data().readBytes(data);
  XDR xdr = new XDR(data);
  XDR out = new XDR();
  InetAddress client = ((InetSocketAddress) info.remoteAddress()).getAddress();

  if (mntproc == MNTPROC.NULL) {
    out = nullOp(out, xid, client);
  } else if (mntproc == MNTPROC.MNT) {
    // Only do port monitoring for MNT
    if (!doPortMonitoring(info.remoteAddress())) {
      out = MountResponse.writeMNTResponse(Nfs3Status.NFS3ERR_ACCES, out,
          xid, null);
    } else {
      out = mnt(xdr, out, xid, client);
    }
  } else if (mntproc == MNTPROC.DUMP) {
    out = dump(out, xid, client);
  } else if (mntproc == MNTPROC.UMNT) {      
    out = umnt(xdr, out, xid, client);
  } else if (mntproc == MNTPROC.UMNTALL) {
    umntall(out, xid, client);
  } else if (mntproc == MNTPROC.EXPORT) {
    // Currently only support one NFS export
    List<NfsExports> hostsMatchers = new ArrayList<NfsExports>();
    if (hostsMatcher != null) {
      hostsMatchers.add(hostsMatcher);
      out = MountResponse.writeExportList(out, xid, exports, hostsMatchers);
    } else {
      // This means there are no valid exports provided.
      RpcAcceptedReply.getInstance(xid,
        RpcAcceptedReply.AcceptState.PROC_UNAVAIL, new VerifierNone()).write(
        out);
    }
  } else {
    // Invalid procedure
    RpcAcceptedReply.getInstance(xid,
        RpcAcceptedReply.AcceptState.PROC_UNAVAIL, new VerifierNone()).write(
        out);
  }
  ChannelBuffer buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer());
  RpcResponse rsp = new RpcResponse(buf, info.remoteAddress());
  RpcUtil.sendRpcResponse(ctx, rsp);
}
开发者ID:naver，项目名称:hadoop，代码行数:50，代码来源:RpcProgramMountd.java



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

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java EmitInfo类代码示例发布时间：2022-05-22
下一篇：
Java RamlModelResult类代码示例发布时间：2022-05-22
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

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

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