blob: 603f6036b0c748ef2b4a578be1a4eee40f42bc0b [file] [log] [blame]
// Copyright 2017 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef COMPONENTS_SERVICES_HEAP_PROFILING_RECEIVER_PIPE_WIN_H_
#define COMPONENTS_SERVICES_HEAP_PROFILING_RECEIVER_PIPE_WIN_H_
#include <windows.h>
#include <string>
#include "base/files/platform_file.h"
#include "base/macros.h"
#include "base/message_loop/message_pump_win.h"
#include "base/strings/string16.h"
#include "build/build_config.h"
#include "components/services/heap_profiling/receiver_pipe.h"
namespace heap_profiling {
class ReceiverPipe : public ReceiverPipeBase,
public base::MessagePumpForIO::IOHandler {
public:
explicit ReceiverPipe(mojo::PlatformHandle handle);
// Must be called on the IO thread.
void StartReadingOnIOThread();
private:
~ReceiverPipe() override;
void ReadUntilBlocking();
void ZeroOverlapped();
// IOHandler implementation.
void OnIOCompleted(base::MessagePumpForIO::IOContext* context,
DWORD bytes_transfered,
DWORD error) override;
base::MessagePumpForIO::IOContext context_;
// Used to keep |this| live while awaiting IO completion, which is required
// to avoid premature destruction during shutdown.
scoped_refptr<ReceiverPipe> read_outstanding_;
std::unique_ptr<char[]> read_buffer_;
DISALLOW_COPY_AND_ASSIGN(ReceiverPipe);
};
} // namespace heap_profiling
#endif // COMPONENTS_SERVICES_HEAP_PROFILING_RECEIVER_PIPE_WIN_H_