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
@@ -96,9 +96,8 @@ 
 			'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;
@@ -111,9 +110,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;
 	}
@@ -125,9 +124,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(
+			spip_log('arguments job errones / longueur '.strlen($args).' vs '.strlen($arguments).' / valeur : '.var_export(
 				$arguments,
 				true
 			), 'queue');
@@ -157,7 +156,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();
 }
@@ -173,8 +172,8 @@ 
 	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))
+		$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 ?
@@ -224,7 +223,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));
 }
 
 /**
@@ -240,7 +239,7 @@ 
 	// deserialiser les arguments
 	$args = unserialize($row['args']);
 	if (!is_array($args)) {
-		spip_log('arguments job errones ' . var_export($row, true), 'queue');
+		spip_log('arguments job errones '.var_export($row, true), 'queue');
 		$args = [];
 	}
 
@@ -257,14 +256,14 @@ 
 	}
 
 	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');
 	$res = $fonction(...$args);
-	spip_log('queue [' . $row['id_job'] . "]: $fonction() end", 'queue');
+	spip_log('queue ['.$row['id_job']."]: $fonction() end", 'queue');
 
 	return $res;
 }
@@ -295,14 +294,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;
 	}
@@ -323,7 +322,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);
@@ -337,19 +336,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;
@@ -364,13 +363,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();
 	}
@@ -405,9 +404,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']));
 }
 
 /**
@@ -480,18 +479,18 @@ 
 	$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)) {
@@ -504,7 +503,7 @@ 
 		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++;
@@ -573,7 +572,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;
 	}
 
@@ -645,7 +644,7 @@ 
 				$port = 80;
 		}
 		$fp = @fsockopen(
-			$scheme . $parts['host'],
+			$scheme.$parts['host'],
 			$parts['port'] ?? $port,
 			$errno,
 			$errstr,
@@ -655,13 +654,13 @@ 
 		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');