Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(901)

Unified Diff: runtime/bin/socket.cc

Issue 78393005: More cleanup in the socket C++ code (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « no previous file | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: runtime/bin/socket.cc
diff --git a/runtime/bin/socket.cc b/runtime/bin/socket.cc
index 02f53e75fb246644c0e26eec2fcd44f8858c2c3b..bc07ea09ba968d673e2f5d086e416e6a8252d856 100644
--- a/runtime/bin/socket.cc
+++ b/runtime/bin/socket.cc
@@ -26,23 +26,25 @@ Dart_Port* Socket::service_ports_ = NULL;
int Socket::service_ports_index_ = 0;
-static Dart_Handle GetSockAddr(Dart_Handle obj, RawAddr* addr) {
+static void GetSockAddr(Dart_Handle obj, RawAddr* addr) {
Dart_TypedData_Type data_type;
uint8_t* data = NULL;
intptr_t len;
Dart_Handle result = Dart_TypedDataAcquireData(
obj, &data_type, reinterpret_cast<void**>(&data), &len);
- if (Dart_IsError(result)) return result;
+ if (Dart_IsError(result)) {
+ printf("XXXXXXXXXXXXXXXXXX\n");
Anders Johnsen 2013/11/22 06:43:41 Debug print.
Søren Gjesse 2013/11/22 07:18:52 Removed.
+ Dart_TypedDataReleaseData(obj);
Anders Johnsen 2013/11/22 06:43:41 Why do we need to release the data, when we failed
+ Dart_PropagateError(result);
+ }
memmove(reinterpret_cast<void *>(addr), data, len);
- return Dart_Null();
+ Dart_TypedDataReleaseData(obj);
}
void FUNCTION_NAME(InternetAddress_Fixed)(Dart_NativeArguments args) {
- Dart_Handle id_obj = Dart_GetNativeArgument(args, 0);
- ASSERT(!Dart_IsError(id_obj));
int64_t id = 0;
- bool ok = DartUtils::GetInt64Value(id_obj, &id);
+ bool ok = DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 0), &id);
ASSERT(ok);
USE(ok);
RawAddr raw;
@@ -103,18 +105,14 @@ void FUNCTION_NAME(InternetAddress_Parse)(Dart_NativeArguments args) {
void FUNCTION_NAME(Socket_CreateConnect)(Dart_NativeArguments args) {
- Dart_Handle socket_obj = Dart_GetNativeArgument(args, 0);
- Dart_Handle host_obj = Dart_GetNativeArgument(args, 1);
RawAddr addr;
- Dart_Handle result = GetSockAddr(host_obj, &addr);
+ GetSockAddr(Dart_GetNativeArgument(args, 1), &addr);
int64_t port = 0;
- if (!Dart_IsError(result) &&
- DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 2), &port)) {
+ if (DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 2), &port)) {
intptr_t socket = Socket::CreateConnect(addr, port);
OSError error;
- Dart_TypedDataReleaseData(host_obj);
if (socket >= 0) {
- Socket::SetSocketIdNativeField(socket_obj, socket);
+ Socket::SetSocketIdNativeField(Dart_GetNativeArgument(args, 0), socket);
Dart_SetReturnValue(args, Dart_True());
} else {
Dart_SetReturnValue(args, DartUtils::NewDartOSError(&error));
@@ -147,8 +145,7 @@ void FUNCTION_NAME(Socket_Read)(Dart_NativeArguments args) {
intptr_t available = Socket::Available(socket);
if (available > 0) {
int64_t length = 0;
- Dart_Handle length_obj = Dart_GetNativeArgument(args, 1);
- if (DartUtils::GetInt64Value(length_obj, &length)) {
+ if (DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 1), &length)) {
if (length == -1 || available < length) {
length = available;
}
@@ -292,44 +289,35 @@ void FUNCTION_NAME(Socket_GetType)(Dart_NativeArguments args) {
void FUNCTION_NAME(Socket_GetStdioHandle)(Dart_NativeArguments args) {
- Dart_Handle socket_obj = Dart_GetNativeArgument(args, 0);
intptr_t num =
DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 1));
ASSERT(num == 0 || num == 1 || num == 2);
intptr_t socket = Socket::GetStdioHandle(num);
- Socket::SetSocketIdNativeField(socket_obj, socket);
+ Socket::SetSocketIdNativeField(Dart_GetNativeArgument(args, 0), socket);
Dart_SetReturnValue(args, Dart_NewBoolean(socket >= 0));
}
void FUNCTION_NAME(Socket_SetSocketId)(Dart_NativeArguments args) {
- Dart_Handle socket_obj = Dart_GetNativeArgument(args, 0);
intptr_t id =
DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 1));
- Socket::SetSocketIdNativeField(socket_obj, id);
+ Socket::SetSocketIdNativeField(Dart_GetNativeArgument(args, 0), id);
}
void FUNCTION_NAME(ServerSocket_CreateBindListen)(Dart_NativeArguments args) {
- Dart_Handle socket_obj = Dart_GetNativeArgument(args, 0);
- Dart_Handle host_obj = Dart_GetNativeArgument(args, 1);
RawAddr addr;
- Dart_Handle result = GetSockAddr(host_obj, &addr);
- Dart_Handle port_obj = Dart_GetNativeArgument(args, 2);
- Dart_Handle backlog_obj = Dart_GetNativeArgument(args, 3);
- Dart_Handle v6_only_obj = Dart_GetNativeArgument(args, 4);
- bool v6_only = DartUtils::GetBooleanValue(v6_only_obj);
int64_t port = 0;
int64_t backlog = 0;
- if (!Dart_IsError(result) &&
- DartUtils::GetInt64Value(port_obj, &port) &&
- DartUtils::GetInt64Value(backlog_obj, &backlog)) {
+ GetSockAddr(Dart_GetNativeArgument(args, 1), &addr);
+ if (DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 2), &port) &&
+ DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 3), &backlog)) {
+ bool v6_only = DartUtils::GetBooleanValue(Dart_GetNativeArgument(args, 4));
intptr_t socket = ServerSocket::CreateBindListen(
addr, port, backlog, v6_only);
OSError error;
- Dart_TypedDataReleaseData(host_obj);
if (socket >= 0) {
- Socket::SetSocketIdNativeField(socket_obj, socket);
+ Socket::SetSocketIdNativeField(Dart_GetNativeArgument(args, 0), socket);
Dart_SetReturnValue(args, Dart_True());
} else {
if (socket == -5) {
@@ -351,10 +339,9 @@ void FUNCTION_NAME(ServerSocket_CreateBindListen)(Dart_NativeArguments args) {
void FUNCTION_NAME(ServerSocket_Accept)(Dart_NativeArguments args) {
intptr_t socket =
Socket::GetSocketIdNativeField(Dart_GetNativeArgument(args, 0));
- Dart_Handle result_socket_obj = Dart_GetNativeArgument(args, 1);
intptr_t new_socket = ServerSocket::Accept(socket);
if (new_socket >= 0) {
- Socket::SetSocketIdNativeField(result_socket_obj, new_socket);
+ Socket::SetSocketIdNativeField(Dart_GetNativeArgument(args, 1), new_socket);
Dart_SetReturnValue(args, Dart_True());
} else if (new_socket == ServerSocket::kTemporaryFailure) {
Dart_SetReturnValue(args, Dart_False());
« no previous file with comments | « no previous file | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698