remove cabblack invocation
This commit is contained in:
parent
0cac9d56e0
commit
36b0413d32
|
@ -557,8 +557,7 @@ enum ConnectStatus {
|
||||||
refused,
|
refused,
|
||||||
timeout,
|
timeout,
|
||||||
bindFailure,
|
bindFailure,
|
||||||
unknownError,
|
unknownError
|
||||||
cancelled
|
|
||||||
}
|
}
|
||||||
|
|
||||||
enum ConnectionState {
|
enum ConnectionState {
|
||||||
|
|
|
@ -129,13 +129,10 @@ final class PosixEventDriverSockets(Loop : PosixEventLoop) : EventDriverSockets
|
||||||
assert(state == ConnectionState.connecting,
|
assert(state == ConnectionState.connecting,
|
||||||
"Unable to cancel connect on the socket that is not in connecting state");
|
"Unable to cancel connect on the socket that is not in connecting state");
|
||||||
state = ConnectionState.closed;
|
state = ConnectionState.closed;
|
||||||
auto cb = connectCallback;
|
|
||||||
connectCallback = null;
|
connectCallback = null;
|
||||||
m_loop.clearFD(sock);
|
m_loop.clearFD(sock);
|
||||||
m_loop.unregisterFD(sock, EventMask.read|EventMask.write|EventMask.status);
|
m_loop.unregisterFD(sock, EventMask.read|EventMask.write|EventMask.status);
|
||||||
closeSocket(cast(sock_t)sock.value);
|
closeSocket(cast(sock_t)sock.value);
|
||||||
if (cb)
|
|
||||||
cb(StreamSocketFD.invalid, ConnectStatus.cancelled);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue