Skip to content

Move mutex.h header to public internal #792

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 7 commits into from
Dec 16, 2021
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions app/CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -227,6 +227,7 @@ set(internal_HDRS
src/include/firebase/future.h
src/include/firebase/internal/common.h
src/include/firebase/internal/future_impl.h
src/include/firebase/internal/mutex.h
src/include/firebase/internal/type_traits.h
src/include/firebase/log.h
src/include/firebase/util.h
Expand Down
96 changes: 96 additions & 0 deletions app/src/include/firebase/internal/mutex.h
Original file line number Diff line number Diff line change
@@ -0,0 +1,96 @@
/*
* Copyright 2016 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

#ifndef FIREBASE_APP_SRC_INCLUDE_FIREBASE_INTERNAL_MUTEX_H_
#define FIREBASE_APP_SRC_INCLUDE_FIREBASE_INTERNAL_MUTEX_H_

#include "firebase/internal/platform.h"

#if FIREBASE_PLATFORM_WINDOWS
#include <windows.h>
#else
#include <pthread.h>
#endif // FIREBASE_PLATFORM_WINDOWS

namespace firebase {

/// @brief A simple synchronization lock. Only one thread at a time can Acquire.
class Mutex {
public:
// Bitfield that describes the mutex configuration.
enum Mode {
kModeNonRecursive = (0 << 0),
kModeRecursive = (1 << 0),
};

Mutex() : Mutex(kModeRecursive) {}

explicit Mutex(Mode mode);

~Mutex();

// Acquires the lock for this mutex, blocking until it is available.
void Acquire();

// Releases the lock for this mutex acquired by a previous `Acquire()` call.
void Release();

// Returns the implementation-defined native mutex handle.
// Used by firebase::Thread implementation.
#if FIREBASE_PLATFORM_WINDOWS
HANDLE* native_handle() { return &synchronization_object_; }
#else
pthread_mutex_t* native_handle() { return &mutex_; }
#endif // FIREBASE_PLATFORM_WINDOWS

private:
Mutex(const Mutex&) = delete;
Mutex& operator=(const Mutex&) = delete;

#if FIREBASE_PLATFORM_WINDOWS
HANDLE synchronization_object_;
Mode mode_;
#else
pthread_mutex_t mutex_;
#endif // FIREBASE_PLATFORM_WINDOWS
};

/// @brief Acquire and hold a /ref Mutex, while in scope.
///
/// Example usage:
/// \code{.cpp}
/// Mutex syncronization_mutex;
/// void MyFunctionThatRequiresSynchronization() {
/// MutexLock lock(syncronization_mutex);
/// // ... logic ...
/// }
/// \endcode
class MutexLock {
public:
explicit MutexLock(Mutex& mutex) : mutex_(&mutex) { mutex_->Acquire(); }
~MutexLock() { mutex_->Release(); }

private:
// Copy is disallowed.
MutexLock(const MutexLock& rhs); // NOLINT
MutexLock& operator=(const MutexLock& rhs);

Mutex* mutex_;
};

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

📝 Documentation issue: [10 lines up] warning: Member MutexLock(Mutex &mutex) (function) of class firebase::MutexLock is not documented.

} // namespace firebase

#endif // FIREBASE_APP_SRC_INCLUDE_FIREBASE_INTERNAL_MUTEX_H_
76 changes: 1 addition & 75 deletions app/src/mutex.h
Original file line number Diff line number Diff line change
Expand Up @@ -17,80 +17,6 @@
#ifndef FIREBASE_APP_SRC_MUTEX_H_
#define FIREBASE_APP_SRC_MUTEX_H_

#include "app/src/include/firebase/internal/platform.h"

#if FIREBASE_PLATFORM_WINDOWS
#include <windows.h>
#else
#include <pthread.h>
#endif // FIREBASE_PLATFORM_WINDOWS

namespace firebase {

/// @brief A simple synchronization lock. Only one thread at a time can Acquire.
class Mutex {
public:
// Bitfield that describes the mutex configuration.
enum Mode {
kModeNonRecursive = (0 << 0),
kModeRecursive = (1 << 0),
};

Mutex() : Mutex(kModeRecursive) {}

explicit Mutex(Mode mode);

~Mutex();

// Acquires the lock for this mutex, blocking until it is available.
void Acquire();

// Releases the lock for this mutex acquired by a previous `Acquire()` call.
void Release();

// Returns the implementation-defined native mutex handle.
// Used by firebase::Thread implementation.
#if FIREBASE_PLATFORM_WINDOWS
HANDLE* native_handle() { return &synchronization_object_; }
#else
pthread_mutex_t* native_handle() { return &mutex_; }
#endif // FIREBASE_PLATFORM_WINDOWS

private:
Mutex(const Mutex&) = delete;
Mutex& operator=(const Mutex&) = delete;

#if FIREBASE_PLATFORM_WINDOWS
HANDLE synchronization_object_;
Mode mode_;
#else
pthread_mutex_t mutex_;
#endif // FIREBASE_PLATFORM_WINDOWS
};

/// @brief Acquire and hold a /ref Mutex, while in scope.
///
/// Example usage:
/// \code{.cpp}
/// Mutex syncronization_mutex;
/// void MyFunctionThatRequiresSynchronization() {
/// MutexLock lock(syncronization_mutex);
/// // ... logic ...
/// }
/// \endcode
class MutexLock {
public:
explicit MutexLock(Mutex& mutex) : mutex_(&mutex) { mutex_->Acquire(); }
~MutexLock() { mutex_->Release(); }

private:
// Copy is disallowed.
MutexLock(const MutexLock& rhs); // NOLINT
MutexLock& operator=(const MutexLock& rhs);

Mutex* mutex_;
};

} // namespace firebase
#include "app/src/include/firebase/internal/mutex.h"

#endif // FIREBASE_APP_SRC_MUTEX_H_
2 changes: 1 addition & 1 deletion docs/Doxyfile
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ REFERENCES_LINK_SOURCE = NO
EXTRACT_STATIC = YES # Required for constant headers in firebase/analytics.

ENABLED_SECTIONS=cpp_examples
EXCLUDE_SYMBOLS = internal
EXCLUDE = app/src/include/firebase/internal

#WARN_IF_UNDOCUMENTED = YES
WARN_IF_DOC_ERROR = YES
Expand Down
1 change: 1 addition & 0 deletions testing/CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -148,6 +148,7 @@ target_include_directories(firebase_testing
${FLATBUFFERS_SOURCE_DIR}/include
PRIVATE
${FIREBASE_CPP_SDK_ROOT_DIR}
${FIREBASE_CPP_SDK_ROOT_DIR}/app/src/include
${FIREBASE_GEN_FILE_DIR}
)

Expand Down