Browse Source

Restoring authorship annotation for Vasily Gerasimov <UgnineSirdis@gmail.com>. Commit 2 of 2.

Vasily Gerasimov 3 years ago
parent
commit
1eb755fbca

+ 25 - 25
build/scripts/coverage-info.py

@@ -4,7 +4,7 @@ import sys
 import tarfile
 import collections
 import subprocess
-import re 
+import re
 
 
 GCDA_EXT = '.gcda'
@@ -150,13 +150,13 @@ def gen_info_global(cmd, cov_info, probe_path, update_stat, lcov_args):
 
 
 def init_all_coverage_files(gcno_archive, fname2gcno, fname2info, geninfo_executable, gcov_tool, gen_info, prefix_filter, exclude_files):
-    with tarfile.open(gcno_archive) as gcno_tf: 
-        for gcno_item in gcno_tf: 
-            if gcno_item.isfile() and gcno_item.name.endswith(GCNO_EXT): 
-                gcno_tf.extract(gcno_item) 
- 
-                gcno_name = gcno_item.name 
-                source_fname = gcno_name[:-len(GCNO_EXT)] 
+    with tarfile.open(gcno_archive) as gcno_tf:
+        for gcno_item in gcno_tf:
+            if gcno_item.isfile() and gcno_item.name.endswith(GCNO_EXT):
+                gcno_tf.extract(gcno_item)
+
+                gcno_name = gcno_item.name
+                source_fname = gcno_name[:-len(GCNO_EXT)]
                 if prefix_filter and not source_fname.startswith(prefix_filter):
                     sys.stderr.write("Skipping {} (doesn't match prefix '{}')\n".format(source_fname, prefix_filter))
                     continue
