spip / SPIP

ecrire/inc/queue.php

Spacing +37 added lines, -38 removed lines

@@ -70,7 +70,7 @@ 
 	$md5args = md5($arguments);
 
 	// si pas de date programee, des que possible
-	$duplicate_where = 'status=' . intval(_JQ_SCHEDULED) . ' AND ';
+	$duplicate_where = 'status='.intval(_JQ_SCHEDULED).' AND ';
 	if (!$time) {
 		$time = time();
 		$duplicate_where = ""; // ne pas dupliquer si deja le meme job en cours d'execution
@@ -94,9 +94,8 @@ 
 		and
 		$id_job = sql_getfetsel('id_job', 'spip_jobs',
 			$duplicate_where =
-				$duplicate_where . 'fonction=' . sql_quote($function)
-				. (($no_duplicate === 'function_only') ? '' :
-					' AND md5args=' . sql_quote($md5args) . ' AND inclure=' . sql_quote($file)))
+				$duplicate_where.'fonction='.sql_quote($function)
+				. (($no_duplicate === 'function_only') ? '' : ' AND md5args='.sql_quote($md5args).' AND inclure='.sql_quote($file)))
 	) {
 		return $id_job;
 	}
@@ -108,9 +107,9 @@ 
 	if (
 		$no_duplicate
 		and
-		$id_prev = sql_getfetsel('id_job', 'spip_jobs', "id_job<" . intval($id_job) . " AND $duplicate_where")
+		$id_prev = sql_getfetsel('id_job', 'spip_jobs', "id_job<".intval($id_job)." AND $duplicate_where")
 	) {
-		sql_delete('spip_jobs', 'id_job=' . intval($id_job));
+		sql_delete('spip_jobs', 'id_job='.intval($id_job));
 
 		return $id_prev;
 	}
