Merge changes I20670684,If38c6d14,I94889125,I66169ed5 am: 85a6ca459f (ca7bea8c) · Commits · e / os / android_system_core

debuggerd/Android.bp

+3 −1

Original line number	Original line	Diff line number	Diff line
	@@ -163,6 +163,7 @@ cc_test {
	srcs: [		srcs: [
	"client/debuggerd_client_test.cpp",		"client/debuggerd_client_test.cpp",
	"debuggerd_test.cpp",		"debuggerd_test.cpp",
			"tombstoned_client.cpp",
	"util.cpp"		"util.cpp"
	],		],
	},		},
	@@ -176,7 +177,8 @@ cc_test {
	],		],

	static_libs: [		static_libs: [
	"libdebuggerd"		"libdebuggerd",
			"libc_logging",
	],		],

	local_include_dirs: [		local_include_dirs: [

debuggerd/client/debuggerd_client.cpp

+29 −19

Original line number	Original line	Diff line number	Diff line
	@@ -65,24 +65,25 @@ bool debuggerd_trigger_dump(pid_t pid, unique_fd output_fd, DebuggerdDumpType du
	auto time_left = [timeout_ms, &end]() { return end - std::chrono::steady_clock::now(); };		auto time_left = [timeout_ms, &end]() { return end - std::chrono::steady_clock::now(); };
	auto set_timeout = [timeout_ms, &time_left](int sockfd) {		auto set_timeout = [timeout_ms, &time_left](int sockfd) {
	if (timeout_ms <= 0) {		if (timeout_ms <= 0) {
	return true;		return -1;
	}		}

	auto remaining = time_left();		auto remaining = time_left();
	if (remaining < decltype(remaining)::zero()) {		if (remaining < decltype(remaining)::zero()) {
	return false;		LOG(ERROR) << "timeout expired";
			return -1;
	}		}
	struct timeval timeout;		struct timeval timeout;
	populate_timeval(&timeout, remaining);		populate_timeval(&timeout, remaining);

	if (setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout)) != 0) {		if (setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, &timeout, sizeof(timeout)) != 0) {
	return false;		return -1;
	}		}
	if (setsockopt(sockfd, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout)) != 0) {		if (setsockopt(sockfd, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout)) != 0) {
	return false;		return -1;
	}		}

	return true;		return sockfd;
	};		};

	sockfd.reset(socket(AF_LOCAL, SOCK_SEQPACKET, 0));		sockfd.reset(socket(AF_LOCAL, SOCK_SEQPACKET, 0));
	@@ -91,12 +92,7 @@ bool debuggerd_trigger_dump(pid_t pid, unique_fd output_fd, DebuggerdDumpType du
	return false;		return false;
	}		}

	if (!set_timeout(sockfd)) {		if (socket_local_client_connect(set_timeout(sockfd.get()), kTombstonedInterceptSocketName,
	PLOG(ERROR) << "libdebugger_client: failed to set timeout";
	return false;
	}

	if (socket_local_client_connect(sockfd.get(), kTombstonedInterceptSocketName,
	ANDROID_SOCKET_NAMESPACE_RESERVED, SOCK_SEQPACKET) == -1) {		ANDROID_SOCKET_NAMESPACE_RESERVED, SOCK_SEQPACKET) == -1) {
	PLOG(ERROR) << "libdebuggerd_client: failed to connect to tombstoned";		PLOG(ERROR) << "libdebuggerd_client: failed to connect to tombstoned";
	return false;		return false;
	@@ -115,21 +111,35 @@ bool debuggerd_trigger_dump(pid_t pid, unique_fd output_fd, DebuggerdDumpType du
	return false;		return false;
	}		}

	if (send_fd(sockfd.get(), &req, sizeof(req), std::move(pipe_write)) != sizeof(req)) {		if (send_fd(set_timeout(sockfd), &req, sizeof(req), std::move(pipe_write)) != sizeof(req)) {
	PLOG(ERROR) << "libdebuggerd_client: failed to send output fd to tombstoned";		PLOG(ERROR) << "libdebuggerd_client: failed to send output fd to tombstoned";
	return false;		return false;
	}		}

	bool backtrace = dump_type == kDebuggerdBacktrace;		// Check to make sure we've successfully registered.
	send_signal(pid, backtrace);		InterceptResponse response;
			ssize_t rc =
			TEMP_FAILURE_RETRY(recv(set_timeout(sockfd.get()), &response, sizeof(response), MSG_TRUNC));
			if (rc == 0) {
			LOG(ERROR) << "libdebuggerd_client: failed to read response from tombstoned: timeout reached?";
			return false;
			} else if (rc != sizeof(response)) {
			LOG(ERROR)
			<< "libdebuggerd_client: received packet of unexpected length from tombstoned: expected "
			<< sizeof(response) << ", received " << rc;
			return false;
			}

	if (!set_timeout(sockfd)) {		if (response.status != InterceptStatus::kRegistered) {
	PLOG(ERROR) << "libdebuggerd_client: failed to set timeout";		LOG(ERROR) << "libdebuggerd_client: unexpected registration response: "
			<< static_cast<int>(response.status);
	return false;		return false;
	}		}

	InterceptResponse response;		bool backtrace = dump_type == kDebuggerdBacktrace;
	ssize_t rc = TEMP_FAILURE_RETRY(recv(sockfd.get(), &response, sizeof(response), MSG_TRUNC));		send_signal(pid, backtrace);

			rc = TEMP_FAILURE_RETRY(recv(set_timeout(sockfd.get()), &response, sizeof(response), MSG_TRUNC));
	if (rc == 0) {		if (rc == 0) {
	LOG(ERROR) << "libdebuggerd_client: failed to read response from tombstoned: timeout reached?";		LOG(ERROR) << "libdebuggerd_client: failed to read response from tombstoned: timeout reached?";
	return false;		return false;
	@@ -140,7 +150,7 @@ bool debuggerd_trigger_dump(pid_t pid, unique_fd output_fd, DebuggerdDumpType du
	return false;		return false;
	}		}

	if (response.success != 1) {		if (response.status != InterceptStatus::kStarted) {
	response.error_message[sizeof(response.error_message) - 1] = '\0';		response.error_message[sizeof(response.error_message) - 1] = '\0';
	LOG(ERROR) << "libdebuggerd_client: tombstoned reported failure: " << response.error_message;		LOG(ERROR) << "libdebuggerd_client: tombstoned reported failure: " << response.error_message;
	return false;		return false;

debuggerd/debuggerd_test.cpp

+145 −33

Original line number	Original line	Diff line number	Diff line
	@@ -36,6 +36,7 @@
	#include <cutils/sockets.h>		#include <cutils/sockets.h>
	#include <debuggerd/handler.h>		#include <debuggerd/handler.h>
	#include <debuggerd/protocol.h>		#include <debuggerd/protocol.h>
			#include <debuggerd/tombstoned.h>
	#include <debuggerd/util.h>		#include <debuggerd/util.h>
	#include <gtest/gtest.h>		#include <gtest/gtest.h>

	@@ -77,6 +78,54 @@ constexpr char kWaitForGdbKey[] = "debug.debuggerd.wait_for_gdb";
	} \		} \
	} while (0)		} while (0)

			static void tombstoned_intercept(pid_t target_pid, unique_fd* intercept_fd, unique_fd* output_fd) {
			intercept_fd->reset(socket_local_client(kTombstonedInterceptSocketName,
			ANDROID_SOCKET_NAMESPACE_RESERVED, SOCK_SEQPACKET));
			if (intercept_fd->get() == -1) {
			FAIL() << "failed to contact tombstoned: " << strerror(errno);
			}

			InterceptRequest req = {.pid = target_pid};

			unique_fd output_pipe_write;
			if (!Pipe(output_fd, &output_pipe_write)) {
			FAIL() << "failed to create output pipe: " << strerror(errno);
			}

			std::string pipe_size_str;
			int pipe_buffer_size;
			if (!android::base::ReadFileToString("/proc/sys/fs/pipe-max-size", &pipe_size_str)) {
			FAIL() << "failed to read /proc/sys/fs/pipe-max-size: " << strerror(errno);
			}

			pipe_size_str = android::base::Trim(pipe_size_str);

			if (!android::base::ParseInt(pipe_size_str.c_str(), &pipe_buffer_size, 0)) {
			FAIL() << "failed to parse pipe max size";
			}

			if (fcntl(output_fd->get(), F_SETPIPE_SZ, pipe_buffer_size) != pipe_buffer_size) {
			FAIL() << "failed to set pipe size: " << strerror(errno);
			}

			if (send_fd(intercept_fd->get(), &req, sizeof(req), std::move(output_pipe_write)) != sizeof(req)) {
			FAIL() << "failed to send output fd to tombstoned: " << strerror(errno);
			}

			InterceptResponse response;
			ssize_t rc = TEMP_FAILURE_RETRY(read(intercept_fd->get(), &response, sizeof(response)));
			if (rc == -1) {
			FAIL() << "failed to read response from tombstoned: " << strerror(errno);
			} else if (rc == 0) {
			FAIL() << "failed to read response from tombstoned (EOF)";
			} else if (rc != sizeof(response)) {
			FAIL() << "received packet of unexpected length from tombstoned: expected " << sizeof(response)
			<< ", received " << rc;
			}

			ASSERT_EQ(InterceptStatus::kRegistered, response.status);
			}

	class CrasherTest : public ::testing::Test {		class CrasherTest : public ::testing::Test {
	public:		public:
	pid_t crasher_pid = -1;		pid_t crasher_pid = -1;
	@@ -118,38 +167,7 @@ void CrasherTest::StartIntercept(unique_fd* output_fd) {
	FAIL() << "crasher hasn't been started";		FAIL() << "crasher hasn't been started";
	}		}

	intercept_fd.reset(socket_local_client(kTombstonedInterceptSocketName,		tombstoned_intercept(crasher_pid, &this->intercept_fd, output_fd);
	ANDROID_SOCKET_NAMESPACE_RESERVED, SOCK_SEQPACKET));
	if (intercept_fd == -1) {
	FAIL() << "failed to contact tombstoned: " << strerror(errno);
	}

	InterceptRequest req = {.pid = crasher_pid };

	unique_fd output_pipe_write;
	if (!Pipe(output_fd, &output_pipe_write)) {
	FAIL() << "failed to create output pipe: " << strerror(errno);
	}

	std::string pipe_size_str;
	int pipe_buffer_size;
	if (!android::base::ReadFileToString("/proc/sys/fs/pipe-max-size", &pipe_size_str)) {
	FAIL() << "failed to read /proc/sys/fs/pipe-max-size: " << strerror(errno);
	}

	pipe_size_str = android::base::Trim(pipe_size_str);

	if (!android::base::ParseInt(pipe_size_str.c_str(), &pipe_buffer_size, 0)) {
	FAIL() << "failed to parse pipe max size";
	}

	if (fcntl(output_fd->get(), F_SETPIPE_SZ, pipe_buffer_size) != pipe_buffer_size) {
	FAIL() << "failed to set pipe size: " << strerror(errno);
	}

	if (send_fd(intercept_fd.get(), &req, sizeof(req), std::move(output_pipe_write)) != sizeof(req)) {
	FAIL() << "failed to send output fd to tombstoned: " << strerror(errno);
	}
	}		}

	void CrasherTest::FinishIntercept(int* result) {		void CrasherTest::FinishIntercept(int* result) {
	@@ -165,7 +183,7 @@ void CrasherTest::FinishIntercept(int* result) {
	FAIL() << "received packet of unexpected length from tombstoned: expected " << sizeof(response)		FAIL() << "received packet of unexpected length from tombstoned: expected " << sizeof(response)
	<< ", received " << rc;		<< ", received " << rc;
	} else {		} else {
	*result = response.success;		*result = response.status == InterceptStatus::kStarted ? 1 : 0;
	}		}
	}		}

	@@ -508,3 +526,97 @@ TEST(crash_dump, zombie) {
	ASSERT_EQ(0, WEXITSTATUS(status));		ASSERT_EQ(0, WEXITSTATUS(status));
	}		}
	}		}

			TEST(tombstoned, no_notify) {
			// Do this a few times.
			for (int i = 0; i < 3; ++i) {
			pid_t pid = 123'456'789 + i;

			unique_fd intercept_fd, output_fd;
			tombstoned_intercept(pid, &intercept_fd, &output_fd);

			{
			unique_fd tombstoned_socket, input_fd;
			ASSERT_TRUE(tombstoned_connect(pid, &tombstoned_socket, &input_fd));
			ASSERT_TRUE(android::base::WriteFully(input_fd.get(), &pid, sizeof(pid)));
			}

			pid_t read_pid;
			ASSERT_TRUE(android::base::ReadFully(output_fd.get(), &read_pid, sizeof(read_pid)));
			ASSERT_EQ(read_pid, pid);
			}
			}

			TEST(tombstoned, stress) {
			// Spawn threads to simultaneously do a bunch of failing dumps and a bunch of successful dumps.
			static constexpr int kDumpCount = 100;

			std::atomic<bool> start(false);
			std::vector<std::thread> threads;
			threads.emplace_back([&start]() {
			while (!start) {
			continue;
			}

			// Use a way out of range pid, to avoid stomping on an actual process.
			pid_t pid_base = 1'000'000;

			for (int dump = 0; dump < kDumpCount; ++dump) {
			pid_t pid = pid_base + dump;

			unique_fd intercept_fd, output_fd;
			tombstoned_intercept(pid, &intercept_fd, &output_fd);

			// Pretend to crash, and then immediately close the socket.
			unique_fd sockfd(socket_local_client(kTombstonedCrashSocketName,
			ANDROID_SOCKET_NAMESPACE_RESERVED, SOCK_SEQPACKET));
			if (sockfd == -1) {
			FAIL() << "failed to connect to tombstoned: " << strerror(errno);
			}
			TombstonedCrashPacket packet = {};
			packet.packet_type = CrashPacketType::kDumpRequest;
			packet.packet.dump_request.pid = pid;
			if (TEMP_FAILURE_RETRY(write(sockfd, &packet, sizeof(packet))) != sizeof(packet)) {
			FAIL() << "failed to write to tombstoned: " << strerror(errno);
			}

			continue;
			}
			});

			threads.emplace_back([&start]() {
			while (!start) {
			continue;
			}

			// Use a way out of range pid, to avoid stomping on an actual process.
			pid_t pid_base = 2'000'000;

			for (int dump = 0; dump < kDumpCount; ++dump) {
			pid_t pid = pid_base + dump;

			unique_fd intercept_fd, output_fd;
			tombstoned_intercept(pid, &intercept_fd, &output_fd);

			{
			unique_fd tombstoned_socket, input_fd;
			ASSERT_TRUE(tombstoned_connect(pid, &tombstoned_socket, &input_fd));
			ASSERT_TRUE(android::base::WriteFully(input_fd.get(), &pid, sizeof(pid)));
			tombstoned_notify_completion(tombstoned_socket.get());
			}

			// TODO: Fix the race that requires this sleep.
			std::this_thread::sleep_for(50ms);

			pid_t read_pid;
			ASSERT_TRUE(android::base::ReadFully(output_fd.get(), &read_pid, sizeof(read_pid)));
			ASSERT_EQ(read_pid, pid);
			}
			});

			start = true;

			for (std::thread& thread : threads) {
			thread.join();
			}
			}

