report.cpp

/*******************************************************************************
 * Copyright 2017, 2018 MINRES Technologies GmbH
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *******************************************************************************/
#include "report.h"
#include "configurer.h"
#include <array>
#include <cci_configuration>
#include <deque>
#include <fstream>
#include <mutex>
#include <nonstd/optional.hpp>
#include <spdlog/async.h>
#include <spdlog/sinks/basic_file_sink.h>
#include <spdlog/sinks/stdout_color_sinks.h>
#include <spdlog/spdlog.h>
#include <sysc/kernel/sc_status.h>
#include <tuple>
#include <unordered_map>
#include <util/logging.h>
#ifdef WITH_STACKTRACE
#include <boost/stacktrace.hpp>
#endif
#include <cstdlib>
#ifdef __GNUC__
#define GCC_VERSION (__GNUC__ * 10000 + __GNUC_MINOR__ * 100 + __GNUC_PATCHLEVEL__)
#if GCC_VERSION < 40900
#define USE_C_REGEX
#endif
#define likely(x) __builtin_expect(x, 1)
#define unlikely(x) __builtin_expect(x, 0)
#else
#define likely(x) x
#define unlikely(x) x
#endif
 
#ifdef USE_C_REGEX
#include <regex.h>
#else
#include <regex>
#endif
#ifdef ERROR
#undef ERROR
#endif
using namespace std;
using namespace sc_core;
using namespace scc;
 
