Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(658)

Unified Diff: third_party/crashpad/crashpad/handler/mac/exception_handler_server.cc

Issue 1505213004: Copy Crashpad into the Chrome tree instead of importing it via DEPS (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Address review comments, update README.chromium Created 5 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/crashpad/crashpad/handler/mac/exception_handler_server.cc
diff --git a/third_party/crashpad/crashpad/handler/mac/exception_handler_server.cc b/third_party/crashpad/crashpad/handler/mac/exception_handler_server.cc
new file mode 100644
index 0000000000000000000000000000000000000000..050cc6f385480766b6cec5009e99b5db7ebc1b38
--- /dev/null
+++ b/third_party/crashpad/crashpad/handler/mac/exception_handler_server.cc
@@ -0,0 +1,234 @@
+// Copyright 2014 The Crashpad Authors. All rights reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#include "handler/mac/exception_handler_server.h"
+
+#include "base/logging.h"
+#include "base/mac/mach_logging.h"
+#include "util/mach/composite_mach_message_server.h"
+#include "util/mach/mach_extensions.h"
+#include "util/mach/mach_message.h"
+#include "util/mach/mach_message_server.h"
+#include "util/mach/notify_server.h"
+#include "util/stdlib/move.h"
+
+namespace crashpad {
+
+namespace {
+
+class ExceptionHandlerServerRun : public UniversalMachExcServer::Interface,
+ public NotifyServer::DefaultInterface {
+ public:
+ ExceptionHandlerServerRun(
+ mach_port_t exception_port,
+ mach_port_t notify_port,
+ bool launchd,
+ UniversalMachExcServer::Interface* exception_interface)
+ : UniversalMachExcServer::Interface(),
+ NotifyServer::DefaultInterface(),
+ mach_exc_server_(this),
+ notify_server_(this),
+ composite_mach_message_server_(),
+ exception_interface_(exception_interface),
+ exception_port_(exception_port),
+ notify_port_(notify_port),
+ running_(true),
+ launchd_(launchd) {
+ composite_mach_message_server_.AddHandler(&mach_exc_server_);
+ composite_mach_message_server_.AddHandler(&notify_server_);
+ }
+
+ ~ExceptionHandlerServerRun() {
+ }
+
+ void Run() {
+ DCHECK(running_);
+
+ kern_return_t kr;
+ if (!launchd_) {
+ // Request that a no-senders notification for exception_port_ be sent to
+ // notify_port_.
+ mach_port_t previous;
+ kr = mach_port_request_notification(mach_task_self(),
+ exception_port_,
+ MACH_NOTIFY_NO_SENDERS,
+ 0,
+ notify_port_,
+ MACH_MSG_TYPE_MAKE_SEND_ONCE,
+ &previous);
+ MACH_CHECK(kr == KERN_SUCCESS, kr) << "mach_port_request_notification";
+ base::mac::ScopedMachSendRight previous_owner(previous);
+ }
+
+ // A single CompositeMachMessageServer will dispatch both exception messages
+ // and the no-senders notification. Put both receive rights into a port set.
+ //
+ // A single receive right can’t be used because the notification request
+ // requires a send-once right, which would prevent the no-senders condition
+ // from ever existing. Using distinct receive rights also allows the handler
+ // methods to ensure that the messages they process were sent by a holder of
+ // the proper send right.
+ base::mac::ScopedMachPortSet server_port_set(
+ NewMachPort(MACH_PORT_RIGHT_PORT_SET));
+ CHECK(server_port_set.is_valid());
+
+ kr = mach_port_insert_member(
+ mach_task_self(), exception_port_, server_port_set.get());
+ MACH_CHECK(kr == KERN_SUCCESS, kr) << "mach_port_insert_member";
+
+ kr = mach_port_insert_member(
+ mach_task_self(), notify_port_, server_port_set.get());
+ MACH_CHECK(kr == KERN_SUCCESS, kr) << "mach_port_insert_member";
+
+ // Run the server in kOneShot mode so that running_ can be reevaluated after
+ // each message. Receipt of a valid no-senders notification causes it to be
+ // set to false.
+ while (running_) {
+ // This will result in a call to CatchMachException() or
+ // DoMachNotifyNoSenders() as appropriate.
+ mach_msg_return_t mr =
+ MachMessageServer::Run(&composite_mach_message_server_,
+ server_port_set.get(),
+ kMachMessageReceiveAuditTrailer,
+ MachMessageServer::kOneShot,
+ MachMessageServer::kReceiveLargeIgnore,
+ kMachMessageTimeoutWaitIndefinitely);
+ MACH_CHECK(mr == MACH_MSG_SUCCESS, mr) << "MachMessageServer::Run";
+ }
+ }
+
+ // UniversalMachExcServer::Interface:
+
+ kern_return_t CatchMachException(exception_behavior_t behavior,
+ exception_handler_t exception_port,
+ thread_t thread,
+ task_t task,
+ exception_type_t exception,
+ const mach_exception_data_type_t* code,
+ mach_msg_type_number_t code_count,
+ thread_state_flavor_t* flavor,
+ ConstThreadState old_state,
+ mach_msg_type_number_t old_state_count,
+ thread_state_t new_state,
+ mach_msg_type_number_t* new_state_count,
+ const mach_msg_trailer_t* trailer,
+ bool* destroy_complex_request) override {
+ if (exception_port != exception_port_) {
+ LOG(WARNING) << "exception port mismatch";
+ return KERN_FAILURE;
+ }
+
+ return exception_interface_->CatchMachException(behavior,
+ exception_port,
+ thread,
+ task,
+ exception,
+ code,
+ code_count,
+ flavor,
+ old_state,
+ old_state_count,
+ new_state,
+ new_state_count,
+ trailer,
+ destroy_complex_request);
+ }
+
+ // NotifyServer::DefaultInterface:
+
+ kern_return_t DoMachNotifyNoSenders(
+ notify_port_t notify,
+ mach_port_mscount_t mscount,
+ const mach_msg_trailer_t* trailer) override {
+ if (notify != notify_port_) {
+ // The message was received as part of a port set. This check ensures that
+ // only the authorized sender of the no-senders notification is able to
+ // stop the exception server. Otherwise, a malicious client would be able
+ // to craft and send a no-senders notification via its exception port, and
+ // cause the handler to stop processing exceptions and exit.
+ LOG(WARNING) << "notify port mismatch";
+ return KERN_FAILURE;
+ }
+
+ running_ = false;
+
+ return KERN_SUCCESS;
+ }
+
+ private:
+ UniversalMachExcServer mach_exc_server_;
+ NotifyServer notify_server_;
+ CompositeMachMessageServer composite_mach_message_server_;
+ UniversalMachExcServer::Interface* exception_interface_; // weak
+ mach_port_t exception_port_; // weak
+ mach_port_t notify_port_; // weak
+ bool running_;
+ bool launchd_;
+
+ DISALLOW_COPY_AND_ASSIGN(ExceptionHandlerServerRun);
+};
+
+} // namespace
+
+ExceptionHandlerServer::ExceptionHandlerServer(
+ base::mac::ScopedMachReceiveRight receive_port,
+ bool launchd)
+ : receive_port_(crashpad::move(receive_port)),
+ notify_port_(NewMachPort(MACH_PORT_RIGHT_RECEIVE)),
+ launchd_(launchd) {
+ CHECK(receive_port_.is_valid());
+ CHECK(notify_port_.is_valid());
+}
+
+ExceptionHandlerServer::~ExceptionHandlerServer() {
+}
+
+void ExceptionHandlerServer::Run(
+ UniversalMachExcServer::Interface* exception_interface) {
+ ExceptionHandlerServerRun run(
+ receive_port_.get(), notify_port_.get(), launchd_, exception_interface);
+ run.Run();
+}
+
+void ExceptionHandlerServer::Stop() {
+ // Cause the exception handler server to stop running by sending it a
+ // synthesized no-senders notification.
+ //
+ // mach_no_senders_notification_t defines the receive side of this structure,
+ // with a trailer element that’s undesirable for the send side.
+ struct {
+ mach_msg_header_t header;
+ NDR_record_t ndr;
+ mach_msg_type_number_t mscount;
+ } no_senders_notification = {};
+ no_senders_notification.header.msgh_bits =
+ MACH_MSGH_BITS(MACH_MSG_TYPE_MAKE_SEND_ONCE, 0);
+ no_senders_notification.header.msgh_size = sizeof(no_senders_notification);
+ no_senders_notification.header.msgh_remote_port = notify_port_.get();
+ no_senders_notification.header.msgh_local_port = MACH_PORT_NULL;
+ no_senders_notification.header.msgh_id = MACH_NOTIFY_NO_SENDERS;
+ no_senders_notification.ndr = NDR_record;
+ no_senders_notification.mscount = 0;
+
+ kern_return_t kr = mach_msg(&no_senders_notification.header,
+ MACH_SEND_MSG,
+ sizeof(no_senders_notification),
+ 0,
+ MACH_PORT_NULL,
+ MACH_MSG_TIMEOUT_NONE,
+ MACH_PORT_NULL);
+ MACH_CHECK(kr == KERN_SUCCESS, kr) << "mach_msg";
+}
+
+} // namespace crashpad

Powered by Google App Engine
This is Rietveld 408576698