pidgin3: comparison libpurple/protocols/gg/lib/resolver.c

-:783e5cce1a46
+:fd11790cc4d6
 	if (pthread)
 		pthread_setcancelstate(old_state, NULL);
 #endif
 	if (buf != NULL) {
+		while (1) {
 #ifndef sun
-		while ((ret = gethostbyname_r(hostname, &he, buf, buf_len, &he_ptr, &h_errnop)) == ERANGE) {
+			ret = gethostbyname_r(hostname, &he, buf, buf_len, &he_ptr, &h_errnop);
+			if (ret != ERANGE)
+				break;
 #else
-		while (((he_ptr = gethostbyname_r(hostname, &he, buf, buf_len, &h_errnop)) == NULL) && (errno == ERANGE)) {
+			he_ptr = gethostbyname_r(hostname, &he, buf, buf_len, &h_errnop);
-#endif
+			if (he_ptr != NULL || errno != ERANGE)
+				break;
+#endif
 			buf_len *= 2;
 #ifdef GG_CONFIG_HAVE_PTHREAD
 			if (pthread)
 				pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &old_state);
 		if (ret == 0 && he_ptr != NULL && he_ptr->h_addr_list[0] != NULL) {
 			int i;
 			/* Policz liczbę adresów */
-			for (i = 0; he_ptr->h_addr_list[i] != NULL; i++)
+			for (i = 0; he_ptr->h_addr_list[i] != NULL; i++);
-				;
 			/* Zaalokuj */
 #ifdef GG_CONFIG_HAVE_PTHREAD
 			if (pthread)
 	if (he == NULL || he->h_addr_list[0] == NULL)
 		return -1;
 	/* Policz liczbę adresów */
-	for (i = 0; he->h_addr_list[i] != NULL; i++)
+	for (i = 0; he->h_addr_list[i] != NULL; i++);
-		;
 	/* Zaalokuj */
 #ifdef GG_CONFIG_HAVE_PTHREAD
 	if (pthread)
 	} else {
 		addr_ip[1].s_addr = INADDR_NONE;
 		addr_count = 1;
 	}
-	if (send(fd, addr_list != NULL ? addr_list : addr_ip, (addr_count + 1) * sizeof(struct in_addr), 0) != (int)((addr_count + 1) * sizeof(struct in_addr)))
+	if (send(fd, addr_list != NULL ? addr_list : addr_ip,
+		(addr_count + 1) * sizeof(struct in_addr), 0) !=
+		(int)((addr_count + 1) * sizeof(struct in_addr)))
+	{
 		res = -1;
+	}
 #ifdef GG_CONFIG_HAVE_PTHREAD
 	if (pthread)
 		pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &old_state);
 #endif
 /**
 * \internal Rozwiązuje nazwę serwera w osobnym procesie.
 *
 * Połączenia asynchroniczne nie mogą blokować procesu w trakcie rozwiązywania
 * nazwy serwera. W tym celu tworzona jest para gniazd, nowy proces i dopiero
 * w nim przeprowadzane jest rozwiązywanie nazwy. Deskryptor gniazda do odczytu
 * zapisuje się w strukturze sieci i czeka na dane w postaci struktury
 * \c in_addr. Jeśli nie znaleziono nazwy, zwracana jest \c INADDR_NONE.
 *
 * \param fd Wskaźnik na zmienną, gdzie zostanie umieszczony deskryptor gniazda
 * \param priv_data Wskaźnik na zmienną, gdzie zostanie umieszczony wskaźnik
 		gg_debug(GG_DEBUG_MISC, "// gg_resolver_fork_start() out of memory for resolver data\n");
 		return -1;
 	}
 	if (socketpair(AF_LOCAL, SOCK_STREAM, 0, pipes) == -1) {
-		gg_debug(GG_DEBUG_MISC, "// gg_resolver_fork_start() unable to create pipes (errno=%d, %s)\n", errno, strerror(errno));
+		gg_debug(GG_DEBUG_MISC, "// gg_resolver_fork_start() unable "
+			"to create pipes (errno=%d, %s)\n",
+			errno, strerror(errno));
 		free(data);
 		return -1;
 	}
 	data->pid = fork();
 		gg_debug(GG_DEBUG_MISC, "// gg_resolver_pthread_start() out of memory for resolver data\n");
 		return -1;
 	}
 	if (socketpair(AF_LOCAL, SOCK_STREAM, 0, pipes) == -1) {
-		gg_debug(GG_DEBUG_MISC, "// gg_resolver_pthread_start() unable to create pipes (errno=%d, %s)\n", errno, strerror(errno));
+		gg_debug(GG_DEBUG_MISC, "// gg_resolver_pthread_start() unable "
+			"to create pipes (errno=%d, %s)\n",
+			errno, strerror(errno));
 		free(data);
 		return -1;
 	}
 	data->hostname = strdup(hostname);
 /**
 * \internal Struktura przekazywana do wątku rozwiązującego nazwę.
 */
 struct gg_resolver_win32_data {
 	HANDLE thread;		/*< Uchwyt wątku */
+	CRITICAL_SECTION mutex;	/*< Semafor wątku */
 	char *hostname;		/*< Nazwa serwera */
 	int wfd;		/*< Deskryptor do zapisu */
+	int orphan;		/*< Wątek powinien sam po sobie posprzątać */
+	int finished;		/*< Wątek już skończył pracę */
 };
 /**
 * \internal Wątek rozwiązujący nazwę.
 *
 * \param arg Wskaźnik na strukturę \c gg_resolver_win32_data
 */
 static DWORD WINAPI gg_resolver_win32_thread(void *arg)
 {
 	struct gg_resolver_win32_data *data = arg;
+	int result, is_orphan;
-	if (gg_resolver_run(data->wfd, data->hostname, 0) == -1)
-		ExitThread(-1);
+	result = gg_resolver_run(data->wfd, data->hostname, 0);
-	else
-		ExitThread(0);
+	EnterCriticalSection(&data->mutex);
+	is_orphan = data->orphan;
-	return 0;	/* żeby kompilator nie marudził */
+	data->finished = 1;
+	LeaveCriticalSection(&data->mutex);
+	if (is_orphan) {
+		CloseHandle(data->thread);
+		DeleteCriticalSection(&data->mutex);
+		close(data->wfd);
+		free(data->hostname);
+		free(data);
+	}
+	ExitThread(result);
+	return 0; /* żeby kompilator nie marudził */
 }
 /**
 * \internal Rozwiązuje nazwę serwera w osobnym wątku.
 *
 */
 static int gg_resolver_win32_start(int *fd, void **priv_data, const char *hostname)
 {
 	struct gg_resolver_win32_data *data = NULL;
 	int pipes[2], new_errno;
+	CRITICAL_SECTION *mutex = NULL;
 	gg_debug(GG_DEBUG_FUNCTION, "** gg_resolver_win32_start(%p, %p, \"%s\");\n", fd, priv_data, hostname);
 	if (fd == NULL || priv_data == NULL || hostname == NULL) {
 		gg_debug(GG_DEBUG_MISC, "// gg_resolver_win32_start() invalid arguments\n");
 	if (data == NULL) {
 		gg_debug(GG_DEBUG_MISC, "// gg_resolver_win32_start() out of memory for resolver data\n");
 		return -1;
 	}
+	data->orphan = 0;
+	data->finished = 0;
 	if (socketpair(AF_LOCAL, SOCK_STREAM, 0, pipes) == -1) {
-		gg_debug(GG_DEBUG_MISC, "// gg_resolver_win32_start() unable to create pipes (errno=%d, %s)\n", errno, strerror(errno));
+		gg_debug(GG_DEBUG_MISC, "// gg_resolver_win32_start() unable to "
+			"create pipes (errno=%d, %s)\n",
+			errno, strerror(errno));
 		free(data);
 		return -1;
 	}
 	data->hostname = strdup(hostname);
 		new_errno = errno;
 		goto cleanup;
 	}
 	data->wfd = pipes[1];
+	mutex = &data->mutex;
+	InitializeCriticalSection(mutex);
 	data->thread = CreateThread(NULL, 0, gg_resolver_win32_thread, data, 0, NULL);
 	if (!data->thread) {
 		gg_debug(GG_DEBUG_MISC, "// gg_resolver_win32_start() unable to create thread\n");
 		new_errno = errno;
 	}
 	close(pipes[0]);
 	close(pipes[1]);
+	if (mutex)
+		DeleteCriticalSection(mutex);
 	errno = new_errno;
 	return -1;
 }
 	data = (struct gg_resolver_win32_data *) *priv_data;
 	*priv_data = NULL;
 	if (WaitForSingleObject(data->thread, 0) == WAIT_TIMEOUT) {
-		if (force)
+		int finished;
-			TerminateThread(data->thread, 0);
+		/* We cannot call TerminateThread here - it doesn't
+		 * release critical section locks (see MSDN docs).
+		 * if (force) TerminateThread(data->thread, 0);
+		 */
+		EnterCriticalSection(&data->mutex);
+		finished = data->finished;
+		if (!finished)
+			data->orphan = 1;
+		LeaveCriticalSection(&data->mutex);
+		if (!finished)
+			return;
 	}
 	CloseHandle(data->thread);
+	DeleteCriticalSection(&data->mutex);
 	close(data->wfd);
 	free(data->hostname);
 	free(data);
 }
 * \param resolver_start Funkcja rozpoczynająca rozwiązywanie nazwy
 * \param resolver_cleanup Funkcja zwalniająca zasoby
 *
 * Parametry funkcji rozpoczynającej rozwiązywanie nazwy wyglądają następująco:
 *  - \c "int *fd" &mdash; wskaźnik na zmienną, gdzie zostanie umieszczony deskryptor gniazda
-*  - \c "void **priv_data" &mdash; wskaźnik na zmienną, gdzie można umieścić wskaźnik do prywatnych danych na potrzeby rozwiązywania nazwy
+*  - \c "void **priv_data" &mdash; wskaźnik na zmienną, gdzie można umieścić
+*    wskaźnik do prywatnych danych na potrzeby rozwiązywania nazwy
 *  - \c "const char *name" &mdash; nazwa serwera do rozwiązania
 *
 * Parametry funkcji zwalniającej zasoby wyglądają następująco:
-*  - \c "void **priv_data" &mdash; wskaźnik na zmienną przechowującą wskaźnik do prywatnych danych, należy go ustawić na \c NULL po zakończeniu
+*  - \c "void **priv_data" &mdash; wskaźnik na zmienną przechowującą wskaźnik
-*  - \c "int force" &mdash; flaga mówiąca o tym, że zasoby są zwalniane przed zakończeniem rozwiązywania nazwy, np. z powodu zamknięcia sesji.
+*    do prywatnych danych, należy go ustawić na \c NULL po zakończeniu
+*  - \c "int force" &mdash; flaga mówiąca o tym, że zasoby są zwalniane przed
+*    zakończeniem rozwiązywania nazwy, np. z powodu zamknięcia sesji.
 *
 * Własny kod rozwiązywania nazwy powinien stworzyć potok, parę gniazd lub
 * inny deskryptor pozwalający na co najmniej odbiór danych i przekazać go
 * w parametrze \c fd. Na platformie Windows możliwe jest przekazanie jedynie
 * deskryptora gniazda. Po zakończeniu rozwiązywania nazwy powinien wysłać
 * nazwy, np. za pomocą funkcji \c gg_logoff(), funkcja zwalniająca zasoby
 * zostanie wywołana z parametrem \c force równym \c 1.
 *
 * \return 0 jeśli się powiodło, -1 w przypadku błędu
 */
-int gg_session_set_custom_resolver(struct gg_session *gs, int (*resolver_start)(int*, void**, const char*), void (*resolver_cleanup)(void**, int))
+int gg_session_set_custom_resolver(struct gg_session *gs,
+	int (*resolver_start)(int*, void**, const char*),
+	void (*resolver_cleanup)(void**, int))
 {
 	GG_SESSION_CHECK(gs, -1);
 	if (resolver_start == NULL || resolver_cleanup == NULL) {
 		errno = EINVAL;
 * \param resolver_start Funkcja rozpoczynająca rozwiązywanie nazwy
 * \param resolver_cleanup Funkcja zwalniająca zasoby
 *
 * \return 0 jeśli się powiodło, -1 w przypadku błędu
 */
-int gg_http_set_custom_resolver(struct gg_http *gh, int (*resolver_start)(int*, void**, const char*), void (*resolver_cleanup)(void**, int))
+int gg_http_set_custom_resolver(struct gg_http *gh,
+	int (*resolver_start)(int*, void**, const char*),
+	void (*resolver_cleanup)(void**, int))
 {
 	if (gh == NULL || resolver_start == NULL || resolver_cleanup == NULL) {
 		errno = EINVAL;
 		return -1;
 	}
 *
 * Patrz \ref gg_session_set_custom_resolver.
 *
 * \return 0 jeśli się powiodło, -1 w przypadku błędu
 */
-int gg_global_set_custom_resolver(int (*resolver_start)(int*, void**, const char*), void (*resolver_cleanup)(void**, int))
+int gg_global_set_custom_resolver(
+	int (*resolver_start)(int*, void**, const char*),
+	void (*resolver_cleanup)(void**, int))
 {
 	if (resolver_start == NULL || resolver_cleanup == NULL) {
 		errno = EINVAL;
 		return -1;
 	}
 	return read(fd, buf, len);
 #else
 	return recv(fd, buf, len, 0);
 #endif
 }

Mercurial > pidgin3 / file comparison

comparison: libpurple/protocols/gg/lib/resolver.c

libpurple/protocols/gg/lib/resolver.c