public void read()

in tephra-core/src/main/java/org/apache/tephra/distributed/thrift/TTransaction.java [1302:1368]
67 lines of code
13 McCabe index (conditional complexity)

    public void read(org.apache.thrift.protocol.TProtocol prot, TTransaction struct) throws org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      BitSet incoming = iprot.readBitSet(9);
      if (incoming.get(0)) {
        struct.transactionId = iprot.readI64();
        struct.setTransactionIdIsSet(true);
      }
      if (incoming.get(1)) {
        struct.readPointer = iprot.readI64();
        struct.setReadPointerIsSet(true);
      }
      if (incoming.get(2)) {
        {
          org.apache.thrift.protocol.TList _list15 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
          struct.invalids = new ArrayList<Long>(_list15.size);
          for (int _i16 = 0; _i16 < _list15.size; ++_i16)
          {
            long _elem17; // required
            _elem17 = iprot.readI64();
            struct.invalids.add(_elem17);
          }
        }
        struct.setInvalidsIsSet(true);
      }
      if (incoming.get(3)) {
        {
          org.apache.thrift.protocol.TList _list18 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
          struct.inProgress = new ArrayList<Long>(_list18.size);
          for (int _i19 = 0; _i19 < _list18.size; ++_i19)
          {
            long _elem20; // required
            _elem20 = iprot.readI64();
            struct.inProgress.add(_elem20);
          }
        }
        struct.setInProgressIsSet(true);
      }
      if (incoming.get(4)) {
        struct.firstShort = iprot.readI64();
        struct.setFirstShortIsSet(true);
      }
      if (incoming.get(5)) {
        struct.type = TTransactionType.findByValue(iprot.readI32());
        struct.setTypeIsSet(true);
      }
      if (incoming.get(6)) {
        struct.writePointer = iprot.readI64();
        struct.setWritePointerIsSet(true);
      }
      if (incoming.get(7)) {
        {
          org.apache.thrift.protocol.TList _list21 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
          struct.checkpointWritePointers = new ArrayList<Long>(_list21.size);
          for (int _i22 = 0; _i22 < _list21.size; ++_i22)
          {
            long _elem23; // required
            _elem23 = iprot.readI64();
            struct.checkpointWritePointers.add(_elem23);
          }
        }
        struct.setCheckpointWritePointersIsSet(true);
      }
      if (incoming.get(8)) {
        struct.visibilityLevel = TVisibilityLevel.findByValue(iprot.readI32());
        struct.setVisibilityLevelIsSet(true);
      }
    }