Index: ppapi/proxy/directory_reader_resource.cc |
diff --git a/ppapi/proxy/directory_reader_resource.cc b/ppapi/proxy/directory_reader_resource.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..54a330ff2c55f522e8e323a4fe43e06ff5e50a1a |
--- /dev/null |
+++ b/ppapi/proxy/directory_reader_resource.cc |
@@ -0,0 +1,121 @@ |
+// Copyright (c) 2013 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+#include "ppapi/proxy/directory_reader_resource.h" |
+ |
+#include "base/bind.h" |
+#include "ipc/ipc_message.h" |
+#include "ppapi/c/pp_errors.h" |
+#include "ppapi/proxy/dispatch_reply_message.h" |
+#include "ppapi/proxy/ppapi_messages.h" |
+#include "ppapi/proxy/ppb_file_ref_proxy.h" |
+#include "ppapi/shared_impl/ppapi_globals.h" |
+#include "ppapi/shared_impl/resource_tracker.h" |
+#include "ppapi/shared_impl/tracked_callback.h" |
+#include "ppapi/thunk/enter.h" |
+#include "ppapi/thunk/ppb_file_ref_api.h" |
+ |
+using ppapi::proxy::PPB_FileRef_Proxy; |
+ |
+namespace ppapi { |
+namespace proxy { |
+ |
+DirectoryReaderResource::DirectoryReaderResource( |
+ Connection connection, |
+ PP_Instance instance, |
+ PP_Resource directory_ref) |
+ : PluginResource(connection, instance), |
+ directory_ref_(directory_ref), |
+ output_(NULL), |
+ has_more_(true) { |
+ PpapiGlobals::Get()->GetResourceTracker()->AddRefResource(directory_ref_); |
+} |
+ |
+DirectoryReaderResource::~DirectoryReaderResource() { |
+ ResourceTracker* tracker = PpapiGlobals::Get()->GetResourceTracker(); |
+ while (!entries_.empty()) { |
+ tracker->ReleaseResource(entries_.front().file_ref); |
+ entries_.pop(); |
+ } |
+ tracker->ReleaseResource(directory_ref_); |
+} |
+ |
+thunk::PPB_DirectoryReader_API* |
+DirectoryReaderResource::AsPPB_DirectoryReader_API() { |
+ return this; |
+} |
+ |
+int32_t DirectoryReaderResource::GetNextEntry( |
+ PP_DirectoryEntry_Dev* entry, |
+ scoped_refptr<TrackedCallback> callback) { |
+ if (TrackedCallback::IsPending(callback_)) |
+ return PP_ERROR_INPROGRESS; |
+ |
+ output_ = entry; |
+ callback_ = callback; |
+ |
+ if (FillUpEntry()) |
+ return PP_OK; |
+ |
+ if (!sent_create_to_renderer()) |
+ SendCreate(RENDERER, PpapiHostMsg_DirectoryReader_Create()); |
+ |
+ ppapi::ResourceTracker* tracker = PpapiGlobals::Get()->GetResourceTracker(); |
+ PpapiHostMsg_DirectoryReader_GetEntries msg( |
+ tracker->GetResource(directory_ref_)->host_resource()); |
+ Call<PpapiPluginMsg_DirectoryReader_GetEntriesReply>( |
+ RENDERER, msg, |
+ base::Bind(&DirectoryReaderResource::OnPluginMsgGetEntriesReply, this)); |
+ return PP_OK_COMPLETIONPENDING; |
+} |
+ |
+void DirectoryReaderResource::OnPluginMsgGetEntriesReply( |
+ const ResourceMessageReplyParams& params, |
+ const std::vector<ppapi::PPB_FileRef_CreateInfo>& infos, |
+ const std::vector<PP_FileType>& file_types, |
+ bool has_more) { |
+ CHECK_EQ(infos.size(), file_types.size()); |
+ |
+ for (std::vector<ppapi::PPB_FileRef_CreateInfo>::size_type i = 0; |
+ i < infos.size(); ++i) { |
+ PP_DirectoryEntry_Dev entry; |
+ entry.file_ref = PPB_FileRef_Proxy::DeserializeFileRef(infos[i]); |
+ entry.file_type = file_types[i]; |
+ entries_.push(entry); |
+ } |
+ |
+ // Current implementation returns all entries at once from the host-side. |
+ // TODO(nhiroki): The host-side should return entries in multiple chunks. |
+ has_more_ = has_more; |
+ DCHECK(!has_more_); |
dmichael (off chromium)
2013/01/29 21:22:42
If we never use this parameter currently, maybe we
nhiroki
2013/01/30 09:24:51
Done.
|
+ |
+ if (!TrackedCallback::IsPending(callback_)) |
+ return; |
+ |
+ FillUpEntry(); |
+ callback_->Run(params.result()); |
+} |
+ |
+bool DirectoryReaderResource::FillUpEntry() { |
+ DCHECK(output_); |
+ |
+ if (!entries_.empty()) { |
+ *output_ = entries_.front(); |
+ entries_.pop(); |
+ output_ = NULL; |
+ return true; |
+ } |
+ |
+ if (!has_more_) { |
+ output_->file_ref = 0; |
+ output_->file_type = PP_FILETYPE_OTHER; |
+ output_ = NULL; |
+ return true; |
+ } |
+ |
+ return false; |
+} |
+ |
+} // namespace proxy |
+} // namespace ppapi |