chromium/remoting/host/linux/audio_pipe_reader.cc

// Copyright 2012 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#ifdef UNSAFE_BUFFERS_BUILD
// TODO(crbug.com/40285824): Remove this and convert code to safer constructs.
#pragma allow_unsafe_buffers
#endif

#include "remoting/host/linux/audio_pipe_reader.h"

#include <fcntl.h>
#include <stddef.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>

#include <utility>

#include "base/functional/bind.h"
#include "base/logging.h"
#include "base/posix/eintr_wrapper.h"
#include "base/task/single_thread_task_runner.h"

namespace remoting {

namespace {

const int kSampleBytesPerSecond = …;

#if !defined(F_SETPIPE_SZ)
// F_SETPIPE_SZ is supported only starting linux 2.6.35, but we want to be able
// to compile this code on machines with older kernel.
#define F_SETPIPE_SZ …
#endif  // defined(F_SETPIPE_SZ)

}  // namespace

// static
scoped_refptr<AudioPipeReader> AudioPipeReader::Create(
    scoped_refptr<base::SingleThreadTaskRunner> task_runner,
    const base::FilePath& pipe_path) { … }

AudioPipeReader::AudioPipeReader(
    scoped_refptr<base::SingleThreadTaskRunner> task_runner,
    const base::FilePath& pipe_path)
    : … { … }

AudioPipeReader::~AudioPipeReader() = default;

void AudioPipeReader::AddObserver(StreamObserver* observer) { … }
void AudioPipeReader::RemoveObserver(StreamObserver* observer) { … }

void AudioPipeReader::StartOnAudioThread() { … }

void AudioPipeReader::OnDirectoryChanged(const base::FilePath& path,
                                         bool error) { … }

void AudioPipeReader::TryOpenPipe() { … }

void AudioPipeReader::StartTimer() { … }

void AudioPipeReader::DoCapture() { … }

void AudioPipeReader::WaitForPipeReadable() { … }

// static
void AudioPipeReaderTraits::Destruct(const AudioPipeReader* audio_pipe_reader) { … }

}  // namespace remoting