debuggerd/include/debuggerd/protocol.h

+7 −1

Original line number	Original line	Diff line number	Diff line
	@@ -56,8 +56,14 @@ struct InterceptRequest {
	int32_t pid;		int32_t pid;
	};		};

			enum class InterceptStatus : uint8_t {
			kFailed,
			kStarted,
			kRegistered,
			};

	// Sent either immediately upon failure, or when the intercept has been used.		// Sent either immediately upon failure, or when the intercept has been used.
	struct InterceptResponse {		struct InterceptResponse {
	uint8_t success; // 0 or 1		InterceptStatus status;
	char error_message[127]; // always null-terminated		char error_message[127]; // always null-terminated
	};		};

debuggerd/tombstoned/intercept_manager.cpp

+13 −2

Original line number	Original line	Diff line number	Diff line
	@@ -105,6 +105,7 @@ static void intercept_request_cb(evutil_socket_t sockfd, short ev, void* arg) {
	// We trust the other side, so only do minimal validity checking.		// We trust the other side, so only do minimal validity checking.
	if (intercept_request.pid <= 0 \|\| intercept_request.pid > std::numeric_limits<pid_t>::max()) {		if (intercept_request.pid <= 0 \|\| intercept_request.pid > std::numeric_limits<pid_t>::max()) {
	InterceptResponse response = {};		InterceptResponse response = {};
			response.status = InterceptStatus::kFailed;
	snprintf(response.error_message, sizeof(response.error_message), "invalid pid %" PRId32,		snprintf(response.error_message, sizeof(response.error_message), "invalid pid %" PRId32,
	intercept_request.pid);		intercept_request.pid);
	TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response)));		TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response)));
	@@ -113,9 +114,10 @@ static void intercept_request_cb(evutil_socket_t sockfd, short ev, void* arg) {

	intercept->intercept_pid = intercept_request.pid;		intercept->intercept_pid = intercept_request.pid;

	// Register the intercept with the InterceptManager.		// Check if it's already registered.
	if (intercept_manager->intercepts.count(intercept_request.pid) > 0) {		if (intercept_manager->intercepts.count(intercept_request.pid) > 0) {
	InterceptResponse response = {};		InterceptResponse response = {};
			response.status = InterceptStatus::kFailed;
	snprintf(response.error_message, sizeof(response.error_message),		snprintf(response.error_message, sizeof(response.error_message),
	"pid %" PRId32 " already intercepted", intercept_request.pid);		"pid %" PRId32 " already intercepted", intercept_request.pid);
	TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response)));		TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response)));
	@@ -123,6 +125,15 @@ static void intercept_request_cb(evutil_socket_t sockfd, short ev, void* arg) {
	goto fail;		goto fail;
	}		}

			// Let the other side know that the intercept has been registered, now that we know we can't
			// fail. tombstoned is single threaded, so this isn't racy.
			InterceptResponse response = {};
			response.status = InterceptStatus::kRegistered;
			if (TEMP_FAILURE_RETRY(write(sockfd, &response, sizeof(response))) == -1) {
			PLOG(WARNING) << "failed to notify interceptor of registration";
			goto fail;
			}

	intercept->output_fd = std::move(rcv_fd);		intercept->output_fd = std::move(rcv_fd);
	intercept_manager->intercepts[intercept_request.pid] = std::unique_ptr<Intercept>(intercept);		intercept_manager->intercepts[intercept_request.pid] = std::unique_ptr<Intercept>(intercept);
	intercept->registered = true;		intercept->registered = true;
	@@ -174,7 +185,7 @@ bool InterceptManager::GetIntercept(pid_t pid, android::base::unique_fd* out_fd)

	LOG(INFO) << "found intercept fd " << intercept->output_fd.get() << " for pid " << pid;		LOG(INFO) << "found intercept fd " << intercept->output_fd.get() << " for pid " << pid;
	InterceptResponse response = {};		InterceptResponse response = {};
	response.success = 1;		response.status = InterceptStatus::kStarted;
	TEMP_FAILURE_RETRY(write(intercept->sockfd, &response, sizeof(response)));		TEMP_FAILURE_RETRY(write(intercept->sockfd, &response, sizeof(response)));
	*out_fd = std::move(intercept->output_fd);		*out_fd = std::move(intercept->output_fd);