Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 59) sorted by relevance

123

/plugin/pureldap/vendor/freedsx/socket/src/FreeDSx/Socket/
H A DSocket.php39 protected $socket; variable in FreeDSx\\Socket\\Socket
103 $this->socket = $resource;
112 if ($this->socket !== null) {
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);
144 @\fwrite($this->socket, $data);
155 \stream_set_blocking($this->socket, $block);
165 return $this->socket !== null && !@\feof($this->socket);
[all …]
H A DSocketServer.php100 $socket = @\stream_socket_server(
107 if ($socket === false) {
115 $this->socket = $socket;
126 $socket = @\stream_socket_accept($this->socket, $timeout);
127 if (\is_resource($socket)) {
128 $socket = new Socket($socket, \array_merge($this->options, [
131 $this->clients[] = $socket;
134 return $socket instanceof Socket ? $socket : null;
149 $this->socket,
165 * @param Socket $socket
[all …]
H A DSocketPool.php63 $socket = null;
66 $socket = Socket::create(
76 if ($socket === null) {
83 return $socket;
/plugin/recaptcha2/lib/ReCaptcha/RequestMethod/
DSocketPost.php64 private $socket; variable in ReCaptcha\\RequestMethod\\SocketPost
71 public function __construct(Socket $socket = null) argument
73 if (!is_null($socket)) {
74 $this->socket = $socket;
76 $this->socket = new Socket();
91 …if ($this->socket->fsockopen('ssl://' . self::RECAPTCHA_HOST, 443, $errno, $errstr, 30) !== false)…
101 $this->socket->fwrite($request);
104 while (!$this->socket->feof()) {
105 $response .= $this->socket->fgets(4096);
108 $this->socket->fclose();
/plugin/upgrade/HTTP/
DHTTPClient.php254 $socket = null;
257 $socket = self::$connections[$connectionId];
259 if (is_null($socket) || feof($socket)) {
262 $socket = @fsockopen($server,$port,$errno, $errstr, $this->timeout);
263 if (!$socket){
271 if($this->ssltunnel($socket, $request_url)){
280 fclose($socket);
286 self::$connections[$connectionId] = $socket;
303 stream_set_blocking($socket, 0);
313 $this->sendData($socket, $request, 'request');
[all …]
/plugin/elwikiupgrade/
DHTTPClient.php262 $socket = null;
265 $socket = self::$connections[$connectionId];
267 if (is_null($socket) || feof($socket)) {
270 $socket = @fsockopen($server,$port,$errno, $errstr, $this->timeout);
271 if (!$socket){
279 if($this->_ssltunnel($socket, $request_url)){
288 fclose($socket);
294 self::$connections[$connectionId] = $socket;
311 stream_set_blocking($socket, 0);
321 $this->_sendData($socket, $request, 'request');
[all …]
/plugin/authgooglesheets/vendor/monolog/monolog/src/Monolog/Handler/SyslogUdp/
DUdpSocket.php26 protected $socket; variable in Monolog\\Handler\\SyslogUdp\\UdpSocket
39 $this->socket = socket_create($domain, SOCK_DGRAM, $protocol) ?: null;
54 if (is_resource($this->socket) || $this->socket instanceof Socket) {
55 socket_close($this->socket);
56 $this->socket = null;
62 if (!is_resource($this->socket) && !$this->socket instanceof Socket) {
65 socket_sendto($this->socket, $chunk, strlen($chunk), $flags = 0, $this->ip, $this->port);
/plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Protocol/
H A DLdapQueue.php47 protected $socket; variable in FreeDSx\\Ldap\\Protocol\\LdapQueue
54 public function __construct(Socket $socket, EncoderInterface $encoder = null) argument
56 parent::__construct($socket, $encoder ?? new LdapEncoder());
67 $this->socket->block(true);
68 $this->socket->encrypt(true);
69 $this->socket->block(false);
79 return ($this->socket->isConnected() && $this->socket->isEncrypted());
87 $this->socket->close();
150 $this->socket->write(substr($buffer, 0, self::BUFFER_SIZE));
155 $this->socket->write($buffer);
[all …]
/plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Server/
H A DChildProcess.php26 private $socket; variable in FreeDSx\\Ldap\\Server\\ChildProcess
30 Socket $socket argument
33 $this->socket = $socket;
43 return $this->socket;
48 $this->socket->close();
/plugin/linkback/
Dhttp.php112 $socket = @ fsockopen($server, $port, $errno, $errstr, $this->timeout);
113 if (!$socket) {
119 stream_set_blocking($socket, 0);
131 fputs($socket, $request);
140 if (feof($socket)) {
144 $r_headers .= fread($socket, 1); #FIXME read full lines here?
210 if (feof($socket)) {
219 $byte = fread($socket, 1);
223 $byte = fread($socket, 1); // readtrailing \n
225 $this_chunk = fread($socket, $chunk_size);
[all …]
/plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/Server/ServerRunner/
H A DPcntlServerRunner.php150 $socket = $childProcess->getSocket();
151 $this->server->removeClient($socket);
152 $socket->close();
176 $socket = $this->server->accept(self::SOCKET_ACCEPT_TIMEOUT);
179 if ($socket) {
184 $socket->close();
191 if ($socket === null) {
207 $socket,
214 $socket
358 Socket $socket, argument
[all …]
/plugin/revealjs/plugin/notes-server/
Dindex.js18 io.on( 'connection', function( socket ) { argument
20 socket.on( 'new-subscriber', function( data ) {
21 socket.broadcast.emit( 'new-subscriber', data );
24 socket.on( 'statechanged', function( data ) {
26 socket.broadcast.emit( 'statechanged', data );
29 socket.on( 'statechanged-speaker', function( data ) {
31 socket.broadcast.emit( 'statechanged-speaker', data );
Dclient.js6 var socket = io.connect( window.location.origin ),
39 socket.emit( 'statechanged', messageData );
44 socket.on( 'new-subscriber', function( data ) {
49 socket.on( 'statechanged-speaker', function( data ) {
/plugin/authgooglesheets/vendor/monolog/monolog/src/Monolog/Handler/
DSyslogUdpHandler.php39 protected $socket; variable in Monolog\\Handler\\SyslogUdpHandler
67 $this->socket = new UdpSocket($host, $port);
77 $this->socket->write($line, $header);
83 $this->socket->close();
144 public function setSocket(UdpSocket $socket): self argument
146 $this->socket = $socket;
/plugin/pureldap/vendor/freedsx/socket/src/FreeDSx/Socket/Queue/
H A DMessageQueue.php27 protected $socket; variable in FreeDSx\\Socket\\Queue\\MessageQueue
40 * @param Socket $socket
42 public function __construct(Socket $socket) argument
44 $this->socket = $socket;
88 $bytes = $this->socket->read();
134 if ($this->toConsume === '' && ($peek = $this->socket->read(false)) !== false) {
H A DAsn1MessageQueue.php37 * @param Socket $socket
41 public function __construct(Socket $socket, EncoderInterface $encoder, ?string $pduClass = null) argument
52 parent::__construct($socket);
/plugin/diagramsnet/lib/js/diagramly/
DP2PCollab.js3 socket = io(App.SOCKET_IO_SRV);
32 socket.emit('message', msg);
128 socket.on('message', processMsg);
143 socket.emit('sendSignal', {to: id, from: myClientId, signal: data});
160 socket.emit('movedToP2P', '');
176 socket.on('clientsList', function(data)
186 socket.on('signal', function(data)
203 socket.on('newClient', function(clientId)
211 socket.emit('join', {name: channelId});
/plugin/pureldap/vendor/freedsx/ldap/src/FreeDSx/Ldap/
H A DLdapServer.php201 private function removeExistingSocketIfNeeded(string $socket): void argument
203 if (!file_exists($socket)) {
207 if (!is_writeable($socket)) {
210 $socket
214 if (!unlink($socket)) {
217 $socket
/plugin/redirectssl/
Daction.php85 $socket = @socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
86 if ($socket >= 0 && @socket_connect($socket,$this->servername()?:'127.0.0.1',$port)>=0){
87 @socket_close($socket);
90 @socket_close($socket);
/plugin/html2pdf/html2pdf/html2ps/
Dfetcher.url.class.php320 $socket = $this->_connect();
321 if (is_null($socket)) { return null; };
333 fputs ($socket, $header);
344 $res = fread($socket, 1024*1024);
347 fclose($socket);
353 $socket = $this->_connect();
355 if (is_null($socket)) { return null; };
371 fputs ($socket, $header);
382 $res = fread($socket, 4096);
385 fclose($socket);
/plugin/pureldap/vendor/freedsx/socket/
H A DCHANGELOG.md6 * Support constructing a socket server from a unix socket.
10 * Support constructing a socket pool from a unix socket.
/plugin/revealjs/plugin/multiplex/
Dindex.js18 io.on( 'connection', function( socket ) { argument
19 socket.on('multiplex-statechanged', function(data) {
23 socket.broadcast.emit(data.socketId, data);
Dclient.js4 var socket = io.connect(multiplex.url);
6 socket.on(multiplex.id, function(data) {
Dmaster.js8 var socket = io.connect( multiplex.url );
18 socket.emit( 'multiplex-statechanged', messageData );
/plugin/gemini/
Dcli.php87 $socket = stream_socket_server(
94 if ($socket === false) throw new \splitbrain\phpcli\Exception($errstr, $errno);
107 $conn = stream_socket_accept($socket, -1, $peername);

123