Source code

Revision control

Copy as Markdown

Other Tools

/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* vim: set ts=8 sts=2 et sw=2 tw=80: */
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
* You can obtain one at http://mozilla.org/MPL/2.0/. */
#ifndef mozilla_AsyncPlatformPipes_h
#define mozilla_AsyncPlatformPipes_h
#include "mozilla/UniquePtrExtensions.h"
#include "nsIAsyncInputStream.h"
namespace mozilla {
namespace platform_pipe_detail {
class PlatformPipeLink;
} // namespace platform_pipe_detail
// PlatformPipeReader wraps an OS-level file handle as a non-blocking xpcom
// input stream. It is intended for use with byte-oriented OS primitives such
// as pipes or sockets.
//
// Handle Requirements:
// - On POSIX, the handle must support non-blocking I/O and must have
// O_NONBLOCK set. Note that regular files ignore O_NONBLOCK: reads and
// writes always complete synchronously and will block the I/O thread, so
// are unsupported.
// - On Windows, the handle must be opened with FILE_FLAG_OVERLAPPED.
//
// aBufferSize controls the size of the internal buffer used to stage data
// between the caller and the OS.
class PlatformPipeReader final : public nsIAsyncInputStream {
public:
NS_DECL_THREADSAFE_ISUPPORTS
NS_DECL_NSIINPUTSTREAM
NS_DECL_NSIASYNCINPUTSTREAM
PlatformPipeReader(UniqueFileHandle aHandle, uint32_t aBufferSize);
private:
~PlatformPipeReader();
RefPtr<platform_pipe_detail::PlatformPipeLink> mLink;
};
} // namespace mozilla
#endif // mozilla_AsyncPlatformPipes_h