Restoring authorship annotation for <cerevra@yandex-team.ru>. Commit 2 of 2.

1 files changed, 175 insertions, 175 deletions

diff --git a/library/cpp/tvmauth/client/misc/async_updater.h b/library/cpp/tvmauth/client/misc/async_updater.h
index 1ad6c209f8..7b556d7a38 100644
--- a/library/cpp/tvmauth/client/misc/async_updater.h
+++ b/library/cpp/tvmauth/client/misc/async_updater.h
@@ -1,183 +1,183 @@
-#pragma once 
- 
-#include "last_error.h" 
-#include "settings.h" 
-#include "roles/roles.h" 
- 
-#include <library/cpp/tvmauth/client/client_status.h> 
-#include <library/cpp/tvmauth/client/logger.h> 
- 
-#include <library/cpp/tvmauth/deprecated/service_context.h> 
-#include <library/cpp/tvmauth/deprecated/user_context.h> 
-#include <library/cpp/tvmauth/src/utils.h> 
- 
-#include <util/datetime/base.h> 
-#include <util/generic/hash.h> 
-#include <util/generic/maybe.h> 
-#include <util/generic/noncopyable.h> 
-#include <util/generic/ptr.h> 
- 
-#include <array> 
+#pragma once
+
+#include "last_error.h"
+#include "settings.h"
+#include "roles/roles.h"
+
+#include <library/cpp/tvmauth/client/client_status.h>
+#include <library/cpp/tvmauth/client/logger.h>
+
+#include <library/cpp/tvmauth/deprecated/service_context.h>
+#include <library/cpp/tvmauth/deprecated/user_context.h>
+#include <library/cpp/tvmauth/src/utils.h>
+
+#include <util/datetime/base.h>
+#include <util/generic/hash.h>
+#include <util/generic/maybe.h>
+#include <util/generic/noncopyable.h>
+#include <util/generic/ptr.h>
+
+#include <array>
 #include <atomic>
