ftp_sockets

28class ftp_sockets extends ftp_base {29 30	function __construct($verb=FALSE, $le=FALSE) {31		parent::__construct(true, $verb, $le);32	}33 34// <!-- --------------------------------------------------------------------------------------- -->35// <!--       Private functions                                                                 -->36// <!-- --------------------------------------------------------------------------------------- -->37 38	function _settimeout($sock) {39		if(!@socket_set_option($sock, SOL_SOCKET, SO_RCVTIMEO, array("sec"=>$this->_timeout, "usec"=>0))) {40			$this->PushError('_connect','socket set receive timeout',socket_strerror(socket_last_error($sock)));41			@socket_close($sock);42			return FALSE;43		}44		if(!@socket_set_option($sock, SOL_SOCKET , SO_SNDTIMEO, array("sec"=>$this->_timeout, "usec"=>0))) {45			$this->PushError('_connect','socket set send timeout',socket_strerror(socket_last_error($sock)));46			@socket_close($sock);47			return FALSE;48		}49		return true;50	}51 52	function _connect($host, $port) {53		$this->SendMSG("Creating socket");54		if(!($sock = @socket_create(AF_INET, SOCK_STREAM, SOL_TCP))) {55			$this->PushError('_connect','socket create failed',socket_strerror(socket_last_error($sock)));56			return FALSE;57		}58		if(!$this->_settimeout($sock)) return FALSE;59		$this->SendMSG("Connecting to \"".$host.":".$port."\"");60		if (!($res = @socket_connect($sock, $host, $port))) {61			$this->PushError('_connect','socket connect failed',socket_strerror(socket_last_error($sock)));62			@socket_close($sock);63			return FALSE;64		}65		$this->_connected=true;66		return $sock;67	}68 69	function _readmsg($fnction="_readmsg"){70		if(!$this->_connected) {71			$this->PushError($fnction,'Connect first');72			return FALSE;73		}74		$result=true;75		$this->_message="";76		$this->_code=0;77		$go=true;78		do {79			$tmp=@socket_read($this->_ftp_control_sock, 4096, PHP_BINARY_READ);80			if($tmp===false) {81				$go=$result=false;82				$this->PushError($fnction,'Read failed', socket_strerror(socket_last_error($this->_ftp_control_sock)));83			} else {84				$this->_message.=$tmp;85				$go = !preg_match("/^([0-9]{3})(-.+\\1)? [^".CRLF."]+".CRLF."$/Us", $this->_message, $regs);86			}87		} while($go);88		if($this->LocalEcho) echo "GET < ".rtrim($this->_message, CRLF).CRLF;89		$this->_code=(int)$regs[1];90		return $result;91	}92 93	function _exec($cmd, $fnction="_exec") {94		if(!$this->_ready) {95			$this->PushError($fnction,'Connect first');96			return FALSE;97		}98		if($this->LocalEcho) echo "PUT > ",$cmd,CRLF;99		$status=@socket_write($this->_ftp_control_sock, $cmd.CRLF);100		if($status===false) {101			$this->PushError($fnction,'socket write failed', socket_strerror(socket_last_error($this->stream)));102			return FALSE;103		}104		$this->_lastaction=time();105		if(!$this->_readmsg($fnction)) return FALSE;106		return TRUE;107	}