* This script is started from mod/item.php to save some time when doing a post.
*/
-use \Friendica\Core\Config;
-
-require_once("boot.php");
require_once("include/threads.php");
function create_shadowentry_run($argv, $argc) {
- global $a, $db;
-
- if (is_null($a))
- $a = new App;
-
- if (is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- }
-
- Config::load();
-
if ($argc != 2) {
return;
}
add_shadow_entry($message_id);
}
-
-if (array_search(__file__,get_included_files())===0){
- create_shadowentry_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
?>
<?php
-if (!file_exists("boot.php") AND (sizeof($_SERVER["argv"]) != 0)) {
- $directory = dirname($_SERVER["argv"][0]);
-
- if (substr($directory, 0, 1) != "/")
- $directory = $_SERVER["PWD"]."/".$directory;
-
- $directory = realpath($directory."/..");
-
- chdir($directory);
-}
-
use \Friendica\Core\Config;
-require_once("boot.php");
require_once("include/photos.php");
require_once("include/user.php");
-
function cron_run(&$argv, &$argc){
- global $a, $db;
-
- if(is_null($a)) {
- $a = new App;
- }
-
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
+ global $a;
require_once('include/session.php');
require_once('include/datetime.php');
require_once('mod/nodeinfo.php');
require_once('include/post_update.php');
- Config::load();
-
- // Don't check this stuff if the function is called by the poller
- if (App::callstack() != "poller_run") {
- if ($a->maxload_reached())
- return;
- if (App::is_already_running('cron', 'include/cron.php', 540))
- return;
- }
-
$last = get_config('system','last_cron');
$poll_interval = intval(get_config('system','cron_interval'));
}
}
- $a->set_baseurl(get_config('system','url'));
-
- load_hooks();
-
logger('cron: start');
// run queue delivery process in the background
// Expire and remove user entries
cron_expire_and_remove_users();
- // If the worker is active, split the jobs in several sub processes
- if (get_config("system", "worker")) {
- // Check OStatus conversations
- proc_run(PRIORITY_MEDIUM, "include/cronjobs.php", "ostatus_mentions");
-
- // Check every conversation
- proc_run(PRIORITY_MEDIUM, "include/cronjobs.php", "ostatus_conversations");
-
- // Call possible post update functions
- proc_run(PRIORITY_LOW, "include/cronjobs.php", "post_update");
-
- // update nodeinfo data
- proc_run(PRIORITY_LOW, "include/cronjobs.php", "nodeinfo");
- } else {
- // Check OStatus conversations
- // Check only conversations with mentions (for a longer time)
- ostatus::check_conversations(true);
+ // Check OStatus conversations
+ proc_run(PRIORITY_MEDIUM, "include/cronjobs.php", "ostatus_mentions");
- // Check every conversation
- ostatus::check_conversations(false);
+ // Check every conversation
+ proc_run(PRIORITY_MEDIUM, "include/cronjobs.php", "ostatus_conversations");
- // Call possible post update functions
- // see include/post_update.php for more details
- post_update();
+ // Call possible post update functions
+ proc_run(PRIORITY_LOW, "include/cronjobs.php", "post_update");
- // update nodeinfo data
- nodeinfo_cron();
- }
+ // update nodeinfo data
+ proc_run(PRIORITY_LOW, "include/cronjobs.php", "nodeinfo");
// once daily run birthday_updates and then expire in background
$force = true;
}
- $interval = intval(get_config('system','poll_interval'));
- if (!$interval)
- $interval = ((get_config('system','delivery_interval') === false) ? 3 : intval(get_config('system','delivery_interval')));
-
- // If we are using the worker we don't need a delivery interval
- if (get_config("system", "worker"))
- $interval = false;
-
$sql_extra = (($manual_id) ? " AND `id` = $manual_id " : "");
reload_plugins();
} else {
proc_run(PRIORITY_LOW, 'include/onepoll.php', $contact['id']);
}
-
- if($interval)
- @time_sleep_until(microtime(true) + (float) $interval);
}
}
}
/// - remove children when parent got lost
/// - set contact-id in item when not present
}
-
-if (array_search(__file__,get_included_files())===0){
- cron_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
use \Friendica\Core\Config;
-require_once("boot.php");
-
function cronhooks_run(&$argv, &$argc){
- global $a, $db;
-
- if(is_null($a)) {
- $a = new App;
- }
-
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
+ global $a;
- require_once('include/session.php');
require_once('include/datetime.php');
- Config::load();
-
- // Don't check this stuff if the function is called by the poller
- if (App::callstack() != "poller_run") {
- if ($a->maxload_reached())
- return;
- if (App::is_already_running('cronhooks', 'include/cronhooks.php', 1140))
- return;
- }
-
- load_hooks();
-
if (($argc == 2) AND is_array($a->hooks) AND array_key_exists("cron", $a->hooks)) {
foreach ($a->hooks["cron"] as $hook)
if ($hook[1] == $argv[1]) {
$d = datetime_convert();
- if (get_config("system", "worker") AND is_array($a->hooks) AND array_key_exists("cron", $a->hooks)) {
+ if (is_array($a->hooks) AND array_key_exists("cron", $a->hooks)) {
foreach ($a->hooks["cron"] as $hook) {
logger("Calling cronhooks for '".$hook[1]."'", LOGGER_DEBUG);
proc_run(PRIORITY_MEDIUM, "include/cronhooks.php", $hook[1]);
}
- } else
- call_hooks('cron', $d);
+ }
logger('cronhooks: end');
return;
}
-
-if (array_search(__file__,get_included_files())===0){
- cronhooks_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
<?php
use \Friendica\Core\Config;
-if (!file_exists("boot.php") AND (sizeof($_SERVER["argv"]) != 0)) {
- $directory = dirname($_SERVER["argv"][0]);
-
- if (substr($directory, 0, 1) != "/")
- $directory = $_SERVER["PWD"]."/".$directory;
-
- $directory = realpath($directory."/..");
-
- chdir($directory);
-}
-
-require_once("boot.php");
-
-
function cronjobs_run(&$argv, &$argc){
- global $a, $db;
+ global $a;
- if(is_null($a)) {
- $a = new App;
- }
-
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
-
- require_once('include/session.php');
require_once('include/datetime.php');
require_once('include/ostatus.php');
require_once('include/post_update.php');
require_once('mod/nodeinfo.php');
- Config::load();
-
- $a->set_baseurl(get_config('system','url'));
-
// No parameter set? So return
if ($argc <= 1)
return;
return;
}
-
-if (array_search(__file__,get_included_files())===0){
- cronjobs_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
*/
use \Friendica\Core\Config;
-use \Friendica\Core\PConfig;
-
-require_once("boot.php");
function dbclean_run(&$argv, &$argc) {
- global $a, $db;
-
- if (is_null($a)) {
- $a = new App;
- }
-
- if (is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- }
-
- Config::load();
-
if (!Config::get('system', 'dbclean', false)) {
return;
}
$stage = 0;
}
- if (Config::get("system", "worker") AND ($stage == 0)) {
+ if ($stage == 0) {
proc_run(PRIORITY_LOW, 'include/dbclean.php', 1);
proc_run(PRIORITY_LOW, 'include/dbclean.php', 2);
proc_run(PRIORITY_LOW, 'include/dbclean.php', 3);
$count = 0;
- // With activated worker we split the deletion in many small tasks
- if (Config::get("system", "worker")) {
- $limit = 1000;
- } else {
- $limit = 10000;
- }
+ // We split the deletion in many small tasks
+ $limit = 1000;
if (($stage == 1) OR ($stage == 0)) {
logger("Deleting old global item entries from item table without user copy");
}
// Call it again if not all entries were purged
- if (($stage != 0) AND ($count > 0) AND Config::get("system", "worker")) {
+ if (($stage != 0) AND ($count > 0)) {
proc_run(PRIORITY_MEDIUM, 'include/dbclean.php');
}
}
-
-if (array_search(__file__,get_included_files())===0){
- dbclean_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
?>
use \Friendica\Core\Config;
-require_once("boot.php");
-
function dbupdate_run(&$argv, &$argc) {
- global $a, $db;
-
- if(is_null($a)){
- $a = new App;
- }
-
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- }
-
- Config::load();
+ global $a;
// We are deleting the latest dbupdate entry.
// This is done to avoid endless loops because the update was interupted.
update_db($a);
}
-
-if (array_search(__file__,get_included_files())===0){
- dbupdate_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
use \Friendica\Core\Config;
-require_once("boot.php");
require_once('include/queue_fn.php');
require_once('include/html2plain.php');
require_once("include/Scrape.php");
require_once("include/dfrn.php");
function delivery_run(&$argv, &$argc){
- global $a, $db;
+ global $a;
- if (is_null($a)) {
- $a = new App;
- }
-
- if (is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- }
-
- require_once("include/session.php");
require_once("include/datetime.php");
require_once('include/items.php');
require_once('include/bbcode.php');
require_once('include/email.php');
- Config::load();
-
- load_hooks();
-
if ($argc < 3) {
return;
}
- $a->set_baseurl(get_config('system','url'));
-
logger('delivery: invoked: '. print_r($argv,true), LOGGER_DEBUG);
$cmd = $argv[1];
return;
}
-
-if (array_search(__file__,get_included_files())===0){
- delivery_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
<?php
-require_once("boot.php");
-
use \Friendica\Core\Config;
function directory_run(&$argv, &$argc){
- global $a, $db;
-
- if(is_null($a)) {
- $a = new App;
- }
-
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
-
- Config::load();
-
- if($argc != 2)
+ if ($argc != 2) {
return;
-
- load_hooks();
-
-
- $a->set_baseurl(get_config('system','url'));
+ }
$dir = get_config('system','directory');
- if(! strlen($dir))
+ if (!strlen($dir)) {
return;
+ }
$dir .= "/submit";
call_hooks('globaldir_update', $arr);
logger('Updating directory: ' . $arr['url'], LOGGER_DEBUG);
- if(strlen($arr['url']))
+ if (strlen($arr['url'])) {
fetch_url($dir . '?url=' . bin2hex($arr['url']));
-
+ }
return;
}
-
-if (array_search(__file__,get_included_files())===0){
- directory_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
use \Friendica\Core\Config;
-require_once("boot.php");
require_once("include/socgraph.php");
+require_once('include/datetime.php');
function discover_poco_run(&$argv, &$argc){
- global $a, $db;
- if(is_null($a)) {
- $a = new App;
- }
-
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
-
- require_once('include/session.php');
- require_once('include/datetime.php');
-
- Config::load();
-
- // Don't check this stuff if the function is called by the poller
- if (App::callstack() != "poller_run")
- if ($a->maxload_reached())
- return;
-
- if(($argc > 2) && ($argv[1] == "dirsearch")) {
+ if (($argc > 2) && ($argv[1] == "dirsearch")) {
$search = urldecode($argv[2]);
$mode = 1;
} elseif(($argc == 2) && ($argv[1] == "checkcontact")) {
} else
die("Unknown or missing parameter ".$argv[1]."\n");
- // Don't check this stuff if the function is called by the poller
- if (App::callstack() != "poller_run")
- if (App::is_already_running('discover_poco'.$mode.urlencode($search), 'include/discover_poco.php', 1140))
- return;
-
- $a->set_baseurl(get_config('system','url'));
-
- load_hooks();
-
logger('start '.$search);
if ($mode==3)
}
}
}
-
-
-if (array_search(__file__,get_included_files())===0){
- discover_poco_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
use \Friendica\Core\Config;
-require_once("boot.php");
-
function expire_run(&$argv, &$argc){
- global $a, $db;
-
- if(is_null($a)) {
- $a = new App;
- }
+ global $a;
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
-
- require_once('include/session.php');
require_once('include/datetime.php');
require_once('include/items.php');
require_once('include/Contact.php');
- Config::load();
-
- $a->set_baseurl(get_config('system','url'));
-
-
// physically remove anything that has been deleted for more than two months
$r = q("delete from item where deleted = 1 and changed < UTC_TIMESTAMP() - INTERVAL 60 DAY");
return;
}
-
-if (array_search(__file__,get_included_files())===0){
- expire_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
use \Friendica\Core\Config;
-require_once("boot.php");
require_once('include/Scrape.php');
require_once('include/socgraph.php');
+require_once('include/datetime.php');
function gprobe_run(&$argv, &$argc){
- global $a, $db;
-
- if(is_null($a)) {
- $a = new App;
- }
-
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
-
- require_once('include/session.php');
- require_once('include/datetime.php');
-
- Config::load();
-
- $a->set_baseurl(get_config('system','url'));
-
- load_hooks();
-
if($argc != 2)
return;
logger("gprobe end for ".normalise_link($url), LOGGER_DEBUG);
return;
}
-
-if (array_search(__file__,get_included_files())===0){
- gprobe_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
use \Friendica\Core\Config;
-require_once("boot.php");
require_once('include/queue_fn.php');
require_once('include/html2plain.php');
require_once("include/Scrape.php");
function notifier_run(&$argv, &$argc){
- global $a, $db;
+ global $a;
- if (is_null($a)) {
- $a = new App;
- }
-
- if (is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- }
-
- require_once("include/session.php");
require_once("include/datetime.php");
require_once('include/items.php');
require_once('include/bbcode.php');
require_once('include/email.php');
- Config::load();
-
- load_hooks();
-
if ($argc < 3) {
return;
}
- $a->set_baseurl(get_config('system','url'));
-
logger('notifier: invoked: ' . print_r($argv,true), LOGGER_DEBUG);
$cmd = $argv[1];
);
}
- $interval = ((get_config('system','delivery_interval') === false) ? 2 : intval(get_config('system','delivery_interval')));
-
- // If we are using the worker we don't need a delivery interval
- if (get_config("system", "worker")) {
- $interval = false;
- }
// delivery loop
if (dbm::is_result($r)) {
}
}
-
- // This controls the number of deliveries to execute with each separate delivery process.
- // By default we'll perform one delivery per process. Assuming a hostile shared hosting
- // provider, this provides the greatest chance of deliveries if processes start getting
- // killed. We can also space them out with the delivery_interval to also help avoid them
- // getting whacked.
-
- // If $deliveries_per_process > 1, we will chain this number of multiple deliveries
- // together into a single process. This will reduce the overall number of processes
- // spawned for each delivery, but they will run longer.
-
- // When using the workerqueue, we don't need this functionality.
-
- $deliveries_per_process = intval(get_config('system','delivery_batch_count'));
- if (($deliveries_per_process <= 0) OR get_config("system", "worker")) {
- $deliveries_per_process = 1;
- }
-
- $this_batch = array();
-
for ($x = 0; $x < count($r); $x ++) {
$contact = $r[$x];
}
logger("Deliver ".$target_item["guid"]." to ".$contact['url']." via network ".$contact['network'], LOGGER_DEBUG);
- // potentially more than one recipient. Start a new process and space them out a bit.
- // we will deliver single recipient types of message and email recipients here.
-
- $this_batch[] = $contact['id'];
-
- if (count($this_batch) >= $deliveries_per_process) {
- proc_run(PRIORITY_HIGH,'include/delivery.php',$cmd,$item_id,$this_batch);
- $this_batch = array();
- if ($interval) {
- @time_sleep_until(microtime(true) + (float) $interval);
- }
- }
+ proc_run(PRIORITY_HIGH,'include/delivery.php', $cmd, $item_id, $contact['id']);
continue;
}
-
- // be sure to pick up any stragglers
- if (count($this_batch)) {
- proc_run(PRIORITY_HIGH,'include/delivery.php',$cmd,$item_id,$this_batch);
- }
}
// send salmon slaps to mentioned remote tags (@foo@example.com) in OStatus posts
if ((! $mail) && (! $fsuggest) && (! $followup)) {
logger('notifier: delivery agent: '.$rr['name'].' '.$rr['id'].' '.$rr['network'].' '.$target_item["guid"]);
proc_run(PRIORITY_HIGH,'include/delivery.php',$cmd,$item_id,$rr['id']);
- if ($interval) {
- @time_sleep_until(microtime(true) + (float) $interval);
- }
}
}
}
return;
}
-
-
-if (array_search(__file__,get_included_files())===0){
- notifier_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
use \Friendica\Core\Config;
-require_once("boot.php");
require_once("include/follow.php");
function RemoveReply($subject) {
}
function onepoll_run(&$argv, &$argc){
- global $a, $db;
+ global $a;
- if(is_null($a)) {
- $a = new App;
- }
-
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
-
- require_once('include/session.php');
require_once('include/datetime.php');
require_once('include/items.php');
require_once('include/Contact.php');
require_once('include/socgraph.php');
require_once('include/queue_fn.php');
- Config::load();
-
- $a->set_baseurl(get_config('system','url'));
-
- load_hooks();
-
logger('onepoll: start');
$manual_id = 0;
return;
}
- // Don't check this stuff if the function is called by the poller
- if (App::callstack() != "poller_run")
- if (App::is_already_running('onepoll'.$contact_id, '', 540))
- return;
-
$d = datetime_convert();
// Only poll from those with suitable relationships,
return;
}
-
-if (array_search(__file__,get_included_files())===0){
- onepoll_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
return;
}
+ $a->set_baseurl(Config::get('system', 'url'));
+
+ load_hooks();
+
$a->start_process();
if (poller_max_connections_reached()) {
* @brief Call the front end worker
*/
function call_worker() {
- if (!Config::get("system", "frontend_worker") OR !Config::get("system", "worker")) {
+ if (!Config::get("system", "frontend_worker")) {
return;
}
* @brief Call the front end worker if there aren't any active
*/
function call_worker_if_idle() {
- if (!Config::get("system", "frontend_worker") OR !Config::get("system", "worker")) {
+ if (!Config::get("system", "frontend_worker")) {
return;
}
<?php
-require_once("boot.php");
+use \Friendica\Core\Config;
+
+require_once('include/items.php');
require_once("include/ostatus.php");
-use \Friendica\Core\Config;
-use \Friendica\Core\PConfig;
+function pubsubpublish_run(&$argv, &$argc){
+
+ if ($argc > 1) {
+ $pubsubpublish_id = intval($argv[1]);
+ } else {
+ // We'll push to each subscriber that has push > 0,
+ // i.e. there has been an update (set in notifier.php).
+ $r = q("SELECT `id`, `callback_url` FROM `push_subscriber` WHERE `push` > 0");
+
+ foreach ($r as $rr) {
+ logger("Publish feed to ".$rr["callback_url"], LOGGER_DEBUG);
+ proc_run(PRIORITY_HIGH, 'include/pubsubpublish.php', $rr["id"]);
+ }
+ }
+
+ handle_pubsubhubbub($pubsubpublish_id);
+
+ return;
+}
function handle_pubsubhubbub($id) {
- global $a, $db;
+ global $a;
$r = q("SELECT * FROM `push_subscriber` WHERE `id` = %d", intval($id));
if (!$r)
intval($rr['id']));
}
}
-
-
-function pubsubpublish_run(&$argv, &$argc){
- global $a, $db;
-
- if(is_null($a)){
- $a = new App;
- }
-
- if(is_null($db)){
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
-
- require_once('include/items.php');
-
- Config::load();
-
- // Don't check this stuff if the function is called by the poller
- if (App::callstack() != "poller_run") {
- if (App::is_already_running("pubsubpublish", "include/pubsubpublish.php", 540)) {
- return;
- }
- }
-
- $a->set_baseurl(get_config('system','url'));
-
- load_hooks();
-
- if ($argc > 1) {
- $pubsubpublish_id = intval($argv[1]);
- }
- else {
- // We'll push to each subscriber that has push > 0,
- // i.e. there has been an update (set in notifier.php).
- $r = q("SELECT `id`, `callback_url` FROM `push_subscriber` WHERE `push` > 0");
-
- // Use the delivery interval that is also used for the notifier
- $interval = Config::get("system", "delivery_interval", 2);
-
- // If we are using the worker we don't need a delivery interval
- if (get_config("system", "worker")) {
- $interval = false;
- }
-
- foreach ($r as $rr) {
- logger("Publish feed to ".$rr["callback_url"], LOGGER_DEBUG);
- proc_run(PRIORITY_HIGH, 'include/pubsubpublish.php', $rr["id"]);
-
- if($interval)
- @time_sleep_until(microtime(true) + (float) $interval);
- }
- }
-
- handle_pubsubhubbub($pubsubpublish_id);
-
- return;
-
-}
-
-if (array_search(__file__,get_included_files())===0){
- pubsubpublish_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
-
<?php
+/// @todo Rework the whole file to a single item processing
+
use \Friendica\Core\Config;
-require_once("boot.php");
require_once('include/queue_fn.php');
require_once('include/dfrn.php');
+require_once("include/datetime.php");
+require_once('include/items.php');
+require_once('include/bbcode.php');
+require_once('include/socgraph.php');
function queue_run(&$argv, &$argc){
- global $a, $db;
-
- if(is_null($a)){
- $a = new App;
- }
-
- if(is_null($db)){
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
-
- require_once("include/session.php");
- require_once("include/datetime.php");
- require_once('include/items.php');
- require_once('include/bbcode.php');
- require_once('include/socgraph.php');
-
- Config::load();
-
- // Don't check this stuff if the function is called by the poller
- if (App::callstack() != "poller_run")
- if (App::is_already_running('queue', 'include/queue.php', 540))
- return;
-
- $a->set_baseurl(get_config('system','url'));
-
- load_hooks();
+ global $a;
if($argc > 1)
$queue_id = intval($argv[1]);
// Handling the pubsubhubbub requests
proc_run(PRIORITY_HIGH,'include/pubsubpublish.php');
- $interval = ((get_config('system','delivery_interval') === false) ? 2 : intval(get_config('system','delivery_interval')));
-
- // If we are using the worker we don't need a delivery interval
- if (get_config("system", "worker"))
- $interval = false;
-
$r = q("select * from deliverq where 1");
if ($r) {
foreach ($r as $rr) {
logger('queue: deliverq');
proc_run(PRIORITY_HIGH,'include/delivery.php',$rr['cmd'],$rr['item'],$rr['contact']);
- if($interval) {
- time_sleep_until(microtime(true) + (float) $interval);
- }
}
}
// queue_predeliver hooks may have changed the queue db details,
// so check again if this entry still needs processing
- if($queue_id)
+ if ($queue_id) {
$qi = q("SELECT * FROM `queue` WHERE `id` = %d LIMIT 1",
intval($queue_id));
- elseif (get_config("system", "worker")) {
+ } else {
logger('Call queue for id '.$q_item['id']);
proc_run(PRIORITY_LOW, "include/queue.php", $q_item['id']);
continue;
- } else
- $qi = q("SELECT * FROM `queue` WHERE `id` = %d AND `last` < UTC_TIMESTAMP() - INTERVAL 15 MINUTE ",
- intval($q_item['id']));
+ }
if(! count($qi))
continue;
}
return;
-
-}
-
-if (array_search(__file__,get_included_files())===0){
- queue_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
}
use \Friendica\Core\Config;
-require_once("boot.php");
-
function remove_contact_run($argv, $argc) {
- global $a, $db;
-
- if (is_null($a)) {
- $a = new App;
- }
-
- if (is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- }
-
- Config::load();
-
if ($argc != 2) {
return;
}
q("DELETE FROM `queue` WHERE `cid` = %d", intval($id));
}
-
-if (array_search(__file__, get_included_files()) === 0) {
- remove_contact_run($_SERVER["argv"], $_SERVER["argc"]);
- killme();
-}
?>
require_once("boot.php");
require_once("include/threads.php");
-global $a, $db;
+function shadowupdate_run(&$argv, &$argc){
+ global $a, $db;
-if(is_null($a))
- $a = new App;
+ if (is_null($a)) {
+ $a = new App;
+ }
-if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
-}
+ if (is_null($db)) {
+ @include(".htconfig.php");
+ require_once("include/dba.php");
+ $db = new dba($db_host, $db_user, $db_pass, $db_data);
+ unset($db_host, $db_user, $db_pass, $db_data);
+ }
+
+ Config::load();
-Config::load();
+ update_shadow_copy();
+}
-update_shadow_copy();
-killme();
-?>
+if (array_search(__file__,get_included_files())===0){
+ shadowupdate_run($_SERVER["argv"],$_SERVER["argc"]);
+ killme();
+}
use \Friendica\Core\Config;
-require_once("boot.php");
require_once("include/items.php");
function spool_post_run($argv, $argc) {
- global $a, $db;
-
- if (is_null($a)) {
- $a = new App;
- }
-
- if (is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- }
-
- Config::load();
+ global $a;
$path = get_spoolpath();
}
}
}
-
-if (array_search(__file__, get_included_files()) === 0) {
- spool_post_run($_SERVER["argv"], $_SERVER["argc"]);
- killme();
-}
?>
<?php
-
-use \Friendica\Core\Config;
-
-require_once("boot.php");
require_once("include/tags.php");
-global $a, $db;
-
-if(is_null($a))
- $a = new App;
-
-if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
+function tagupdate_run(&$argv, &$argc){
+ update_items();
}
-
-Config::load();
-
-update_items();
-killme();
-?>
<?php
-
-use \Friendica\Core\Config;
-
-require_once("boot.php");
require_once("include/threads.php");
-global $a, $db;
-
-if(is_null($a))
- $a = new App;
-
-if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
+function threadupdate_run(&$argv, &$argc){
+ update_threads();
+ update_threads_mention();
}
-
-Config::load();
-
-update_threads();
-update_threads_mention();
-killme();
-?>
use \Friendica\Core\Config;
-require_once("boot.php");
-
function update_gcontact_run(&$argv, &$argc){
- global $a, $db;
-
- if(is_null($a)) {
- $a = new App;
- }
-
- if(is_null($db)) {
- @include(".htconfig.php");
- require_once("include/dba.php");
- $db = new dba($db_host, $db_user, $db_pass, $db_data);
- unset($db_host, $db_user, $db_pass, $db_data);
- };
+ global $a;
require_once('include/Scrape.php');
require_once("include/socgraph.php");
- Config::load();
-
- $a->set_baseurl(get_config('system','url'));
-
- load_hooks();
-
logger('update_gcontact: start');
if(($argc > 1) && (intval($argv[1])))
return;
}
- // Don't check this stuff if the function is called by the poller
- if (App::callstack() != "poller_run")
- if (App::is_already_running('update_gcontact'.$contact_id, '', 540))
- return;
-
$r = q("SELECT * FROM `gcontact` WHERE `id` = %d", intval($contact_id));
if (!$r)
dbesc(normalise_link($data["url"]))
);
}
-
-if (array_search(__file__,get_included_files())===0){
- update_gcontact_run($_SERVER["argv"],$_SERVER["argc"]);
- killme();
-}
function worker_init($a){
- if (!Config::get("system", "frontend_worker") OR !Config::get("system", "worker")) {
+ if (!Config::get("system", "frontend_worker")) {
return;
}
{{include file="field_input.tpl" field=$proxy}}
{{include file="field_input.tpl" field=$proxyuser}}
{{include file="field_input.tpl" field=$timeout}}
- {{if NOT $worker.2}}
- {{include file="field_input.tpl" field=$delivery_interval}}
- {{include file="field_input.tpl" field=$poll_interval}}
- {{/if}}
{{include file="field_input.tpl" field=$maxloadavg}}
{{include file="field_input.tpl" field=$maxloadavg_frontend}}
{{include file="field_input.tpl" field=$optimize_max_tablesize}}
<div class="submit"><input type="submit" name="page_site" value="{{$submit|escape:'html'}}" /></div>
<h3>{{$worker_title}}</h3>
- {{include file="field_checkbox.tpl" field=$worker}}
- {{if $worker.2}}
- {{include file="field_input.tpl" field=$worker_queues}}
- {{include file="field_checkbox.tpl" field=$worker_dont_fork}}
- {{include file="field_checkbox.tpl" field=$worker_fastlane}}
- {{include file="field_checkbox.tpl" field=$worker_frontend}}
- {{/if}}
+ {{include file="field_input.tpl" field=$worker_queues}}
+ {{include file="field_checkbox.tpl" field=$worker_dont_fork}}
+ {{include file="field_checkbox.tpl" field=$worker_fastlane}}
+ {{include file="field_checkbox.tpl" field=$worker_frontend}}
<div class="submit"><input type="submit" name="page_site" value="{{$submit|escape:'html'}}" /></div>
</form>
<dl>
<dt>{{$queues.label}}</dt>
- <dd>{{$queues.deliverq}} - <a href="{{$baseurl}}/admin/queue">{{$queues.queue}}</a>{{if $workeractive}} - {{$queues.workerq}}{{/if}}</dd>
+ <dd>{{$queues.deliverq}} - <a href="{{$baseurl}}/admin/queue">{{$queues.queue}}</a> - {{$queues.workerq}}</dd>
</dl>
<dl>
<dt>{{$pending.0}}</dt>
projects / friendica.git / commitdiff