yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(db): check if OTP has mnesia_hook, otherwise fallback to mnesia 

Adds a check to `bin/emqx` to see if the OTP version being used has
support for `mnesia_hook`, which is required by Mria for using the
RLOG backend.  If OTP is not compatible and the user tries to use
RLOG, a warning is printed during startup and the configuration falls
back to using the Mnesia backend.
This commit is contained in:
Thales Macedo Garitezi 2022-04-11 10:34:02 -03:00
parent 72e16eb7d1
commit b5ac56ba50
No known key found for this signature in database
GPG Key ID: DD279F8152A9B6DD
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
bin/emqx
View File

@ -582,6 +582,12 @@ maybe_log_to_console() {
fi
}
# check if using an OTP version that has the mnesia_hook patch for use
# in mria.
is_otp_compatible() {
"$ERTS_DIR"/bin/erl -noshell -eval 'try mnesia_hook:module_info() of _ -> init:stop() catch _:_ -> init:stop(1) end.' 1>/dev/null 2>/dev/null
}
## IS_BOOT_COMMAND is set for later to inspect node name and cookie from hocon config (or env variable)
case "${COMMAND}" in
start|console|console_clean|foreground)
@ -652,6 +658,20 @@ if [ -z "$COOKIE" ]; then
die "Please set node.cookie in $EMQX_ETC_DIR/emqx.conf or override from environment variable EMQX_NODE__COOKIE"
fi
## check if OTP version has mnesia_hook patch; if not, fallback to
## using Mnesia DB backend.
if [[ "${EMQX_DB__BACKEND:-}" != "mnesia"
|| "${EMQX_DB__ROLE:-}" != "core" ]]; then
if [[ "$IS_BOOT_COMMAND" == 'yes'
&& "$(get_config_value 'db.backend')" == "rlog" ]]; then
if ! is_otp_compatible; then
echoerr "DB Backend is RLOG, but an incompatible OTP version has been detected. Falling back to using Mnesia DB backend."
export EMQX_DB__BACKEND=mnesia
export EMQX_DB__ROLE=core
fi
fi
fi
cd "$ROOTDIR"
case "${COMMAND}" in