beu/TrackManiaControl
1
0
Fork 0
Code Issues 11 Pull Requests Releases Wiki Activity

cleanup

Browse Source
This commit is contained in:
kremsy 2014-02-17 00:38:32 +01:00 committed by Steffen Schröder
parent 93a7a997f8
commit 0054d8931d
1 changed files with 21 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
application/core/Files/AsynchronousFileReader.php
View File

@ -55,38 +55,39 @@ class AsynchronousFileReader {
unset($this->sockets[$key]); unset($this->sockets[$key]);
$this->handleContent($socket); $this->handleContent($socket);
continue 2; continue 2;
}else{
$meta = stream_get_meta_data($socket->socket);
} }
$meta = stream_get_meta_data($socket->socket);
} while($meta["unread_bytes"] > 0); } while($meta["unread_bytes"] > 0);
} }
} }
/** /**
* Handles the Content * Handles the Content
*
* @param $socket * @param $socket
*/ */
private function handleContent(SocketStructure $socket){ //TODO timeout handling private function handleContent(SocketStructure $socket) { //TODO timeout handling
//if (feof($socket->socket) || time() > ($socket->creationTime + self::SOCKET_TIMEOUT)) { //if (feof($socket->socket) || time() > ($socket->creationTime + self::SOCKET_TIMEOUT)) {
$result = ""; $result = "";
$error = 0; $error = 0;
/*if (time() > ($socket->creationTime + self::SOCKET_TIMEOUT)) { /*if (time() > ($socket->creationTime + self::SOCKET_TIMEOUT)) {
$error = self::TIMEOUT_ERROR; $error = self::TIMEOUT_ERROR;
} else*/ } else*/
if ($socket->header["status"] != "200") { if ($socket->header["status"] != "200") {
$error = self::RESPONSE_ERROR; $error = self::RESPONSE_ERROR;
$result = $this->parseResult2($socket); $result = $this->parseResult2($socket);
} else if ($socket->streamBuffer == '') { } else if ($socket->streamBuffer == '') {
$error = self::NO_DATA_ERROR; $error = self::NO_DATA_ERROR;
} else { } else {
$result = $this->parseResult2($socket); $result = $this->parseResult2($socket);
if ($result == self::INVALID_RESULT_ERROR) { if ($result == self::INVALID_RESULT_ERROR) {
$error = self::INVALID_RESULT_ERROR; $error = self::INVALID_RESULT_ERROR;
}
} }
//var_dump($result); }
call_user_func($socket->function, $result, $error); //var_dump($result);
call_user_func($socket->function, $result, $error);
//} //}
} }