|
18 | 18 |
|
19 | 19 | module ocean.io.select.protocol.fiber.FiberSocketConnection; |
20 | 20 |
|
21 | | - |
22 | | - |
23 | | - |
24 | | -import ocean.meta.types.Qualifiers; |
25 | | - |
| 21 | +import ocean.core.Array : copy; |
26 | 22 | import ocean.core.Verify; |
27 | | - |
28 | | -import ocean.io.select.protocol.fiber.model.IFiberSelectProtocol; |
29 | | - |
30 | 23 | import ocean.io.select.EpollSelectDispatcher; |
31 | | - |
32 | | -import ocean.core.Array : copy; |
33 | | - |
34 | | -import ocean.sys.socket.AddressIPSocket, |
35 | | - ocean.sys.socket.InetAddress, |
36 | | - ocean.sys.socket.IPSocket: IIPSocket; |
37 | | - |
38 | | - |
| 24 | +import ocean.io.select.protocol.fiber.model.IFiberSelectProtocol; |
39 | 25 | import ocean.io.select.protocol.generic.ErrnoIOException: SocketError; |
40 | | - |
41 | | -import core.stdc.errno: errno, EINPROGRESS, EINTR, EALREADY, EISCONN; |
42 | | - |
43 | | -debug ( EpollTiming ) import ocean.time.StopWatch; |
44 | | -debug ( ISelectClient ) |
| 26 | +import ocean.meta.types.Qualifiers; |
| 27 | +import ocean.sys.socket.AddressIPSocket; |
| 28 | +import ocean.sys.socket.InetAddress; |
| 29 | +import ocean.sys.socket.IPSocket: IIPSocket; |
| 30 | +debug (EpollTiming) import ocean.time.StopWatch; |
| 31 | +debug (ISelectClient) |
45 | 32 | { |
46 | 33 | import ocean.io.Stdout : Stderr; |
47 | 34 | import ocean.text.util.StringC; |
48 | 35 | } |
| 36 | +import core.stdc.errno: errno, EINPROGRESS, EINTR, EALREADY, EISCONN; |
49 | 37 |
|
50 | 38 |
|
51 | | - |
52 | | -public class FiberSocketConnection ( bool IPv6 = false ) : IFiberSocketConnection |
| 39 | +/// Ditto |
| 40 | +public class FiberSocketConnection (bool IPv6 = false) : IFiberSocketConnection |
53 | 41 | { |
54 | 42 | /************************************************************************** |
55 | 43 |
|
@@ -562,10 +550,8 @@ public class IFiberSocketConnection : IFiberSelectProtocol |
562 | 550 | if (this.socket.fileHandle < 0) |
563 | 551 | { |
564 | 552 | this.connected_ = false; |
565 | | - |
566 | 553 | this.socket_error.assertExSock(this.socket.tcpSocket(true) >= 0, |
567 | 554 | "error creating socket", __FILE__, __LINE__); |
568 | | - |
569 | 555 | this.initSocket(); |
570 | 556 | } |
571 | 557 |
|
|
0 commit comments