Native Client side changes for debugging support: stdout/err -> postmessage.

src/trusted/reverse_service/reverse_service.cc

 /*
  * Copyright (c) 2011 The Native Client 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 <string.h>
 
 #include "native_client/src/trusted/reverse_service/reverse_service.h"
 
@@ skipping 106 matching lines @@
   if (NULL == service->reverse_interface()) {
     NaClLog(4, "ModuleExitRpc: no reverse_interface.  Nothing to do.\n");
   } else {
     NaClLog(4, "ModuleExitRpc: invoking ReportExitStatus\n");
     service->reverse_interface()->ReportExitStatus(exit_status);
   }
   NaClLog(4, "Leaving ModuleExitRpc\n");
   rpc->result = NACL_SRPC_RESULT_OK;
 }
 
+void PostMessageRpc(NaClSrpcRpc* rpc,
+                    NaClSrpcArg** in_args,
+                    NaClSrpcArg** out_args,
+                    NaClSrpcClosure* done) {
+  nacl::ReverseService* service = reinterpret_cast<nacl::ReverseService*>(
+      rpc->channel->server_instance_data);
+  char* message = in_args[0]->arrays.carr;
+  nacl_abi_size_t nbytes = in_args[0]->u.count;
+  NaClSrpcClosureRunner on_return(done);
+
+  NaClLog(4, "Entered PostMessageRpc\n");
+  if (NULL == service->reverse_interface()) {
+    NaClLog(1, "PostMessage RPC, no reverse_interface.  Message: %s\n",
+            message);
+  } else {
+    service->reverse_interface()->PostMessage(std::string(message, nbytes));
+  }
+  out_args[0]->u.ival = (int32_t) nbytes;
+  NaClLog(4, "Leaving PostMessageRpc\n");
+  rpc->result = NACL_SRPC_RESULT_OK;
+}
+
 // Manifest name service, internal APIs.
 //
 // Manifest file lookups result in read-only file descriptors with a
 // handle.  When the descriptor is closed, the service runtime must
 // inform the plugin of this using the handle, so that the File object
 // reference can be closed (thereby allowing the browser to delete or
 // otherwise garbage collect the file).  Files, being from the
 // manifest, cannot be deleted.  The manifest is also a read-only
 // object, so no new entries can be made to it.
 //
@@ skipping 128 matching lines @@
   //
   // TODO(bsy): replace with real code.
   out_args[0]->u.ival = 0;  // ok
   rpc->result = NACL_SRPC_RESULT_OK;
 }
 
 }  // namespace
 
 namespace nacl {
 
+// TODO(bsy): this is a temporary cross-repo hack; should be removed
+// when the interface is made pure virtual again
+void ReverseInterface::PostMessage(nacl::string message) {
+  NaClLog(0, "ReverseInterface::PostMessage(NACL_OUTPUT_TAG:%s)\n",
+          message.c_str());
+}
+
 // need NaClThreadIfFactoryFunction that keeps "this" to do counting
 
 struct ReverseCountingThreadInterface {
   struct NaClThreadInterface base NACL_IS_REFCOUNT_SUBCLASS;
   nacl::ReverseService* rev;
 };
 
 /* fwd */ extern NaClThreadInterfaceVtbl const kReverseThreadInterfaceVtbl;
 
 int ReverseThreadIfFactoryFn(
@@ skipping 102 matching lines @@
   ReverseThreadIfLaunchCallback,
   ReverseThreadIfExit,
 };
 
 NaClSrpcHandlerDesc const ReverseService::handlers[] = {
   { NACL_REVERSE_CONTROL_TEST, Test, },
   { NACL_REVERSE_CONTROL_LOG, RevLog, },
   { NACL_REVERSE_CONTROL_ADD_CHANNEL, AddChannel, },
   { NACL_REVERSE_CONTROL_INIT_DONE, ModuleInitDoneRpc, },
   { NACL_REVERSE_CONTROL_REPORT_STATUS, ModuleExitRpc, },
+  { NACL_REVERSE_CONTROL_POST_MESSAGE, PostMessageRpc, },
   { NACL_MANIFEST_LIST, ManifestListRpc, },
   { NACL_MANIFEST_LOOKUP, ManifestLookupRpc, },
   { NACL_MANIFEST_UNREF, ManifestUnrefRpc, },
   { NULL, NULL, },
 };
 
 ReverseService::ReverseService(nacl::DescWrapper* conn_cap,
                                ReverseInterface* rif)
     : service_socket_(NULL),
       reverse_interface_(rif),
@@ skipping 71 matching lines @@
             ("ReverseService::DecrThreadCount:"
              " Decrementing thread count when count is zero\n"));
   }
   if (0 == --thread_count_) {
     NaClXCondVarBroadcast(&cv_);
   }
   NaClXMutexUnlock(&mu_);
 }
 
 }  // namespace nacl