namespace {
struct char_equal_to : public std::equal_to<char const*> {
    bool operator()(char const* __x, char const* __y) const { return strcmp(__x, __y) == 0; }
};
 
struct char_hash {
    // BKDR hash algorithm
    uint64_t operator()(char const* str) const {
        constexpr unsigned int seed = 131; // 31  131 1313 13131131313 etc//
        uint64_t hash = 0;
        while(*str) {
            hash = (hash * seed) + (*str);
            str++;
        }
        return hash;
    }
};
static class {
    std::unordered_map<char const*, sc_core::sc_verbosity, char_hash, char_equal_to> table;
    std::deque<std::string> cache;
    std::mutex mtx;
 
public:
    std::tuple<bool, sc_core::sc_verbosity> get(char const* key) {
        std::lock_guard<std::mutex> lock(mtx);
        auto it = table.find(key);
        if(it != table.end())
            return {true, it->second};
        else
            return {false, sc_core::SC_DEBUG};
    }
    void insert(char const* key, sc_core::sc_verbosity verb) {
        std::lock_guard<std::mutex> lock(mtx);
        cache.emplace_back(key);
        table.insert({cache.back().c_str(), verb});
    }
    void clear() {
        std::lock_guard<std::mutex> lock(mtx);
        table.clear();
        cache.clear();
    }
} lut;
#ifdef MTI_SYSTEMC
static const cci::cci_originator originator;
#else
static const cci::cci_originator originator("reporting");
#endif
 
bool& inst_based_logging() {
    thread_local bool active = getenv("SCC_DISABLE_INSTANCE_BASED_LOGGING") == nullptr;
    return active;
}
 
static struct ExtLogConfig : public scc::LogConfig {
    shared_ptr<spdlog::logger> file_logger;
    shared_ptr<spdlog::logger> console_logger;
#ifdef USE_C_REGEX
    regex_t start_state{};
#else
    regex reg_ex;
#endif
    sc_time cycle_base{0, SC_NS};
    auto operator=(const scc::LogConfig& o) -> ExtLogConfig& {
        scc::LogConfig::operator=(o);
        return *this;
    }
    auto match(const char* type) -> bool {
#ifdef USE_C_REGEX
        return regexec(&start_state, type, 0, nullptr, 0) == 0;
#else
        return regex_search(type, reg_ex);
#endif
    }
    bool initialized{false};
    std::mutex mtx;
    nonstd::optional<cci::cci_broker_handle> broker;
} log_cfg;
 
auto get_tuple(const sc_time& t) -> tuple<sc_time::value_type, sc_time_unit> {
    auto val = t.value();
    auto tr = (uint64_t)(sc_time::from_value(1).to_seconds() * 1E15);
    auto scale = 0U;
    while((tr % 10) == 0) {
        tr /= 10;
        scale++;
    }
    sc_assert(tr == 1);
 
    auto tu = scale / 3;
    while(tu < SC_SEC && (val % 10) == 0) {
        val /= 10;
        scale++;
        tu += (0 == (scale % 3));
    }
    for(scale %= 3; scale != 0; scale--)
        val *= 10;
    return make_tuple(val, static_cast<sc_time_unit>(tu));
}
 
auto time2string(const sc_time& t) -> string {
    const array<const char*, 6> time_units{"fs", "ps", "ns", "us", "ms", "s "};
    const array<uint64_t, 6> multiplier{
        1ULL, 1000ULL, 1000ULL * 1000, 1000ULL * 1000 * 1000, 1000ULL * 1000 * 1000 * 1000, 1000ULL * 1000 * 1000 * 1000 * 1000};
    ostringstream oss;
    if(!t.value()) {
        oss << "0 s ";
    } else {
        const auto tt = get_tuple(t);
        const auto val = get<0>(tt);
        const auto scale = get<1>(tt);
        const auto fs_val = val * multiplier[scale];
        for(int j = multiplier.size() - 1; j >= scale; --j) {
            if(fs_val >= multiplier[j]) {
                const auto i = val / multiplier[j - scale];
                const auto f = val % multiplier[j - scale];
                oss << i << '.' << setw(3 * (j - scale)) << setfill('0') << right << f << ' ' << time_units[j];
                break;
            }
        }
    }
    return oss.str();
}
auto compose_message(const sc_report& rep, const scc::LogConfig& cfg) -> const string {
    if(rep.get_severity() > SC_INFO || cfg.log_filter_regex.length() == 0 || rep.get_verbosity() == sc_core::SC_MEDIUM ||
       log_cfg.match(rep.get_msg_type())) {
        stringstream os;
        if(unlikely(cfg.print_sys_time))
            os << "<" << logging::now_time() << ">";
        if(likely(cfg.print_sim_time)) {
            if(unlikely(log_cfg.cycle_base.value())) {
                if(unlikely(cfg.print_delta))
                    os << "[" << std::setw(7) << std::setfill(' ') << sc_time_stamp().value() / log_cfg.cycle_base.value() << "(" << setw(5)
                       << sc_delta_count() << ")]";
                else
                    os << "[" << std::setw(7) << std::setfill(' ') << sc_time_stamp().value() / log_cfg.cycle_base.value() << "]";
            } else {
                auto t = time2string(sc_time_stamp());
                if(unlikely(cfg.print_delta))
                    os << "[" << std::setw(20) << std::setfill(' ') << t << "(" << setw(5) << sc_delta_count() << ")]";
                else
                    os << "[" << std::setw(20) << std::setfill(' ') << t << "]";
            }
        }
        if(unlikely(rep.get_id() >= 0))
            os << " ("
               << "IWEF"[rep.get_severity()] << rep.get_id() << ") " << rep.get_msg_type() << ": ";
        else if(cfg.msg_type_field_width) {
            if(cfg.msg_type_field_width == std::numeric_limits<unsigned>::max())
                os << " " << rep.get_msg_type() << ": ";
            else
                os << " " << util::padded(rep.get_msg_type(), cfg.msg_type_field_width) << ": ";
        }
        if(*rep.get_msg())
            os << rep.get_msg();
        if(rep.get_severity() > SC_INFO) {
            if(rep.get_line_number())
                os << "\n         [FILE:" << rep.get_file_name() << ":" << rep.get_line_number() << "]";
            sc_simcontext* simc = sc_get_curr_simcontext();
            if(simc && sc_is_running()) {
                const char* proc_name = rep.get_process_name();
                if(proc_name)
                    os << "\n         [PROCESS:" << proc_name << "]";
            }
        }
        return os.str();
    } else
        return "";
}
 
inline void log2logger(spdlog::logger& logger, const sc_report& rep, const scc::LogConfig& cfg) {
    auto msg = compose_message(rep, cfg);
    if(!msg.size())
        return;
    switch(rep.get_severity()) {
    case SC_INFO:
        switch(rep.get_verbosity()) {
        case SC_DEBUG:
        case SC_FULL:
            logger.trace(msg);
            break;
        case SC_HIGH:
            logger.debug(msg);
            break;
        default:
            logger.info(msg);
            break;
        }
        break;
    case SC_WARNING:
        logger.warn(msg);
        break;
    case SC_ERROR:
        logger.error(msg);
#ifdef WITH_STACKTRACE
        if(getenv("SCC_PRINT_STACK_ON_ERROR"))
            logger.error(boost::stacktrace::to_string(boost::stacktrace::stacktrace()));
#endif
        break;
    case SC_FATAL:
        logger.critical(msg);
#ifdef WITH_STACKTRACE
        if(getenv("SCC_PRINT_STACK_ON_ERROR"))
            logger.error(boost::stacktrace::to_string(boost::stacktrace::stacktrace()));
#endif
        break;
    default:
        break;
    }
}
 
inline void flush_loggers() {
    log_cfg.console_logger->flush();
    if(log_cfg.file_logger)
        log_cfg.file_logger->flush();
}
 
void report_handler(const sc_report& rep, const sc_actions& actions) {
    thread_local bool sc_stop_called = false;
    if(actions & SC_DO_NOTHING)
        return;
    if(rep.get_severity() == sc_core::SC_INFO || !log_cfg.report_only_first_error || sc_report_handler::get_count(SC_ERROR) < 2) {
        if((actions & SC_DISPLAY) && (!log_cfg.file_logger || rep.get_verbosity() < SC_HIGH))
            try {
                log2logger(*log_cfg.console_logger, rep, log_cfg);
            } catch(const spdlog::spdlog_ex& e) {
            }
        if((actions & SC_LOG) && log_cfg.file_logger) {
            scc::LogConfig lcfg(log_cfg);
            lcfg.print_sim_time = true;
            if(!lcfg.msg_type_field_width)
                lcfg.msg_type_field_width = 24;
            log2logger(*log_cfg.file_logger, rep, lcfg);
        }
    }
    if(actions & SC_STOP) {
        try {
            flush_loggers();
        } catch(const spdlog::spdlog_ex& e) {
        }
#if SYSTEMC_VERSION < 20241015
        static const int stop_expr = sc_core::SC_START_OF_SIMULATION | SC_RUNNING | SC_PAUSED;
#else
        static constexpr int stop_expr = sc_core::SC_START_OF_SIMULATION | SC_RUNNING | SC_PAUSED | SC_SUSPENDED;
#endif
        if((sc_get_status() & stop_expr) && !sc_stop_called) {
            sc_stop();
            sc_stop_called = true;
        }
    }
    if(actions & SC_ABORT) {
        try {
            flush_loggers();
        } catch(const spdlog::spdlog_ex& e) {
        }
        spdlog::shutdown();
        abort();
    }
    if(actions & SC_THROW) {
        try {
            flush_loggers();
        } catch(const spdlog::spdlog_ex& e) {
        }
        throw rep;
    }
    if(sc_time_stamp().value() && !sc_is_running()) {
        try {
            flush_loggers();
        } catch(const spdlog::spdlog_ex& e) {
        }
    }
}
} // namespace
namespace scc {
std::mutex verbosity_mtx;
}
scc::stream_redirection::stream_redirection(ostream& os, log level)
: os(os)
, level(level) {
    old_buf = os.rdbuf(this); // save and redirect
}
 
