Java 类org.apache.thrift.protocol.TTupleProtocol 实例源码

项目：drift 文件：scribe.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, Log_args struct)
        throws TException
{
    TTupleProtocol iprot = (TTupleProtocol) prot;
    BitSet incoming = iprot.readBitSet(1);
    if (incoming.get(0)) {
        {
            org.apache.thrift.protocol.TList _list5 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
            struct.messages = new ArrayList<>(_list5.size);
            for (int _i6 = 0; _i6 < _list5.size; ++_i6) {
                LogEntry _elem7; // required
                _elem7 = new LogEntry();
                _elem7.read(iprot);
                struct.messages.add(_elem7);
            }
        }
        struct.setMessagesIsSet(true);
    }
}

项目：ditb 文件：Hbase.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, getRowWithColumnsTs_result struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetSuccess()) {
    optionals.set(0);
  }
  if (struct.isSetIo()) {
    optionals.set(1);
  }
  oprot.writeBitSet(optionals, 2);
  if (struct.isSetSuccess()) {
    {
      oprot.writeI32(struct.success.size());
      for (TRowResult _iter222 : struct.success)
      {
        _iter222.write(oprot);
      }
    }
  }
  if (struct.isSetIo()) {
    struct.io.write(oprot);
  }
}

项目：ditb 文件：Hbase.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, getTableNames_result struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetSuccess()) {
    optionals.set(0);
  }
  if (struct.isSetIo()) {
    optionals.set(1);
  }
  oprot.writeBitSet(optionals, 2);
  if (struct.isSetSuccess()) {
    {
      oprot.writeI32(struct.success.size());
      for (ByteBuffer _iter54 : struct.success)
      {
        oprot.writeBinary(_iter54);
      }
    }
  }
  if (struct.isSetIo()) {
    struct.io.write(oprot);
  }
}

项目：ditb 文件：THBaseService.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, getMultiple_result struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(2);
  if (incoming.get(0)) {
    {
      org.apache.thrift.protocol.TList _list145 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.success = new ArrayList<TResult>(_list145.size);
      TResult _elem146;
      for (int _i147 = 0; _i147 < _list145.size; ++_i147)
      {
        _elem146 = new TResult();
        _elem146.read(iprot);
        struct.success.add(_elem146);
      }
    }
    struct.setSuccessIsSet(true);
  }
  if (incoming.get(1)) {
    struct.io = new TIOError();
    struct.io.read(iprot);
    struct.setIoIsSet(true);
  }
}

项目：java-benchmark 文件：ThriftTestObject.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, ThriftTestObject struct) throws TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(5);
  if (incoming.get(0)) {
    struct.field1 = iprot.readString();
    struct.setField1IsSet(true);
  }
  if (incoming.get(1)) {
    struct.field2 = iprot.readString();
    struct.setField2IsSet(true);
  }
  if (incoming.get(2)) {
    struct.field3 = iprot.readString();
    struct.setField3IsSet(true);
  }
  if (incoming.get(3)) {
    struct.field4 = iprot.readString();
    struct.setField4IsSet(true);
  }
  if (incoming.get(4)) {
    struct.field5 = iprot.readString();
    struct.setField5IsSet(true);
  }
}

项目：scheduler 文件：AgentService.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, instructionInvokeAsync_result struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
    {
      org.apache.thrift.protocol.TList _list13 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.success = new ArrayList<Reinstruct>(_list13.size);
      Reinstruct _elem14;
      for (int _i15 = 0; _i15 < _list13.size; ++_i15)
      {
        _elem14 = new Reinstruct();
        _elem14.read(iprot);
        struct.success.add(_elem14);
      }
    }
    struct.setSuccessIsSet(true);
  }
}

项目：Cobweb 文件：LocalWorkerCrawlerServiceBase.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, giveUpTask_args struct) throws TException {
    TTupleProtocol oprot = (TTupleProtocol) prot;
    BitSet optionals = new BitSet();
    if (struct.isSetTaskId()) {
        optionals.set(0);
    }
    if (struct.isSetReason()) {
        optionals.set(1);
    }
    oprot.writeBitSet(optionals, 2);
    if (struct.isSetTaskId()) {
        oprot.writeString(struct.taskId);
    }
    if (struct.isSetReason()) {
        oprot.writeString(struct.reason);
    }
}

