def transfer()

in scrooge-core/src/main/scala/com/twitter/scrooge/ThriftUtil.scala [10:108]
76 lines of code
21 McCabe index (conditional complexity)

  def transfer(outProt: TProtocol, inProt: TProtocol, typ: Byte): Unit =
    transfer(outProt, inProt, typ, Int.MaxValue)

  /**
   * Transfers a piece of thrift data from one TProtocol to another.
   *
   * @param outProt the protocol that the data will be written to
   * @param inProt the protocol that the data will be read from
   * @param typ specifies the type of thrift data to be read
   * @param maxDepth specifies how deeply to recurse through the data transferring it
   */
  def transfer(outProt: TProtocol, inProt: TProtocol, typ: Byte, maxDepth: Int): Unit = {
    if (maxDepth <= 0)
      throw new TException("Maximum depth exceeded")

    typ match {
      case TType.VOID => /* no-op */

      case TType.BOOL =>
        outProt.writeBool(inProt.readBool())

      case TType.BYTE =>
        outProt.writeByte(inProt.readByte())

      case TType.I16 =>
        outProt.writeI16(inProt.readI16())

      case TType.I32 =>
        outProt.writeI32(inProt.readI32())

      case TType.I64 =>
        outProt.writeI64(inProt.readI64())

      case TType.DOUBLE =>
        outProt.writeDouble(inProt.readDouble())

      case TType.STRING =>
        outProt.writeBinary(inProt.readBinary())

      case TType.STRUCT =>
        val struct = inProt.readStructBegin()
        outProt.writeStructBegin(struct)
        var done = false
        while (!done) {
          val field = inProt.readFieldBegin()
          if (field.`type` == TType.STOP) {
            outProt.writeFieldStop()
            done = true
          } else {
            outProt.writeFieldBegin(field)
            transfer(outProt, inProt, field.`type`, maxDepth - 1)
            inProt.readFieldEnd()
            outProt.writeFieldEnd()
          }
        }
        inProt.readStructEnd()
        outProt.writeStructEnd()

      case TType.MAP =>
        val map = inProt.readMapBegin()
        outProt.writeMapBegin(map)
        var i = 0
        while (i < map.size) {
          transfer(outProt, inProt, map.keyType, maxDepth - 1)
          transfer(outProt, inProt, map.valueType, maxDepth - 1)
          i += 1
        }
        inProt.readMapEnd()
        outProt.writeMapEnd()

      case TType.SET =>
        val set = inProt.readSetBegin()
        outProt.writeSetBegin(set)
        var i = 0
        while (i < set.size) {
          transfer(outProt, inProt, set.elemType, maxDepth - 1)
          i += 1
        }
        inProt.readSetEnd()
        outProt.writeSetEnd()

      case TType.LIST =>
        val list = inProt.readListBegin()
        outProt.writeListBegin(list)
        var i = 0
        while (i < list.size) {
          transfer(outProt, inProt, list.elemType, maxDepth - 1)
          i += 1
        }
        inProt.readListEnd()
        outProt.writeListEnd()

      case TType.ENUM =>
        outProt.writeI32(inProt.readI32())

      case unknown =>
        throw new TProtocolException(s"unrecognized type code $unknown")
    }
  }