scc::stream_redirection::~stream_redirection() {
    os.rdbuf(old_buf); // restore
}
 
void scc::stream_redirection::reset() {
    os.rdbuf(old_buf); // restore
    old_buf = nullptr;
}
 
auto scc::stream_redirection::xsputn(const char_type* s, streamsize n) -> streamsize {
    auto sz = stringbuf::xsputn(s, n);
    if(s[n - 1] == '\n') {
        sync();
    }
    return sz;
}
 
static const array<sc_severity, 8> severity = {SC_FATAL,    // scc::log::NONE
                                               SC_FATAL,    // scc::log::FATAL
                                               SC_ERROR,    // scc::log::ERROR
                                               SC_WARNING,  // scc::log::WARNING
                                               SC_INFO,     // scc::log::INFO
                                               SC_INFO,     // scc::log::DEBUG
                                               SC_INFO,     // scc::log::TRACE
                                               SC_INFO};    // scc::log::DBGTRACE
static const array<sc_verbosity, 8> verbosity = {SC_NONE,   // scc::log::NONE
                                                 SC_LOW,    // scc::log::FATAL
                                                 SC_LOW,    // scc::log::ERROR
                                                 SC_LOW,    // scc::log::WARNING
                                                 SC_MEDIUM, // scc::log::INFO
                                                 SC_HIGH,   // scc::log::DEBUG
                                                 SC_FULL,   // scc::log::TRACE
                                                 SC_DEBUG}; // scc::log::DBGTRACE
 
