diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:15 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:15 +0300 |
commit | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch) | |
tree | da2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /library/cpp/messagebus/message_status.h | |
parent | 778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff) | |
download | ydb-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.h | 76 |
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 |