aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/www
diff options
context:
space:
mode:
authorilnurkh <ilnurkh@yandex-team.com>2023-10-09 23:39:40 +0300
committerilnurkh <ilnurkh@yandex-team.com>2023-10-09 23:57:14 +0300
commite601ca03f859335d57ecff2e5aa6af234b6052ed (patch)
treede519a847e58a1b3993fcbfe05ff44cc946a3e24 /library/cpp/messagebus/www
parentbbf2b6878af3854815a2c0ecb07a687071787639 (diff)
downloadydb-e601ca03f859335d57ecff2e5aa6af234b6052ed.tar.gz
Y_VERIFY->Y_ABORT_UNLESS at ^l
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'library/cpp/messagebus/www')
-rw-r--r--library/cpp/messagebus/www/html_output.h2
-rw-r--r--library/cpp/messagebus/www/www.cpp18
2 files changed, 10 insertions, 10 deletions
diff --git a/library/cpp/messagebus/www/html_output.h b/library/cpp/messagebus/www/html_output.h
index 27e77adefa..cf9cba831d 100644
--- a/library/cpp/messagebus/www/html_output.h
+++ b/library/cpp/messagebus/www/html_output.h
@@ -10,7 +10,7 @@
extern Y_POD_THREAD(IOutputStream*) HtmlOutputStreamPtr;
static IOutputStream& HtmlOutputStream() {
- Y_VERIFY(!!HtmlOutputStreamPtr);
+ Y_ABORT_UNLESS(!!HtmlOutputStreamPtr);
return *HtmlOutputStreamPtr;
}
diff --git a/library/cpp/messagebus/www/www.cpp b/library/cpp/messagebus/www/www.cpp
index 6c8b4bc732..a52ad404ff 100644
--- a/library/cpp/messagebus/www/www.cpp
+++ b/library/cpp/messagebus/www/www.cpp
@@ -38,7 +38,7 @@ namespace {
TVector<std::pair<TString, TValuePtr>> Entries;
TValuePtr FindByName(TStringBuf name) {
- Y_VERIFY(!!name);
+ Y_ABORT_UNLESS(!!name);
for (unsigned i = 0; i < Entries.size(); ++i) {
if (Entries[i].first == name) {
@@ -49,7 +49,7 @@ namespace {
}
TString FindNameByPtr(TValuePtr value) {
- Y_VERIFY(!!value);
+ Y_ABORT_UNLESS(!!value);
for (unsigned i = 0; i < Entries.size(); ++i) {
if (Entries[i].second.Get() == value.Get()) {
@@ -61,7 +61,7 @@ namespace {
}
void Add(TValuePtr p) {
- Y_VERIFY(!!p);
+ Y_ABORT_UNLESS(!!p);
// Do not add twice
for (unsigned i = 0; i < Entries.size(); ++i) {
@@ -175,27 +175,27 @@ struct TBusWww::TImpl {
TMutex Mutex;
void RegisterClientSession(TBusClientSessionPtr s) {
- Y_VERIFY(!!s);
+ Y_ABORT_UNLESS(!!s);
TGuard<TMutex> g(Mutex);
ClientSessions.Add(s.Get());
Queues.Add(s->GetQueue());
}
void RegisterServerSession(TBusServerSessionPtr s) {
- Y_VERIFY(!!s);
+ Y_ABORT_UNLESS(!!s);
TGuard<TMutex> g(Mutex);
ServerSessions.Add(s.Get());
Queues.Add(s->GetQueue());
}
void RegisterQueue(TBusMessageQueuePtr q) {
- Y_VERIFY(!!q);
+ Y_ABORT_UNLESS(!!q);
TGuard<TMutex> g(Mutex);
Queues.Add(q);
}
void RegisterModule(TBusModule* module) {
- Y_VERIFY(!!module);
+ Y_ABORT_UNLESS(!!module);
TGuard<TMutex> g(Mutex);
{
@@ -227,7 +227,7 @@ struct TBusWww::TImpl {
serverSession = ServerSessions.FindByName(sessionName);
session = serverSession.Get();
}
- Y_VERIFY(!!session);
+ Y_ABORT_UNLESS(!!session);
return Queues.FindNameByPtr(session->GetQueue());
}
@@ -831,7 +831,7 @@ struct TBusWwwHttpServer::TImpl: public THttpServer::ICallBack {
THttpServer HttpServer;
static THttpServer::TOptions MakeHttpServerOptions(unsigned port) {
- Y_VERIFY(port > 0);
+ Y_ABORT_UNLESS(port > 0);
THttpServer::TOptions r;
r.Port = port;
return r;