Function ProcessSpawnImpl

lib/base/process.cpp:76–224

#ifndef _WIN32
static Value ProcessSpawnImpl(struct msghdr *msgh, const Dictionary::Ptr& request)
{
	struct cmsghdr *cmsg = CMSG_FIRSTHDR(msgh);

	if (cmsg == nullptr || cmsg->cmsg_level != SOL_SOCKET || cmsg->cmsg_len != CMSG_LEN(sizeof(int) * 3)) {
		std::cerr << "Invalid 'spawn' request: FDs missing" << std::endl;
		return Empty;
	}

	auto *fds = (int *)CMSG_DATA(cmsg);

	Array::Ptr arguments = request->Get("arguments");
	Dictionary::Ptr extraEnvironment = request->Get("extraEnvironment");
	bool adjustPriority = request->Get("adjustPriority");

	// build argv
	auto **argv = new char *[arguments->GetLength() + 1];

	for (unsigned int i = 0; i < arguments->GetLength(); i++) {
		String arg = arguments->Get(i);
		argv[i] = strdup(arg.CStr());
	}

	argv[arguments->GetLength()] = nullptr;

	// build envp
	int envc = 0;

	/* count existing environment variables */
	while (environ[envc])
		envc++;

	auto **envp = new char *[envc + (extraEnvironment ? extraEnvironment->GetLength() : 0) + 2];
	const char* lcnumeric = "LC_NUMERIC=";
	const char* notifySocket = "NOTIFY_SOCKET=";
	int j = 0;

	for (int i = 0; i < envc; i++) {
		if (strncmp(environ[i], lcnumeric, strlen(lcnumeric)) == 0) {
			continue;
		}

		if (strncmp(environ[i], notifySocket, strlen(notifySocket)) == 0) {
			continue;
		}

		envp[j] = strdup(environ[i]);
		++j;
	}

	if (extraEnvironment) {
		ObjectLock olock(extraEnvironment);

		for (const Dictionary::Pair& kv : extraEnvironment) {
			String skv = kv.first + "=" + Convert::ToString(kv.second);
			envp[j] = strdup(skv.CStr());
			j++;
		}