Revert 130716 - Use ScopedProcessInformation and other RAII types in sandbox.

sandbox/src/broker_services.cc

 // Copyright (c) 2012 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 "sandbox/src/broker_services.h"
 
 #include "base/logging.h"
-#include "base/memory/scoped_ptr.h"
 #include "base/threading/platform_thread.h"
-#include "base/win/scoped_handle.h"
-#include "base/win/scoped_process_information.h"
 #include "sandbox/src/sandbox_policy_base.h"
 #include "sandbox/src/sandbox.h"
 #include "sandbox/src/target_process.h"
 #include "sandbox/src/win2k_threadpool.h"
 #include "sandbox/src/win_utils.h"
 
 namespace {
 
 // Utility function to associate a completion port to a job object.
 bool AssociateCompletionPort(HANDLE job, HANDLE port, void* key) {
@@ skipping 268 matching lines @@
   static DWORD thread_id = ::GetCurrentThreadId();
   DCHECK(thread_id == ::GetCurrentThreadId());
 
   AutoLock lock(&lock_);
 
   // This downcast is safe as long as we control CreatePolicy()
   PolicyBase* policy_base = static_cast<PolicyBase*>(policy);
 
   // Construct the tokens and the job object that we are going to associate
   // with the soon to be created target process.
-  base::win::ScopedHandle lockdown_token;
-  base::win::ScopedHandle initial_token;
-  DWORD win_result = policy_base->MakeTokens(initial_token.Receive(),
-                                             lockdown_token.Receive());
+  HANDLE lockdown_token = NULL;
+  HANDLE initial_token = NULL;
+  DWORD win_result = policy_base->MakeTokens(&initial_token, &lockdown_token);
   if (ERROR_SUCCESS != win_result)
     return SBOX_ERROR_GENERIC;
 
-  base::win::ScopedHandle job;
-  win_result = policy_base->MakeJobObject(job.Receive());
+  HANDLE job = NULL;
+  win_result = policy_base->MakeJobObject(&job);
   if (ERROR_SUCCESS != win_result)
     return SBOX_ERROR_GENERIC;
 
   if (ERROR_ALREADY_EXISTS == ::GetLastError())
     return SBOX_ERROR_GENERIC;
 
   // Construct the thread pool here in case it is expensive.
   // The thread pool is shared by all the targets
   if (NULL == thread_pool_)
     thread_pool_ = new Win2kThreadPool();
 
   // Create the TargetProces object and spawn the target suspended. Note that
   // Brokerservices does not own the target object. It is owned by the Policy.
-  base::win::ScopedProcessInformation process_info;
-  TargetProcess* target = new TargetProcess(initial_token.Take(),
-                                            lockdown_token.Take(),
-                                            job,
-                                            thread_pool_);
+  PROCESS_INFORMATION process_info = {0};
+  TargetProcess* target = new TargetProcess(initial_token, lockdown_token,
+                                            job, thread_pool_);
 
   std::wstring desktop = policy_base->GetAlternateDesktop();
 
   win_result = target->Create(exe_path, command_line,
                               desktop.empty() ? NULL : desktop.c_str(),
                               &process_info);
   if (ERROR_SUCCESS != win_result)
     return SpawnCleanup(target, win_result);
 
+  if ((INVALID_HANDLE_VALUE == process_info.hProcess) ||
+      (INVALID_HANDLE_VALUE == process_info.hThread))
+    return SpawnCleanup(target, win_result);
+
   // Now the policy is the owner of the target.
   if (!policy_base->AddTarget(target)) {
     return SpawnCleanup(target, 0);
   }
 
   // We are going to keep a pointer to the policy because we'll call it when
   // the job object generates notifications using the completion port.
   policy_base->AddRef();
-  scoped_ptr<JobTracker> tracker(new JobTracker(job.Take(), policy_base));
-  if (!AssociateCompletionPort(tracker->job, job_port_, tracker.get()))
+  JobTracker* tracker = new JobTracker(job, policy_base);
+  if (!AssociateCompletionPort(job, job_port_, tracker))
     return SpawnCleanup(target, 0);
   // Save the tracker because in cleanup we might need to force closing
   // the Jobs.
-  tracker_list_.push_back(tracker.release());
-  child_process_ids_.insert(process_info.process_id());
+  tracker_list_.push_back(tracker);
+  child_process_ids_.insert(process_info.dwProcessId);
 
-  *target_info = process_info.Take();
+  // We return the caller a duplicate of the process handle so they
+  // can close it at will.
+  HANDLE dup_process_handle = NULL;
+  if (!::DuplicateHandle(::GetCurrentProcess(), process_info.hProcess,
+                         ::GetCurrentProcess(), &dup_process_handle,
+                         0, FALSE, DUPLICATE_SAME_ACCESS))
+    return SpawnCleanup(target, 0);
+
+  *target_info = process_info;
+  target_info->hProcess = dup_process_handle;
   return SBOX_ALL_OK;
 }
 
 
 ResultCode BrokerServicesBase::WaitForAllTargets() {
   ::WaitForSingleObject(no_targets_, INFINITE);
   return SBOX_ALL_OK;
 }
 
 bool BrokerServicesBase::IsActiveTarget(DWORD process_id) {
@@ skipping 32 matching lines @@
     peer_map_.erase(peer->id);
     return SBOX_ERROR_GENERIC;
   }
 
   // Leak the pointer since it will be cleaned up by the callback.
   peer.release();
   return SBOX_ALL_OK;
 }
 
 }  // namespace sandbox