| 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_LINUX) | 6 #if defined(TARGET_OS_LINUX) |
| 7 | 7 |
| 8 #include <errno.h> // NOLINT | 8 #include <errno.h> // NOLINT |
| 9 #include <stdio.h> // NOLINT | 9 #include <stdio.h> // NOLINT |
| 10 #include <stdlib.h> // NOLINT | 10 #include <stdlib.h> // NOLINT |
| (...skipping 186 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 197 intptr_t backlog) { | 197 intptr_t backlog) { |
| 198 intptr_t fd; | 198 intptr_t fd; |
| 199 struct sockaddr_in server_address; | 199 struct sockaddr_in server_address; |
| 200 | 200 |
| 201 in_addr_t s_addr = inet_addr(host); | 201 in_addr_t s_addr = inet_addr(host); |
| 202 if (s_addr == INADDR_NONE) { | 202 if (s_addr == INADDR_NONE) { |
| 203 return -5; | 203 return -5; |
| 204 } | 204 } |
| 205 | 205 |
| 206 fd = TEMP_FAILURE_RETRY(socket(AF_INET, SOCK_STREAM, 0)); | 206 fd = TEMP_FAILURE_RETRY(socket(AF_INET, SOCK_STREAM, 0)); |
| 207 if (fd < 0) { | 207 if (fd < 0) return -1; |
| 208 Log::PrintErr("Error CreateBind: %s\n", strerror(errno)); | |
| 209 return -1; | |
| 210 } | |
| 211 | 208 |
| 212 FDUtils::SetCloseOnExec(fd); | 209 FDUtils::SetCloseOnExec(fd); |
| 213 | 210 |
| 214 int optval = 1; | 211 int optval = 1; |
| 215 TEMP_FAILURE_RETRY( | 212 TEMP_FAILURE_RETRY( |
| 216 setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval))); | 213 setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(optval))); |
| 217 | 214 |
| 218 server_address.sin_family = AF_INET; | 215 server_address.sin_family = AF_INET; |
| 219 server_address.sin_port = htons(port); | 216 server_address.sin_port = htons(port); |
| 220 server_address.sin_addr.s_addr = s_addr; | 217 server_address.sin_addr.s_addr = s_addr; |
| 221 memset(&server_address.sin_zero, 0, sizeof(server_address.sin_zero)); | 218 memset(&server_address.sin_zero, 0, sizeof(server_address.sin_zero)); |
| 222 | 219 |
| 223 if (TEMP_FAILURE_RETRY( | 220 if (TEMP_FAILURE_RETRY( |
| 224 bind(fd, | 221 bind(fd, |
| 225 reinterpret_cast<struct sockaddr *>(&server_address), | 222 reinterpret_cast<struct sockaddr *>(&server_address), |
| 226 sizeof(server_address))) < 0) { | 223 sizeof(server_address))) < 0) { |
| 227 TEMP_FAILURE_RETRY(close(fd)); | 224 TEMP_FAILURE_RETRY(close(fd)); |
| 228 Log::PrintErr("Error Bind: %s\n", strerror(errno)); | |
| 229 return -1; | 225 return -1; |
| 230 } | 226 } |
| 231 | 227 |
| 232 if (TEMP_FAILURE_RETRY(listen(fd, backlog)) != 0) { | 228 if (TEMP_FAILURE_RETRY(listen(fd, backlog > 0 ? backlog : SOMAXCONN)) != 0) { |
| 233 Log::PrintErr("Error Listen: %s\n", strerror(errno)); | 229 TEMP_FAILURE_RETRY(close(fd)); |
| 234 return -1; | 230 return -1; |
| 235 } | 231 } |
| 236 | 232 |
| 237 FDUtils::SetNonBlocking(fd); | 233 FDUtils::SetNonBlocking(fd); |
| 238 return fd; | 234 return fd; |
| 239 } | 235 } |
| 240 | 236 |
| 241 | 237 |
| 242 static bool IsTemporaryAcceptError(int error) { | 238 static bool IsTemporaryAcceptError(int error) { |
| 243 // On Linux a number of protocol errors should be treated as EAGAIN. | 239 // On Linux a number of protocol errors should be treated as EAGAIN. |
| (...skipping 30 matching lines...) Expand all Loading... |
| 274 int err = TEMP_FAILURE_RETRY(close(fd)); | 270 int err = TEMP_FAILURE_RETRY(close(fd)); |
| 275 if (err != 0) { | 271 if (err != 0) { |
| 276 const int kBufferSize = 1024; | 272 const int kBufferSize = 1024; |
| 277 char error_message[kBufferSize]; | 273 char error_message[kBufferSize]; |
| 278 strerror_r(errno, error_message, kBufferSize); | 274 strerror_r(errno, error_message, kBufferSize); |
| 279 Log::PrintErr("%s\n", error_message); | 275 Log::PrintErr("%s\n", error_message); |
| 280 } | 276 } |
| 281 } | 277 } |
| 282 | 278 |
| 283 #endif // defined(TARGET_OS_LINUX) | 279 #endif // defined(TARGET_OS_LINUX) |
| OLD | NEW |