diff options
| author | Stefan Boberg <[email protected]> | 2021-09-16 22:49:59 +0200 |
|---|---|---|
| committer | Stefan Boberg <[email protected]> | 2021-09-16 22:49:59 +0200 |
| commit | 14a9b3d70c39e9823bdd93b44c5bc7479062defd (patch) | |
| tree | d6856ae66f0089121e3cfa6f26dcbac0d96799b8 | |
| parent | Added Oid::FromMemory() (diff) | |
| download | zen-14a9b3d70c39e9823bdd93b44c5bc7479062defd.tar.xz zen-14a9b3d70c39e9823bdd93b44c5bc7479062defd.zip | |
clang-format
| -rw-r--r-- | zencore/include/zencore/thread.h | 4 | ||||
| -rw-r--r-- | zencore/thread.cpp | 4 | ||||
| -rw-r--r-- | zenserver/upstream/jupiter.cpp | 12 |
3 files changed, 13 insertions, 7 deletions
diff --git a/zencore/include/zencore/thread.h b/zencore/include/zencore/thread.h index 0e34d6518..e65867ec4 100644 --- a/zencore/include/zencore/thread.h +++ b/zencore/include/zencore/thread.h @@ -128,7 +128,7 @@ private: }; /** Basic process abstraction - */ + */ class ProcessHandle { public: @@ -155,7 +155,7 @@ private: /** Process monitor - monitors a list of running processes via polling - Intended to be used to monitor a set of "sponsor" processes, where + Intended to be used to monitor a set of "sponsor" processes, where we need to determine when none of them remain alive */ diff --git a/zencore/thread.cpp b/zencore/thread.cpp index ee00d38d4..1c7e4b3ab 100644 --- a/zencore/thread.cpp +++ b/zencore/thread.cpp @@ -76,7 +76,7 @@ Event::Reset() ResetEvent(m_EventHandle); } -void +void Event::Close() { CloseHandle(m_EventHandle); @@ -291,7 +291,7 @@ ProcessMonitor::IsRunning() { DWORD ExitCode = 0; GetExitCodeProcess(Proc, &ExitCode); - + if (ExitCode != STILL_ACTIVE) { CloseHandle(Proc); diff --git a/zenserver/upstream/jupiter.cpp b/zenserver/upstream/jupiter.cpp index 4a5467648..fbd945528 100644 --- a/zenserver/upstream/jupiter.cpp +++ b/zenserver/upstream/jupiter.cpp @@ -163,7 +163,9 @@ CloudCacheSession::PutDerivedData(std::string_view BucketId, std::string_view Ke cpr::Response Response = Session.Put(); ZEN_DEBUG("PUT {}", Response); - return {.Bytes = Response.uploaded_bytes, .ElapsedSeconds = Response.elapsed, .Success = (Response.status_code == 200 || Response.status_code == 201)}; + return {.Bytes = Response.uploaded_bytes, + .ElapsedSeconds = Response.elapsed, + .Success = (Response.status_code == 200 || Response.status_code == 201)}; } CloudCacheResult @@ -194,7 +196,9 @@ CloudCacheSession::PutRef(std::string_view BucketId, const IoHash& Key, IoBuffer cpr::Response Response = Session.Put(); ZEN_DEBUG("PUT {}", Response); - return {.Bytes = Response.uploaded_bytes, .ElapsedSeconds = Response.elapsed, .Success = (Response.status_code == 200 || Response.status_code == 201)}; + return {.Bytes = Response.uploaded_bytes, + .ElapsedSeconds = Response.elapsed, + .Success = (Response.status_code == 200 || Response.status_code == 201)}; } CloudCacheResult @@ -215,7 +219,9 @@ CloudCacheSession::PutCompressedBlob(const IoHash& Key, IoBuffer Blob) cpr::Response Response = Session.Put(); ZEN_DEBUG("PUT {}", Response); - return {.Bytes = Response.uploaded_bytes, .ElapsedSeconds = Response.elapsed, .Success = (Response.status_code == 200 || Response.status_code == 201)}; + return {.Bytes = Response.uploaded_bytes, + .ElapsedSeconds = Response.elapsed, + .Success = (Response.status_code == 200 || Response.status_code == 201)}; } std::vector<IoHash> |