Pepper: Stop using SRPC for irt_open_resource().

chrome/test/data/nacl/manifest_file/pm_manifest_file_test.cc

-/*

[Mark Seaborn, 2014/08/28 23:40:22]

BTW, since this is a big change, it would be nice to commit the removal of these
old tests as a separate change first.

[teravest, 2014/09/04 22:13:29]

Done.

- * Copyright 2014 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.
- */
-
-//
-// Post-message based test for simple rpc based access to name services.
-//
-
-#include <string>
-
-#include <assert.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <inttypes.h>
-#include <sys/fcntl.h>
-#include <string.h>
-#include <unistd.h>
-#include <pthread.h>
-
-#include "native_client/src/include/nacl_base.h"
-#include "native_client/src/public/imc_syscalls.h"
-#include "native_client/src/public/name_service.h"
-#include "native_client/src/shared/platform/nacl_sync.h"
-#include "native_client/src/shared/platform/nacl_sync_checked.h"
-#include "native_client/src/shared/platform/nacl_sync_raii.h"
-#include "native_client/src/shared/srpc/nacl_srpc.h"
-
-// TODO(bsy): move weak_ref module to the shared directory
-#include "native_client/src/trusted/weak_ref/weak_ref.h"
-
-#include "ppapi/cpp/instance.h"
-#include "ppapi/cpp/module.h"
-#include "ppapi/cpp/var.h"
-
-#include "ppapi/native_client/src/trusted/weak_ref/call_on_main_thread.h"
-#include "ppapi/native_client/src/untrusted/nacl_ppapi_util/nacl_ppapi_util.h"
-#include "ppapi/native_client/src/untrusted/nacl_ppapi_util/string_buffer.h"
-
-class PostStringMessageWrapper
-    : public nacl_ppapi::EventThreadWorkStateWrapper<nacl_ppapi::VoidResult> {
- public:
-  PostStringMessageWrapper(nacl_ppapi::EventThreadWorkState<
-                             nacl_ppapi::VoidResult>
-                           *state,
-                           const std::string &msg)
-      : nacl_ppapi::EventThreadWorkStateWrapper<nacl_ppapi::VoidResult>(
-          state),
-        msg_(msg) {}
-  ~PostStringMessageWrapper();
-  const std::string &msg() const { return msg_; }
- private:
-  std::string msg_;
-
-  DISALLOW_COPY_AND_ASSIGN(PostStringMessageWrapper);
-};
-
-// ---------------------------------------------------------------------------
-
-class MyInstance;
-
-struct WorkRequest {
-  explicit WorkRequest(const std::string &message)
-      : msg(message),
-        next(reinterpret_cast<WorkRequest *>(NULL)) {}
-  std::string msg;  // copied from HandleMessage
-  WorkRequest *next;
- private:
-  DISALLOW_COPY_AND_ASSIGN(WorkRequest);
-};
-
-// A Worker object is associated with a single worker thread and a
-// plugin instance (which may be associated with multiple Worker
-// objects/threads).  It is created by a plugin instance (on the event
-// handler thread) with a refcount of 2, with the expectation that one
-// reference will be immediately handed off to its associated worker
-// thread.  When the plugin instance is about to be destroyed in the
-// event handler thread, the event handler should invoke the
-// ShouldExit member function, which automatically decrements the
-// reference associated with the event handler thread (i.e., the event
-// handler thread should no longer use the Worker*).
-class Worker {
- public:
-  explicit Worker(MyInstance *instance);
-
-  // RunToCompletion should be invoked in the worker thread.  It
-  // returns when the plugin instance went away, and will
-  // automatically unref the Worker object, so the worker thread
-  // should no longer use the Worker object pointer after invoking
-  // RunToCompletion().
-  void RunToCompletion();
-
-  WorkRequest *Dequeue();
-  void Enqueue(WorkRequest *req);
-
-  void Initialize(nacl::StringBuffer *sb);
-  void ManifestListTest(nacl::StringBuffer *sb);
-  void ManifestOpenTest(nacl::StringBuffer *sb);
-
-  // Called on the event thread as part of the instance shutdown.
-  // Automatically unreferences the Worker object, so the event thread
-  // should stop using the Worker pointer after invoking ShouldExit.
-  void ShouldExit();
-
-  void Unref();  // used only for error cleanup, e.g., when the worker
-                 // thread did not launch.
-
-  bool InitializeChannel(nacl::StringBuffer *sb);
-
- protected:
-  // Event thread operation(s):
-  //
-  // In order for a test method to send reply messages, it should use
-  // this PostStringMessage method, since (currently) the PostMessage
-  // interface is event thread-only and not thread-safe.  Returns true
-  // if successful and the thread should continue to do work, false
-  // otherwise (anchor has been abandoned).
-  bool PostStringMessage(const std::string &msg);
-  // ... more Event thread operations here.
-
- private:
-  MyInstance *instance_;  // cannot use directly from test worker thread!
-  nacl::WeakRefAnchor *anchor_;
-  // must copy out and Ref in ctor, since instance_ might go bad at any time.
-
-  NaClMutex mu_;
-  NaClCondVar cv_;  // queue not empty or should_exit_
-
-  int ref_count_;
-  WorkRequest *queue_head_;
-  WorkRequest **queue_insert_;
-
-  bool should_exit_;
-
-  ~Worker();
-
-  WorkRequest *Dequeue_mu();
-  void Enqueue_mu(WorkRequest *req);
-
-  struct DispatchTable {
-    char const *op_name;
-    void (Worker::*mfunc)(nacl::StringBuffer *sb);
-  };
-
-  bool            ns_channel_initialized_;
-  NaClSrpcChannel ns_channel_;
-
-  static DispatchTable const kDispatch[];  // null terminated
-
-  DISALLOW_COPY_AND_ASSIGN(Worker);
-};
-
-// This object represents one time the page says <embed>.
-class MyInstance : public nacl_ppapi::NaClPpapiPluginInstance {
- public:
-  explicit MyInstance(PP_Instance instance);
-  virtual ~MyInstance();
-  virtual void HandleMessage(const pp::Var& message_data);
-
-  Worker *worker() { return worker_; }
-
-  // used with plugin::WeakRefCompletionCallback
-  void PostStringMessage_EventThread(PostStringMessageWrapper *msg_wrapper,
-                                     int32_t err);
- private:
-  Worker *worker_;
-
-  DISALLOW_COPY_AND_ASSIGN(MyInstance);
-};
-
-// ---------------------------------------------------------------------------
-
-PostStringMessageWrapper::~PostStringMessageWrapper() {}
-
-// ---------------------------------------------------------------------------
-
-MyInstance::MyInstance(PP_Instance instance)
-    : nacl_ppapi::NaClPpapiPluginInstance(instance),
-      worker_(new Worker(this)) {
-}
-
-MyInstance::~MyInstance() {
-  worker_->ShouldExit();
-}
-
-void MyInstance::PostStringMessage_EventThread(
-    PostStringMessageWrapper *msg_wrapper,
-    int32_t err) {
-  PostMessage(msg_wrapper->msg());
-  msg_wrapper->SetResult(nacl_ppapi::g_void_result);
-}
-
-// ---------------------------------------------------------------------------
-
-Worker::Worker(MyInstance *instance)
-    : instance_(instance),
-      anchor_(instance->anchor()->Ref()),
-      ref_count_(2),  // one for the master and one for the dame...
-      queue_head_(NULL),
-      queue_insert_(&queue_head_),
-      should_exit_(false),
-      ns_channel_initialized_(false) {
-  NaClXMutexCtor(&mu_);
-  NaClXCondVarCtor(&cv_);
-}
-
-void Worker::Unref() {
-  bool do_delete;
-  do {
-    nacl::MutexLocker take(&mu_);
-    do_delete = (--ref_count_ == 0);
-  } while (0);
-  // dropped lock before invoking dtor
-  if (do_delete) {
-    delete this;
-  }
-}
-
-Worker::~Worker() {
-  anchor_->Unref();
-
-  WorkRequest *req;
-  while ((req = Dequeue_mu()) != NULL) {
-    delete req;
-  }
-
-  NaClMutexDtor(&mu_);
-  NaClCondVarDtor(&cv_);
-}
-
-void Worker::ShouldExit() {
-  do {
-    nacl::MutexLocker take(&mu_);
-    should_exit_ = true;
-    NaClXCondVarBroadcast(&cv_);
-  } while (0);
-  Unref();
-}
-
-WorkRequest *Worker::Dequeue_mu() {
-  WorkRequest *head = queue_head_;
-
-  if (head != NULL) {
-    queue_head_ = head->next;
-    if (queue_head_ == NULL) {
-      queue_insert_ = &queue_head_;
-    }
-  }
-  return head;
-}
-
-void Worker::Enqueue_mu(WorkRequest *req) {
-  req->next = NULL;
-  *queue_insert_ = req;
-  queue_insert_ = &req->next;
-}
-
-WorkRequest *Worker::Dequeue() {
-  nacl::MutexLocker take(&mu_);
-  return Dequeue_mu();
-}
-
-void Worker::Enqueue(WorkRequest *req) {
-  nacl::MutexLocker take(&mu_);
-  Enqueue_mu(req);
-  NaClXCondVarBroadcast(&cv_);
-}
-
-Worker::DispatchTable const Worker::kDispatch[] = {
-  { "init", &Worker::Initialize },
-  { "manifest_open", &Worker::ManifestOpenTest },
-  { reinterpret_cast<char const *>(NULL), NULL }
-};
-
-bool Worker::PostStringMessage(const std::string &msg) {
-  nacl_ppapi::EventThreadWorkState<nacl_ppapi::VoidResult> state;
-  plugin::WeakRefCallOnMainThread(anchor_,
-                                  0  /* mS */,
-                                  instance_,
-                                  &MyInstance::PostStringMessage_EventThread,
-                                  new PostStringMessageWrapper(&state, msg));
-  if (NULL == state.WaitForCompletion()) {
-    // anchor_ has been abandoned, so the plugin instance went away.
-    // we should drop our ref to the anchor, then shut down the worker
-    // thread.
-    nacl::MutexLocker take(&mu_);
-    should_exit_ = true;
-    // There's no need to condvar broadcast, since it is the worker
-    // thread that will look at the work queue and the should_exit_ to
-    // act on this.  Unfortunately every worker thread must test the
-    // return value of PostStringMessage to determine if it should do
-    // early exit (if the worker needs to do multiple event-thread
-    // operations).
-    return false;
-  }
-  return true;
-}
-
-void Worker::RunToCompletion() {
-  for (;;) {
-    WorkRequest *req;
-    do {
-      nacl::MutexLocker take(&mu_);
-      for (;;) {
-        if (should_exit_) {
-          // drop the lock and drop the reference count to this
-          goto break_x3;
-        }
-        fprintf(stderr, "RunToCompletion: Dequeuing...\n");
-        if ((req = Dequeue_mu()) != NULL) {
-          fprintf(stderr, "RunToCompletion: found work %p\n",
-                  reinterpret_cast<void *>(req));
-          break;
-        }
-        fprintf(stderr, "RunToCompletion: waiting\n");
-        NaClXCondVarWait(&cv_, &mu_);
-        fprintf(stderr, "RunToCompletion: woke up\n");
-      }
-    } while (0);
-
-    // Do the work, without holding the lock.  The work function
-    // should reacquire mu_ as needed.
-
-    nacl::StringBuffer sb;
-
-    // scan dispatch table for op_name
-    fprintf(stderr, "RunToCompletion: scanning for %s\n", req->msg.c_str());
-    for (size_t ix = 0; kDispatch[ix].op_name != NULL; ++ix) {
-      fprintf(stderr,
-              "RunToCompletion: comparing against %s\n", kDispatch[ix].op_name);
-      if (req->msg == kDispatch[ix].op_name) {
-        if (InitializeChannel(&sb)) {
-          fprintf(stderr, "RunToCompletion:  invoking table entry %u\n", ix);
-          (this->*(kDispatch[ix].mfunc))(&sb);
-        }
-        break;
-      }
-    }
-    // always post a reply, even if it is the empty string
-    fprintf(stderr,
-            "RunToCompletion: posting reply %s\n", sb.ToString().c_str());
-    if (!PostStringMessage(sb.ToString())) {
-      break;
-    }
-  }
- break_x3:
-  fprintf(stderr, "RunToCompletion: exiting\n");
-  Unref();
-}
-
-bool Worker::InitializeChannel(nacl::StringBuffer *sb) {
-  if (ns_channel_initialized_) {
-    return true;
-  }
-  int ns = -1;
-  nacl_nameservice(&ns);
-  printf("ns = %d\n", ns);
-  assert(-1 != ns);
-  int connected_socket = imc_connect(ns);
-  assert(-1 != connected_socket);
-  if (!NaClSrpcClientCtor(&ns_channel_, connected_socket)) {
-    sb->Printf("Srpc client channel ctor failed\n");
-    close(ns);
-    return false;
-  }
-  sb->Printf("NaClSrpcClientCtor succeeded\n");
-  close(ns);
-  ns_channel_initialized_ = true;
-  return true;
-}
-
-void Worker::Initialize(nacl::StringBuffer *sb) {
-  // we just want the log output from the InitializeChannel
-  return;
-}
-
-void Worker::ManifestOpenTest(nacl::StringBuffer *sb) {
-  int                     status = -1;
-  int                     manifest;
-  struct NaClSrpcChannel  manifest_channel;
-
-  // name service lookup for the manifest service descriptor
-  if (NACL_SRPC_RESULT_OK !=
-      NaClSrpcInvokeBySignature(&ns_channel_, NACL_NAME_SERVICE_LOOKUP,
-                                "ManifestNameService", O_RDWR,
-                                &status, &manifest) ||
-      NACL_NAME_SERVICE_SUCCESS != status) {
-    sb->Printf("nameservice lookup failed, status %d\n", status);
-    return;
-  }
-  sb->Printf("Got manifest descriptor %d\n", manifest);
-  if (-1 == manifest) {
-    return;
-  }
-
-  // connect to manifest name server
-  int manifest_conn = imc_connect(manifest);
-  close(manifest);
-  sb->Printf("got manifest connection %d\n", manifest_conn);
-  if (-1 == manifest_conn) {
-    sb->Printf("could not connect\n");
-    return;
-  }
-
-  // build the SRPC connection (do service discovery)
-  if (!NaClSrpcClientCtor(&manifest_channel, manifest_conn)) {
-    sb->Printf("could not build srpc client\n");
-    return;
-  }
-
-  int desc;
-
-  sb->Printf("Invoking name service lookup\n");
-  if (NACL_SRPC_RESULT_OK !=
-      NaClSrpcInvokeBySignature(&manifest_channel,
-                                NACL_NAME_SERVICE_LOOKUP,
-                                "files/test_file", O_RDONLY,
-                                &status, &desc)) {
-    sb->Printf("manifest lookup RPC failed\n");
-    NaClSrpcDtor(&manifest_channel);
-    return;
-  }
-
-  sb->DiscardOutput();
-  sb->Printf("File Contents:\n");
-
-  char buffer[4096];
-  int len;
-  while ((len = read(desc, buffer, sizeof buffer - 1)) > 0) {
-    // Null terminate.
-    buffer[len] = '\0';
-    sb->Printf("%s", buffer);
-  }
-  NaClSrpcDtor(&manifest_channel);
-  return;
-}
-
-// HandleMessage gets invoked when postMessage is called on the DOM
-// element associated with this plugin instance.  In this case, if we
-// are given a string, we'll post a message back to JavaScript with a
-// reply -- essentially treating this as a string-based RPC.
-void MyInstance::HandleMessage(const pp::Var& message) {
-  if (message.is_string()) {
-    fprintf(stderr,
-            "HandleMessage: enqueuing %s\n", message.AsString().c_str());
-    fflush(NULL);
-    worker_->Enqueue(new WorkRequest(message.AsString()));
-  } else {
-    fprintf(stderr, "HandleMessage: message is not a string\n");
-    fflush(NULL);
-  }
-}
-
-void *worker_thread_start(void *arg) {
-  Worker *worker = reinterpret_cast<Worker *>(arg);
-
-  fprintf(stderr, "Sleeping...\n"); fflush(stderr);
-  sleep(1);
-  fprintf(stderr, "worker_thread_start: worker %p\n",
-          reinterpret_cast<void *>(worker));
-  fflush(NULL);
-  worker->RunToCompletion();
-  worker = NULL;  // RunToCompletion automatically Unrefs
-  return reinterpret_cast<void *>(NULL);
-}
-
-// This object is the global object representing this plugin library as long
-// as it is loaded.
-class MyModule : public pp::Module {
- public:
-  MyModule() : pp::Module() {}
-  virtual ~MyModule() {}
-
-  // Override CreateInstance to create your customized Instance object.
-  virtual pp::Instance *CreateInstance(PP_Instance instance);
-
-  DISALLOW_COPY_AND_ASSIGN(MyModule);
-};
-
-pp::Instance *MyModule::CreateInstance(PP_Instance pp_instance) {
-  MyInstance *instance = new MyInstance(pp_instance);
-  // spawn worker thread associated with this instance
-  pthread_t thread;
-
-  fprintf(stderr, "CreateInstance invoked\n"); fflush(NULL);
-  if (0 != pthread_create(&thread,
-                          reinterpret_cast<pthread_attr_t *>(NULL),
-                          worker_thread_start,
-                          reinterpret_cast<void *>(instance->worker()))) {
-    // Remove the reference the ownership of which should have been
-    // passed to the worker thread.
-    instance->worker()->Unref();
-    delete instance;
-    instance = NULL;
-    fprintf(stderr, "pthread_create failed\n"); fflush(NULL);
-  } else {
-    fprintf(stderr, "CreateInstance: Worker thread started\n");
-    fprintf(stderr, "CreateInstance: worker thread object %p\n",
-            reinterpret_cast<void *>(instance->worker()));
-    (void) pthread_detach(thread);
-  }
-  fprintf(stderr, "CreateInstance: returning instance %p\n",
-          reinterpret_cast<void *>(instance));
-
-  return instance;
-}
-
-namespace pp {
-
-// Factory function for your specialization of the Module object.
-Module* CreateModule() {
-  fprintf(stderr, "CreateModule invoked\n"); fflush(NULL);
-  return new MyModule();
-}
-
-}  // namespace pp