mirror of https://github.com/getdnsapi/getdns.git
Minor fixes
This commit is contained in:
parent
52e3d2e1b0
commit
fe446a0d66
|
@ -77,11 +77,11 @@ extern "C" {
|
||||||
#define GETDNS_CONTEXT_CODE_PUBKEY_PINSET 621
|
#define GETDNS_CONTEXT_CODE_PUBKEY_PINSET 621
|
||||||
#define GETDNS_CONTEXT_CODE_PUBKEY_PINSET_TEXT "Change related to getdns_context_set_pubkey_pinset"
|
#define GETDNS_CONTEXT_CODE_PUBKEY_PINSET_TEXT "Change related to getdns_context_set_pubkey_pinset"
|
||||||
#define GETDNS_CONTEXT_CODE_ROUND_ROBIN_UPSTREAMS 622
|
#define GETDNS_CONTEXT_CODE_ROUND_ROBIN_UPSTREAMS 622
|
||||||
#define GETDNS_CONTEXT_CODE_ROUND_ROBIN_UPSTREAMS_TEXT "Change related to getdns_context_set_pubkey_pinset"
|
#define GETDNS_CONTEXT_CODE_ROUND_ROBIN_UPSTREAMS_TEXT "Change related to getdns_context_set_round_robin_upstreams"
|
||||||
#define GETDNS_CONTEXT_CODE_TLS_BACKOFF_TIME 623
|
#define GETDNS_CONTEXT_CODE_TLS_BACKOFF_TIME 623
|
||||||
#define GETDNS_CONTEXT_CODE_TLS_BACKOFF_TIME_TEXT "Change related to getdns_context_set_pubkey_pinset"
|
#define GETDNS_CONTEXT_CODE_TLS_BACKOFF_TIME_TEXT "Change related to getdns_context_set_tls_backoff_time"
|
||||||
#define GETDNS_CONTEXT_CODE_TLS_CONNECTION_RETRIES 624
|
#define GETDNS_CONTEXT_CODE_TLS_CONNECTION_RETRIES 624
|
||||||
#define GETDNS_CONTEXT_CODE_TLS_CONNECTION_RETRIES_TEXT "Change related to getdns_context_set_pubkey_pinset"
|
#define GETDNS_CONTEXT_CODE_TLS_CONNECTION_RETRIES_TEXT "Change related to getdns_context_set_tls_connection_retries"
|
||||||
/** @}
|
/** @}
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
|
26
src/stub.c
26
src/stub.c
|
@ -32,6 +32,13 @@
|
||||||
*/
|
*/
|
||||||
|
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
|
#ifdef USE_POLL_DEFAULT_EVENTLOOP
|
||||||
|
# ifdef HAVE_SYS_POLL_H
|
||||||
|
# include <sys/poll.h>
|
||||||
|
# else
|
||||||
|
# include <poll.h>
|
||||||
|
# endif
|
||||||
|
#endif
|
||||||
#include "debug.h"
|
#include "debug.h"
|
||||||
#include <openssl/err.h>
|
#include <openssl/err.h>
|
||||||
#include <openssl/conf.h>
|
#include <openssl/conf.h>
|
||||||
|
@ -626,7 +633,15 @@ upstream_idle_timeout_cb(void *userarg)
|
||||||
static void
|
static void
|
||||||
upstream_setup_timeout_cb(void *userarg)
|
upstream_setup_timeout_cb(void *userarg)
|
||||||
{
|
{
|
||||||
|
int ret;
|
||||||
getdns_upstream *upstream = (getdns_upstream *)userarg;
|
getdns_upstream *upstream = (getdns_upstream *)userarg;
|
||||||
|
#ifdef USE_POLL_DEFAULT_EVENTLOOP
|
||||||
|
struct pollfd fds;
|
||||||
|
#else
|
||||||
|
fd_set fds;
|
||||||
|
struct timeval tval;
|
||||||
|
#endif
|
||||||
|
|
||||||
DEBUG_STUB("%s %-35s: FD: %d\n",
|
DEBUG_STUB("%s %-35s: FD: %d\n",
|
||||||
STUB_DEBUG_CLEANUP, __FUNC__, upstream->fd);
|
STUB_DEBUG_CLEANUP, __FUNC__, upstream->fd);
|
||||||
/* Clean up and trigger a write to let the fallback code to its job */
|
/* Clean up and trigger a write to let the fallback code to its job */
|
||||||
|
@ -636,14 +651,17 @@ upstream_setup_timeout_cb(void *userarg)
|
||||||
* TCP SYN and doesn't do a reset (as is the case with e.g. 8.8.8.8@853).
|
* TCP SYN and doesn't do a reset (as is the case with e.g. 8.8.8.8@853).
|
||||||
* For that case the socket never becomes writable so doesn't trigger any
|
* For that case the socket never becomes writable so doesn't trigger any
|
||||||
* callbacks. If so then clear out the queue in one go.*/
|
* callbacks. If so then clear out the queue in one go.*/
|
||||||
int ret;
|
#ifdef USE_POLL_DEFAULT_EVENTLOOP
|
||||||
fd_set fds;
|
fds.fd = upstream->fd;
|
||||||
|
fds.events = POLLOUT;
|
||||||
|
ret = poll(&fds, 1, 0);
|
||||||
|
#else
|
||||||
FD_ZERO(&fds);
|
FD_ZERO(&fds);
|
||||||
FD_SET(FD_SET_T upstream->fd, &fds);
|
FD_SET((int)(upstream->fd), &fds);
|
||||||
struct timeval tval;
|
|
||||||
tval.tv_sec = 0;
|
tval.tv_sec = 0;
|
||||||
tval.tv_usec = 0;
|
tval.tv_usec = 0;
|
||||||
ret = select(upstream->fd+1, NULL, &fds, NULL, &tval);
|
ret = select(upstream->fd+1, NULL, &fds, NULL, &tval);
|
||||||
|
#endif
|
||||||
if (ret == 0) {
|
if (ret == 0) {
|
||||||
DEBUG_STUB("%s %-35s: FD: %d Cleaning up dangling queue\n",
|
DEBUG_STUB("%s %-35s: FD: %d Cleaning up dangling queue\n",
|
||||||
STUB_DEBUG_CLEANUP, __FUNC__, upstream->fd);
|
STUB_DEBUG_CLEANUP, __FUNC__, upstream->fd);
|
||||||
|
|
Loading…
Reference in New Issue