gpt4 book ai didi

org.apache.zookeeper.server.ZooKeeperServer.getNextZxid()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-17 02:46:40 26 4
gpt4 key购买 nike

本文整理了Java中org.apache.zookeeper.server.ZooKeeperServer.getNextZxid()方法的一些代码示例,展示了ZooKeeperServer.getNextZxid()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperServer.getNextZxid()方法的具体详情如下:
包路径:org.apache.zookeeper.server.ZooKeeperServer
类名称:ZooKeeperServer
方法名:getNextZxid

ZooKeeperServer.getNextZxid介绍

暂无

代码示例

代码示例来源:origin: apache/zookeeper

case OpCode.create2:
  CreateRequest create2Request = new CreateRequest();
  pRequest2Txn(request.type, zks.getNextZxid(), request, create2Request, true);
  break;
case OpCode.createTTL:
  CreateTTLRequest createTtlRequest = new CreateTTLRequest();
  pRequest2Txn(request.type, zks.getNextZxid(), request, createTtlRequest, true);
  break;
case OpCode.deleteContainer:
case OpCode.delete:
  DeleteRequest deleteRequest = new DeleteRequest();
  pRequest2Txn(request.type, zks.getNextZxid(), request, deleteRequest, true);
  break;
case OpCode.setData:
  SetDataRequest setDataRequest = new SetDataRequest();
  pRequest2Txn(request.type, zks.getNextZxid(), request, setDataRequest, true);
  break;
case OpCode.reconfig:
  ReconfigRequest reconfigRequest = new ReconfigRequest();
  ByteBufferInputStream.byteBuffer2Record(request.request, reconfigRequest);
  pRequest2Txn(request.type, zks.getNextZxid(), request, reconfigRequest, true);
  break;
case OpCode.setACL:
  SetACLRequest setAclRequest = new SetACLRequest();
  pRequest2Txn(request.type, zks.getNextZxid(), request, setAclRequest, true);
  break;
case OpCode.check:
  CheckVersionRequest checkRequest = new CheckVersionRequest();
  pRequest2Txn(request.type, zks.getNextZxid(), request, checkRequest, true);

代码示例来源:origin: org.apache.zookeeper/zookeeper

case OpCode.create:
  CreateRequest createRequest = new CreateRequest();
  pRequest2Txn(request.type, zks.getNextZxid(), request, createRequest, true);
  break;
case OpCode.delete:
  DeleteRequest deleteRequest = new DeleteRequest();               
  pRequest2Txn(request.type, zks.getNextZxid(), request, deleteRequest, true);
  break;
case OpCode.setData:
  SetDataRequest setDataRequest = new SetDataRequest();                
  pRequest2Txn(request.type, zks.getNextZxid(), request, setDataRequest, true);
  break;
case OpCode.setACL:
  SetACLRequest setAclRequest = new SetACLRequest();                
  pRequest2Txn(request.type, zks.getNextZxid(), request, setAclRequest, true);
  break;
case OpCode.check:
  CheckVersionRequest checkRequest = new CheckVersionRequest();              
  pRequest2Txn(request.type, zks.getNextZxid(), request, checkRequest, true);
  break;
case OpCode.multi:
    ByteBufferInputStream.byteBuffer2Record(request.request, multiRequest);
  } catch(IOException e) {
    request.hdr =  new TxnHeader(request.sessionId, request.cxid, zks.getNextZxid(),
        Time.currentWallTime(), OpCode.multi);
    throw e;
  long zxid = zks.getNextZxid();

代码示例来源:origin: org.apache.hadoop/zookeeper

case OpCode.create:
  txnHeader = new TxnHeader(request.sessionId, request.cxid, zks
      .getNextZxid(), zks.getTime(), OpCode.create);
  zks.sessionTracker.checkSession(request.sessionId, request.getOwner());
  CreateRequest createRequest = new CreateRequest();
case OpCode.delete:
  txnHeader = new TxnHeader(request.sessionId, request.cxid, zks
      .getNextZxid(), zks.getTime(), OpCode.delete);
  zks.sessionTracker.checkSession(request.sessionId, request.getOwner());
  DeleteRequest deleteRequest = new DeleteRequest();
case OpCode.setData:
  txnHeader = new TxnHeader(request.sessionId, request.cxid, zks
      .getNextZxid(), zks.getTime(), OpCode.setData);
  zks.sessionTracker.checkSession(request.sessionId, request.getOwner());
  SetDataRequest setDataRequest = new SetDataRequest();
case OpCode.setACL:
  txnHeader = new TxnHeader(request.sessionId, request.cxid, zks
      .getNextZxid(), zks.getTime(), OpCode.setACL);
  zks.sessionTracker.checkSession(request.sessionId, request.getOwner());
  SetACLRequest setAclRequest = new SetACLRequest();
case OpCode.createSession:
  txnHeader = new TxnHeader(request.sessionId, request.cxid, zks
      .getNextZxid(), zks.getTime(), OpCode.createSession);
  request.request.rewind();
  int to = request.request.getInt();

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com