include.hpp 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
  1. /**
  2. * Copyright (c) 2019 Paul-Louis Ageneau
  3. *
  4. * This library is free software; you can redistribute it and/or
  5. * modify it under the terms of the GNU Lesser General Public
  6. * License as published by the Free Software Foundation; either
  7. * version 2.1 of the License, or (at your option) any later version.
  8. *
  9. * This library is distributed in the hope that it will be useful,
  10. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  12. * Lesser General Public License for more details.
  13. *
  14. * You should have received a copy of the GNU Lesser General Public
  15. * License along with this library; if not, write to the Free Software
  16. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  17. */
  18. #ifndef RTC_INCLUDE_H
  19. #define RTC_INCLUDE_H
  20. #ifdef _WIN32
  21. #ifndef _WIN32_WINNT
  22. #define _WIN32_WINNT 0x0602
  23. #endif
  24. #endif
  25. #include <cstddef>
  26. #include <functional>
  27. #include <memory>
  28. #include <mutex>
  29. #include <optional>
  30. #include <string>
  31. #include <vector>
  32. #include "plog/Appenders/ColorConsoleAppender.h"
  33. #include "plog/Log.h"
  34. namespace rtc {
  35. using std::byte;
  36. using std::string;
  37. using binary = std::vector<byte>;
  38. using std::nullopt;
  39. using std::size_t;
  40. using std::uint16_t;
  41. using std::uint32_t;
  42. using std::uint64_t;
  43. using std::uint8_t;
  44. // Constants
  45. const size_t MAX_NUMERICNODE_LEN = 48; // Max IPv6 string representation length
  46. const size_t MAX_NUMERICSERV_LEN = 6; // Max port string representation length
  47. const uint16_t DEFAULT_SCTP_PORT = 5000; // SCTP port to use by default
  48. const size_t DEFAULT_MAX_MESSAGE_SIZE = 65536; // Remote max message size if not specified in SDP
  49. const size_t LOCAL_MAX_MESSAGE_SIZE = 256 * 1024; // Local max message size
  50. // Log
  51. enum class LogLevel { // Don't change, it must match plog severity
  52. None = 0,
  53. Fatal = 1,
  54. Error = 2,
  55. Warning = 3,
  56. Info = 4,
  57. Debug = 5,
  58. Verbose = 6
  59. };
  60. inline void InitLogger(plog::Severity severity, plog::IAppender *appender = nullptr) {
  61. static plog::ColorConsoleAppender<plog::TxtFormatter> consoleAppender;
  62. if (!appender)
  63. appender = &consoleAppender;
  64. plog::init(severity, appender);
  65. PLOG_DEBUG << "Logger initialized";
  66. }
  67. inline void InitLogger(LogLevel level) { InitLogger(static_cast<plog::Severity>(level)); }
  68. // Utils
  69. template <class... Ts> struct overloaded : Ts... { using Ts::operator()...; };
  70. template <class... Ts> overloaded(Ts...)->overloaded<Ts...>;
  71. template <typename... P> class synchronized_callback {
  72. public:
  73. synchronized_callback() = default;
  74. ~synchronized_callback() { *this = nullptr; }
  75. synchronized_callback &operator=(std::function<void(P...)> func) {
  76. std::lock_guard lock(mutex);
  77. callback = func;
  78. return *this;
  79. }
  80. void operator()(P... args) const {
  81. std::lock_guard lock(mutex);
  82. if (callback)
  83. callback(args...);
  84. }
  85. operator bool() const { return callback ? true : false; }
  86. private:
  87. std::function<void(P...)> callback;
  88. mutable std::recursive_mutex mutex;
  89. };
  90. }
  91. #endif