#define sendheader(c, r) sendto_one_notice(c, HeaderMessages[(r)])
static rb_dlink_list auth_poll_list;
-static BlockHeap *auth_heap;
+static rb_bh *auth_heap;
static EVH timeout_auth_queries_event;
static PF read_auth_reply;
/* This hook takes a struct Client for its argument */
memset(&auth_poll_list, 0, sizeof(auth_poll_list));
eventAddIsh("timeout_auth_queries_event", timeout_auth_queries_event, NULL, 1);
- auth_heap = BlockHeapCreate(sizeof(struct AuthRequest), LCLIENT_HEAP_SIZE);
+ auth_heap = rb_bh_create(sizeof(struct AuthRequest), LCLIENT_HEAP_SIZE);
}
/*
static struct AuthRequest *
make_auth_request(struct Client *client)
{
- struct AuthRequest *request = BlockHeapAlloc(auth_heap);
+ struct AuthRequest *request = rb_bh_alloc(auth_heap);
client->localClient->auth_request = request;
request->fd = -1;
request->client = client;
- request->timeout = CurrentTime + ConfigFileEntry.connect_timeout;
+ request->timeout = rb_current_time() + ConfigFileEntry.connect_timeout;
return request;
}
static void
free_auth_request(struct AuthRequest *request)
{
- BlockHeapFree(auth_heap, request);
+ rb_bh_free(auth_heap, request);
}
/*
{
auth = ptr->data;
- if(auth->timeout < CurrentTime)
+ if(auth->timeout < rb_current_time())
{
if(auth->fd >= 0)
rb_close(auth->fd);
sendheader(auth->client, REPORT_FAIL_DNS);
}
- auth->client->localClient->lasttime = CurrentTime;
+ auth->client->localClient->lasttime = rb_current_time();
release_auth_client(auth);
}
}