1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
// Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
#pragma once
#if !defined(RXCPP_RX_TRACE_HPP)
#define RXCPP_RX_TRACE_HPP
#include <iostream>
#include <exception>
#include <atomic>
namespace rxcpp {
struct trace_id
{
static inline trace_id make_next_id_subscriber() {
static std::atomic<unsigned long> id(0xB0000000);
return trace_id{++id};
}
unsigned long id;
};
inline bool operator==(const trace_id& lhs, const trace_id& rhs) {
return lhs.id == rhs.id;
}
inline bool operator!=(const trace_id& lhs, const trace_id& rhs) {
return !(lhs==rhs);
}
inline bool operator<(const trace_id& lhs, const trace_id& rhs) {
if ((lhs.id & 0xF0000000) != (rhs.id & 0xF0000000)) std::terminate();
return lhs.id < rhs.id;
}
inline bool operator>(const trace_id& lhs, const trace_id& rhs) {
return rhs<lhs;
}
inline std::ostream& operator<< (std::ostream& os, const trace_id& id) {
return os << std::hex << id.id << std::dec;
}
struct trace_noop
{
template<class Worker, class Schedulable>
inline void schedule_enter(const Worker&, const Schedulable&) {}
template<class Worker>
inline void schedule_return(const Worker&) {}
template<class Worker, class When, class Schedulable>
inline void schedule_when_enter(const Worker&, const When&, const Schedulable&) {}
template<class Worker>
inline void schedule_when_return(const Worker&) {}
template<class Schedulable>
inline void action_enter(const Schedulable&) {}
template<class Schedulable>
inline void action_return(const Schedulable&) {}
template<class Schedulable>
inline void action_recurse(const Schedulable&) {}
template<class Observable, class Subscriber>
inline void subscribe_enter(const Observable& , const Subscriber& ) {}
template<class Observable>
inline void subscribe_return(const Observable& ) {}
template<class SubscriberFrom, class SubscriberTo>
inline void connect(const SubscriberFrom&, const SubscriberTo&) {}
template<class OperatorSource, class OperatorChain, class Subscriber, class SubscriberLifted>
inline void lift_enter(const OperatorSource&, const OperatorChain&, const Subscriber&, const SubscriberLifted&) {}
template<class OperatorSource, class OperatorChain>
inline void lift_return(const OperatorSource&, const OperatorChain&) {}
template<class SubscriptionState>
inline void unsubscribe_enter(const SubscriptionState&) {}
template<class SubscriptionState>
inline void unsubscribe_return(const SubscriptionState&) {}
template<class SubscriptionState, class Subscription>
inline void subscription_add_enter(const SubscriptionState&, const Subscription&) {}
template<class SubscriptionState>
inline void subscription_add_return(const SubscriptionState&) {}
template<class SubscriptionState, class WeakSubscription>
inline void subscription_remove_enter(const SubscriptionState&, const WeakSubscription&) {}
template<class SubscriptionState>
inline void subscription_remove_return(const SubscriptionState&) {}
template<class Subscriber>
inline void create_subscriber(const Subscriber&) {}
template<class Subscriber, class T>
inline void on_next_enter(const Subscriber&, const T&) {}
template<class Subscriber>
inline void on_next_return(const Subscriber&) {}
template<class Subscriber, class ErrorPtr>
inline void on_error_enter(const Subscriber&, const ErrorPtr&) {}
template<class Subscriber>
inline void on_error_return(const Subscriber&) {}
template<class Subscriber>
inline void on_completed_enter(const Subscriber&) {}
template<class Subscriber>
inline void on_completed_return(const Subscriber&) {}
};
struct trace_tag {};
}
inline auto rxcpp_trace_activity(...) -> rxcpp::trace_noop;
#endif
|
