Function PrintAnnotations

src/brpc/builtin/rpcz_service.cpp:186–230

}

static void PrintAnnotations(
    std::ostream& os, int64_t cur_time, int64_t* last_time,
    SpanInfoExtractor** extractors, int num_extr, const RpczSpan* span) {
    int64_t anno_time;
    std::string a;
    const char* span_type_str = "Span";
    if (span) {
        switch (span->type()) {
        case SPAN_TYPE_SERVER:
            span_type_str = "ServerSpan";
            break;
        case SPAN_TYPE_CLIENT:
            span_type_str = "ClientSpan";
            break;
        case SPAN_TYPE_BTHREAD:
            span_type_str = "BthreadSpan";
            break;
        }
    }

    // TODO: Going through all extractors is not strictly correct because 
    // later extractors may have earlier annotations.
    for (int i = 0; i < num_extr; ++i) {
        while (extractors[i]->PopAnnotation(cur_time, &anno_time, &a)) {
            PrintRealTime(os, anno_time);
            PrintElapse(os, anno_time, last_time);
            os << ' ';
            if (span) {
                const char* short_type = "SPAN";
                if (span->type() == SPAN_TYPE_SERVER) {
                    short_type = "Server";
                } else if (span->type() == SPAN_TYPE_CLIENT) {
                    short_type = "Client";
                } else if (span->type() == SPAN_TYPE_BTHREAD) {
                    short_type = "Bthread";
                }
                os << '[' << short_type << " SPAN#" << Hex(span->span_id()) << "] ";
            }
            os << WebEscape(a);
            if (a.empty() || butil::back_char(a) != '\n') {
                os << '\n';
            }
        }
    }
}

static bool PrintAnnotationsAndRealTimeSpan(
    std::ostream& os, int64_t cur_time, int64_t* last_time,