Lines Matching refs:this
8 * file that was distributed with this source code.
103 $this->socket = $resource;
104 $this->options = \array_merge($this->options, $options);
105 if (!\in_array($this->options['transport'], self::TRANSPORTS, true)) {
108 $this->options['transport'],
112 if ($this->socket !== null) {
113 $this->setStreamOpts();
125 \stream_set_blocking($this->socket, $block);
126 while (\strlen((string) ($buffer = \fread($this->socket, $this->options['buffer_size']))) > 0) {
130 \stream_set_blocking($this->socket, false);
133 \stream_set_blocking($this->socket, true);
140 * @return $this
144 @\fwrite($this->socket, $data);
146 return $this;
151 * @return $this
155 \stream_set_blocking($this->socket, $block);
157 return $this;
165 return $this->socket !== null && !@\feof($this->socket);
173 return $this->isEncrypted;
177 * @return $this
181 if ($this->socket !== null) {
182 \stream_socket_shutdown($this->socket, STREAM_SHUT_RDWR);
184 $this->socket = null;
185 $this->isEncrypted = false;
186 $this->context = null;
188 return $this;
195 * @return $this
200 \stream_set_blocking($this->socket, true);
201 $result = \stream_socket_enable_crypto($this->socket, $encrypt, $this->options['ssl_crypto_type']);
202 \stream_set_blocking($this->socket, false);
208 $this->errorMessage
211 $this->isEncrypted = $encrypt;
213 return $this;
218 * @return $this
223 $transport = $this->options['transport'];
224 if ($transport === 'tcp' && (bool) $this->options['use_ssl'] === true) {
231 $uri .= ':' . $this->options['port'];
236 $this->errorNumber,
237 $this->errorMessage,
238 $this->options['timeout_connect'],
240 $this->createSocketContext()
246 $this->errorMessage
249 $this->socket = $socket;
250 $this->setStreamOpts();
251 $this->isEncrypted = $this->options['use_ssl'];
253 return $this;
263 return $this->options;
334 $sslOpts = $this->sslOpts;
335 foreach ($this->sslOptsMap as $optName => $sslOptsName) {
336 if (isset($this->options[$optName])) {
337 $sslOpts[$sslOptsName] = $this->options[$optName];
340 if ($this->options['ssl_validate_cert'] === false) {
347 $this->context = \stream_context_create([
351 return $this->context;
359 \stream_set_timeout($this->socket, $this->options['timeout_read']);