项目：fresco_floodlight 文件：ClusterJoinResponseMessage.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, ClusterJoinResponseMessage struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  struct.header = new AsyncMessageHeader();
  struct.header.read(iprot);
  struct.setHeaderIsSet(true);
  BitSet incoming = iprot.readBitSet(2);
  if (incoming.get(0)) {
    struct.newNodeId = iprot.readI16();
    struct.setNewNodeIdIsSet(true);
  }
  if (incoming.get(1)) {
    {
      org.apache.thrift.protocol.TList _list69 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.nodeStore = new ArrayList<KeyedValues>(_list69.size);
      for (int _i70 = 0; _i70 < _list69.size; ++_i70)
      {
        KeyedValues _elem71; // required
        _elem71 = new KeyedValues();
        _elem71.read(iprot);
        struct.nodeStore.add(_elem71);
      }
    }
    struct.setNodeStoreIsSet(true);
  }
}

项目：iTAP-controller 文件：VectorClock.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, VectorClock struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetVersions()) {
    optionals.set(0);
  }
  if (struct.isSetTimestamp()) {
    optionals.set(1);
  }
  oprot.writeBitSet(optionals, 2);
  if (struct.isSetVersions()) {
    {
      oprot.writeI32(struct.versions.size());
      for (ClockEntry _iter4 : struct.versions)
      {
        _iter4.write(oprot);
      }
    }
  }
  if (struct.isSetTimestamp()) {
    oprot.writeI64(struct.timestamp);
  }
}

项目：fresco_floodlight 文件：VectorClock.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, VectorClock struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetVersions()) {
    optionals.set(0);
  }
  if (struct.isSetTimestamp()) {
    optionals.set(1);
  }
  oprot.writeBitSet(optionals, 2);
  if (struct.isSetVersions()) {
    {
      oprot.writeI32(struct.versions.size());
      for (ClockEntry _iter4 : struct.versions)
      {
        _iter4.write(oprot);
      }
    }
  }
  if (struct.isSetTimestamp()) {
    oprot.writeI64(struct.timestamp);
  }
}

项目：ditb 文件：Hbase.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, incrementRows_args struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
    {
      org.apache.thrift.protocol.TList _list453 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.increments = new ArrayList<TIncrement>(_list453.size);
      TIncrement _elem454;
      for (int _i455 = 0; _i455 < _list453.size; ++_i455)
      {
        _elem454 = new TIncrement();
        _elem454.read(iprot);
        struct.increments.add(_elem454);
      }
    }
    struct.setIncrementsIsSet(true);
  }
}

项目：ditb 文件：Hbase.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, getRowsWithColumns_result struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(2);
  if (incoming.get(0)) {
    {
      org.apache.thrift.protocol.TList _list283 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.success = new ArrayList<TRowResult>(_list283.size);
      TRowResult _elem284;
      for (int _i285 = 0; _i285 < _list283.size; ++_i285)
      {
        _elem284 = new TRowResult();
        _elem284.read(iprot);
        struct.success.add(_elem284);
      }
    }
    struct.setSuccessIsSet(true);
  }
  if (incoming.get(1)) {
    struct.io = new IOError();
    struct.io.read(iprot);
    struct.setIoIsSet(true);
  }
}

项目：fresco_floodlight 文件：CursorRequestMessage.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, CursorRequestMessage struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  struct.header.write(oprot);
  BitSet optionals = new BitSet();
  if (struct.isSetStoreName()) {
    optionals.set(0);
  }
  if (struct.isSetCursorId()) {
    optionals.set(1);
  }
  if (struct.isSetClose()) {
    optionals.set(2);
  }
  oprot.writeBitSet(optionals, 3);
  if (struct.isSetStoreName()) {
    oprot.writeString(struct.storeName);
  }
  if (struct.isSetCursorId()) {
    oprot.writeI32(struct.cursorId);
  }
  if (struct.isSetClose()) {
    oprot.writeBool(struct.close);
  }
}

