summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCarl Hetherington <cth@carlh.net>2023-07-07 17:20:54 +0200
committerCarl Hetherington <cth@carlh.net>2023-07-07 17:20:54 +0200
commit0879896f0ca9d4f1922929ddd686c05786df9979 (patch)
tree7598dbe652d8cfe7a97ca18ced22a7487cb3eceb
parentb30ac026d3923fb7925d5dad708dd46a177b0f70 (diff)
Rename some camelCase.
-rw-r--r--src/lib/grok_context.h6
-rw-r--r--src/lib/grok_messenger.h46
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());
}
}