mirror of
https://github.com/dart-lang/sdk
synced 2024-10-03 20:11:39 +00:00
7f60b90a48
BUG=dart:4730 Review URL: https://codereview.chromium.org//11748017 git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge/dart@16636 260f80e4-7a28-3924-810f-c04153c831b5
370 lines
12 KiB
C++
370 lines
12 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();
|
|
}
|
|
|
|
|
|
void FUNCTION_NAME(Directory_List)(Dart_NativeArguments args) {
|
|
Dart_EnterScope();
|
|
Dart_Handle path = Dart_GetNativeArgument(args, 0);
|
|
Dart_Handle recursive = Dart_GetNativeArgument(args, 1);
|
|
// Create the list to hold the directory listing here, and pass it to the
|
|
// SyncDirectoryListing object, which adds elements to it.
|
|
Dart_Handle results =
|
|
Dart_New(DartUtils::GetDartClass(DartUtils::kCoreLibURL, "List"),
|
|
Dart_Null(),
|
|
0,
|
|
NULL);
|
|
SyncDirectoryListing sync_listing(results);
|
|
Directory::List(DartUtils::GetStringValue(path),
|
|
DartUtils::GetBooleanValue(recursive),
|
|
&sync_listing);
|
|
Dart_SetReturnValue(args, results);
|
|
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()) {
|
|
AsyncDirectoryListing* dir_listing =
|
|
new AsyncDirectoryListing(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(AsyncDirectoryListing::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(AsyncDirectoryListing::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(AsyncDirectoryListing::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* AsyncDirectoryListing::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 AsyncDirectoryListing::HandleDirectory(char* dir_name) {
|
|
CObjectArray* response = NewResponse(kListDirectory, dir_name);
|
|
return Dart_PostCObject(response_port_, response->AsApiCObject());
|
|
}
|
|
|
|
|
|
bool AsyncDirectoryListing::HandleFile(char* file_name) {
|
|
CObjectArray* response = NewResponse(kListFile, file_name);
|
|
return Dart_PostCObject(response_port_, response->AsApiCObject());
|
|
}
|
|
|
|
|
|
bool AsyncDirectoryListing::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());
|
|
}
|
|
|
|
bool SyncDirectoryListing::HandleDirectory(char* dir_name) {
|
|
Dart_Handle dir_name_dart = DartUtils::NewString(dir_name);
|
|
Dart_Handle dir = Dart_New(directory_class_, Dart_Null(), 1, &dir_name_dart);
|
|
Dart_Invoke(results_, add_string_, 1, &dir);
|
|
return true;
|
|
}
|
|
|
|
bool SyncDirectoryListing::HandleFile(char* file_name) {
|
|
Dart_Handle file_name_dart = DartUtils::NewString(file_name);
|
|
Dart_Handle file = Dart_New(file_class_, Dart_Null(), 1, &file_name_dart);
|
|
Dart_Invoke(results_, add_string_, 1, &file);
|
|
return true;
|
|
}
|
|
|
|
bool SyncDirectoryListing::HandleError(const char* dir_name) {
|
|
Dart_Handle dart_os_error = DartUtils::NewDartOSError();
|
|
Dart_Handle args[3];
|
|
args[0] = DartUtils::NewString("Directory listing failed");
|
|
args[1] = DartUtils::NewString(dir_name);
|
|
args[2] = dart_os_error;
|
|
Dart_ThrowException(Dart_New(
|
|
DartUtils::GetDartClass(DartUtils::kIOLibURL, "DirectoryIOException"),
|
|
Dart_Null(),
|
|
3,
|
|
args));
|
|
return true;
|
|
}
|