master

HarbormasterExecFuture.php
View Options

			<?php

			final class HarbormasterExecFuture
			extends Future {

			private $future;
			private $stdout;
			private $stderr;

			public function setFuture(ExecFuture $future) {
			$this->future = $future;
			return $this;
			}

			public function getFuture() {
			return $this->future;
			}

			public function setLogs(
			HarbormasterBuildLog $stdout,
			HarbormasterBuildLog $stderr) {
			$this->stdout = $stdout;
			$this->stderr = $stderr;
			return $this;
			}

			public function isReady() {
			if ($this->hasResult()) {
			return true;
			}

			$future = $this->getFuture();

			$is_ready = $future->isReady();

			list($stdout, $stderr) = $future->read();
			$future->discardBuffers();

			if ($this->stdout) {
			$this->stdout->append($stdout);
			}

			if ($this->stderr) {
			$this->stderr->append($stderr);
			}

			if ($future->hasResult()) {
			$this->setResult($future->getResult());
			}

			// TODO: This should probably be implemented as a FutureProxy; it will
			// not currently propagate exceptions or sockets properly.

			return $is_ready;
			}

			}