- 
-namespace NTvmAuth::NInternal { 
-    class TClientCaningKnife; 
-} 
- 
-namespace NTvmAuth { 
-    class TServiceTickets: public TAtomicRefCount<TServiceTickets> { 
-    public: 
-        using TMapAliasStr = THashMap<TClientSettings::TAlias, TString>; 
-        using TMapIdStr = THashMap<TTvmId, TString>; 
+
+namespace NTvmAuth::NInternal {
+    class TClientCaningKnife;
+}
+
+namespace NTvmAuth {
+    class TServiceTickets: public TAtomicRefCount<TServiceTickets> {
+    public:
+        using TMapAliasStr = THashMap<TClientSettings::TAlias, TString>;
+        using TMapIdStr = THashMap<TTvmId, TString>;
         using TIdSet = THashSet<TTvmId>;
         using TAliasSet = THashSet<TClientSettings::TAlias>;
-        using TMapAliasId = THashMap<TClientSettings::TAlias, TTvmId>; 
- 
-        TServiceTickets(TMapIdStr&& tickets, TMapIdStr&& errors, const TMapAliasId& dstMap) 
-            : TicketsById(std::move(tickets)) 
-            , ErrorsById(std::move(errors)) 
-        { 
+        using TMapAliasId = THashMap<TClientSettings::TAlias, TTvmId>;
+
+        TServiceTickets(TMapIdStr&& tickets, TMapIdStr&& errors, const TMapAliasId& dstMap)
+            : TicketsById(std::move(tickets))
+            , ErrorsById(std::move(errors))
+        {
             InitAliasesAndUnfetchedIds(dstMap);
-            InitInvalidationTime(); 
-        } 
- 
-        static TInstant GetInvalidationTime(const TMapIdStr& ticketsById) { 
-            TInstant res; 
- 
-            for (const auto& pair : ticketsById) { 
-                TMaybe<TInstant> t = NTvmAuth::NInternal::TCanningKnife::GetExpirationTime(pair.second); 
-                if (!t) { 
-                    continue; 
-                } 
- 
-                res = res == TInstant() ? *t : std::min(res, *t); 
-            } 
- 
-            return res; 
-        } 
- 
-    public: 
-        TMapIdStr TicketsById; 
-        TMapIdStr ErrorsById; 
-        TMapAliasStr TicketsByAlias; 
-        TMapAliasStr ErrorsByAlias; 
-        TInstant InvalidationTime; 
-        TIdSet UnfetchedIds; 
-        TAliasSet UnfetchedAliases; 
- 
-    private: 
+            InitInvalidationTime();
+        }
+
+        static TInstant GetInvalidationTime(const TMapIdStr& ticketsById) {
+            TInstant res;
+
+            for (const auto& pair : ticketsById) {
+                TMaybe<TInstant> t = NTvmAuth::NInternal::TCanningKnife::GetExpirationTime(pair.second);
+                if (!t) {
+                    continue;
+                }
+
+                res = res == TInstant() ? *t : std::min(res, *t);
+            }
+
+            return res;
+        }
+
+    public:
+        TMapIdStr TicketsById;
+        TMapIdStr ErrorsById;
+        TMapAliasStr TicketsByAlias;
+        TMapAliasStr ErrorsByAlias;
+        TInstant InvalidationTime;
+        TIdSet UnfetchedIds;
+        TAliasSet UnfetchedAliases;
+
+    private:
         void InitAliasesAndUnfetchedIds(const TMapAliasId& dstMap) {
-            for (const auto& pair : dstMap) { 
-                auto it = TicketsById.find(pair.second); 
-                auto errIt = ErrorsById.find(pair.second); 
- 
-                if (it == TicketsById.end()) { 
-                    if (errIt != ErrorsById.end()) { 
-                        Y_ENSURE(ErrorsByAlias.insert({pair.first, errIt->second}).second, 
+            for (const auto& pair : dstMap) {
+                auto it = TicketsById.find(pair.second);
+                auto errIt = ErrorsById.find(pair.second);
+
+                if (it == TicketsById.end()) {
+                    if (errIt != ErrorsById.end()) {
+                        Y_ENSURE(ErrorsByAlias.insert({pair.first, errIt->second}).second,
                                  "failed to add: " << pair.first);
                     } else {
-                        UnfetchedAliases.insert(pair.first); 
-                        UnfetchedIds.insert(pair.second); 
+                        UnfetchedAliases.insert(pair.first);
+                        UnfetchedIds.insert(pair.second);
                     }
-                } else { 
-                    Y_ENSURE(TicketsByAlias.insert({pair.first, it->second}).second, 
-                             "failed to add: " << pair.first); 
-                } 
-            } 
-        } 
- 
-        void InitInvalidationTime() { 
-            InvalidationTime = GetInvalidationTime(TicketsById); 
-        } 
-    }; 
-    using TServiceTicketsPtr = TIntrusiveConstPtr<TServiceTickets>; 
- 
-    class TAllUserContexts: public TAtomicRefCount<TAllUserContexts> { 
-    public: 
-        TAllUserContexts(TStringBuf publicKeys); 
- 
-        TUserContextPtr Get(EBlackboxEnv env) const; 
- 
-    private: 
-        std::array<TUserContextPtr, 5> Ctx_; 
-    }; 
-    using TAllUserContextsPtr = TIntrusiveConstPtr<TAllUserContexts>; 
- 
-    class TAsyncUpdaterBase: public TAtomicRefCount<TAsyncUpdaterBase>, protected TLastError, TNonCopyable { 
-    public: 
-        TAsyncUpdaterBase(); 
-        virtual ~TAsyncUpdaterBase() = default; 
- 
-        virtual TClientStatus GetStatus() const = 0; 
-        virtual NRoles::TRolesPtr GetRoles() const; 
- 
-        TServiceTicketsPtr GetCachedServiceTickets() const; 
-        TServiceContextPtr GetCachedServiceContext() const; 
-        TUserContextPtr GetCachedUserContext(TMaybe<EBlackboxEnv> overridenEnv = {}) const; 
- 
-        TInstant GetUpdateTimeOfPublicKeys() const; 
-        TInstant GetUpdateTimeOfServiceTickets() const; 
-        TInstant GetUpdateTimeOfRoles() const; 
-        TInstant GetInvalidationTimeOfPublicKeys() const; 
-        TInstant GetInvalidationTimeOfServiceTickets() const; 
- 
-        bool ArePublicKeysInvalid(TInstant now) const; 
-        bool AreServiceTicketsInvalid(TInstant now) const; 
-        static bool IsInvalid(TInstant invTime, TInstant now); 
- 
-    protected: 
-        void SetBbEnv(EBlackboxEnv original, TMaybe<EBlackboxEnv> overrided = {}); 
- 
-        void SetServiceTickets(TServiceTicketsPtr c); 
-        void SetServiceContext(TServiceContextPtr c); 
-        void SetUserContext(TStringBuf publicKeys); 
-        void SetUpdateTimeOfPublicKeys(TInstant ins); 
-        void SetUpdateTimeOfServiceTickets(TInstant ins); 
-        void SetUpdateTimeOfRoles(TInstant ins); 
- 
-        static bool IsServiceTicketMapOk(TServiceTicketsPtr c, size_t expectedTicketCount, bool strict); 
- 
-    protected: 
-        struct TPairTicketsErrors { 
-            TServiceTickets::TMapIdStr Tickets; 
-            TServiceTickets::TMapIdStr Errors; 
- 
-            bool operator==(const TPairTicketsErrors& o) const { 
-                return Tickets == o.Tickets && Errors == o.Errors; 
-            } 
-        }; 
- 
-        struct TStateDurations { 
-            TDuration RefreshPeriod; 
-            TDuration Expiring; 
-            TDuration Invalid; 
-        }; 
- 
-        TStateDurations ServiceTicketsDurations_; 
-        TStateDurations PublicKeysDurations_; 
- 
-    protected: 
-        virtual void StartTvmClientStopping() const { 
-        } 
-        virtual bool IsTvmClientStopped() const { 
-            return true; 
-        } 
-        friend class NTvmAuth::NInternal::TClientCaningKnife; 
- 
-    private: 
-        struct TEnvs { 
-            TMaybe<EBlackboxEnv> Original; 
-            TMaybe<EBlackboxEnv> Overrided; 
-        }; 
-        static_assert(sizeof(TEnvs) <= 8, "Small struct is easy to store as atomic"); 
-        std::atomic<TEnvs> Envs_ = {{}}; 
- 
-        NUtils::TProtectedValue<TServiceTicketsPtr> ServiceTickets_; 
-        NUtils::TProtectedValue<TServiceContextPtr> ServiceContext_; 
-        NUtils::TProtectedValue<TAllUserContextsPtr> AllUserContexts_; 
-        NUtils::TProtectedValue<TInstant> PublicKeysTime_; 
-        NUtils::TProtectedValue<TInstant> ServiceTicketsTime_; 
-        NUtils::TProtectedValue<TInstant> RolesTime_; 
-    }; 
-    using TAsyncUpdaterPtr = TIntrusiveConstPtr<TAsyncUpdaterBase>; 
-} 
+                } else {
+                    Y_ENSURE(TicketsByAlias.insert({pair.first, it->second}).second,
+                             "failed to add: " << pair.first);
+                }
+            }
+        }
+
+        void InitInvalidationTime() {
+            InvalidationTime = GetInvalidationTime(TicketsById);
+        }
+    };
+    using TServiceTicketsPtr = TIntrusiveConstPtr<TServiceTickets>;
+
+    class TAllUserContexts: public TAtomicRefCount<TAllUserContexts> {
+    public:
+        TAllUserContexts(TStringBuf publicKeys);
+
+        TUserContextPtr Get(EBlackboxEnv env) const;
+
+    private:
+        std::array<TUserContextPtr, 5> Ctx_;
+    };
+    using TAllUserContextsPtr = TIntrusiveConstPtr<TAllUserContexts>;
+
+    class TAsyncUpdaterBase: public TAtomicRefCount<TAsyncUpdaterBase>, protected TLastError, TNonCopyable {
+    public:
+        TAsyncUpdaterBase();
+        virtual ~TAsyncUpdaterBase() = default;
+
+        virtual TClientStatus GetStatus() const = 0;
+        virtual NRoles::TRolesPtr GetRoles() const;
+
+        TServiceTicketsPtr GetCachedServiceTickets() const;
+        TServiceContextPtr GetCachedServiceContext() const;
+        TUserContextPtr GetCachedUserContext(TMaybe<EBlackboxEnv> overridenEnv = {}) const;
+
+        TInstant GetUpdateTimeOfPublicKeys() const;
+        TInstant GetUpdateTimeOfServiceTickets() const;
+        TInstant GetUpdateTimeOfRoles() const;
+        TInstant GetInvalidationTimeOfPublicKeys() const;
+        TInstant GetInvalidationTimeOfServiceTickets() const;
+
+        bool ArePublicKeysInvalid(TInstant now) const;
+        bool AreServiceTicketsInvalid(TInstant now) const;
+        static bool IsInvalid(TInstant invTime, TInstant now);
+
+    protected:
+        void SetBbEnv(EBlackboxEnv original, TMaybe<EBlackboxEnv> overrided = {});
+
+        void SetServiceTickets(TServiceTicketsPtr c);
+        void SetServiceContext(TServiceContextPtr c);
+        void SetUserContext(TStringBuf publicKeys);
+        void SetUpdateTimeOfPublicKeys(TInstant ins);
+        void SetUpdateTimeOfServiceTickets(TInstant ins);
+        void SetUpdateTimeOfRoles(TInstant ins);
+
+        static bool IsServiceTicketMapOk(TServiceTicketsPtr c, size_t expectedTicketCount, bool strict);
+
+    protected:
+        struct TPairTicketsErrors {
+            TServiceTickets::TMapIdStr Tickets;
+            TServiceTickets::TMapIdStr Errors;
+
+            bool operator==(const TPairTicketsErrors& o) const {
+                return Tickets == o.Tickets && Errors == o.Errors;
+            }
+        };
+
+        struct TStateDurations {
+            TDuration RefreshPeriod;
+            TDuration Expiring;
+            TDuration Invalid;
+        };
+
+        TStateDurations ServiceTicketsDurations_;
+        TStateDurations PublicKeysDurations_;
+
+    protected:
+        virtual void StartTvmClientStopping() const {
+        }
+        virtual bool IsTvmClientStopped() const {
+            return true;
+        }
+        friend class NTvmAuth::NInternal::TClientCaningKnife;
+
+    private:
+        struct TEnvs {
+            TMaybe<EBlackboxEnv> Original;
+            TMaybe<EBlackboxEnv> Overrided;
+        };
+        static_assert(sizeof(TEnvs) <= 8, "Small struct is easy to store as atomic");
+        std::atomic<TEnvs> Envs_ = {{}};
+
+        NUtils::TProtectedValue<TServiceTicketsPtr> ServiceTickets_;
+        NUtils::TProtectedValue<TServiceContextPtr> ServiceContext_;
+        NUtils::TProtectedValue<TAllUserContextsPtr> AllUserContexts_;
+        NUtils::TProtectedValue<TInstant> PublicKeysTime_;
+        NUtils::TProtectedValue<TInstant> ServiceTicketsTime_;
+        NUtils::TProtectedValue<TInstant> RolesTime_;
+    };
+    using TAsyncUpdaterPtr = TIntrusiveConstPtr<TAsyncUpdaterBase>;
+}