File Manager

003 File Manager

Current Path: /usr/src/contrib/llvm-project/lldb/include/lldb/Utility

usr / src / contrib / llvm-project / lldb / include / lldb / Utility /

📁 ..
📄 AnsiTerminal.h(4.97 KB)
📄 ArchSpec.h(17.08 KB)
📄 Args.h(13.72 KB)
📄 Baton.h(2.25 KB)
📄 Broadcaster.h(17.55 KB)
📄 CompletionRequest.h(9.23 KB)
📄 Connection.h(6.42 KB)
📄 ConstString.h(17.92 KB)
📄 DataBuffer.h(3.39 KB)
📄 DataBufferHeap.h(3.65 KB)
📄 DataBufferLLVM.h(1.17 KB)
📄 DataEncoder.h(8.45 KB)
📄 DataExtractor.h(39.18 KB)
📄 Endian.h(865 B)
📄 Environment.h(2.68 KB)
📄 Event.h(6.64 KB)
📄 FileSpec.h(15.41 KB)
📄 Flags.h(3.39 KB)
📄 GDBRemote.h(4.15 KB)
📄 IOObject.h(1.38 KB)
📄 Iterable.h(5.5 KB)
📄 LLDBAssert.h(911 B)
📄 Listener.h(5.2 KB)
📄 Log.h(10.51 KB)
📄 Logging.h(2.27 KB)
📄 NameMatches.h(716 B)
📄 Predicate.h(8.08 KB)
📄 ProcessInfo.h(7.92 KB)
📄 RangeMap.h(23.05 KB)
📄 RegisterValue.h(7.08 KB)
📄 RegularExpression.h(3.2 KB)
📄 Reproducer.h(13.25 KB)
📄 ReproducerInstrumentation.h(39.38 KB)
📄 Scalar.h(11.27 KB)
📄 SelectHelper.h(2.53 KB)
📄 SharedCluster.h(1.69 KB)
📄 State.h(2.54 KB)
📄 Status.h(7.31 KB)
📄 Stream.h(14.34 KB)
📄 StreamCallback.h(978 B)
📄 StreamString.h(1.23 KB)
📄 StreamTee.h(4.52 KB)
📄 StringExtractor.h(3.13 KB)
📄 StringExtractorGDBRemote.h(6.12 KB)
📄 StringLexer.h(1.31 KB)
📄 StringList.h(3.47 KB)
📄 StructuredData.h(15.49 KB)
📄 TildeExpressionResolver.h(2.42 KB)
📄 Timeout.h(2.45 KB)
📄 Timer.h(1.87 KB)
📄 TraceOptions.h(1.79 KB)
📄 UUID.h(3.74 KB)
📄 UriParser.h(1.01 KB)
📄 UserID.h(2.8 KB)
📄 UserIDResolver.h(1.8 KB)
📄 VASPrintf.h(636 B)
📄 VMRange.h(3.06 KB)
📄 XcodeSDK.h(2.85 KB)

Editing: StreamTee.h

//===-- StreamTee.h ------------------------------------------*- C++ -*-===//
//
// Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
// See https://llvm.org/LICENSE.txt for license information.
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
//
//===----------------------------------------------------------------------===//

#ifndef LLDB_UTILITY_STREAMTEE_H
#define LLDB_UTILITY_STREAMTEE_H

#include <limits.h>

#include <mutex>

#include "lldb/Utility/Stream.h"

