// Copyright (c) 2006, Google Inc. // All rights reserved. // // Redistribution and use in source and binary forms, with or without // modification, are permitted provided that the following conditions are // met: // // * Redistributions of source code must retain the above copyright // notice, this list of conditions and the following disclaimer. // * Redistributions in binary form must reproduce the above // copyright notice, this list of conditions and the following disclaimer // in the documentation and/or other materials provided with the // distribution. // * Neither the name of Google Inc. nor the names of its // contributors may be used to endorse or promote products derived from // this software without specific prior written permission. // // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. #include #include #include "client/windows/handler/exception_handler.h" #include "common/windows/guid_string.h" namespace google_airbag { ExceptionHandler *ExceptionHandler::current_handler_ = NULL; HANDLE ExceptionHandler::handler_thread_ = NULL; CRITICAL_SECTION ExceptionHandler::handler_critical_section_; HANDLE ExceptionHandler::handler_start_semaphore_ = NULL; HANDLE ExceptionHandler::handler_finish_semaphore_ = NULL; ExceptionHandler *ExceptionHandler::requesting_handler_ = NULL; DWORD ExceptionHandler::requesting_thread_id_ = 0; EXCEPTION_POINTERS *ExceptionHandler::exception_info_ = NULL; bool ExceptionHandler::handler_return_value_ = false; ExceptionHandler::ExceptionHandler(const wstring &dump_path, MinidumpCallback callback, void *callback_context, bool install_handler) : callback_(callback), callback_context_(callback_context), dump_path_(dump_path), dbghelp_module_(NULL), minidump_write_dump_(NULL), previous_handler_(current_handler_), previous_filter_(NULL) { if (!handler_thread_) { // The first time an ExceptionHandler is created, set up the handler // thread and the synchronization primitives. InitializeCriticalSection(&handler_critical_section_); handler_start_semaphore_ = CreateSemaphore(NULL, 0, 1, NULL); handler_finish_semaphore_ = CreateSemaphore(NULL, 0, 1, NULL); DWORD thread_id; handler_thread_ = CreateThread(NULL, // lpThreadAttributes 64 * 1024, // dwStackSize ExceptionHandlerThreadMain, NULL, // lpParameter 0, // dwCreationFlags &thread_id); } UpdateNextID(); dbghelp_module_ = LoadLibrary(L"dbghelp.dll"); if (dbghelp_module_) { minidump_write_dump_ = reinterpret_cast( GetProcAddress(dbghelp_module_, "MiniDumpWriteDump")); } if (install_handler) { previous_filter_ = SetUnhandledExceptionFilter(HandleException); current_handler_ = this; } } ExceptionHandler::~ExceptionHandler() { if (dbghelp_module_) { FreeLibrary(dbghelp_module_); } if (current_handler_ == this) { SetUnhandledExceptionFilter(previous_filter_); current_handler_ = previous_handler_; } if (previous_handler_ == NULL) { // When destroying the last ExceptionHandler, clean up the handler thread // and synchronization primitives. TerminateThread(handler_thread_, 1); handler_thread_ = NULL; DeleteCriticalSection(&handler_critical_section_); CloseHandle(handler_start_semaphore_); handler_start_semaphore_ = NULL; CloseHandle(handler_finish_semaphore_); handler_finish_semaphore_ = NULL; } } // static DWORD ExceptionHandler::ExceptionHandlerThreadMain(void *lpParameter) { while (true) { if (WaitForSingleObject(handler_start_semaphore_, INFINITE) == WAIT_OBJECT_0) { // Perform the requested action. handler_return_value_ = requesting_handler_->WriteMinidumpWithException( requesting_thread_id_, exception_info_); // Allow the requesting thread to proceed. ReleaseSemaphore(handler_finish_semaphore_, 1, NULL); } } // Not reached. This thread will be terminated by ExceptionHandler's // destructor. return 0; } // static LONG ExceptionHandler::HandleException(EXCEPTION_POINTERS *exinfo) { return current_handler_->WriteMinidumpOnHandlerThread(exinfo) ? EXCEPTION_EXECUTE_HANDLER : EXCEPTION_CONTINUE_SEARCH; } bool ExceptionHandler::WriteMinidumpOnHandlerThread(EXCEPTION_POINTERS *exinfo) { EnterCriticalSection(&handler_critical_section_); // Set up data to be passed in to the handler thread. requesting_handler_ = this; requesting_thread_id_ = GetCurrentThreadId(); exception_info_ = exinfo; // This causes the handler thread to call WriteMinidumpWithException. ReleaseSemaphore(handler_start_semaphore_, 1, NULL); // Wait until WriteMinidumpWithException is done and collect its return value. WaitForSingleObject(handler_finish_semaphore_, INFINITE); bool status = handler_return_value_; // Clean up. requesting_handler_ = NULL; requesting_thread_id_ = 0; exception_info_ = NULL; LeaveCriticalSection(&handler_critical_section_); return status; } bool ExceptionHandler::WriteMinidump() { bool success = WriteMinidumpOnHandlerThread(NULL); UpdateNextID(); return success; } // static bool ExceptionHandler::WriteMinidump(const wstring &dump_path, MinidumpCallback callback, void *callback_context) { ExceptionHandler handler(dump_path, callback, callback_context, false); return handler.WriteMinidump(); } bool ExceptionHandler::WriteMinidumpWithException(DWORD requesting_thread_id, EXCEPTION_POINTERS *exinfo) { wchar_t dump_file_name[MAX_PATH]; swprintf_s(dump_file_name, MAX_PATH, L"%s\\%s.dmp", dump_path_.c_str(), next_minidump_id_.c_str()); bool success = false; if (minidump_write_dump_) { HANDLE dump_file = CreateFile(dump_file_name, GENERIC_WRITE, FILE_SHARE_WRITE, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL); if (dump_file != INVALID_HANDLE_VALUE) { MINIDUMP_EXCEPTION_INFORMATION except_info; except_info.ThreadId = requesting_thread_id; except_info.ExceptionPointers = exinfo; except_info.ClientPointers = FALSE; // TODO(mmentovai): include IDs of handler and requesting threads. // The explicit comparison to TRUE avoids a warning (C4800). success = (minidump_write_dump_(GetCurrentProcess(), GetCurrentProcessId(), dump_file, MiniDumpNormal, exinfo ? &except_info : NULL, NULL, NULL) == TRUE); CloseHandle(dump_file); } } if (callback_) { callback_(next_minidump_id_, callback_context_, success); } // TODO(bryner): log an error on failure return success; } void ExceptionHandler::UpdateNextID() { GUID id; CoCreateGuid(&id); next_minidump_id_ = GUIDString::GUIDToWString(&id); } } // namespace google_airbag