public void write()

in tephra-core/src/main/java/org/apache/tephra/distributed/thrift/TTransaction.java [1223:1299]
77 lines of code
22 McCabe index (conditional complexity)

    public void write(org.apache.thrift.protocol.TProtocol prot, TTransaction struct) throws org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      BitSet optionals = new BitSet();
      if (struct.isSetTransactionId()) {
        optionals.set(0);
      }
      if (struct.isSetReadPointer()) {
        optionals.set(1);
      }
      if (struct.isSetInvalids()) {
        optionals.set(2);
      }
      if (struct.isSetInProgress()) {
        optionals.set(3);
      }
      if (struct.isSetFirstShort()) {
        optionals.set(4);
      }
      if (struct.isSetType()) {
        optionals.set(5);
      }
      if (struct.isSetWritePointer()) {
        optionals.set(6);
      }
      if (struct.isSetCheckpointWritePointers()) {
        optionals.set(7);
      }
      if (struct.isSetVisibilityLevel()) {
        optionals.set(8);
      }
      oprot.writeBitSet(optionals, 9);
      if (struct.isSetTransactionId()) {
        oprot.writeI64(struct.transactionId);
      }
      if (struct.isSetReadPointer()) {
        oprot.writeI64(struct.readPointer);
      }
      if (struct.isSetInvalids()) {
        {
          oprot.writeI32(struct.invalids.size());
          for (long _iter12 : struct.invalids)
          {
            oprot.writeI64(_iter12);
          }
        }
      }
      if (struct.isSetInProgress()) {
        {
          oprot.writeI32(struct.inProgress.size());
          for (long _iter13 : struct.inProgress)
          {
            oprot.writeI64(_iter13);
          }
        }
      }
      if (struct.isSetFirstShort()) {
        oprot.writeI64(struct.firstShort);
      }
      if (struct.isSetType()) {
        oprot.writeI32(struct.type.getValue());
      }
      if (struct.isSetWritePointer()) {
        oprot.writeI64(struct.writePointer);
      }
      if (struct.isSetCheckpointWritePointers()) {
        {
          oprot.writeI32(struct.checkpointWritePointers.size());
          for (long _iter14 : struct.checkpointWritePointers)
          {
            oprot.writeI64(_iter14);
          }
        }
      }
      if (struct.isSetVisibilityLevel()) {
        oprot.writeI32(struct.visibilityLevel.getValue());
      }
    }