项目：ditb 文件：Hbase.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, mutateRowTs_result struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetIo()) {
    optionals.set(0);
  }
  if (struct.isSetIa()) {
    optionals.set(1);
  }
  oprot.writeBitSet(optionals, 2);
  if (struct.isSetIo()) {
    struct.io.write(oprot);
  }
  if (struct.isSetIa()) {
    struct.ia.write(oprot);
  }
}

项目：ditb 文件：Hbase.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, getColumnDescriptors_result struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(2);
  if (incoming.get(0)) {
    {
      org.apache.thrift.protocol.TMap _map64 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.success = new HashMap<ByteBuffer,ColumnDescriptor>(2*_map64.size);
      ByteBuffer _key65;
      ColumnDescriptor _val66;
      for (int _i67 = 0; _i67 < _map64.size; ++_i67)
      {
        _key65 = iprot.readBinary();
        _val66 = new ColumnDescriptor();
        _val66.read(iprot);
        struct.success.put(_key65, _val66);
      }
    }
    struct.setSuccessIsSet(true);
  }
  if (incoming.get(1)) {
    struct.io = new IOError();
    struct.io.read(iprot);
    struct.setIoIsSet(true);
  }
}

项目：ditb 文件：THBaseService.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, deleteMultiple_result struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(2);
  if (incoming.get(0)) {
    {
      org.apache.thrift.protocol.TList _list169 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.success = new ArrayList<TDelete>(_list169.size);
      TDelete _elem170;
      for (int _i171 = 0; _i171 < _list169.size; ++_i171)
      {
        _elem170 = new TDelete();
        _elem170.read(iprot);
        struct.success.add(_elem170);
      }
    }
    struct.setSuccessIsSet(true);
  }
  if (incoming.get(1)) {
    struct.io = new TIOError();
    struct.io.read(iprot);
    struct.setIoIsSet(true);
  }
}

项目：fresco_floodlight 文件：AuthChallengeResponse.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, AuthChallengeResponse struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetChallenge()) {
    optionals.set(0);
  }
  if (struct.isSetResponse()) {
    optionals.set(1);
  }
  oprot.writeBitSet(optionals, 2);
  if (struct.isSetChallenge()) {
    oprot.writeString(struct.challenge);
  }
  if (struct.isSetResponse()) {
    oprot.writeString(struct.response);
  }
}

项目：fresco_floodlight 文件：ClusterJoinResponseMessage.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, ClusterJoinResponseMessage struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  struct.header.write(oprot);
  BitSet optionals = new BitSet();
  if (struct.isSetNewNodeId()) {
    optionals.set(0);
  }
  if (struct.isSetNodeStore()) {
    optionals.set(1);
  }
  oprot.writeBitSet(optionals, 2);
  if (struct.isSetNewNodeId()) {
    oprot.writeI16(struct.newNodeId);
  }
  if (struct.isSetNodeStore()) {
    {
      oprot.writeI32(struct.nodeStore.size());
      for (KeyedValues _iter68 : struct.nodeStore)
      {
        _iter68.write(oprot);
      }
    }
  }
}

项目：iTAP-controller 文件：SyncError.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, SyncError struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetErrorCode()) {
    optionals.set(0);
  }
  if (struct.isSetMessage()) {
    optionals.set(1);
  }
  oprot.writeBitSet(optionals, 2);
  if (struct.isSetErrorCode()) {
    oprot.writeI32(struct.errorCode);
  }
  if (struct.isSetMessage()) {
    oprot.writeString(struct.message);
  }
}

项目：iTAP-controller 文件：CursorResponseMessage.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, CursorResponseMessage struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  struct.header = new AsyncMessageHeader();
  struct.header.read(iprot);
  struct.setHeaderIsSet(true);
  struct.cursorId = iprot.readI32();
  struct.setCursorIdIsSet(true);
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
    {
      org.apache.thrift.protocol.TList _list61 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.values = new ArrayList<KeyedValues>(_list61.size);
      for (int _i62 = 0; _i62 < _list61.size; ++_i62)
      {
        KeyedValues _elem63; // required
        _elem63 = new KeyedValues();
        _elem63.read(iprot);
        struct.values.add(_elem63);
      }
    }
    struct.setValuesIsSet(true);
  }
}

