Fixed code structure
This commit is contained in:
parent
ee5ada6991
commit
b99f5b576e
4 changed files with 26 additions and 22 deletions
|
@ -134,7 +134,7 @@ class Config {
|
||||||
$a->config[$family][$key] = $value;
|
$a->config[$family][$key] = $value;
|
||||||
|
|
||||||
// manage array value
|
// manage array value
|
||||||
$dbvalue = (is_array($value) ? serialize($value):$value);
|
$dbvalue = (is_array($value) ? serialize($value) : $value);
|
||||||
$dbvalue = (is_bool($dbvalue) ? intval($dbvalue) : $dbvalue);
|
$dbvalue = (is_bool($dbvalue) ? intval($dbvalue) : $dbvalue);
|
||||||
|
|
||||||
if (is_null($stored)) {
|
if (is_null($stored)) {
|
||||||
|
|
|
@ -69,15 +69,15 @@ function cron_run(&$argv, &$argc){
|
||||||
|
|
||||||
// run queue delivery process in the background
|
// run queue delivery process in the background
|
||||||
|
|
||||||
proc_run(PRIORITY_NEGLIGIBLE,"include/queue.php");
|
proc_run(PRIORITY_NEGLIGIBLE, "include/queue.php");
|
||||||
|
|
||||||
// run the process to discover global contacts in the background
|
// run the process to discover global contacts in the background
|
||||||
|
|
||||||
proc_run(PRIORITY_LOW,"include/discover_poco.php");
|
proc_run(PRIORITY_LOW, "include/discover_poco.php");
|
||||||
|
|
||||||
// run the process to update locally stored global contacts in the background
|
// run the process to update locally stored global contacts in the background
|
||||||
|
|
||||||
proc_run(PRIORITY_LOW,"include/discover_poco.php", "checkcontact");
|
proc_run(PRIORITY_LOW, "include/discover_poco.php", "checkcontact");
|
||||||
|
|
||||||
// Expire and remove user entries
|
// Expire and remove user entries
|
||||||
cron_expire_and_remove_users();
|
cron_expire_and_remove_users();
|
||||||
|
@ -120,19 +120,19 @@ function cron_run(&$argv, &$argc){
|
||||||
|
|
||||||
update_contact_birthdays();
|
update_contact_birthdays();
|
||||||
|
|
||||||
proc_run(PRIORITY_LOW,"include/discover_poco.php", "suggestions");
|
proc_run(PRIORITY_LOW, "include/discover_poco.php", "suggestions");
|
||||||
|
|
||||||
set_config('system','last_expire_day',$d2);
|
set_config('system','last_expire_day',$d2);
|
||||||
|
|
||||||
proc_run(PRIORITY_LOW,'include/expire.php');
|
proc_run(PRIORITY_LOW, 'include/expire.php');
|
||||||
|
|
||||||
if (get_config("system", "worker")) {
|
if (get_config("system", "worker")) {
|
||||||
proc_run(PRIORITY_LOW,'include/dbclean.php', 1);
|
proc_run(PRIORITY_LOW, 'include/dbclean.php', 1);
|
||||||
proc_run(PRIORITY_LOW,'include/dbclean.php', 2);
|
proc_run(PRIORITY_LOW, 'include/dbclean.php', 2);
|
||||||
proc_run(PRIORITY_LOW,'include/dbclean.php', 3);
|
proc_run(PRIORITY_LOW, 'include/dbclean.php', 3);
|
||||||
proc_run(PRIORITY_LOW,'include/dbclean.php', 4);
|
proc_run(PRIORITY_LOW, 'include/dbclean.php', 4);
|
||||||
} else {
|
} else {
|
||||||
proc_run(PRIORITY_LOW,'include/dbclean.php');
|
proc_run(PRIORITY_LOW, 'include/dbclean.php');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -315,7 +315,7 @@ function cron_poll_contacts($argc, $argv) {
|
||||||
|
|
||||||
logger("Polling ".$contact["network"]." ".$contact["id"]." ".$contact["nick"]." ".$contact["name"]);
|
logger("Polling ".$contact["network"]." ".$contact["id"]." ".$contact["nick"]." ".$contact["name"]);
|
||||||
|
|
||||||
proc_run(PRIORITY_MEDIUM,'include/onepoll.php',$contact['id']);
|
proc_run(PRIORITY_MEDIUM, 'include/onepoll.php', $contact['id']);
|
||||||
|
|
||||||
if($interval)
|
if($interval)
|
||||||
@time_sleep_until(microtime(true) + (float) $interval);
|
@time_sleep_until(microtime(true) + (float) $interval);
|
||||||
|
|
|
@ -34,7 +34,7 @@ class dba {
|
||||||
public $connected = false;
|
public $connected = false;
|
||||||
public $error = false;
|
public $error = false;
|
||||||
|
|
||||||
function __construct($server,$user,$pass,$db,$install = false) {
|
function __construct($server, $user, $pass, $db, $install = false) {
|
||||||
global $a;
|
global $a;
|
||||||
|
|
||||||
$stamp1 = microtime(true);
|
$stamp1 = microtime(true);
|
||||||
|
@ -80,9 +80,10 @@ class dba {
|
||||||
}
|
}
|
||||||
if (!$this->connected) {
|
if (!$this->connected) {
|
||||||
$this->db = null;
|
$this->db = null;
|
||||||
if (!$install)
|
if (!$install) {
|
||||||
system_unavailable();
|
system_unavailable();
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
$a->save_timestamp($stamp1, "network");
|
$a->save_timestamp($stamp1, "network");
|
||||||
}
|
}
|
||||||
|
@ -114,8 +115,9 @@ class dba {
|
||||||
* @return integer
|
* @return integer
|
||||||
*/
|
*/
|
||||||
public function num_rows() {
|
public function num_rows() {
|
||||||
if (!$this->result)
|
if (!$this->result) {
|
||||||
return 0;
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
if ($this->mysqli) {
|
if ($this->mysqli) {
|
||||||
$return = $this->result->num_rows;
|
$return = $this->result->num_rows;
|
||||||
|
@ -128,8 +130,9 @@ class dba {
|
||||||
public function q($sql, $onlyquery = false) {
|
public function q($sql, $onlyquery = false) {
|
||||||
global $a;
|
global $a;
|
||||||
|
|
||||||
if ((!$this->db) || (!$this->connected))
|
if (!$this->db || !$this->connected) {
|
||||||
return false;
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
$this->error = '';
|
$this->error = '';
|
||||||
|
|
||||||
|
@ -139,13 +142,13 @@ class dba {
|
||||||
} else {
|
} else {
|
||||||
$connected = mysql_ping($this->db);
|
$connected = mysql_ping($this->db);
|
||||||
}
|
}
|
||||||
$connstr = ($connected ? "Connected": "Disonnected");
|
$connstr = ($connected ? "Connected" : "Disonnected");
|
||||||
|
|
||||||
$stamp1 = microtime(true);
|
$stamp1 = microtime(true);
|
||||||
|
|
||||||
$orig_sql = $sql;
|
$orig_sql = $sql;
|
||||||
|
|
||||||
if (x($a->config,'system') && x($a->config['system'],'db_callstack')) {
|
if (x($a->config,'system') && x($a->config['system'], 'db_callstack')) {
|
||||||
$sql = "/*".$a->callstack()." */ ".$sql;
|
$sql = "/*".$a->callstack()." */ ".$sql;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -255,7 +258,7 @@ class dba {
|
||||||
public function qfetch() {
|
public function qfetch() {
|
||||||
$x = false;
|
$x = false;
|
||||||
|
|
||||||
if ($this->result)
|
if ($this->result) {
|
||||||
if ($this->mysqli) {
|
if ($this->mysqli) {
|
||||||
if ($this->result->num_rows)
|
if ($this->result->num_rows)
|
||||||
$x = $this->result->fetch_array(MYSQLI_ASSOC);
|
$x = $this->result->fetch_array(MYSQLI_ASSOC);
|
||||||
|
@ -263,18 +266,19 @@ class dba {
|
||||||
if (mysql_num_rows($this->result))
|
if (mysql_num_rows($this->result))
|
||||||
$x = mysql_fetch_array($this->result, MYSQL_ASSOC);
|
$x = mysql_fetch_array($this->result, MYSQL_ASSOC);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
return($x);
|
return($x);
|
||||||
}
|
}
|
||||||
|
|
||||||
public function qclose() {
|
public function qclose() {
|
||||||
if ($this->result)
|
if ($this->result) {
|
||||||
if ($this->mysqli) {
|
if ($this->mysqli) {
|
||||||
$this->result->free_result();
|
$this->result->free_result();
|
||||||
} else {
|
} else {
|
||||||
mysql_free_result($this->result);
|
mysql_free_result($this->result);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public function dbg($dbg) {
|
public function dbg($dbg) {
|
||||||
$this->debug = $dbg;
|
$this->debug = $dbg;
|
||||||
|
|
|
@ -810,7 +810,7 @@ class ostatus {
|
||||||
`item`.`verb`, `item`.`visible` FROM `term`
|
`item`.`verb`, `item`.`visible` FROM `term`
|
||||||
STRAIGHT_JOIN `item` AS `thritem` ON `thritem`.`parent` = `term`.`oid`
|
STRAIGHT_JOIN `item` AS `thritem` ON `thritem`.`parent` = `term`.`oid`
|
||||||
STRAIGHT_JOIN `item` ON `item`.`parent` = `thritem`.`parent`
|
STRAIGHT_JOIN `item` ON `item`.`parent` = `thritem`.`parent`
|
||||||
WHERE `term`.`uid` = %d AND `term`.`otype` = %d AND `term`.`type` = %d AND `term`.`url` = '%s'))",
|
WHERE `term`.`uid` = %d AND `term`.`otype` = %d AND `term`.`type` = %d AND `term`.`url` = '%s'",
|
||||||
intval($uid), intval(TERM_OBJ_POST), intval(TERM_CONVERSATION), dbesc($conversation_url));
|
intval($uid), intval(TERM_OBJ_POST), intval(TERM_CONVERSATION), dbesc($conversation_url));
|
||||||
|
|
||||||
/* 2016-10-23: The old query will be kept until we are sure that the query above is a good and fast replacement
|
/* 2016-10-23: The old query will be kept until we are sure that the query above is a good and fast replacement
|
||||||
|
|
Loading…
Reference in a new issue