mirror of
https://github.com/dart-lang/sdk
synced 2024-10-03 20:22:23 +00:00
ebbb7c4134
compatible with webkit and will allow for easy externalization of strings. One byte strings are retained for pure ASCII strings. (The language specification was changed recently to reflect this as follows "A string is a sequence of UTF-16 code units"). - Remove four byte string class and all references to it. - Rename some of the string functions in Dart API to make them consistent and better describe the underlying functionality Dart_NewString => Dart_NewStringFromCString Dart_NewString8 => Dart_NewStringFromUTF8 Dart_NewString16 => Dart_NewStringFromUTF16 Dart_NewString32 => Dart_NewStringFromUTF32 Dart_NewExternalString8 => Dart_NewExternalUTF8String Dart_NewExternalString16 => Dart_NewExternalUTF16String Dart_NewExternalString32 => Dart_NewExternalUTF32String Dart_StringGet8 => Dart_StringToUTF8 Dart_StringGet16 => Dart_StringToUTF16 Dart_StringToCString => Dart_StringToCString Dart_IsString8 => Removed Dart_IsString16 -> Removed Dart_StringToBytes -> Removed Dart_StringGet32 -> Removed Review URL: https://codereview.chromium.org//11318018 git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge/dart@14357 260f80e4-7a28-3924-810f-c04153c831b5
320 lines
10 KiB
C++
320 lines
10 KiB
C++
// Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file
|
|
// for details. All rights reserved. Use of this source code is governed by a
|
|
// BSD-style license that can be found in the LICENSE file.
|
|
|
|
#include "bin/directory.h"
|
|
|
|
#include "bin/dartutils.h"
|
|
#include "bin/thread.h"
|
|
#include "include/dart_api.h"
|
|
#include "platform/assert.h"
|
|
|
|
dart::Mutex Directory::mutex_;
|
|
int Directory::service_ports_size_ = 0;
|
|
Dart_Port* Directory::service_ports_ = NULL;
|
|
int Directory::service_ports_index_ = 0;
|
|
|
|
void FUNCTION_NAME(Directory_Current)(Dart_NativeArguments args) {
|
|
Dart_EnterScope();
|
|
char* current = Directory::Current();
|
|
if (current != NULL) {
|
|
Dart_SetReturnValue(args, DartUtils::NewString(current));
|
|
free(current);
|
|
}
|
|
Dart_ExitScope();
|
|
}
|
|
|
|
|
|
void FUNCTION_NAME(Directory_Exists)(Dart_NativeArguments args) {
|
|
static const int kExists = 1;
|
|
static const int kDoesNotExist = 0;
|
|
Dart_EnterScope();
|
|
Dart_Handle path = Dart_GetNativeArgument(args, 0);
|
|
Directory::ExistsResult result =
|
|
Directory::Exists(DartUtils::GetStringValue(path));
|
|
if (result == Directory::EXISTS) {
|
|
Dart_SetReturnValue(args, Dart_NewInteger(kExists));
|
|
} else if (result == Directory::DOES_NOT_EXIST) {
|
|
Dart_SetReturnValue(args, Dart_NewInteger(kDoesNotExist));
|
|
} else {
|
|
Dart_Handle err = DartUtils::NewDartOSError();
|
|
if (Dart_IsError(err)) Dart_PropagateError(err);
|
|
Dart_SetReturnValue(args, err);
|
|
}
|
|
Dart_ExitScope();
|
|
}
|
|
|
|
|
|
void FUNCTION_NAME(Directory_Create)(Dart_NativeArguments args) {
|
|
Dart_EnterScope();
|
|
Dart_Handle path = Dart_GetNativeArgument(args, 0);
|
|
if (Directory::Create(DartUtils::GetStringValue(path))) {
|
|
Dart_SetReturnValue(args, Dart_True());
|
|
} else {
|
|
Dart_Handle err = DartUtils::NewDartOSError();
|
|
if (Dart_IsError(err)) Dart_PropagateError(err);
|
|
Dart_SetReturnValue(args, err);
|
|
}
|
|
Dart_ExitScope();
|
|
}
|
|
|
|
|
|
void FUNCTION_NAME(Directory_CreateTemp)(Dart_NativeArguments args) {
|
|
Dart_EnterScope();
|
|
Dart_Handle path = Dart_GetNativeArgument(args, 0);
|
|
char* result = Directory::CreateTemp(DartUtils::GetStringValue(path));
|
|
if (result != NULL) {
|
|
Dart_SetReturnValue(args, DartUtils::NewString(result));
|
|
free(result);
|
|
} else {
|
|
Dart_Handle err = DartUtils::NewDartOSError();
|
|
if (Dart_IsError(err)) Dart_PropagateError(err);
|
|
Dart_SetReturnValue(args, err);
|
|
}
|
|
Dart_ExitScope();
|
|
}
|
|
|
|
|
|
void FUNCTION_NAME(Directory_Delete)(Dart_NativeArguments args) {
|
|
Dart_EnterScope();
|
|
Dart_Handle path = Dart_GetNativeArgument(args, 0);
|
|
Dart_Handle recursive = Dart_GetNativeArgument(args, 1);
|
|
if (Directory::Delete(DartUtils::GetStringValue(path),
|
|
DartUtils::GetBooleanValue(recursive))) {
|
|
Dart_SetReturnValue(args, Dart_True());
|
|
} else {
|
|
Dart_Handle err = DartUtils::NewDartOSError();
|
|
if (Dart_IsError(err)) Dart_PropagateError(err);
|
|
Dart_SetReturnValue(args, err);
|
|
}
|
|
Dart_ExitScope();
|
|
}
|
|
|
|
|
|
void FUNCTION_NAME(Directory_Rename)(Dart_NativeArguments args) {
|
|
Dart_EnterScope();
|
|
Dart_Handle path = Dart_GetNativeArgument(args, 0);
|
|
Dart_Handle newPath = Dart_GetNativeArgument(args, 1);
|
|
if (Directory::Rename(DartUtils::GetStringValue(path),
|
|
DartUtils::GetStringValue(newPath))) {
|
|
Dart_SetReturnValue(args, Dart_True());
|
|
} else {
|
|
Dart_Handle err = DartUtils::NewDartOSError();
|
|
if (Dart_IsError(err)) Dart_PropagateError(err);
|
|
Dart_SetReturnValue(args, err);
|
|
}
|
|
Dart_ExitScope();
|
|
}
|
|
|
|
|
|
static CObject* DirectoryCreateRequest(const CObjectArray& request) {
|
|
if (request.Length() == 2 && request[1]->IsString()) {
|
|
CObjectString path(request[1]);
|
|
if (Directory::Create(path.CString())) {
|
|
return CObject::True();
|
|
} else {
|
|
return CObject::NewOSError();
|
|
}
|
|
}
|
|
return CObject::IllegalArgumentError();
|
|
}
|
|
|
|
|
|
static CObject* DirectoryDeleteRequest(const CObjectArray& request) {
|
|
if (request.Length() == 3 && request[1]->IsString() && request[2]->IsBool()) {
|
|
CObjectString path(request[1]);
|
|
CObjectBool recursive(request[2]);
|
|
if (Directory::Delete(path.CString(), recursive.Value())) {
|
|
return CObject::True();
|
|
} else {
|
|
return CObject::NewOSError();
|
|
}
|
|
}
|
|
return CObject::IllegalArgumentError();
|
|
}
|
|
|
|
|
|
static CObject* DirectoryExistsRequest(const CObjectArray& request) {
|
|
static const int kExists = 1;
|
|
static const int kDoesNotExist = 0;
|
|
if (request.Length() == 2 && request[1]->IsString()) {
|
|
CObjectString path(request[1]);
|
|
Directory::ExistsResult result = Directory::Exists(path.CString());
|
|
if (result == Directory::EXISTS) {
|
|
return new CObjectInt32(CObject::NewInt32(kExists));
|
|
} else if (result == Directory::DOES_NOT_EXIST) {
|
|
return new CObjectInt32(CObject::NewInt32(kDoesNotExist));
|
|
} else {
|
|
return CObject::NewOSError();
|
|
}
|
|
}
|
|
return CObject::IllegalArgumentError();
|
|
}
|
|
|
|
|
|
static CObject* DirectoryCreateTempRequest(const CObjectArray& request) {
|
|
if (request.Length() == 2 && request[1]->IsString()) {
|
|
CObjectString path(request[1]);
|
|
char* result = Directory::CreateTemp(path.CString());
|
|
if (result != NULL) {
|
|
CObject* temp_dir = new CObjectString(CObject::NewString(result));
|
|
free(result);
|
|
return temp_dir;
|
|
} else {
|
|
return CObject::NewOSError();
|
|
}
|
|
}
|
|
return CObject::IllegalArgumentError();
|
|
}
|
|
|
|
|
|
static CObject* DirectoryListRequest(const CObjectArray& request,
|
|
Dart_Port response_port) {
|
|
if (request.Length() == 3 && request[1]->IsString() && request[2]->IsBool()) {
|
|
DirectoryListing* dir_listing = new DirectoryListing(response_port);
|
|
CObjectString path(request[1]);
|
|
CObjectBool recursive(request[2]);
|
|
bool completed = Directory::List(
|
|
path.CString(), recursive.Value(), dir_listing);
|
|
delete dir_listing;
|
|
CObjectArray* response = new CObjectArray(CObject::NewArray(2));
|
|
response->SetAt(
|
|
0, new CObjectInt32(CObject::NewInt32(DirectoryListing::kListDone)));
|
|
response->SetAt(1, CObject::Bool(completed));
|
|
return response;
|
|
}
|
|
// Respond with an illegal argument list error message.
|
|
CObjectArray* response = new CObjectArray(CObject::NewArray(3));
|
|
response->SetAt(0, new CObjectInt32(
|
|
CObject::NewInt32(DirectoryListing::kListError)));
|
|
response->SetAt(1, CObject::Null());
|
|
response->SetAt(2, CObject::IllegalArgumentError());
|
|
Dart_PostCObject(response_port, response->AsApiCObject());
|
|
|
|
response = new CObjectArray(CObject::NewArray(2));
|
|
response->SetAt(
|
|
0, new CObjectInt32(CObject::NewInt32(DirectoryListing::kListDone)));
|
|
response->SetAt(1, CObject::False());
|
|
return response;
|
|
}
|
|
|
|
|
|
static CObject* DirectoryRenameRequest(const CObjectArray& request,
|
|
Dart_Port response_port) {
|
|
if (request.Length() == 3 &&
|
|
request[1]->IsString() &&
|
|
request[2]->IsString()) {
|
|
CObjectString path(request[1]);
|
|
CObjectString new_path(request[2]);
|
|
bool completed = Directory::Rename(path.CString(), new_path.CString());
|
|
if (completed) return CObject::True();
|
|
return CObject::NewOSError();
|
|
}
|
|
return CObject::IllegalArgumentError();
|
|
}
|
|
|
|
|
|
void DirectoryService(Dart_Port dest_port_id,
|
|
Dart_Port reply_port_id,
|
|
Dart_CObject* message) {
|
|
CObject* response = CObject::False();
|
|
CObjectArray request(message);
|
|
if (message->type == Dart_CObject::kArray) {
|
|
if (request.Length() > 1 && request[0]->IsInt32()) {
|
|
CObjectInt32 requestType(request[0]);
|
|
switch (requestType.Value()) {
|
|
case Directory::kCreateRequest:
|
|
response = DirectoryCreateRequest(request);
|
|
break;
|
|
case Directory::kDeleteRequest:
|
|
response = DirectoryDeleteRequest(request);
|
|
break;
|
|
case Directory::kExistsRequest:
|
|
response = DirectoryExistsRequest(request);
|
|
break;
|
|
case Directory::kCreateTempRequest:
|
|
response = DirectoryCreateTempRequest(request);
|
|
break;
|
|
case Directory::kListRequest:
|
|
response = DirectoryListRequest(request, reply_port_id);
|
|
break;
|
|
case Directory::kRenameRequest:
|
|
response = DirectoryRenameRequest(request, reply_port_id);
|
|
break;
|
|
default:
|
|
UNREACHABLE();
|
|
}
|
|
}
|
|
}
|
|
|
|
Dart_PostCObject(reply_port_id, response->AsApiCObject());
|
|
}
|
|
|
|
|
|
Dart_Port Directory::GetServicePort() {
|
|
MutexLocker lock(&mutex_);
|
|
if (service_ports_size_ == 0) {
|
|
ASSERT(service_ports_ == NULL);
|
|
service_ports_size_ = 16;
|
|
service_ports_ = new Dart_Port[service_ports_size_];
|
|
service_ports_index_ = 0;
|
|
for (int i = 0; i < service_ports_size_; i++) {
|
|
service_ports_[i] = ILLEGAL_PORT;
|
|
}
|
|
}
|
|
|
|
Dart_Port result = service_ports_[service_ports_index_];
|
|
if (result == ILLEGAL_PORT) {
|
|
result = Dart_NewNativePort("DirectoryService",
|
|
DirectoryService,
|
|
true);
|
|
ASSERT(result != ILLEGAL_PORT);
|
|
service_ports_[service_ports_index_] = result;
|
|
}
|
|
service_ports_index_ = (service_ports_index_ + 1) % service_ports_size_;
|
|
return result;
|
|
}
|
|
|
|
|
|
void FUNCTION_NAME(Directory_NewServicePort)(Dart_NativeArguments args) {
|
|
Dart_EnterScope();
|
|
Dart_SetReturnValue(args, Dart_Null());
|
|
Dart_Port service_port = Directory::GetServicePort();
|
|
if (service_port != ILLEGAL_PORT) {
|
|
// Return a send port for the service port.
|
|
Dart_Handle send_port = Dart_NewSendPort(service_port);
|
|
Dart_SetReturnValue(args, send_port);
|
|
}
|
|
Dart_ExitScope();
|
|
}
|
|
|
|
|
|
CObjectArray* DirectoryListing::NewResponse(Response type, char* arg) {
|
|
CObjectArray* response = new CObjectArray(CObject::NewArray(2));
|
|
response->SetAt(0, new CObjectInt32(CObject::NewInt32(type)));
|
|
response->SetAt(1, new CObjectString(CObject::NewString(arg)));
|
|
return response;
|
|
}
|
|
|
|
|
|
bool DirectoryListing::HandleDirectory(char* dir_name) {
|
|
CObjectArray* response = NewResponse(kListDirectory, dir_name);
|
|
return Dart_PostCObject(response_port_, response->AsApiCObject());
|
|
}
|
|
|
|
|
|
bool DirectoryListing::HandleFile(char* file_name) {
|
|
CObjectArray* response = NewResponse(kListFile, file_name);
|
|
return Dart_PostCObject(response_port_, response->AsApiCObject());
|
|
}
|
|
|
|
|
|
bool DirectoryListing::HandleError(const char* dir_name) {
|
|
CObject* err = CObject::NewOSError();
|
|
CObjectArray* response = new CObjectArray(CObject::NewArray(3));
|
|
response->SetAt(0, new CObjectInt32(CObject::NewInt32(kListError)));
|
|
response->SetAt(1, new CObjectString(CObject::NewString(dir_name)));
|
|
response->SetAt(2, err);
|
|
return Dart_PostCObject(response_port_, response->AsApiCObject());
|
|
}
|