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

13 files changed, 175 insertions, 175 deletions

diff --git a/util/folder/dirut.cpp b/util/folder/dirut.cpp
index ffc9b09f96..953532ec70 100644
--- a/util/folder/dirut.cpp
+++ b/util/folder/dirut.cpp
@@ -379,7 +379,7 @@ const char* GetDirectorySeparatorS() {
 void RemoveDirWithContents(TString dirName) {
     SlashFolderLocal(dirName);
 
-    TDirIterator dir(dirName, TDirIterator::TOptions(FTS_NOSTAT));
+    TDirIterator dir(dirName, TDirIterator::TOptions(FTS_NOSTAT)); 
 
     for (auto it = dir.begin(); it != dir.end(); ++it) {
         switch (it->fts_info) {
diff --git a/util/network/pair.cpp b/util/network/pair.cpp
index 9751ef5c96..e3610aee77 100644
--- a/util/network/pair.cpp
+++ b/util/network/pair.cpp
@@ -1,12 +1,12 @@
 #include "pair.h"
 
-int SocketPair(SOCKET socks[2], bool overlapped, bool cloexec) {
+int SocketPair(SOCKET socks[2], bool overlapped, bool cloexec) { 
 #if defined(_win_)
     struct sockaddr_in addr;
     SOCKET listener;
     int e;
     int addrlen = sizeof(addr);
-    DWORD flags = (overlapped ? WSA_FLAG_OVERLAPPED : 0) | (cloexec ? WSA_FLAG_NO_HANDLE_INHERIT : 0);
+    DWORD flags = (overlapped ? WSA_FLAG_OVERLAPPED : 0) | (cloexec ? WSA_FLAG_NO_HANDLE_INHERIT : 0); 
 
     if (socks == 0) {
         WSASetLastError(WSAEINVAL);
@@ -75,23 +75,23 @@ int SocketPair(SOCKET socks[2], bool overlapped, bool cloexec) {
     (void)overlapped;
 
     #if defined(_linux_)
-    return socketpair(AF_LOCAL, SOCK_STREAM | (cloexec ? SOCK_CLOEXEC : 0), 0, socks);
+    return socketpair(AF_LOCAL, SOCK_STREAM | (cloexec ? SOCK_CLOEXEC : 0), 0, socks); 
     #else
-    int r = socketpair(AF_LOCAL, SOCK_STREAM, 0, socks);
-    // Non-atomic wrt exec
-    if (r == 0 && cloexec) {
-        for (int i = 0; i < 2; ++i) {
-            int flags = fcntl(socks[i], F_GETFD, 0);
-            if (flags < 0) {
-                return flags;
-            }
-            r = fcntl(socks[i], F_SETFD, flags | FD_CLOEXEC);
-            if (r < 0) {
-                return r;
-            }
-        }
-    }
-    return r;
+    int r = socketpair(AF_LOCAL, SOCK_STREAM, 0, socks); 
+    // Non-atomic wrt exec 
+    if (r == 0 && cloexec) { 
+        for (int i = 0; i < 2; ++i) { 
+            int flags = fcntl(socks[i], F_GETFD, 0); 
+            if (flags < 0) { 
+                return flags; 
+            } 
+            r = fcntl(socks[i], F_SETFD, flags | FD_CLOEXEC); 
+            if (r < 0) { 
+                return r; 
+            } 
+        } 
+    } 
+    return r; 
     #endif
 #endif
 }
diff --git a/util/network/pair.h b/util/network/pair.h
index 0d4506f880..64d81bcc7d 100644
--- a/util/network/pair.h
+++ b/util/network/pair.h
@@ -5,5 +5,5 @@
 int SocketPair(SOCKET socks[2], bool overlapped, bool cloexec = false);
 
 static inline int SocketPair(SOCKET socks[2]) {
-    return SocketPair(socks, false, false);
+    return SocketPair(socks, false, false); 
 }
diff --git a/util/system/daemon.cpp b/util/system/daemon.cpp
index 130e6c8f45..5020720206 100644
--- a/util/system/daemon.cpp
+++ b/util/system/daemon.cpp
@@ -17,18 +17,18 @@
 #ifdef _unix_
 using namespace NDaemonMaker;
 
-static bool Fork(EParent parent) {
+static bool Fork(EParent parent) { 
     pid_t pid = fork();
 
     if (pid > 0) {
-        int status = 0;
-        while (waitpid(pid, &status, 0) < 0 && errno == EINTR) {
-        }
-        if (parent == callExitFromParent) {
+        int status = 0; 
+        while (waitpid(pid, &status, 0) < 0 && errno == EINTR) { 
+        } 
+        if (parent == callExitFromParent) { 
             _exit(0);
-        } else {
-            return true;
-        }
+        } else { 
+            return true; 
+        } 
     } else if (pid < 0) {
         ythrow TSystemError() << "Cannot fork";
     }
@@ -44,7 +44,7 @@ static bool Fork(EParent parent) {
     } else if (pid < 0) {
         ythrow TSystemError() << "Cannot second fork";
     }
-    return false;
+    return false; 
 }
 
 #endif
@@ -75,15 +75,15 @@ static void CloseFromToExcept(int from, int to, const int* except) {
 #endif /* _unix_ */
 }
 
-bool NDaemonMaker::MakeMeDaemon(ECloseDescriptors cd, EStdIoDescriptors iod, EChDir chd, EParent parent) {
+bool NDaemonMaker::MakeMeDaemon(ECloseDescriptors cd, EStdIoDescriptors iod, EChDir chd, EParent parent) { 
     (void)cd;
     (void)iod;
     (void)chd;
 
 #ifdef _unix_
-    if (Fork(parent)) {
-        return true;
-    }
+    if (Fork(parent)) { 
+        return true; 
+    } 
 
     if (chd == chdirRoot) {
         if (chdir("/")) {
@@ -156,9 +156,9 @@ bool NDaemonMaker::MakeMeDaemon(ECloseDescriptors cd, EStdIoDescriptors iod, ECh
         default:
             break;
     }
-    return false;
-#else
-    return true;
+    return false; 
+#else 
+    return true; 
 #endif
 }
 
diff --git a/util/system/daemon.h b/util/system/daemon.h
index b00793b9c9..c9cc73fc44 100644
--- a/util/system/daemon.h
+++ b/util/system/daemon.h
@@ -17,11 +17,11 @@ namespace NDaemonMaker {
         chdirRoot
     };
 
-    enum EParent {
-        callExitFromParent = 0,
-        returnFromParent
-    };
-
-    bool MakeMeDaemon(ECloseDescriptors cd = closeAll, EStdIoDescriptors iod = openDevNull, EChDir chd = chdirRoot, EParent parent = callExitFromParent);
+    enum EParent { 
+        callExitFromParent = 0, 
+        returnFromParent 
+    }; 
+ 
+    bool MakeMeDaemon(ECloseDescriptors cd = closeAll, EStdIoDescriptors iod = openDevNull, EChDir chd = chdirRoot, EParent parent = callExitFromParent); 
     void CloseFrom(int fd);
 }
diff --git a/util/system/daemon_ut.cpp b/util/system/daemon_ut.cpp
index f93b9a9645..fd80f3ba8c 100644
--- a/util/system/daemon_ut.cpp
+++ b/util/system/daemon_ut.cpp
@@ -1,94 +1,94 @@
-#include "daemon.h"
-
+#include "daemon.h" 
+ 
 #include <library/cpp/testing/unittest/registar.h>
-
-#include <util/network/pair.h>
-#include <util/network/socket.h>
-#include <util/system/pipe.h>
-
-Y_UNIT_TEST_SUITE(TDaemonTest) {
-#ifdef _unix_
-    template <typename Func>
+ 
+#include <util/network/pair.h> 
+#include <util/network/socket.h> 
+#include <util/system/pipe.h> 
+ 
+Y_UNIT_TEST_SUITE(TDaemonTest) { 
+#ifdef _unix_ 
+    template <typename Func> 
     static bool ProcessBuffer(Func&& func, void* bufin, size_t size) {
-        char* buf = (char*)bufin;
-        do {
-            const ssize_t bytesDone = func(buf, size);
-            if (bytesDone == 0) {
-                return false;
-            }
-
-            if (bytesDone < 0) {
-                if (errno == EAGAIN || errno == EINTR) {
-                    continue;
-                } else {
-                    return false;
-                }
-            }
-
-            buf += bytesDone;
-            size -= bytesDone;
-        } while (size != 0);
-
-        return true;
-    }
-
-    const int size = 1024 * 4;
-    const int pagesSize = sizeof(int) * size;
-
-    Y_UNIT_TEST(WaitForMessageSocket) {
-        using namespace NDaemonMaker;
-        SOCKET sockets[2];
-        SocketPair(sockets, false, true);
-        TSocket sender(sockets[0]);
-        TSocket receiver(sockets[1]);
-
-        int status = -1;
-        int* pages = new int[size];
-
-        memset(pages, 0, pagesSize);
-        if (MakeMeDaemon(closeStdIoOnly, openDevNull, chdirNone, returnFromParent)) {
-            sender.Close();
-            UNIT_ASSERT(ProcessBuffer([&receiver](char* ptr, size_t sz) -> size_t { return receiver.Recv(ptr, sz); }, &status, sizeof(status)));
-            UNIT_ASSERT(ProcessBuffer([&receiver](char* ptr, size_t sz) -> size_t { return receiver.Recv(ptr, sz); }, pages, pagesSize));
-            UNIT_ASSERT(memchr(pages, 0, pagesSize) == nullptr);
-        } else {
-            receiver.Close();
-            status = 0;
-            UNIT_ASSERT(ProcessBuffer([&sender](char* ptr, size_t sz) -> size_t { return sender.Send(ptr, sz); }, &status, sizeof(status)));
-            memset(pages, 1, pagesSize);
-            UNIT_ASSERT(ProcessBuffer([&sender](char* ptr, size_t sz) -> size_t { return sender.Send(ptr, sz); }, pages, pagesSize));
-            exit(0);
-        }
-        UNIT_ASSERT(status == 0);
-
-        delete[] pages;
-    }
-
-    Y_UNIT_TEST(WaitForMessagePipe) {
-        using namespace NDaemonMaker;
-        TPipeHandle sender;
-        TPipeHandle receiver;
-        TPipeHandle::Pipe(receiver, sender);
-
-        int status = -1;
-        int* pages = new int[size];
-        memset(pages, 0, pagesSize);
-        if (MakeMeDaemon(closeStdIoOnly, openDevNull, chdirNone, returnFromParent)) {
-            sender.Close();
-            UNIT_ASSERT(ProcessBuffer([&receiver](char* ptr, size_t sz) -> size_t { return receiver.Read(ptr, sz); }, &status, sizeof(status)));
-            UNIT_ASSERT(ProcessBuffer([&receiver](char* ptr, size_t sz) -> size_t { return receiver.Read(ptr, sz); }, pages, pagesSize));
-            UNIT_ASSERT(memchr(pages, 0, pagesSize) == nullptr);
-        } else {
-            receiver.Close();
-            status = 0;
-            UNIT_ASSERT(ProcessBuffer([&sender](char* ptr, size_t sz) -> size_t { return sender.Write(ptr, sz); }, &status, sizeof(status)));
-            memset(pages, 1, pagesSize);
-            UNIT_ASSERT(ProcessBuffer([&sender](char* ptr, size_t sz) -> size_t { return sender.Write(ptr, sz); }, pages, pagesSize));
-            exit(0);
-        }
-        UNIT_ASSERT(status == 0);
-
-        delete[] pages;
-    }
-#endif
-}
+        char* buf = (char*)bufin; 
+        do { 
+            const ssize_t bytesDone = func(buf, size); 
+            if (bytesDone == 0) { 
+                return false; 
+            } 
+ 
+            if (bytesDone < 0) { 
+                if (errno == EAGAIN || errno == EINTR) { 
+                    continue; 
+                } else { 
+                    return false; 
+                } 
+            } 
+ 
+            buf += bytesDone; 
+            size -= bytesDone; 
+        } while (size != 0); 
+ 
+        return true; 
+    } 
+ 
+    const int size = 1024 * 4; 
+    const int pagesSize = sizeof(int) * size; 
+ 
+    Y_UNIT_TEST(WaitForMessageSocket) { 
+        using namespace NDaemonMaker; 
+        SOCKET sockets[2]; 
+        SocketPair(sockets, false, true); 
+        TSocket sender(sockets[0]); 
+        TSocket receiver(sockets[1]); 
+ 
+        int status = -1; 
+        int* pages = new int[size]; 
+ 
+        memset(pages, 0, pagesSize); 
+        if (MakeMeDaemon(closeStdIoOnly, openDevNull, chdirNone, returnFromParent)) { 
+            sender.Close(); 
+            UNIT_ASSERT(ProcessBuffer([&receiver](char* ptr, size_t sz) -> size_t { return receiver.Recv(ptr, sz); }, &status, sizeof(status))); 
+            UNIT_ASSERT(ProcessBuffer([&receiver](char* ptr, size_t sz) -> size_t { return receiver.Recv(ptr, sz); }, pages, pagesSize)); 
+            UNIT_ASSERT(memchr(pages, 0, pagesSize) == nullptr); 
+        } else { 
+            receiver.Close(); 
+            status = 0; 
+            UNIT_ASSERT(ProcessBuffer([&sender](char* ptr, size_t sz) -> size_t { return sender.Send(ptr, sz); }, &status, sizeof(status))); 
+            memset(pages, 1, pagesSize); 
+            UNIT_ASSERT(ProcessBuffer([&sender](char* ptr, size_t sz) -> size_t { return sender.Send(ptr, sz); }, pages, pagesSize)); 
+            exit(0); 
+        } 
+        UNIT_ASSERT(status == 0); 
+ 
+        delete[] pages; 
+    } 
+ 
+    Y_UNIT_TEST(WaitForMessagePipe) { 
+        using namespace NDaemonMaker; 
+        TPipeHandle sender; 
+        TPipeHandle receiver; 
+        TPipeHandle::Pipe(receiver, sender); 
+ 
+        int status = -1; 
+        int* pages = new int[size]; 
+        memset(pages, 0, pagesSize); 
+        if (MakeMeDaemon(closeStdIoOnly, openDevNull, chdirNone, returnFromParent)) { 
+            sender.Close(); 
+            UNIT_ASSERT(ProcessBuffer([&receiver](char* ptr, size_t sz) -> size_t { return receiver.Read(ptr, sz); }, &status, sizeof(status))); 
+            UNIT_ASSERT(ProcessBuffer([&receiver](char* ptr, size_t sz) -> size_t { return receiver.Read(ptr, sz); }, pages, pagesSize)); 
+            UNIT_ASSERT(memchr(pages, 0, pagesSize) == nullptr); 
+        } else { 
+            receiver.Close(); 
+            status = 0; 
+            UNIT_ASSERT(ProcessBuffer([&sender](char* ptr, size_t sz) -> size_t { return sender.Write(ptr, sz); }, &status, sizeof(status))); 
+            memset(pages, 1, pagesSize); 
+            UNIT_ASSERT(ProcessBuffer([&sender](char* ptr, size_t sz) -> size_t { return sender.Write(ptr, sz); }, pages, pagesSize)); 
+            exit(0); 
+        } 
+        UNIT_ASSERT(status == 0); 
+ 
+        delete[] pages; 
+    } 
+#endif 
+} 
diff --git a/util/system/file.cpp b/util/system/file.cpp
index 4a261d020c..f677819de6 100644
--- a/util/system/file.cpp
+++ b/util/system/file.cpp
@@ -238,9 +238,9 @@ TFileHandle::TFileHandle(const TString& fName, EOpenMode oMode) noexcept {
         permMode |= S_IRUSR;
     }
 
-    do {
-        Fd_ = ::open(fName.data(), fcMode, permMode);
-    } while (Fd_ == -1 && errno == EINTR);
+    do { 
+        Fd_ = ::open(fName.data(), fcMode, permMode); 
+    } while (Fd_ == -1 && errno == EINTR); 
 
     #if HAVE_POSIX_FADVISE
     if (Fd_ >= 0) {
diff --git a/util/system/file_lock.cpp b/util/system/file_lock.cpp
index 45d91282c5..4af6110011 100644
--- a/util/system/file_lock.cpp
+++ b/util/system/file_lock.cpp
@@ -15,7 +15,7 @@ namespace {
             default:
                 Y_UNREACHABLE();
         }
-        Y_UNREACHABLE();
+        Y_UNREACHABLE(); 
     }
 }
 
diff --git a/util/system/flock.cpp b/util/system/flock.cpp
index fe88fecaff..480ae18369 100644
--- a/util/system/flock.cpp
+++ b/util/system/flock.cpp
@@ -55,7 +55,7 @@ extern "C" {
                 break;
             default:
                 break;
-        }
+        } 
         errno = EINVAL;
         return -1;
     }
diff --git a/util/system/pipe.cpp b/util/system/pipe.cpp
index a543bd7472..d16d6830b7 100644
--- a/util/system/pipe.cpp
+++ b/util/system/pipe.cpp
@@ -32,12 +32,12 @@ bool TPipeHandle::Close() noexcept {
     return ok;
 }
 
-void TPipeHandle::Pipe(TPipeHandle& reader, TPipeHandle& writer, EOpenMode mode) {
+void TPipeHandle::Pipe(TPipeHandle& reader, TPipeHandle& writer, EOpenMode mode) { 
     PIPEHANDLE fds[2];
 #ifdef _win_
-    int r = SocketPair(fds, false /* non-overlapped */, mode & CloseOnExec /* cloexec */);
-#elif defined(_linux_)
-    int r = pipe2(fds, mode & CloseOnExec ? O_CLOEXEC : 0);
+    int r = SocketPair(fds, false /* non-overlapped */, mode & CloseOnExec /* cloexec */); 
+#elif defined(_linux_) 
+    int r = pipe2(fds, mode & CloseOnExec ? O_CLOEXEC : 0); 
 #else
     int r = pipe(fds);
 #endif
@@ -45,22 +45,22 @@ void TPipeHandle::Pipe(TPipeHandle& reader, TPipeHandle& writer, EOpenMode mode)
         ythrow TFileError() << "failed to create a pipe";
     }
 
-#if !defined(_win_) && !defined(_linux_)
-    // Non-atomic wrt exec
-    if (mode & CloseOnExec) {
-        for (int i = 0; i < 2; ++i) {
-            int flags = fcntl(fds[i], F_GETFD, 0);
-            if (flags < 0) {
-                ythrow TFileError() << "failed to get flags";
-            }
-            int r = fcntl(fds[i], F_SETFD, flags | FD_CLOEXEC);
-            if (r < 0) {
-                ythrow TFileError() << "failed to set flags";
-            }
-        }
-    }
-#endif
-
+#if !defined(_win_) && !defined(_linux_) 
+    // Non-atomic wrt exec 
+    if (mode & CloseOnExec) { 
+        for (int i = 0; i < 2; ++i) { 
+            int flags = fcntl(fds[i], F_GETFD, 0); 
+            if (flags < 0) { 
+                ythrow TFileError() << "failed to get flags"; 
+            } 
+            int r = fcntl(fds[i], F_SETFD, flags | FD_CLOEXEC); 
+            if (r < 0) { 
+                ythrow TFileError() << "failed to set flags"; 
+            } 
+        } 
+    } 
+#endif 
+ 
     TPipeHandle(fds[0]).Swap(reader);
     TPipeHandle(fds[1]).Swap(writer);
 }
@@ -150,11 +150,11 @@ size_t TPipe::Write(const void* buf, size_t len) const {
     return Impl_->Write(buf, len);
 }
 
-void TPipe::Pipe(TPipe& reader, TPipe& writer, EOpenMode mode) {
+void TPipe::Pipe(TPipe& reader, TPipe& writer, EOpenMode mode) { 
     TImplRef r(new TImpl());
     TImplRef w(new TImpl());
 
-    TPipeHandle::Pipe(r->GetHandle(), w->GetHandle(), mode);
+    TPipeHandle::Pipe(r->GetHandle(), w->GetHandle(), mode); 
 
     r.Swap(reader.Impl_);
     w.Swap(writer.Impl_);
diff --git a/util/system/pipe.h b/util/system/pipe.h
index 75d0360049..60e6440be3 100644
--- a/util/system/pipe.h
+++ b/util/system/pipe.h
@@ -6,7 +6,7 @@
 #endif
 
 #include "defaults.h"
-#include "file.h"
+#include "file.h" 
 #include <util/generic/ptr.h>
 #include <util/network/pair.h>
 #include <util/generic/noncopyable.h>
@@ -54,8 +54,8 @@ public:
     ssize_t Read(void* buffer, size_t byteCount) const noexcept;
     ssize_t Write(const void* buffer, size_t byteCount) const noexcept;
 
-    // Only CloseOnExec is supported
-    static void Pipe(TPipeHandle& reader, TPipeHandle& writer, EOpenMode mode = 0);
+    // Only CloseOnExec is supported 
+    static void Pipe(TPipeHandle& reader, TPipeHandle& writer, EOpenMode mode = 0); 
 
 private:
     PIPEHANDLE Fd_;
@@ -76,8 +76,8 @@ public:
     size_t Read(void* buf, size_t len) const;
     size_t Write(const void* buf, size_t len) const;
 
-    // Only CloseOnExec is supported
-    static void Pipe(TPipe& reader, TPipe& writer, EOpenMode mode = 0);
+    // Only CloseOnExec is supported 
+    static void Pipe(TPipe& reader, TPipe& writer, EOpenMode mode = 0); 
 
 private:
     class TImpl;
diff --git a/util/system/shellcommand.cpp b/util/system/shellcommand.cpp
index b1989b5c8c..099840f684 100644
--- a/util/system/shellcommand.cpp
+++ b/util/system/shellcommand.cpp
@@ -168,10 +168,10 @@ public:
         return doneBytes;
     }
 
-    static void Pipe(TRealPipeHandle& reader, TRealPipeHandle& writer, EOpenMode mode) {
-        (void)mode;
+    static void Pipe(TRealPipeHandle& reader, TRealPipeHandle& writer, EOpenMode mode) { 
+        (void)mode; 
         REALPIPEHANDLE fds[2];
-        if (!CreatePipe(&fds[0], &fds[1], nullptr /* handles are not inherited */, 0))
+        if (!CreatePipe(&fds[0], &fds[1], nullptr /* handles are not inherited */, 0)) 
             ythrow TFileError() << "failed to create a pipe";
         TRealPipeHandle(fds[0]).Swap(reader);
         TRealPipeHandle(fds[1]).Swap(writer);
@@ -254,9 +254,9 @@ private:
             if (ErrorPipeFd[1].IsOpen()) {
                 ErrorPipeFd[1].Close();
             }
-            if (InputPipeFd[1].IsOpen()) {
+            if (InputPipeFd[1].IsOpen()) { 
                 InputPipeFd[0].Close();
-            }
+            } 
         }
         void ReleaseParents() {
             InputPipeFd[1].Release();
@@ -763,13 +763,13 @@ void TShellCommand::TImpl::Run() {
     TPipes pipes;
 
     if (OutputMode != TShellCommandOptions::HANDLE_INHERIT) {
-        TRealPipeHandle::Pipe(pipes.OutputPipeFd[0], pipes.OutputPipeFd[1], CloseOnExec);
+        TRealPipeHandle::Pipe(pipes.OutputPipeFd[0], pipes.OutputPipeFd[1], CloseOnExec); 
     }
     if (ErrorMode != TShellCommandOptions::HANDLE_INHERIT) {
-        TRealPipeHandle::Pipe(pipes.ErrorPipeFd[0], pipes.ErrorPipeFd[1], CloseOnExec);
+        TRealPipeHandle::Pipe(pipes.ErrorPipeFd[0], pipes.ErrorPipeFd[1], CloseOnExec); 
     }
     if (InputMode != TShellCommandOptions::HANDLE_INHERIT) {
-        TRealPipeHandle::Pipe(pipes.InputPipeFd[0], pipes.InputPipeFd[1], CloseOnExec);
+        TRealPipeHandle::Pipe(pipes.InputPipeFd[0], pipes.InputPipeFd[1], CloseOnExec); 
     }
 
     AtomicSet(ExecutionStatus, SHELL_RUNNING);
diff --git a/util/system/ut/ya.make b/util/system/ut/ya.make
index 127e7c261e..a15826cb0d 100644
--- a/util/system/ut/ya.make
+++ b/util/system/ut/ya.make
@@ -35,7 +35,7 @@ SRCS(
     system/condvar_ut.cpp
     system/cpu_id_ut.cpp
     system/datetime_ut.cpp
-    system/daemon_ut.cpp
+    system/daemon_ut.cpp 
     system/direct_io_ut.cpp
     system/env_ut.cpp
     system/error_ut.cpp