项目：ditb 文件：Hbase.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, getRowTs_result struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetSuccess()) {
    optionals.set(0);
  }
  if (struct.isSetIo()) {
    optionals.set(1);
  }
  oprot.writeBitSet(optionals, 2);
  if (struct.isSetSuccess()) {
    {
      oprot.writeI32(struct.success.size());
      for (TRowResult _iter196 : struct.success)
      {
        _iter196.write(oprot);
      }
    }
  }
  if (struct.isSetIo()) {
    struct.io.write(oprot);
  }
}

项目：ditb 文件：Hbase.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, createTable_result struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(3);
  if (incoming.get(0)) {
    struct.io = new IOError();
    struct.io.read(iprot);
    struct.setIoIsSet(true);
  }
  if (incoming.get(1)) {
    struct.ia = new IllegalArgument();
    struct.ia.read(iprot);
    struct.setIaIsSet(true);
  }
  if (incoming.get(2)) {
    struct.exist = new AlreadyExists();
    struct.exist.read(iprot);
    struct.setExistIsSet(true);
  }
}

项目：fresco_floodlight 文件：HelloMessage.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, HelloMessage struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  struct.header.write(oprot);
  BitSet optionals = new BitSet();
  if (struct.isSetNodeId()) {
    optionals.set(0);
  }
  if (struct.isSetAuthScheme()) {
    optionals.set(1);
  }
  if (struct.isSetAuthChallengeResponse()) {
    optionals.set(2);
  }
  oprot.writeBitSet(optionals, 3);
  if (struct.isSetNodeId()) {
    oprot.writeI16(struct.nodeId);
  }
  if (struct.isSetAuthScheme()) {
    oprot.writeI32(struct.authScheme.getValue());
  }
  if (struct.isSetAuthChallengeResponse()) {
    struct.authChallengeResponse.write(oprot);
  }
}

项目：fresco_floodlight 文件：Packet.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, Packet struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetMessageType()) {
    optionals.set(0);
  }
  if (struct.isSetSwPortTuple()) {
    optionals.set(1);
  }
  if (struct.isSetData()) {
    optionals.set(2);
  }
  oprot.writeBitSet(optionals, 3);
  if (struct.isSetMessageType()) {
    oprot.writeI32(struct.messageType.getValue());
  }
  if (struct.isSetSwPortTuple()) {
    struct.swPortTuple.write(oprot);
  }
  if (struct.isSetData()) {
    oprot.writeBinary(struct.data);
  }
}

项目：ditb 文件：Hbase.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, deleteTable_result struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetIo()) {
    optionals.set(0);
  }
  oprot.writeBitSet(optionals, 1);
  if (struct.isSetIo()) {
    struct.io.write(oprot);
  }
}

项目：ditb 文件：AlreadyExists.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, AlreadyExists struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
    struct.message = iprot.readString();
    struct.setMessageIsSet(true);
  }
}

项目：iTAP-controller 文件：DeleteResponseMessage.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, DeleteResponseMessage struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(2);
  if (incoming.get(0)) {
    struct.header = new AsyncMessageHeader();
    struct.header.read(iprot);
    struct.setHeaderIsSet(true);
  }
  if (incoming.get(1)) {
    struct.deleted = iprot.readBool();
    struct.setDeletedIsSet(true);
  }
}

项目：drift 文件：scribe.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, Log_result struct)
        throws TException
{
    TTupleProtocol oprot = (TTupleProtocol) prot;
    BitSet optionals = new BitSet();
    if (struct.isSetSuccess()) {
        optionals.set(0);
    }
    oprot.writeBitSet(optionals, 1);
    if (struct.isSetSuccess()) {
        oprot.writeI32(struct.success.getValue());
    }
}

