running = TRUE; while ($this->running) { try { $conn = connection::getPDOConnection(); } catch (Exception $e) { $this->log($e->getMessage()); if ($this->getRunner() == self::RUNNER_SCHEDULER) { $this->log(("Warning : abox connection lost, restarting in 10 min.")); // DON'T do sleep(600) because it prevents ticks ! for ($t = 60 * 10; $this->running && $t; $t -- ) { sleep(1); } // because connection is lost we cannot change status to 'torestart' // anyway the current status 'running' with no pid // will enforce the scheduler to restart the task } else { // runner = manual : can't restart so simply quit } $this->running = FALSE; return; } $this->setLastExecTime(); try { $sql = 'SELECT settings FROM task2 WHERE task_id = :taskid'; $stmt = $conn->prepare($sql); $stmt->execute(array(':taskid' => $this->getID())); $row = $stmt->fetch(PDO::FETCH_ASSOC); $stmt->closeCursor(); $this->records_done = 0; $duration = time(); } catch (Exception $e) { // failed sql, simply return $this->running = FALSE; return; } if ($row) { if ( ! $this->running) { break; } $appbox = appbox::get_instance(\bootstrap::getCore()); try { $this->loadSettings(simplexml_load_string($row['settings'])); } catch (Exception $e) { $this->log($e->getMessage()); continue; } $process_ret = $this->process($appbox); switch ($process_ret) { case self::STATE_MAXMEGSREACHED: case self::STATE_MAXRECSDONE: if ($this->getRunner() == self::RUNNER_SCHEDULER) { $this->setState(self::STATE_TORESTART); $this->running = FALSE; } break; case self::STATE_TOSTOP: $this->setState(self::STATE_TOSTOP); $this->running = FALSE; break; case self::STATE_TODELETE: // formal 'suicidable' $this->setState(self::STATE_TODELETE); $this->running = FALSE; break; case self::STATE_OK: break; } } // if(row) $this->incrementLoops(); $this->pause($duration); } // while running return; } /** * * @return */ protected function process(appbox $appbox) { $ret = self::STATE_OK; try { // get the records to process $rs = $this->retrieveContent($appbox); $ret = $this->processLoop($appbox, $rs); } catch (Exception $e) { $this->log('Error : ' . $e->getMessage()); } return $ret; /* $ret = self::STATE_OK; try { // get the records to process $rs = $this->retrieveContent($appbox); } catch (Exception $e) { $this->log('Error : ' . $e->getMessage()); $rs = array(); } $rowstodo = count($rs); $rowsdone = 0; if ($rowstodo > 0) { $this->setProgress(0, $rowstodo); } foreach ($rs as $row) { try { // process one record $this->processOneContent($appbox, $row); } catch (Exception $e) { $this->log("Exception : " . $e->getMessage() . " " . basename($e->getFile()) . " " . $e->getLine()); } $this->records_done ++; $this->setProgress($rowsdone, $rowstodo); // post-process $this->postProcessOneContent($appbox, $row); $current_memory = memory_get_usage(); if ($current_memory >> 20 >= $this->maxmegs) { $this->log(sprintf("Max memory (%s M) reached (actual is %s M)", $this->maxmegs, $current_memory)); $this->running = FALSE; $ret = self::STATE_MAXMEGSREACHED; } if ($this->records_done >= (int) ($this->maxrecs)) { $this->log(sprintf("Max records done (%s) reached (actual is %s)", $this->maxrecs, $this->records_done)); $this->running = FALSE; $ret = self::STATE_MAXRECSDONE; } try { $status = $this->getState(); if ($status == self::STATE_TOSTOP) { $this->running = FALSE; $ret = self::STATE_TOSTOP; } } catch (Exception $e) { $this->running = FALSE; } if ( ! $this->running) { break; } } // // if nothing was done, at least check the status if (count($rs) == 0 && $this->running) { $current_memory = memory_get_usage(); if ($current_memory >> 20 >= $this->maxmegs) { $this->log(sprintf("Max memory (%s M) reached (current is %s M)", $this->maxmegs, $current_memory)); $this->running = FALSE; $ret = self::STATE_MAXMEGSREACHED; } if ($this->records_done >= (int) ($this->maxrecs)) { $this->log(sprintf("Max records done (%s) reached (actual is %s)", $this->maxrecs, $this->records_done)); $this->running = FALSE; $ret = self::STATE_MAXRECSDONE; } try { $status = $this->getState(); if ($status == self::STATE_TOSTOP) { $this->running = FALSE; $ret = self::STATE_TOSTOP; } } catch (Exception $e) { $this->running = FALSE; } } if ($rowstodo > 0) { $this->setProgress(0, 0); } return $ret; */ } }