GNUsocial/gnu-social
4
0
Fork 1
Code Issues Releases Wiki Activity

[DAEMONS] Move resetDb to the Daemon class

Browse Source 
As it is used inside the Daemon class now, it should always be available.
This commit is contained in:
Alexei Sorokin 2019-09-13 22:08:42 +03:00
parent 3ea580b537
commit 6bfa593988
2 changed files with 35 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
lib/util/daemon.php
View File

@ -41,6 +41,41 @@ class Daemon
$this->_id = $id;
}
/**
* Reconnect to the database for each child process,
* or they'll get very confused trying to use the
* same socket.
*/
protected function resetDb()
{
global $_DB_DATAOBJECT;
// Can't be called statically
$user = new User();
$conn = $user->getDatabaseConnection();
$conn->disconnect();
// Remove the disconnected connection from the list
foreach ($_DB_DATAOBJECT['CONNECTIONS'] as $k => $v) {
if ($v === $conn) {
unset($_DB_DATAOBJECT['CONNECTIONS'][$k]);
}
}
// Reconnect main memcached, or threads will stomp on
// each other and corrupt their requests.
$cache = Cache::instance();
if ($cache) {
$cache->reconnect();
}
// Also reconnect memcached for status_network table.
if (!empty(Status_network::$cache)) {
Status_network::$cache->close();
Status_network::$cache = null;
}
}
public function background()
{
// Database connection will likely get lost after forking

35
lib/util/spawningdaemon.php
View File

@ -189,41 +189,6 @@ abstract class SpawningDaemon extends Daemon
exit($exitCode);
}
/**
* Reconnect to the database for each child process,
* or they'll get very confused trying to use the
* same socket.
*/
protected function resetDb()
{
global $_DB_DATAOBJECT;
// Can't be called statically
$user = new User();
$conn = $user->getDatabaseConnection();
$conn->disconnect();
// Remove the disconnected connection from the list
foreach ($_DB_DATAOBJECT['CONNECTIONS'] as $k => $v) {
if ($v === $conn) {
unset($_DB_DATAOBJECT['CONNECTIONS'][$k]);
}
}
// Reconnect main memcached, or threads will stomp on
// each other and corrupt their requests.
$cache = Cache::instance();
if ($cache) {
$cache->reconnect();
}
// Also reconnect memcached for status_network table.
if (!empty(Status_network::$cache)) {
Status_network::$cache->close();
Status_network::$cache = null;
}
}
public function log($level, $msg)
{
common_log($level, get_class($this) . ' ('. $this->get_id() .'): '.$msg);