@@ -164,19 +164,19 @@ def init_all_coverage_files(gcno_archive, fname2gcno, fname2info, geninfo_execut
                     sys.stderr.write("Skipping {} (matched exclude pattern '{}')\n".format(source_fname, exclude_files.pattern))
                     continue
 
-                fname2gcno[source_fname] = gcno_name 
- 
-                if os.path.getsize(gcno_name) > 0: 
-                    coverage_info = source_fname + '.' + str(len(fname2info[source_fname])) + '.info' 
-                    fname2info[source_fname].append(coverage_info) 
-                    geninfo_cmd = [ 
-                        geninfo_executable, 
-                        '--gcov-tool', gcov_tool, 
-                        '-i', gcno_name, 
-                        '-o', coverage_info + '.tmp' 
-                    ] 
-                    gen_info(geninfo_cmd, coverage_info) 
- 
+                fname2gcno[source_fname] = gcno_name
+
+                if os.path.getsize(gcno_name) > 0:
+                    coverage_info = source_fname + '.' + str(len(fname2info[source_fname])) + '.info'
+                    fname2info[source_fname].append(coverage_info)
+                    geninfo_cmd = [
+                        geninfo_executable,
+                        '--gcov-tool', gcov_tool,
+                        '-i', gcno_name,
+                        '-o', coverage_info + '.tmp'
+                    ]
+                    gen_info(geninfo_cmd, coverage_info)
+
 
 def process_all_coverage_files(gcda_archive, fname2gcno, fname2info, geninfo_executable, gcov_tool, gen_info):
     with tarfile.open(gcda_archive) as gcda_tf:
@@ -190,10 +190,10 @@ def process_all_coverage_files(gcda_archive, fname2gcno, fname2info, geninfo_exe
                         gcda_item.name = gcda_new_name
                         gcda_tf.extract(gcda_item)
                         if os.path.getsize(gcda_new_name) > 0:
-                            coverage_info = suff + '.' + str(len(fname2info[suff])) + '.info' 
-                            fname2info[suff].append(coverage_info) 
+                            coverage_info = suff + '.' + str(len(fname2info[suff])) + '.info'
+                            fname2info[suff].append(coverage_info)
                             geninfo_cmd = [
-                                geninfo_executable, 
+                                geninfo_executable,
                                 '--gcov-tool', gcov_tool,
                                 gcda_new_name,
                                 '-o', coverage_info + '.tmp'
@@ -272,7 +272,7 @@ if __name__ == '__main__':
     parser.add_argument('--gcda-archive', action='store')
     parser.add_argument('--gcov-tool', action='store')
     parser.add_argument('--prefix-filter', action='store')
-    parser.add_argument('--exclude-regexp', action='store') 
+    parser.add_argument('--exclude-regexp', action='store')
     parser.add_argument('--teamcity-stat-output', action='store_const', const=True)
     parser.add_argument('--coverage-report-path', action='store')
     parser.add_argument('--gcov-report', action='store')

+ 3 - 3
library/cpp/actors/core/actor.h

@@ -401,7 +401,7 @@ namespace NActors {
         template <typename T>
         struct HasActorName<T, decltype((void)T::ActorName, (const char*)nullptr)>: std::true_type { };
 
-        static ui32 GetActivityTypeIndex() { 
+        static ui32 GetActivityTypeIndex() {
             if constexpr(HasActorName<TDerived>::value) {
                 return TLocalProcessKey<TActorActivityTag, TDerived::ActorName>::GetIndex();
             } else {
@@ -425,8 +425,8 @@ namespace NActors {
 
         // static constexpr char ActorName[] = "UNNAMED";
 
-        TActor(void (TDerived::*func)(TAutoPtr<IEventHandle>& ev, const TActorContext& ctx), ui32 activityType = GetActivityTypeIndex()) 
-            : IActor(static_cast<TReceiveFunc>(func), activityType) 
+        TActor(void (TDerived::*func)(TAutoPtr<IEventHandle>& ev, const TActorContext& ctx), ui32 activityType = GetActivityTypeIndex())
+            : IActor(static_cast<TReceiveFunc>(func), activityType)
         { }
 
     public:

+ 2 - 2
library/cpp/actors/core/executor_thread.cpp

@@ -72,7 +72,7 @@ namespace NActors {
     }
 
     void TExecutorThread::Schedule(TInstant deadline, TAutoPtr<IEventHandle> ev, ISchedulerCookie* cookie) {
-        ++CurrentActorScheduledEventsCounter; 
+        ++CurrentActorScheduledEventsCounter;
         Ctx.Executor->Schedule(deadline, ev, cookie, Ctx.WorkerId);
     }
 
@@ -153,7 +153,7 @@ namespace NActors {
                     TCallstack::GetTlsCallstack().SetLinesToSkip();
 #endif
                     CurrentRecipient = recipient;
-                    CurrentActorScheduledEventsCounter = 0; 
+                    CurrentActorScheduledEventsCounter = 0;
 
                     if (executed == 0) {
                         double usec = Ctx.AddActivationStats(AtomicLoad(&mailbox->ScheduleMoment), hpprev);

+ 3 - 3
library/cpp/actors/core/mon_stats.h

@@ -79,7 +79,7 @@ namespace NActors {
         TVector<NHPTimer::STime> ElapsedTicksByActivity;
         TVector<ui64> ReceivedEventsByActivity;
         TVector<i64> ActorsAliveByActivity; // the sum should be positive, but per-thread might be negative
-        TVector<ui64> ScheduledEventsByActivity; 
+        TVector<ui64> ScheduledEventsByActivity;
         ui64 PoolActorRegistrations = 0;
         ui64 PoolDestroyedActors = 0;
         ui64 PoolAllocatedMailboxes = 0;
@@ -91,7 +91,7 @@ namespace NActors {
             : ElapsedTicksByActivity(activityVecSize)
             , ReceivedEventsByActivity(activityVecSize)
             , ActorsAliveByActivity(activityVecSize)
-            , ScheduledEventsByActivity(activityVecSize) 
+            , ScheduledEventsByActivity(activityVecSize)
         {}
 
         template <typename T>
@@ -126,7 +126,7 @@ namespace NActors {
             AggregateOne(ElapsedTicksByActivity, other.ElapsedTicksByActivity);
             AggregateOne(ReceivedEventsByActivity, other.ReceivedEventsByActivity);
             AggregateOne(ActorsAliveByActivity, other.ActorsAliveByActivity);
-            AggregateOne(ScheduledEventsByActivity, other.ScheduledEventsByActivity); 
+            AggregateOne(ScheduledEventsByActivity, other.ScheduledEventsByActivity);
 
             RelaxedStore(
                 &PoolActorRegistrations,

+ 1 - 1
library/cpp/actors/helpers/selfping_actor.cpp

@@ -64,7 +64,7 @@ private:
     const NMonitoring::TDynamicCounters::TCounterPtr Counter;
     const NMonitoring::TDynamicCounters::TCounterPtr CalculationTimeCounter;
 
-    NSlidingWindow::TSlidingWindow<NSlidingWindow::TMaxOperation<ui64>> SlidingWindow; 
+    NSlidingWindow::TSlidingWindow<NSlidingWindow::TMaxOperation<ui64>> SlidingWindow;
     NSlidingWindow::TSlidingWindow<TAvgOperation<ui64>> CalculationSlidingWindow;
 
     THPTimer Timer;

+ 1 - 1
library/cpp/actors/ya.make

@@ -1,7 +1,7 @@
 RECURSE_FOR_TESTS(ut)
 
 RECURSE(
-    log_backend 
+    log_backend
     core
     dnsresolver
     examples

+ 29 - 29
library/cpp/colorizer/colors.cpp

@@ -1,6 +1,6 @@
 #include "colors.h"
 
-#include <util/stream/output.h> 
+#include <util/stream/output.h>
 #include <util/generic/singleton.h>
 #include <util/system/env.h>
 
@@ -166,10 +166,10 @@ bool TColors::CalcIsTTY(FILE* file) {
 #endif
 }
 
-TColors::TColors(FILE* f) 
+TColors::TColors(FILE* f)
     : IsTTY_(true)
 {
-    SetIsTTY(CalcIsTTY(f)); 
+    SetIsTTY(CalcIsTTY(f));
 }
 
 TColors::TColors(bool ontty)
@@ -418,7 +418,7 @@ TStringBuf TColors::WhiteColor() const noexcept {
 }
 
 
-namespace { 
+namespace {
     class TStdErrColors: public TColors {
     public:
         TStdErrColors()
@@ -426,24 +426,24 @@ namespace {
         {
         }
     };
- 
-    class TStdOutColors: public TColors { 
-    public: 
-        TStdOutColors() 
-            : TColors(stdout) 
-        { 
-        } 
-    }; 
- 
-    class TDisabledColors: public TColors { 
-    public: 
-        TDisabledColors() 
-            : TColors(false) 
-        { 
-        } 
-    }; 
-} // anonymous namespace 
- 
+
+    class TStdOutColors: public TColors {
+    public:
+        TStdOutColors()
+            : TColors(stdout)
+        {
+        }
+    };
+
+    class TDisabledColors: public TColors {
+    public:
+        TDisabledColors()
+            : TColors(false)
+        {
+        }
+    };
+} // anonymous namespace
+
 TColors& NColorizer::StdErr() {
     return *Singleton<TStdErrColors>();
 }
@@ -453,13 +453,13 @@ TColors& NColorizer::StdOut() {
 }
 
 TColors& NColorizer::AutoColors(IOutputStream& os) {
-    if (&os == &Cerr) { 
-        return StdErr(); 
-    } 
-    if (&os == &Cout) { 
-        return StdOut(); 
-    } 
-    return *Singleton<TDisabledColors>(); 
+    if (&os == &Cerr) {
+        return StdErr();
+    }
+    if (&os == &Cout) {
+        return StdOut();
+    }
+    return *Singleton<TDisabledColors>();
 }
 
 size_t NColorizer::TotalAnsiEscapeCodeLen(TStringBuf text) {

+ 6 - 6
library/cpp/colorizer/colors.h

@@ -1,6 +1,6 @@
 #pragma once
 
-#include "fwd.h" 
+#include "fwd.h"
 
 #include <util/generic/string.h>
 #include <util/generic/strbuf.h>
@@ -104,8 +104,8 @@ namespace NColorizer {
         static bool CalcIsTTY(FILE* file);
 
     public:
-        explicit TColors(FILE* = stderr); 
-        explicit TColors(bool ontty); 
+        explicit TColors(FILE* = stderr);
+        explicit TColors(bool ontty);
 
         TStringBuf Reset() const noexcept;
 
@@ -213,9 +213,9 @@ namespace NColorizer {
     };
 
     /// Singletone `TColors` instances for stderr/stdout.
-    TColors& StdErr(); 
-    TColors& StdOut(); 
- 
+    TColors& StdErr();
+    TColors& StdOut();
+
     /// Choose `TColors` depending on output stream. If passed stream is stderr/stdout, return a corresponding
     /// singletone. Otherwise, return a disabled singletone (which you can, but should *not* enable).
     TColors& AutoColors(IOutputStream& os);

+ 8 - 8
library/cpp/colorizer/fwd.h

@@ -1,11 +1,11 @@
-#pragma once 
- 
+#pragma once
+
 class IOutputStream;
- 
-namespace NColorizer { 
-    class TColors; 
- 
-    TColors& StdErr(); 
-    TColors& StdOut(); 
+
+namespace NColorizer {
+    class TColors;
+
+    TColors& StdErr();
+    TColors& StdOut();
     TColors& AutoColors(IOutputStream&);
 }

+ 5 - 5
library/cpp/containers/comptrie/comptrie_builder.h

@@ -46,7 +46,7 @@ public:
     typedef typename TCompactTrieKeySelector<TSymbol>::TKey TKey;
     typedef typename TCompactTrieKeySelector<TSymbol>::TKeyBuf TKeyBuf;
 
-    explicit TCompactTrieBuilder(TCompactTrieBuilderFlags flags = CTBF_NONE, TPacker packer = TPacker(), IAllocator* alloc = TDefaultAllocator::Instance()); 
+    explicit TCompactTrieBuilder(TCompactTrieBuilderFlags flags = CTBF_NONE, TPacker packer = TPacker(), IAllocator* alloc = TDefaultAllocator::Instance());
 
     // All Add.. methods return true if it was a new key, false if the key already existed.
 
@@ -72,14 +72,14 @@ public:
     }
 
     bool Find(const TSymbol* key, size_t keylen, TData* value) const;
-    bool Find(const TKeyBuf& key, TData* value = nullptr) const { 
+    bool Find(const TKeyBuf& key, TData* value = nullptr) const {
         return Find(key.data(), key.size(), value);
     }
 
-    bool FindLongestPrefix(const TSymbol* key, size_t keylen, size_t* prefixLen, TData* value = nullptr) const; 
-    bool FindLongestPrefix(const TKeyBuf& key, size_t* prefixLen, TData* value = nullptr) const { 
+    bool FindLongestPrefix(const TSymbol* key, size_t keylen, size_t* prefixLen, TData* value = nullptr) const;
+    bool FindLongestPrefix(const TKeyBuf& key, size_t* prefixLen, TData* value = nullptr) const {
         return FindLongestPrefix(key.data(), key.size(), prefixLen, value);
-    } 
+    }
 
     size_t Save(IOutputStream& os) const;
     size_t SaveAndDestroy(IOutputStream& os);

Some files were not shown because too many files changed in this diff