auto scc::stream_redirection::sync() -> int {
    if(level <= log_cfg.level) {
        auto timestr = time2string(sc_time_stamp());
        istringstream buf(str());
        string line;
        while(getline(buf, line)) {
            ::sc_report_handler::report(severity[static_cast<unsigned>(level)], "SystemC", line.c_str(),
                                        verbosity[static_cast<unsigned>(level)], "", 0);
        }
        str(string(""));
    }
    return 0; // Success
}
 
static void configure_logging() {
    std::lock_guard<mutex> lock(log_cfg.mtx);
    std::lock_guard<mutex> lock2(verbosity_mtx);
    static bool spdlog_initialized = false;
    if(!log_cfg.dont_create_broker)
        scc::init_cci("SCCBroker");
    log_cfg.broker = cci::cci_get_global_broker(originator);
    if(log_cfg.install_handler) {
        if(!log_cfg.instance_based_log_levels || getenv("SCC_DISABLE_INSTANCE_BASED_LOGGING"))
            inst_based_logging() = false;
        sc_report_handler::set_verbosity_level(verbosity[static_cast<unsigned>(log_cfg.level)]);
        sc_report_handler::set_handler(report_handler);
        if(!spdlog_initialized) {
            spdlog::init_thread_pool(1024U,
                                     log_cfg.log_file_name.size() ? 2U : 1U); // queue with 8k items and 1 backing thread.
            log_cfg.console_logger = log_cfg.log_async ? spdlog::stdout_color_mt<spdlog::async_factory>("console_logger")
                                                       : spdlog::stdout_color_mt("console_logger");
            auto logger_fmt = log_cfg.print_severity ? "[%L] %v" : "%v";
            if(log_cfg.colored_output) {
                std::ostringstream os;
                os << "%^" << logger_fmt << "%$";
                log_cfg.console_logger->set_pattern(os.str());
            } else
                log_cfg.console_logger->set_pattern("[%L] %v");
            log_cfg.console_logger->flush_on(spdlog::level::err);
            log_cfg.console_logger->set_level(spdlog::level::level_enum::trace);
            if(log_cfg.log_file_name.size()) {
                {
                    ofstream ofs;
                    ofs.open(log_cfg.log_file_name, ios::out | ios::trunc);
                }
                log_cfg.file_logger = log_cfg.log_async
                                          ? spdlog::basic_logger_mt<spdlog::async_factory>("file_logger", log_cfg.log_file_name)
                                          : spdlog::basic_logger_mt("file_logger", log_cfg.log_file_name);
                if(log_cfg.print_severity)
                    log_cfg.file_logger->set_pattern("[%8l] %v");
                else
                    log_cfg.file_logger->set_pattern("%v");
                log_cfg.file_logger->flush_on(spdlog::level::err);
                log_cfg.file_logger->set_level(spdlog::level::level_enum::trace);
            }
            spdlog_initialized = true;
        } else {
            log_cfg.console_logger = spdlog::get("console_logger");
            if(log_cfg.log_file_name.size())
                log_cfg.file_logger = spdlog::get("file_logger");
        }
        if(log_cfg.log_filter_regex.size()) {
#ifdef USE_C_REGEX
            regcomp(&log_cfg.start_state, log_cfg.log_filter_regex.c_str(), REG_EXTENDED);
#else
            log_cfg.reg_ex = regex(log_cfg.log_filter_regex, regex::extended | regex::icase);
#endif
        }
        logging::LoggerCallbacks::set_output_cb([](logging::log_level lvl, std::string const& msg_type, std::string const& msg) {
            switch(lvl) {
            case logging::log_level::FATAL:
                ::scc ::ScLogger<::sc_core ::SC_FATAL>("", 0, sc_core ::SC_MEDIUM)
                        .type(msg_type.size() ? msg_type : std::string("C++"))
                        .get()
                    << msg;
                break;
            case logging::log_level::ERR:
                ::scc ::ScLogger<::sc_core ::SC_ERROR>("", 0, sc_core ::SC_MEDIUM)
                        .type(msg_type.size() ? msg_type : std::string("C++"))
                        .get()
                    << msg;
                break;
            case logging::log_level::WARN:
                if(::scc ::get_log_verbosity(msg_type) >= sc_core ::SC_LOW)
                    ::scc ::ScLogger<::sc_core ::SC_WARNING>("", 0, sc_core ::SC_MEDIUM)
                            .type(msg_type.size() ? msg_type : std::string("C++"))
                            .get()
                        << msg;
                break;
            case logging::log_level::INFO:
                if(::scc ::get_log_verbosity(msg_type) >= sc_core ::SC_MEDIUM)
                    ::scc ::ScLogger<::sc_core ::SC_INFO>("", 0, sc_core ::SC_MEDIUM)
                            .type(msg_type.size() ? msg_type : std::string("C++"))
                            .get()
                        << msg;
                break;
            case logging::log_level::DEBUG:
                if(::scc ::get_log_verbosity(msg_type) >= sc_core ::SC_HIGH)
                    ::scc ::ScLogger<::sc_core ::SC_INFO>("", 0, sc_core ::SC_HIGH)
                            .type(msg_type.size() ? msg_type : std::string("C++"))
                            .get()
                        << msg;
                break;
            case logging::log_level::TRACE:
                if(::scc ::get_log_verbosity(msg_type) >= sc_core ::SC_FULL)
                    ::scc ::ScLogger<::sc_core ::SC_INFO>("", 0, sc_core ::SC_FULL).type(msg_type).get() << msg;
                break;
            case logging::log_level::TRACEALL:
                if(::scc ::get_log_verbosity(msg_type) >= sc_core ::SC_DEBUG)
                    ::scc ::ScLogger<::sc_core ::SC_INFO>("", 0, sc_core ::SC_DEBUG)
                            .type(msg_type.size() ? msg_type : std::string("C++"))
                            .get()
                        << msg;
                break;
            default:
                break;
            }
        });
    }
}
 
