MessageWriter.php — JetBackup – Backup, Restore & Migrate trunk

backup / src / JetBackup / 3rdparty / SocketAPI / Message / MessageWriter.php

backup / src / JetBackup / 3rdparty / SocketAPI / Message Last commit date

MessageWriter.php

62 lines

1	<?php
2	/*
3	*
4	* JetBackup @ package
5	* Created By Idan Ben-Ezra
6	*
7	* Copyrights @ JetApps
8	* https://www.jetapps.com
9	*
10	**/
11	namespace JetBackup\SocketAPI\Message;
12
13	use JetBackup\SocketAPI\Protocol\ProtocolListener;
14	use JetBackup\SocketAPI\Socket\Socket;
15
16	class MessageWriter extends Message implements ProtocolListener {
17
18	const WRITE_CHUNK = 1024;
19
20	/** @var Socket */
21	private $_socket;
22
23	public function __construct(Socket $socket) {
24	parent::__construct();
25	$this->_socket = $socket;
26	}
27
28	public function write($message) {
29	$message = self::_create($message);
30
31	$written = 0;
32	$total = strlen($message);
33
34	while($written < $total) {
35	$write = [$this->_socket->getSocketResource()];
36	$changes = socket_select($read, $write, $except, 10);
37	if($changes === false) return false;
38	if($changes <= 0) continue;
39	$chunk = substr($message, $written, self::WRITE_CHUNK);
40	$chunk_length = strlen($chunk);
41	if(($written_length = @socket_write($this->_socket->getSocketResource(), $chunk, $chunk_length)) === false) return false;
42	$written += $written_length;
43	}
44
45	return ($total == $written);
46	}
47
48	public function onMessageReady($message) {
49	$this->write($message);
50	}
51
52	/**
53	* @param $message
54	*
55	* @return string
56	*/
57	protected static function _create($message) {
58	$del = self::packInt(self::DELIMITER);
59	$len = self::packInt(strlen($message));
60	return $del . $len . $message . $len;
61	}
62	}