blob: daedd5eab466fc9371ddeb6850ab3b1347930586 [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 CHROME_PROFILING_MEMLOG_STREAM_RECEIVER_H_
#define CHROME_PROFILING_MEMLOG_STREAM_RECEIVER_H_
#include <memory>
#include "base/macros.h"
#include "base/memory/ref_counted.h"
namespace profiling {
// A stream receiver is a sink for unparsed bytes. See also LogReceiver.
class MemlogStreamReceiver
: public base::RefCountedThreadSafe<MemlogStreamReceiver> {
public:
MemlogStreamReceiver() {}
// Returns true on success, false on unrecoverable error. The implementation
// should be able to handle calls after an error has been reported (some
// cross-thread calls may have been dispatched before the flag propagates).
virtual bool OnStreamData(std::unique_ptr<char[]> data, size_t sz) = 0;
// Indicates the connection has been closed.
virtual void OnStreamComplete() = 0;
protected:
friend class base::RefCountedThreadSafe<MemlogStreamReceiver>;
virtual ~MemlogStreamReceiver() {}
};
} // namespace profiling
#endif // CHROME_PROFILING_MEMLOG_STREAM_RECEIVER_H_