项目：iotdb-jdbc 文件：TSGetOperationStatusReq.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TSGetOperationStatusReq struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  struct.operationHandle = new TSOperationHandle();
  struct.operationHandle.read(iprot);
  struct.setOperationHandleIsSet(true);
}

项目：iTAP-controller 文件：AsyncMessageHeader.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, AsyncMessageHeader struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
    struct.transactionId = iprot.readI32();
    struct.setTransactionIdIsSet(true);
  }
}

项目：ditb 文件：THBaseService.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, deleteSingle_result struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetIo()) {
    optionals.set(0);
  }
  oprot.writeBitSet(optionals, 1);
  if (struct.isSetIo()) {
    struct.io.write(oprot);
  }
}

项目：ditb 文件：THBaseService.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, getRegionLocation_args struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  oprot.writeBinary(struct.table);
  oprot.writeBinary(struct.row);
  BitSet optionals = new BitSet();
  if (struct.isSetReload()) {
    optionals.set(0);
  }
  oprot.writeBitSet(optionals, 1);
  if (struct.isSetReload()) {
    oprot.writeBool(struct.reload);
  }
}

项目：ditb 文件：TIllegalArgument.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TIllegalArgument struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
    struct.message = iprot.readString();
    struct.setMessageIsSet(true);
  }
}

项目：grift 文件：GreeterGrpc.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, sayHello_args struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetRequest()) {
    optionals.set(0);
  }
  oprot.writeBitSet(optionals, 1);
  if (struct.isSetRequest()) {
    struct.request.write(oprot);
  }
}

项目：ditb 文件：TIOError.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, TIOError struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
    struct.message = iprot.readString();
    struct.setMessageIsSet(true);
  }
}

项目：tally 文件：MetricBatch.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, MetricBatch struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(2);
  if (incoming.get(0)) {
    {
      org.apache.thrift.protocol.TList _list18 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.metrics = new ArrayList<Metric>(_list18.size);
      for (int _i19 = 0; _i19 < _list18.size; ++_i19)
      {
        Metric _elem20; // required
        _elem20 = new Metric();
        _elem20.read(iprot);
        struct.metrics.add(_elem20);
      }
    }
    struct.setMetricsIsSet(true);
  }
  if (incoming.get(1)) {
    {
      org.apache.thrift.protocol.TSet _set21 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
      struct.commonTags = new HashSet<MetricTag>(2*_set21.size);
      for (int _i22 = 0; _i22 < _set21.size; ++_i22)
      {
        MetricTag _elem23; // required
        _elem23 = new MetricTag();
        _elem23.read(iprot);
        struct.commonTags.add(_elem23);
      }
    }
    struct.setCommonTagsIsSet(true);
  }
}

项目：iTAP-controller 文件：EchoRequestMessage.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, EchoRequestMessage struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  struct.header = new AsyncMessageHeader();
  struct.header.read(iprot);
  struct.setHeaderIsSet(true);
}

项目：high 文件：ThriftTestService.java

@Override
public void read(org.apache.thrift.protocol.TProtocol prot, test_result struct) throws org.apache.thrift.TException {
  TTupleProtocol iprot = (TTupleProtocol) prot;
  BitSet incoming = iprot.readBitSet(1);
  if (incoming.get(0)) {
    struct.success = iprot.readString();
    struct.setSuccessIsSet(true);
  }
}

项目：leaf-snowflake 文件：leafrpc.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, getID_result struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetSuccess()) {
    optionals.set(0);
  }
  oprot.writeBitSet(optionals, 1);
  if (struct.isSetSuccess()) {
    oprot.writeString(struct.success);
  }
}

项目：ditb 文件：Hbase.java

@Override
public void write(org.apache.thrift.protocol.TProtocol prot, deleteAllRowTs_result struct) throws org.apache.thrift.TException {
  TTupleProtocol oprot = (TTupleProtocol) prot;
  BitSet optionals = new BitSet();
  if (struct.isSetIo()) {
    optionals.set(0);
  }
  oprot.writeBitSet(optionals, 1);
  if (struct.isSetIo()) {
    struct.io.write(oprot);
  }
}