OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 #include "platform/globals.h" | 5 #include "platform/globals.h" |
6 #if defined(TARGET_OS_WINDOWS) | 6 #if defined(TARGET_OS_WINDOWS) |
7 | 7 |
8 #include "bin/eventhandler.h" | 8 #include "bin/eventhandler.h" |
9 #include "bin/eventhandler_win.h" | 9 #include "bin/eventhandler_win.h" |
10 | 10 |
(...skipping 857 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
868 RemoveAllPorts(); | 868 RemoveAllPorts(); |
869 } | 869 } |
870 | 870 |
871 | 871 |
872 void ClientSocket::DisconnectComplete(OverlappedBuffer* buffer) { | 872 void ClientSocket::DisconnectComplete(OverlappedBuffer* buffer) { |
873 OverlappedBuffer::DisposeBuffer(buffer); | 873 OverlappedBuffer::DisposeBuffer(buffer); |
874 closesocket(socket()); | 874 closesocket(socket()); |
875 if (data_ready_ != NULL) { | 875 if (data_ready_ != NULL) { |
876 OverlappedBuffer::DisposeBuffer(data_ready_); | 876 OverlappedBuffer::DisposeBuffer(data_ready_); |
877 } | 877 } |
878 closed_ = true; | 878 mark_closed(); |
879 } | 879 } |
880 | 880 |
881 | 881 |
882 void ClientSocket::ConnectComplete(OverlappedBuffer* buffer) { | 882 void ClientSocket::ConnectComplete(OverlappedBuffer* buffer) { |
883 OverlappedBuffer::DisposeBuffer(buffer); | 883 OverlappedBuffer::DisposeBuffer(buffer); |
884 // Update socket to support full socket API, after ConnectEx completed. | 884 // Update socket to support full socket API, after ConnectEx completed. |
885 setsockopt(socket(), SOL_SOCKET, SO_UPDATE_CONNECT_CONTEXT, NULL, 0); | 885 setsockopt(socket(), SOL_SOCKET, SO_UPDATE_CONNECT_CONTEXT, NULL, 0); |
886 // If the port is set, we already listen for this socket in Dart. | 886 // If the port is set, we already listen for this socket in Dart. |
887 // Handle the cases here. | 887 // Handle the cases here. |
888 if (!IsClosedRead() && (Mask() & (1 << kInEvent) != 0)) { | 888 if (!IsClosedRead() && (Mask() & (1 << kInEvent) != 0)) { |
(...skipping 491 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1380 | 1380 |
1381 | 1381 |
1382 void EventHandlerImplementation::Shutdown() { | 1382 void EventHandlerImplementation::Shutdown() { |
1383 SendData(kShutdownId, 0, 0); | 1383 SendData(kShutdownId, 0, 0); |
1384 } | 1384 } |
1385 | 1385 |
1386 } // namespace bin | 1386 } // namespace bin |
1387 } // namespace dart | 1387 } // namespace dart |
1388 | 1388 |
1389 #endif // defined(TARGET_OS_WINDOWS) | 1389 #endif // defined(TARGET_OS_WINDOWS) |
OLD | NEW |