diff options
| author | Carl Hetherington <cth@carlh.net> | 2023-07-07 17:20:54 +0200 |
|---|---|---|
| committer | Carl Hetherington <cth@carlh.net> | 2023-07-07 17:20:54 +0200 |
| commit | 0879896f0ca9d4f1922929ddd686c05786df9979 (patch) | |
| tree | 7598dbe652d8cfe7a97ca18ced22a7487cb3eceb | |
| parent | b30ac026d3923fb7925d5dad708dd46a177b0f70 (diff) | |
Rename some camelCase.
| -rw-r--r-- | src/lib/grok_context.h | 6 | ||||
| -rw-r--r-- | src/lib/grok_messenger.h | 46 |
2 files changed, 26 insertions, 26 deletions
diff --git a/src/lib/grok_context.h b/src/lib/grok_context.h index 2c826d42f..49f916158 100644 --- a/src/lib/grok_context.h +++ b/src/lib/grok_context.h @@ -70,7 +70,7 @@ struct GrokInitializer { GrokInitializer() { - setMessengerLogger(new GrokLogger("[GROK] ")); + set_messenger_logger(new GrokLogger("[GROK] ")); } ~GrokInitializer() = default; @@ -180,7 +180,7 @@ public: boost::filesystem::path folder(_dcpomatic_context.location); boost::filesystem::path binaryPath = folder / "grk_compress"; if (!boost::filesystem::exists(binaryPath)) { - getMessengerLogger()->error("Invalid binary location %s", + get_messenger_logger()->error("Invalid binary location %s", _dcpomatic_context.location.c_str()); return; } @@ -216,7 +216,7 @@ public: } } } catch (std::exception& ex) { - getMessengerLogger()->error("%s", ex.what()); + get_messenger_logger()->error("%s", ex.what()); } }; auto clientInit = diff --git a/src/lib/grok_messenger.h b/src/lib/grok_messenger.h index 69a6dda85..873233da4 100644 --- a/src/lib/grok_messenger.h +++ b/src/lib/grok_messenger.h @@ -133,7 +133,7 @@ static IMessengerLogger* sLogger = nullptr; #pragma GCC diagnostic ignored "-Wunused-function" #endif static void -setMessengerLogger(IMessengerLogger* logger) +set_messenger_logger(IMessengerLogger* logger) { delete sLogger; sLogger = logger; @@ -142,7 +142,7 @@ setMessengerLogger(IMessengerLogger* logger) #pragma GCC diagnostic pop #endif static IMessengerLogger* -getMessengerLogger() +get_messenger_logger() { return sLogger; } @@ -237,7 +237,7 @@ struct Synch auto sem = (dir == SYNCH_SENT ? sentSem_ : receiveReadySem_); int rc = sem_post(sem); if (rc) { - getMessengerLogger()->error("Error posting to semaphore: %s", strerror(errno)); + get_messenger_logger()->error("Error posting to semaphore: %s", strerror(errno)); } } @@ -246,7 +246,7 @@ struct Synch auto sem = dir == SYNCH_SENT ? sentSem_ : receiveReadySem_; int rc = sem_wait(sem); if (rc) { - getMessengerLogger()->error("Error waiting for semaphore: %s", strerror(errno)); + get_messenger_logger()->error("Error waiting for semaphore: %s", strerror(errno)); } } @@ -254,11 +254,11 @@ struct Synch { sentSem_ = sem_open(_sent_sem_name.c_str(), O_CREAT, 0666, 0); if (!sentSem_) { - getMessengerLogger()->error("Error opening shared memory: %s", strerror(errno)); + get_messenger_logger()->error("Error opening shared memory: %s", strerror(errno)); } receiveReadySem_ = sem_open(_receive_ready_sem_name.c_str(), O_CREAT, 0666, 1); if (!receiveReadySem_) { - getMessengerLogger()->error("Error opening shared memory: %s", strerror(errno)); + get_messenger_logger()->error("Error opening shared memory: %s", strerror(errno)); } } @@ -266,12 +266,12 @@ struct Synch { int rc = sem_close(sentSem_); if (rc) { - getMessengerLogger()->error("Error closing semaphore %s: %s", _sent_sem_name.c_str(), + get_messenger_logger()->error("Error closing semaphore %s: %s", _sent_sem_name.c_str(), strerror(errno)); } rc = sem_close(receiveReadySem_); if (rc) { - getMessengerLogger()->error("Error closing semaphore %s: %s", + get_messenger_logger()->error("Error closing semaphore %s: %s", _receive_ready_sem_name.c_str(), strerror(errno)); } } @@ -280,12 +280,12 @@ struct Synch { int rc = sem_unlink(_sent_sem_name.c_str()); if (rc == -1 && errno != ENOENT) { - getMessengerLogger()->error("Error unlinking semaphore %s: %s", _sent_sem_name.c_str(), + get_messenger_logger()->error("Error unlinking semaphore %s: %s", _sent_sem_name.c_str(), strerror(errno)); } rc = sem_unlink(_receive_ready_sem_name.c_str()); if (rc == -1 && errno != ENOENT) { - getMessengerLogger()->error("Error unlinking semaphore %s: %s", + get_messenger_logger()->error("Error unlinking semaphore %s: %s", _receive_ready_sem_name.c_str(), strerror(errno)); } } @@ -304,32 +304,32 @@ struct SharedMemoryManager { *shm_fd = shm_open(name.c_str(), O_CREAT | O_RDWR, 0666); if (*shm_fd < 0) { - getMessengerLogger()->error("Error opening shared memory: %s", strerror(errno)); + get_messenger_logger()->error("Error opening shared memory: %s", strerror(errno)); return false; } int rc = ftruncate(*shm_fd, sizeof(char) * len); if (rc) { - getMessengerLogger()->error("Error truncating shared memory: %s", strerror(errno)); + get_messenger_logger()->error("Error truncating shared memory: %s", strerror(errno)); rc = close(*shm_fd); if (rc) { - getMessengerLogger()->error("Error closing shared memory: %s", strerror(errno)); + get_messenger_logger()->error("Error closing shared memory: %s", strerror(errno)); } rc = shm_unlink(name.c_str()); if (rc) { - getMessengerLogger()->error("Error unlinking shared memory: %s", strerror(errno)); + get_messenger_logger()->error("Error unlinking shared memory: %s", strerror(errno)); } return false; } *buffer = static_cast<char*>(mmap(0, len, PROT_WRITE, MAP_SHARED, *shm_fd, 0)); if (!*buffer) { - getMessengerLogger()->error("Error mapping shared memory: %s", strerror(errno)); + get_messenger_logger()->error("Error mapping shared memory: %s", strerror(errno)); rc = close(*shm_fd); if (rc) { - getMessengerLogger()->error("Error closing shared memory: %s", strerror(errno)); + get_messenger_logger()->error("Error closing shared memory: %s", strerror(errno)); } rc = shm_unlink(name.c_str()); if (rc) { - getMessengerLogger()->error("Error unlinking shared memory: %s", strerror(errno)); + get_messenger_logger()->error("Error unlinking shared memory: %s", strerror(errno)); } } @@ -345,12 +345,12 @@ struct SharedMemoryManager int rc = munmap(*buffer, len); *buffer = nullptr; if (rc) { - getMessengerLogger()->error("Error unmapping shared memory %s: %s", name.c_str(), strerror(errno)); + get_messenger_logger()->error("Error unmapping shared memory %s: %s", name.c_str(), strerror(errno)); } rc = close(shm_fd); shm_fd = 0; if (rc) { - getMessengerLogger()->error("Error closing shared memory %s: %s", name.c_str(), strerror(errno)); + get_messenger_logger()->error("Error closing shared memory %s: %s", name.c_str(), strerror(errno)); } rc = shm_unlink(name.c_str()); if (rc) { @@ -816,7 +816,7 @@ private: // Change the working directory if (!dir.empty()) { if (chdir(dir.c_str()) != 0) { - getMessengerLogger()->error("Error: failed to change the working directory"); + get_messenger_logger()->error("Error: failed to change the working directory"); return; } } @@ -903,7 +903,7 @@ struct Msg std::string next() { if (ct_ == cs_.size()) { - getMessengerLogger()->error("Msg: comma separated list exhausted. returning empty."); + get_messenger_logger()->error("Msg: comma separated list exhausted. returning empty."); return ""; } return cs_[ct_++]; @@ -1056,10 +1056,10 @@ struct ScheduledMessenger : public Messenger send(GRK_MSGR_BATCH_SHUTDOWN); int result = async_result_.get(); if (result != 0) { - getMessengerLogger()->error("Accelerator failed with return code: %d\n", result); + get_messenger_logger()->error("Accelerator failed with return code: %d\n", result); } } catch (std::exception& ex) { - getMessengerLogger()->error("%s", ex.what()); + get_messenger_logger()->error("%s", ex.what()); } } |
