SmbDataSourceRead.kt

class SmbDataSource(private val dataSpec: DataSpec) : BaseDataSource(/* isNetwork= */ true) {
  
  private var bytesRemaining: Long
  
  @Throws(IOException::class)
  override fun read(buffer: ByteArray, offset: Int, readLength) {
    if (readLength == 0) {
      return 0
    } else if (bytesRemaining == 0) {
      return C.RESULT_END_OF_INPUT
    }
    
    // Here we are going to read the input stream and get the number of bytes read
    var bytesRead = -1
    try {
      val bytesToRead = if (bytesRemaining == C.LENGTH_UNSET) readLength else min(bytesRemaining, readLength)
      bytesRead = inputStream.read(buffer, offset, bytesToRead)
    } catch (e: IOException) {
        throw IOException(e)
    }
    
    if (bytesRead == -1) {
      if (bytesRemaining != C.LENGTH_UNSET) {
        // End of stream reached having not read sufficient data.
        throw new IOException(new EOFException());
      }
      return C.RESULT_END_OF_INPUT;
    }
    if (bytesRemaining != C.LENGTH_UNSET) {
      bytesRemaining -= bytesRead;
    }
    
    return bytesRead;
  }
}