@@ -11,32 +11,32 @@ class Socket extends EventEmitter
11
11
{
12
12
protected $ loop ;
13
13
protected $ socket ;
14
- protected $ address ;
15
14
16
15
public $ bufferSize = 65536 ;
17
16
18
- public function __construct (LoopInterface $ loop , $ socket, $ address )
17
+ public function __construct (LoopInterface $ loop , $ socket )
19
18
{
20
19
$ this ->loop = $ loop ;
21
20
$ this ->socket = $ socket ;
22
- $ this ->address = $ address ;
23
21
24
22
$ this ->resume ();
25
23
}
26
24
27
25
public function getAddress ()
28
26
{
29
- return $ this ->address ;
27
+ return stream_socket_get_name ( $ this ->socket , false ) ;
30
28
}
31
29
32
30
public function getPort ()
33
31
{
34
- return (int )substr ($ this ->address , strrpos ($ this ->address , ': ' ) + 1 );
32
+ $ address = $ this ->getAddress ();
33
+ return (int )substr ($ address , strrpos ($ address , ': ' ) + 1 );
35
34
}
36
35
37
36
public function getHost ()
38
37
{
39
- return trim (substr ($ this ->address , 0 , strrpos ($ this ->address , ': ' )), '[] ' );
38
+ $ address = $ this ->getAddress ();
39
+ return trim (substr ($ address , 0 , strrpos ($ address , ': ' )), '[] ' );
40
40
}
41
41
42
42
public function send ($ data , $ target = null )
@@ -101,6 +101,6 @@ private function sanitizeAddress($address)
101
101
102
102
public function __toString ()
103
103
{
104
- return $ this ->address . ' ( ' . $ this ->socket . ') ' ;
104
+ return $ this ->getAddress () . ' ( ' . $ this ->socket . ') ' ;
105
105
}
106
106
}
0 commit comments