write

in lib/aws_lambda_ric/telemetry_log_sink.rb [24:37]

• 13 lines of code
• 4 McCabe index (conditional complexity)

  def write(msg)
    @semaphore ||= Mutex.new
    if @file.nil? || @file.closed?
      $stdout.write(msg)
    else
      @semaphore.synchronize do
        @file.write(FRAME_BYTES)
        @file.write([msg.bytesize].pack('L>'))
        @file.write([(Time.new.to_f*1000000).to_i].pack('Q>'))
        @file.write(msg)
      end
    end
  end