diff options
| author | yazevnul <[email protected]> | 2022-02-10 16:46:46 +0300 | 
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:46:46 +0300 | 
| commit | 8cbc307de0221f84c80c42dcbe07d40727537e2c (patch) | |
| tree | 625d5a673015d1df891e051033e9fcde5c7be4e5 /library/cpp/messagebus/www | |
| parent | 30d1ef3941e0dc835be7609de5ebee66958f215a (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/www')
| -rw-r--r-- | library/cpp/messagebus/www/html_output.h | 10 | ||||
| -rw-r--r-- | library/cpp/messagebus/www/www.cpp | 40 | 
2 files changed, 25 insertions, 25 deletions
diff --git a/library/cpp/messagebus/www/html_output.h b/library/cpp/messagebus/www/html_output.h index 27e77adefa7..3cbf350c0ca 100644 --- a/library/cpp/messagebus/www/html_output.h +++ b/library/cpp/messagebus/www/html_output.h @@ -7,17 +7,17 @@  #include <library/cpp/html/pcdata/pcdata.h>  #include <util/system/tls.h> -extern Y_POD_THREAD(IOutputStream*) HtmlOutputStreamPtr; +extern Y_POD_THREAD(IOutputStream*) HtmlOutputStreamPtr;  -static IOutputStream& HtmlOutputStream() { -    Y_VERIFY(!!HtmlOutputStreamPtr); +static IOutputStream& HtmlOutputStream() {  +    Y_VERIFY(!!HtmlOutputStreamPtr);       return *HtmlOutputStreamPtr;  }  struct THtmlOutputStreamPushPop { -    IOutputStream* const Prev; +    IOutputStream* const Prev;  -    THtmlOutputStreamPushPop(IOutputStream* outputStream) +    THtmlOutputStreamPushPop(IOutputStream* outputStream)           : Prev(HtmlOutputStreamPtr)      {          HtmlOutputStreamPtr = outputStream; diff --git a/library/cpp/messagebus/www/www.cpp b/library/cpp/messagebus/www/www.cpp index 62ec241d852..b9540681b31 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_VERIFY(!!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_VERIFY(!!value);               for (unsigned i = 0; i < Entries.size(); ++i) {                  if (Entries[i].second.Get() == value.Get()) { @@ -57,11 +57,11 @@ namespace {                  }              } -            Y_FAIL("unregistered"); +            Y_FAIL("unregistered");           }          void Add(TValuePtr p) { -            Y_VERIFY(!!p); +            Y_VERIFY(!!p);               // Do not add twice              for (unsigned i = 0; i < Entries.size(); ++i) { @@ -187,27 +187,27 @@ struct TBusWww::TImpl {      TMutex Mutex;      void RegisterClientSession(TBusClientSessionPtr s) { -        Y_VERIFY(!!s); +        Y_VERIFY(!!s);           TGuard<TMutex> g(Mutex);          ClientSessions.Add(s.Get());          Queues.Add(s->GetQueue());      }      void RegisterServerSession(TBusServerSessionPtr s) { -        Y_VERIFY(!!s); +        Y_VERIFY(!!s);           TGuard<TMutex> g(Mutex);          ServerSessions.Add(s.Get());          Queues.Add(s->GetQueue());      }      void RegisterQueue(TBusMessageQueuePtr q) { -        Y_VERIFY(!!q); +        Y_VERIFY(!!q);           TGuard<TMutex> g(Mutex);          Queues.Add(q);      }      void RegisterModule(TBusModule* module) { -        Y_VERIFY(!!module); +        Y_VERIFY(!!module);           TGuard<TMutex> g(Mutex);          { @@ -239,17 +239,17 @@ struct TBusWww::TImpl {              serverSession = ServerSessions.FindByName(sessionName);              session = serverSession.Get();          } -        Y_VERIFY(!!session); +        Y_VERIFY(!!session);           return Queues.FindNameByPtr(session->GetQueue());      }      struct TRequest {          TImpl* const Outer; -        IOutputStream& Os; +        IOutputStream& Os;           const TCgiParameters& CgiParams;          const TOptionalParams& Params; -        TRequest(TImpl* outer, IOutputStream& os, const TCgiParameters& cgiParams, const TOptionalParams& params) +        TRequest(TImpl* outer, IOutputStream& os, const TCgiParameters& cgiParams, const TOptionalParams& params)               : Outer(outer)              , Os(os)              , CgiParams(cgiParams) @@ -681,9 +681,9 @@ struct TBusWww::TImpl {          }          void ServeSolomonJson(const TString& q, const TString& cs, const TString& ss) { -            Y_UNUSED(q); -            Y_UNUSED(cs); -            Y_UNUSED(ss); +            Y_UNUSED(q);  +            Y_UNUSED(cs);  +            Y_UNUSED(ss);               bool all = q == "" && cs == "" && ss == "";              NMonitoring::TDeprecatedJsonWriter sj(&Os); @@ -720,10 +720,10 @@ struct TBusWww::TImpl {              sj.CloseDocument();          } -        void ServeStatic(IOutputStream& os, TStringBuf path) { -            if (path.EndsWith(".js")) { +        void ServeStatic(IOutputStream& os, TStringBuf path) {  +            if (path.EndsWith(".js")) {                   os << HTTP_OK_JS; -            } else if (path.EndsWith(".png")) { +            } else if (path.EndsWith(".png")) {                   os << HTTP_OK_PNG;              } else {                  os << HTTP_OK_BIN; @@ -799,7 +799,7 @@ struct TBusWww::TImpl {          }      }; -    void ServeHttp(IOutputStream& os, const TCgiParameters& queryArgs, const TBusWww::TOptionalParams& params) { +    void ServeHttp(IOutputStream& os, const TCgiParameters& queryArgs, const TBusWww::TOptionalParams& params) {           TGuard<TMutex> g(Mutex);          TRequest request(this, os, queryArgs, params); @@ -832,7 +832,7 @@ void TBusWww::RegisterModule(TBusModule* module) {      Impl->RegisterModule(module);  } -void TBusWww::ServeHttp(IOutputStream& httpOutputStream, +void TBusWww::ServeHttp(IOutputStream& httpOutputStream,                           const TCgiParameters& queryArgs,                          const TBusWww::TOptionalParams& params) {      Impl->ServeHttp(httpOutputStream, queryArgs, params); @@ -843,7 +843,7 @@ struct TBusWwwHttpServer::TImpl: public THttpServer::ICallBack {      THttpServer HttpServer;      static THttpServer::TOptions MakeHttpServerOptions(unsigned port) { -        Y_VERIFY(port > 0); +        Y_VERIFY(port > 0);           THttpServer::TOptions r;          r.Port = port;          return r;  | 
