OLD | NEW |
1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2011, 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 <errno.h> | 5 #include <errno.h> |
6 #include <poll.h> | 6 #include <poll.h> |
7 #include <pthread.h> | 7 #include <pthread.h> |
8 #include <stdio.h> | 8 #include <stdio.h> |
9 #include <string.h> | 9 #include <string.h> |
10 #include <sys/time.h> | 10 #include <sys/time.h> |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
64 if (fd >= port_map_size_) { | 64 if (fd >= port_map_size_) { |
65 intptr_t new_port_map_size = port_map_size_; | 65 intptr_t new_port_map_size = port_map_size_; |
66 do { | 66 do { |
67 new_port_map_size = new_port_map_size * kPortMapGrowingFactor; | 67 new_port_map_size = new_port_map_size * kPortMapGrowingFactor; |
68 } while (fd >= new_port_map_size); | 68 } while (fd >= new_port_map_size); |
69 size_t new_port_map_bytes = new_port_map_size * sizeof(PortData); | 69 size_t new_port_map_bytes = new_port_map_size * sizeof(PortData); |
70 port_map_ = reinterpret_cast<PortData*>(realloc(port_map_, | 70 port_map_ = reinterpret_cast<PortData*>(realloc(port_map_, |
71 new_port_map_bytes)); | 71 new_port_map_bytes)); |
72 ASSERT(port_map_ != NULL); | 72 ASSERT(port_map_ != NULL); |
73 size_t port_map_bytes = port_map_size_ * sizeof(PortData); | 73 size_t port_map_bytes = port_map_size_ * sizeof(PortData); |
74 memset(port_map_ + port_map_bytes, | 74 memset(port_map_ + port_map_size_, |
75 0, | 75 0, |
76 new_port_map_bytes - port_map_bytes); | 76 new_port_map_bytes - port_map_bytes); |
77 port_map_size_ = new_port_map_size; | 77 port_map_size_ = new_port_map_size; |
78 } | 78 } |
79 | 79 |
80 /* | 80 /* |
81 * Only change the port map entries count if SetPort changes | 81 * Only change the port map entries count if SetPort changes |
82 * the port map state. | 82 * the port map state. |
83 */ | 83 */ |
84 if (dart_port == 0 && PortFor(fd) != 0) { | 84 if (dart_port == 0 && PortFor(fd) != 0) { |
(...skipping 231 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
316 FATAL("Create start event handler thread"); | 316 FATAL("Create start event handler thread"); |
317 } | 317 } |
318 } | 318 } |
319 | 319 |
320 | 320 |
321 void EventHandlerImplementation::SendData(intptr_t id, | 321 void EventHandlerImplementation::SendData(intptr_t id, |
322 Dart_Port dart_port, | 322 Dart_Port dart_port, |
323 intptr_t data) { | 323 intptr_t data) { |
324 RegisterFdWakeup(id, dart_port, data); | 324 RegisterFdWakeup(id, dart_port, data); |
325 } | 325 } |
OLD | NEW |