namespace lldb_private {

class StreamTee : public Stream {
public:
  StreamTee(bool colors = false)
      : Stream(colors), m_streams_mutex(), m_streams() {}

StreamTee(lldb::StreamSP &stream_sp)
      : Stream(), m_streams_mutex(), m_streams() {
    // No need to lock mutex during construction
    if (stream_sp)
      m_streams.push_back(stream_sp);
  }

StreamTee(lldb::StreamSP &stream_sp, lldb::StreamSP &stream_2_sp)
      : Stream(), m_streams_mutex(), m_streams() {
    // No need to lock mutex during construction
    if (stream_sp)
      m_streams.push_back(stream_sp);
    if (stream_2_sp)
      m_streams.push_back(stream_2_sp);
  }

StreamTee(const StreamTee &rhs)
      : Stream(rhs), m_streams_mutex(), m_streams() {
    // Don't copy until we lock down "rhs"
    std::lock_guard<std::recursive_mutex> guard(rhs.m_streams_mutex);
    m_streams = rhs.m_streams;
  }

~StreamTee() override {}

StreamTee &operator=(const StreamTee &rhs) {
    if (this != &rhs) {
      Stream::operator=(rhs);
      std::lock(m_streams_mutex, rhs.m_streams_mutex);
      std::lock_guard<std::recursive_mutex> lhs_locker(m_streams_mutex,
                                                       std::adopt_lock);
      std::lock_guard<std::recursive_mutex> rhs_locker(rhs.m_streams_mutex,
                                                       std::adopt_lock);
      m_streams = rhs.m_streams;
    }
    return *this;
  }

void Flush() override {
    std::lock_guard<std::recursive_mutex> guard(m_streams_mutex);
    collection::iterator pos, end;
    for (pos = m_streams.begin(), end = m_streams.end(); pos != end; ++pos) {
      // Allow for our collection to contain NULL streams. This allows the
      // StreamTee to be used with hard coded indexes for clients that might
      // want N total streams with only a few that are set to valid values.
      Stream *strm = pos->get();
      if (strm)
        strm->Flush();
    }
  }

size_t AppendStream(const lldb::StreamSP &stream_sp) {
    size_t new_idx = m_streams.size();
    std::lock_guard<std::recursive_mutex> guard(m_streams_mutex);
    m_streams.push_back(stream_sp);
    return new_idx;
  }

size_t GetNumStreams() const {
    size_t result = 0;
    {
      std::lock_guard<std::recursive_mutex> guard(m_streams_mutex);
      result = m_streams.size();
    }
    return result;
  }

lldb::StreamSP GetStreamAtIndex(uint32_t idx) {
    lldb::StreamSP stream_sp;
    std::lock_guard<std::recursive_mutex> guard(m_streams_mutex);
    if (idx < m_streams.size())
      stream_sp = m_streams[idx];
    return stream_sp;
  }

void SetStreamAtIndex(uint32_t idx, const lldb::StreamSP &stream_sp) {
    std::lock_guard<std::recursive_mutex> guard(m_streams_mutex);
    // Resize our stream vector as necessary to fit as many streams as needed.
    // This also allows this class to be used with hard coded indexes that can
    // be used contain many streams, not all of which are valid.
    if (idx >= m_streams.size())
      m_streams.resize(idx + 1);
    m_streams[idx] = stream_sp;
  }

protected:
  typedef std::vector<lldb::StreamSP> collection;
  mutable std::recursive_mutex m_streams_mutex;
  collection m_streams;

size_t WriteImpl(const void *s, size_t length) override {
    std::lock_guard<std::recursive_mutex> guard(m_streams_mutex);
    if (m_streams.empty())
      return 0;

size_t min_bytes_written = SIZE_MAX;
    collection::iterator pos, end;
    for (pos = m_streams.begin(), end = m_streams.end(); pos != end; ++pos) {
      // Allow for our collection to contain NULL streams. This allows the
      // StreamTee to be used with hard coded indexes for clients that might
      // want N total streams with only a few that are set to valid values.
      Stream *strm = pos->get();
      if (strm) {
        const size_t bytes_written = strm->Write(s, length);
        if (min_bytes_written > bytes_written)
          min_bytes_written = bytes_written;
      }
    }
    if (min_bytes_written == SIZE_MAX)
      return 0;
    return min_bytes_written;
  }
};

} // namespace lldb_private

#endif // LLDB_UTILITY_STREAMTEE_H

003 File Manager

Editing: StreamTee.h

Upload File

Create Folder