summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--modules/database/db_sql.cpp8
-rw-r--r--src/init.cpp1
2 files changed, 8 insertions, 1 deletions
diff --git a/modules/database/db_sql.cpp b/modules/database/db_sql.cpp
index c02edd8aa..1964d136f 100644
--- a/modules/database/db_sql.cpp
+++ b/modules/database/db_sql.cpp
@@ -159,6 +159,14 @@ class DBSQL : public Module, public Pipe
this->import = block->Get<bool>("import");
}
+ void OnPostInit() anope_override
+ {
+ // If we are importing from flatfile we need to force a socket engine
+ // flush to ensure it actually gets written to the database before we
+ // connect to the uplink.
+ SocketEngine::Process();
+ }
+
void OnShutdown() anope_override
{
this->shutting_down = true;
diff --git a/src/init.cpp b/src/init.cpp
index e32bafb74..39d1033c6 100644
--- a/src/init.cpp
+++ b/src/init.cpp
@@ -556,7 +556,6 @@ void Anope::Init(int ac, char **av)
EventReturn MOD_RESULT;
FOREACH_RESULT(OnLoadDatabase, MOD_RESULT, ());
static_cast<void>(MOD_RESULT);
- SocketEngine::Process();
Log() << "Databases loaded";
FOREACH_MOD(OnPostInit, ());