aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/message_status.h
diff options
context:
space:
mode:
authorAnton Samokhvalov <pg83@yandex.ru>2022-02-10 16:45:15 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:15 +0300
commit72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch)
treeda2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/messagebus/message_status.h
parent778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff)
downloadydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/message_status.h')
-rw-r--r--library/cpp/messagebus/message_status.h76
1 files changed, 38 insertions, 38 deletions
diff --git a/library/cpp/messagebus/message_status.h b/library/cpp/messagebus/message_status.h
index e1878960b3..f449004e96 100644
--- a/library/cpp/messagebus/message_status.h
+++ b/library/cpp/messagebus/message_status.h
@@ -9,49 +9,49 @@ namespace NBus {
////////////////////////////////////////////////////////////////
/// \brief Status of message communication
-#define MESSAGE_STATUS_MAP(XX) \
- XX(MESSAGE_OK, "OK") \
- XX(MESSAGE_CONNECT_FAILED, "Connect failed") \
- XX(MESSAGE_TIMEOUT, "Message timed out") \
- XX(MESSAGE_SERVICE_UNKNOWN, "Locator hasn't found address for key") \
- XX(MESSAGE_BUSY, "Too many messages in flight") \
- XX(MESSAGE_UNKNOWN, "Request not found by id, usually it means that message is timed out") \
- XX(MESSAGE_DESERIALIZE_ERROR, "Deserialize by TBusProtocol failed") \
- XX(MESSAGE_HEADER_CORRUPTED, "Header corrupted") \
- XX(MESSAGE_DECOMPRESS_ERROR, "Failed to decompress") \
- XX(MESSAGE_MESSAGE_TOO_LARGE, "Message too large") \
- XX(MESSAGE_REPLY_FAILED, "Unused by messagebus, used by other code") \
- XX(MESSAGE_DELIVERY_FAILED, "Message delivery failed because connection is closed") \
- XX(MESSAGE_INVALID_VERSION, "Protocol error: invalid version") \
- XX(MESSAGE_SERVICE_TOOMANY, "Locator failed to resolve address") \
- XX(MESSAGE_SHUTDOWN, "Failure because of either session or connection shutdown") \
- XX(MESSAGE_DONT_ASK, "Internal error code used by modules")
-
- enum EMessageStatus {
- MESSAGE_STATUS_MAP(ENUM_VALUE_GEN_NO_VALUE)
- MESSAGE_STATUS_COUNT
- };
-
- ENUM_TO_STRING(EMessageStatus, MESSAGE_STATUS_MAP)
-
- const char* MessageStatusDescription(EMessageStatus);
-
- static inline const char* GetMessageStatus(EMessageStatus status) {
- return ToCString(status);
- }
-
- // For lwtrace
- struct TMessageStatusField {
- typedef int TStoreType;
+#define MESSAGE_STATUS_MAP(XX) \
+ XX(MESSAGE_OK, "OK") \
+ XX(MESSAGE_CONNECT_FAILED, "Connect failed") \
+ XX(MESSAGE_TIMEOUT, "Message timed out") \
+ XX(MESSAGE_SERVICE_UNKNOWN, "Locator hasn't found address for key") \
+ XX(MESSAGE_BUSY, "Too many messages in flight") \
+ XX(MESSAGE_UNKNOWN, "Request not found by id, usually it means that message is timed out") \
+ XX(MESSAGE_DESERIALIZE_ERROR, "Deserialize by TBusProtocol failed") \
+ XX(MESSAGE_HEADER_CORRUPTED, "Header corrupted") \
+ XX(MESSAGE_DECOMPRESS_ERROR, "Failed to decompress") \
+ XX(MESSAGE_MESSAGE_TOO_LARGE, "Message too large") \
+ XX(MESSAGE_REPLY_FAILED, "Unused by messagebus, used by other code") \
+ XX(MESSAGE_DELIVERY_FAILED, "Message delivery failed because connection is closed") \
+ XX(MESSAGE_INVALID_VERSION, "Protocol error: invalid version") \
+ XX(MESSAGE_SERVICE_TOOMANY, "Locator failed to resolve address") \
+ XX(MESSAGE_SHUTDOWN, "Failure because of either session or connection shutdown") \
+ XX(MESSAGE_DONT_ASK, "Internal error code used by modules")
+
+ enum EMessageStatus {
+ MESSAGE_STATUS_MAP(ENUM_VALUE_GEN_NO_VALUE)
+ MESSAGE_STATUS_COUNT
+ };
+
+ ENUM_TO_STRING(EMessageStatus, MESSAGE_STATUS_MAP)
+
+ const char* MessageStatusDescription(EMessageStatus);
+
+ static inline const char* GetMessageStatus(EMessageStatus status) {
+ return ToCString(status);
+ }
+
+ // For lwtrace
+ struct TMessageStatusField {
+ typedef int TStoreType;
typedef int TFuncParam;
- static void ToString(int value, TString* out) {
- *out = GetMessageStatus((NBus::EMessageStatus)value);
- }
+ static void ToString(int value, TString* out) {
+ *out = GetMessageStatus((NBus::EMessageStatus)value);
+ }
static int ToStoreType(int value) {
return value;
}
- };
+ };
} // ns