void scc::reinit_logging() { reinit_logging(log_cfg.level); }
 
void scc::reinit_logging(scc::log level) {
    if(log_cfg.install_handler)
        sc_report_handler::set_handler(report_handler);
    log_cfg.level = level;
    lut.clear();
    if(!log_cfg.instance_based_log_levels || getenv("SCC_DISABLE_INSTANCE_BASED_LOGGING"))
        inst_based_logging() = false;
    log_cfg.initialized = true;
}
 
bool scc::is_logging_initialized() { return log_cfg.initialized; }
 
void scc::init_logging(scc::log level, unsigned type_field_width, bool print_time) {
    log_cfg.msg_type_field_width = type_field_width;
    log_cfg.print_sys_time = print_time;
    log_cfg.level = level;
    configure_logging();
    log_cfg.initialized = true;
}
 
void scc::init_logging(const scc::LogConfig& log_config) {
    log_cfg = log_config;
    configure_logging();
    log_cfg.initialized = true;
}
 
void scc::set_logging_level(scc::log level) {
    std::lock_guard<mutex> lock(verbosity_mtx);
    log_cfg.level = level;
    sc_report_handler::set_verbosity_level(verbosity[static_cast<unsigned>(level)]);
    log_cfg.console_logger->set_level(
        static_cast<spdlog::level::level_enum>(SPDLOG_LEVEL_OFF - min<int>(SPDLOG_LEVEL_OFF, static_cast<int>(log_cfg.level))));
    log_cfg.initialized = true;
}
 
auto scc::get_logging_level() -> scc::log { return log_cfg.level; }
 
void scc::set_cycle_base(sc_time period) { log_cfg.cycle_base = period; }
 
auto scc::LogConfig::logLevel(scc::log level) -> scc::LogConfig& {
    this->level = level;
    return *this;
}
 
auto scc::LogConfig::msgTypeFieldWidth(unsigned width) -> scc::LogConfig& {
    this->msg_type_field_width = width;
    return *this;
}
 