@@ -122,9 +121,9 @@ 
 	// ie cas d'un char non acceptables sur certains type de champs
 	// qui coupe la valeur
 	if (defined('_JQ_INSERT_CHECK_ARGS') and $id_job) {
-		$args = sql_getfetsel('args', 'spip_jobs', 'id_job=' . intval($id_job));
+		$args = sql_getfetsel('args', 'spip_jobs', 'id_job='.intval($id_job));
 		if ($args !== $arguments) {
-			spip_log('arguments job errones / longueur ' . strlen($args) . " vs " . strlen($arguments) . ' / valeur : ' . var_export($arguments,
+			spip_log('arguments job errones / longueur '.strlen($args)." vs ".strlen($arguments).' / valeur : '.var_export($arguments,
 					true), 'queue');
 		}
 	}
@@ -152,7 +151,7 @@ 
 function queue_purger() {
 	include_spip('base/abstract_sql');
 	sql_delete('spip_jobs');
-	sql_delete("spip_jobs_liens", "id_job NOT IN (" . sql_get_select("id_job", "spip_jobs") . ")");
+	sql_delete("spip_jobs_liens", "id_job NOT IN (".sql_get_select("id_job", "spip_jobs").")");
 	include_spip('inc/genie');
 	genie_queue_watch_dist();
 }
@@ -167,8 +166,8 @@ 
 function queue_remove_job($id_job) {
 	include_spip('base/abstract_sql');
 
-	if ($row = sql_fetsel('fonction,inclure,date', 'spip_jobs', 'id_job=' . intval($id_job))
-		and $res = sql_delete('spip_jobs', 'id_job=' . intval($id_job))
+	if ($row = sql_fetsel('fonction,inclure,date', 'spip_jobs', 'id_job='.intval($id_job))
+		and $res = sql_delete('spip_jobs', 'id_job='.intval($id_job))
 	) {
 		queue_unlink_job($id_job);
 		// est-ce une tache cron qu'il faut relancer ?
@@ -217,7 +216,7 @@ 
  *  resultat du sql_delete
  */
 function queue_unlink_job($id_job) {
-	return sql_delete("spip_jobs_liens", "id_job=" . intval($id_job));
+	return sql_delete("spip_jobs_liens", "id_job=".intval($id_job));
 }
 
 /**
@@ -233,7 +232,7 @@ 
 	// deserialiser les arguments
 	$args = unserialize($row['args']);
 	if ($args === false) {
-		spip_log('arguments job errones ' . var_export($row, true), 'queue');
+		spip_log('arguments job errones '.var_export($row, true), 'queue');
 		$args = array();
 	}
 
@@ -250,12 +249,12 @@ 
 	}
 
 	if (!function_exists($fonction)) {
-		spip_log("fonction $fonction ($inclure) inexistante " . var_export($row, true), 'queue');
+		spip_log("fonction $fonction ($inclure) inexistante ".var_export($row, true), 'queue');
 
 		return false;
 	}
 
-	spip_log("queue [" . $row['id_job'] . "]: $fonction() start", 'queue');
+	spip_log("queue [".$row['id_job']."]: $fonction() start", 'queue');
 	switch (count($args)) {
 		case 0:
 			$res = $fonction();
@@ -295,7 +294,7 @@ 
 			# plus lent mais completement generique
 			$res = call_user_func_array($fonction, $args);
 	}
-	spip_log("queue [" . $row['id_job'] . "]: $fonction() end", 'queue');
+	spip_log("queue [".$row['id_job']."]: $fonction() end", 'queue');
 
 	return $res;
 
@@ -327,14 +326,14 @@ 
 function queue_schedule($force_jobs = null) {
 	$time = time();
 	if (defined('_DEBUG_BLOCK_QUEUE')) {
-		spip_log("_DEBUG_BLOCK_QUEUE : schedule stop", 'jq' . _LOG_DEBUG);
+		spip_log("_DEBUG_BLOCK_QUEUE : schedule stop", 'jq'._LOG_DEBUG);
 
 		return;
 	}
 
 	// rien a faire si le prochain job est encore dans le futur
 	if (queue_sleep_time_to_next_job() > 0 and (!$force_jobs or !count($force_jobs))) {
-		spip_log("queue_sleep_time_to_next_job", 'jq' . _LOG_DEBUG);
+		spip_log("queue_sleep_time_to_next_job", 'jq'._LOG_DEBUG);
 
 		return;
 	}
@@ -355,7 +354,7 @@ 
 	}
 	$end_time = $time + _JQ_MAX_JOBS_TIME_TO_EXECUTE;
 
-	spip_log("JQ schedule $time / $end_time", 'jq' . _LOG_DEBUG);
+	spip_log("JQ schedule $time / $end_time", 'jq'._LOG_DEBUG);
 
 	if (!defined('_JQ_MAX_JOBS_EXECUTE')) {
 		define('_JQ_MAX_JOBS_EXECUTE', 200);
@@ -369,19 +368,19 @@ 
 	// lorsqu'un job cron n'a pas fini, sa priorite est descendue
 	// pour qu'il ne bloque pas les autres jobs en attente
 	if (is_array($force_jobs) and count($force_jobs)) {
-		$cond = "status=" . intval(_JQ_SCHEDULED) . " AND " . sql_in("id_job", $force_jobs);
+		$cond = "status=".intval(_JQ_SCHEDULED)." AND ".sql_in("id_job", $force_jobs);
 	} else {
 		$now = date('Y-m-d H:i:s', $time);
-		$cond = "status=" . intval(_JQ_SCHEDULED) . " AND date<=" . sql_quote($now);
+		$cond = "status=".intval(_JQ_SCHEDULED)." AND date<=".sql_quote($now);
 	}
 
 	register_shutdown_function('queue_error_handler'); // recuperer les erreurs auant que possible
-	$res = sql_allfetsel('*', 'spip_jobs', $cond, '', 'priorite DESC,date', '0,' . (_JQ_MAX_JOBS_EXECUTE + 1));
+	$res = sql_allfetsel('*', 'spip_jobs', $cond, '', 'priorite DESC,date', '0,'.(_JQ_MAX_JOBS_EXECUTE + 1));
 	do {
 		if ($row = array_shift($res)) {
 			$nbj++;
 			// il faut un verrou, a base de sql_delete
-			if (sql_delete('spip_jobs', "id_job=" . intval($row['id_job']) . " AND status=" . intval(_JQ_SCHEDULED))) {
+			if (sql_delete('spip_jobs', "id_job=".intval($row['id_job'])." AND status=".intval(_JQ_SCHEDULED))) {
 				#spip_log("JQ schedule job ".$nbj." OK",'jq');
 				// on reinsert dans la base aussitot avec un status=_JQ_PENDING
 				$row['status'] = _JQ_PENDING;
@@ -396,13 +395,13 @@ 
 				queue_close_job($row, $time, $result);
 			}
 		}
-		spip_log("JQ schedule job end time " . $time, 'jq' . _LOG_DEBUG);
+		spip_log("JQ schedule job end time ".$time, 'jq'._LOG_DEBUG);
 	} while ($nbj < _JQ_MAX_JOBS_EXECUTE and $row and $time < $end_time);
-	spip_log("JQ schedule end time " . time(), 'jq' . _LOG_DEBUG);
+	spip_log("JQ schedule end time ".time(), 'jq'._LOG_DEBUG);
 
 	if ($row = array_shift($res)) {
 		queue_update_next_job_time(0); // on sait qu'il y a encore des jobs a lancer ASAP
-		spip_log("JQ encore !", 'jq' . _LOG_DEBUG);
+		spip_log("JQ encore !", 'jq'._LOG_DEBUG);
 	} else {
 		queue_update_next_job_time();
 	}
@@ -438,9 +437,9 @@ 
 		}
 	}
 	// purger ses liens eventuels avec des objets
-	sql_delete("spip_jobs_liens", "id_job=" . intval($row['id_job']));
+	sql_delete("spip_jobs_liens", "id_job=".intval($row['id_job']));
 	// supprimer le job fini
-	sql_delete('spip_jobs', 'id_job=' . intval($row['id_job']));
+	sql_delete('spip_jobs', 'id_job='.intval($row['id_job']));
 }
 
 /**
@@ -511,17 +510,17 @@ 
 	// traiter les jobs morts au combat (_JQ_PENDING depuis plus de 180s)
 	// pour cause de timeout ou autre erreur fatale
 	$res = sql_allfetsel("*", "spip_jobs",
-		"status=" . intval(_JQ_PENDING) . " AND date<" . sql_quote(date('Y-m-d H:i:s', $time - 180)));
+		"status=".intval(_JQ_PENDING)." AND date<".sql_quote(date('Y-m-d H:i:s', $time - 180)));
 	if (is_array($res)) {
 		foreach ($res as $row) {
 			queue_close_job($row, $time);
-			spip_log ("queue_close_job car _JQ_PENDING depuis +180s : ".print_r($row,1), "job_mort"._LOG_ERREUR);
+			spip_log("queue_close_job car _JQ_PENDING depuis +180s : ".print_r($row, 1), "job_mort"._LOG_ERREUR);
 		}
 	}
 
 	// chercher la date du prochain job si pas connu
 	if (is_null($next) or is_null(queue_sleep_time_to_next_job())) {
-		$date = sql_getfetsel('date', 'spip_jobs', "status=" . intval(_JQ_SCHEDULED), '', 'date', '0,1');
+		$date = sql_getfetsel('date', 'spip_jobs', "status=".intval(_JQ_SCHEDULED), '', 'date', '0,1');
 		$next = strtotime($date);
 	}
 	if (!is_null($next_time)) {
@@ -533,7 +532,7 @@ 
 	if ($next) {
 		if (is_null($nb_jobs_scheduled)) {
 			$nb_jobs_scheduled = sql_countsel('spip_jobs',
-				"status=" . intval(_JQ_SCHEDULED) . " AND date<" . sql_quote(date('Y-m-d H:i:s', $time)));
+				"status=".intval(_JQ_SCHEDULED)." AND date<".sql_quote(date('Y-m-d H:i:s', $time)));
 		} elseif ($next <= $time) {
 			$nb_jobs_scheduled++;
 		}
@@ -601,7 +600,7 @@ 
 	}
 
 	// ne pas relancer si on vient de lancer dans la meme seconde par un hit concurent
-	if (file_exists($lock = _DIR_TMP . "cron.lock") and !(@filemtime($lock) < $_SERVER['REQUEST_TIME'])) {
+	if (file_exists($lock = _DIR_TMP."cron.lock") and !(@filemtime($lock) < $_SERVER['REQUEST_TIME'])) {
 		return $texte;
 	}
 
@@ -672,20 +671,20 @@ 
 				$scheme = '';
 				$port = 80;
 		}
-		$fp = @fsockopen($scheme . $parts['host'],
+		$fp = @fsockopen($scheme.$parts['host'],
 			isset($parts['port']) ? $parts['port'] : $port,
 			$errno, $errstr, 1);
 
 		if ($fp) {
 			$host_sent = $parts['host'];
 			if (isset($parts['port']) and $parts['port'] !== $port) {
-				$host_sent .= ':' . $parts['port'];
+				$host_sent .= ':'.$parts['port'];
 			}
 			$timeout = 200; // ms
 			stream_set_timeout($fp, 0, $timeout * 1000);
-			$query = $parts['path'] . ($parts['query'] ? "?" . $parts['query'] : "");
-			$out = "GET " . $query . " HTTP/1.1\r\n";
-			$out .= "Host: " . $host_sent . "\r\n";
+			$query = $parts['path'].($parts['query'] ? "?".$parts['query'] : "");
+			$out = "GET ".$query." HTTP/1.1\r\n";
+			$out .= "Host: ".$host_sent."\r\n";
 			$out .= "Connection: Close\r\n\r\n";
 			fwrite($fp, $out);
 			spip_timer('read');