auto scc::LogConfig::printSysTime(bool enable) -> scc::LogConfig& {
    this->print_sys_time = enable;
    return *this;
}
 
auto scc::LogConfig::printSimTime(bool enable) -> scc::LogConfig& {
    this->print_sim_time = enable;
    return *this;
}
 
auto scc::LogConfig::printDelta(bool enable) -> scc::LogConfig& {
    this->print_delta = enable;
    return *this;
}
 
auto scc::LogConfig::printSeverity(bool enable) -> scc::LogConfig& {
    this->print_severity = enable;
    return *this;
}
 
auto scc::LogConfig::logFileName(string&& name) -> scc::LogConfig& {
    this->log_file_name = name;
    return *this;
}
 
auto scc::LogConfig::logFileName(const string& name) -> scc::LogConfig& {
    this->log_file_name = name;
    return *this;
}
 
auto scc::LogConfig::coloredOutput(bool enable) -> scc::LogConfig& {
    this->colored_output = enable;
    return *this;
}
 
auto scc::LogConfig::logFilterRegex(string&& expr) -> scc::LogConfig& {
    this->log_filter_regex = expr;
    return *this;
}
 
auto scc::LogConfig::logFilterRegex(const string& expr) -> scc::LogConfig& {
    this->log_filter_regex = expr;
    return *this;
}
 
auto scc::LogConfig::logAsync(bool v) -> scc::LogConfig& {
    this->log_async = v;
    return *this;
}
 
auto scc::LogConfig::dontCreateBroker(bool v) -> scc::LogConfig& {
    this->dont_create_broker = v;
    return *this;
}
 
auto scc::LogConfig::reportOnlyFirstError(bool v) -> scc::LogConfig& {
    this->report_only_first_error = v;
    return *this;
}
auto scc::LogConfig::instanceBasedLogLevels(bool v) -> scc::LogConfig& {
    this->instance_based_log_levels = v;
    return *this;
}
auto scc::LogConfig::installHandler(bool v) -> scc::LogConfig& {
    this->install_handler = v;
    return *this;
}
namespace {
std::mutex mtx;
auto get_log_verbosity_from_broker(string current_name, char const* str, cci::cci_broker_handle const& broker, sc_core::sc_verbosity verb)
    -> sc_core::sc_verbosity {
    std::lock_guard<std::mutex> lk(mtx);
    while(true) {
        string param_name = (current_name.empty()) ? SCC_LOG_LEVEL_PARAM_NAME : current_name + "." SCC_LOG_LEVEL_PARAM_NAME;
        auto h = broker.get_param_handle(param_name);
        if(h.is_valid()) {
            sc_core::sc_verbosity ret = verbosity.at(std::min<unsigned>(h.get_cci_value().get_int(), verbosity.size() - 1));
            lut.insert(str, ret);
            return ret;
        } else {
            auto val = broker.get_preset_cci_value(param_name);
            if(val.is_int()) {
                sc_core::sc_verbosity ret = verbosity.at(std::min<unsigned>(val.get_int(), verbosity.size() - 1));
                lut.insert(str, ret);
                return ret;
            } else {
                if(current_name.empty()) {
                    lut.insert(str, verb);
                    return verb;
                }
                auto pos = current_name.rfind(".");
                if(pos == std::string::npos) {
                    current_name = "";
                } else {
                    current_name = current_name.substr(0, pos);
                }
            }
        }
    }
    return verb;
}
} // namespace
 
auto scc::get_log_verbosity(char const* str) -> sc_core::sc_verbosity {
    auto global_verb = verbosity[static_cast<unsigned>(log_cfg.level)];
    if(inst_based_logging()) {
        auto res = lut.get(str);
        if(std::get<0>(res))
            return std::get<1>(res);
        auto* curr_object = sc_core::sc_get_current_object();
        if(strchr(str, '.') == nullptr || curr_object) {
            string current_name = std::string(str);
            if(log_cfg.broker)
                return get_log_verbosity_from_broker(current_name, str, log_cfg.broker.value(), global_verb);
            else {
                return get_log_verbosity_from_broker(
                    current_name, str, curr_object ? cci::cci_get_broker() : cci::cci_get_global_broker(originator), global_verb);
            }
        }
    }
    return global_verb;
}