Update the whitespaces

This commit is contained in:
Ondřej Surý
2019-11-05 12:54:44 +01:00
committed by Witold Kręcicki
parent 31c41735a1
commit 41b35d978e
6 changed files with 11 additions and 11 deletions
+1
View File
@@ -8,6 +8,7 @@
* See the COPYRIGHT file distributed with this work for additional
* information regarding copyright ownership.
*/
#pragma once
#include <config.h>
+1 -1
View File
@@ -641,7 +641,7 @@ isc_taskmgr_createinctx(isc_mem_t *mctx,
isc_taskmgr_t **managerp);
isc_result_t
isc_taskmgr_create(isc_mem_t *mctx, unsigned int workers,
unsigned int default_quantum,
unsigned int default_quantum,
isc_nm_t *nm, isc_taskmgr_t **managerp);
/*%<
* Create a new task manager. isc_taskmgr_createinctx() also associates
+3 -3
View File
@@ -41,7 +41,7 @@ typedef struct isc__networker {
int id; /* thread id */
uv_loop_t loop; /* libuv loop structure */
uv_async_t async; /* async channel to send
* data to this networker */
* data to this networker */
isc_mutex_t lock;
isc_mempool_t * mpool_bufs;
isc_condition_t cond;
@@ -76,7 +76,7 @@ struct isc_nmhandle {
* handles when we're destroying the socket. */
isc_nmsocket_t * socket;
size_t ah_pos; /* Position in socket active handles
* array */
* array */
/* The handle is 'inflight' if netmgr is not currently processing it in
* any way - it might mean that e.g. a recursive resolution is
* happening. For an inflight handle we must wait for the calling
@@ -151,7 +151,7 @@ typedef struct isc__nm_uvreq {
int magic;
isc_nm_t * mgr;
uv_buf_t uvbuf; /* translated isc_region_t, to be sent or
* received */
* received */
isc_sockaddr_t local; /* local address */
isc_sockaddr_t peer; /* peer address */
isc__nm_cb_t cb; /* callback */
+4 -4
View File
@@ -1647,12 +1647,12 @@ isc_task_pause(isc_task_t *task0) {
task->state = task_state_paused;
UNLOCK(&task->lock);
/* XXXWPK TODO optimize it - 'lazy' removal in runner? */
LOCK(&manager->queues[task->threadid].lock);
LOCK(&manager->queues[task->threadid].lock);
if (ISC_LINK_LINKED(task, ready_link)) {
DEQUEUE(manager->queues[task->threadid].ready_tasks,
task, ready_link);
DEQUEUE(manager->queues[task->threadid].ready_tasks,
task, ready_link);
}
UNLOCK(&manager->queues[task->threadid].lock);
UNLOCK(&manager->queues[task->threadid].lock);
}
void
+1 -2
View File
@@ -623,7 +623,7 @@ client_allocsendbuf(ns_client_t *client, isc_buffer_t *buffer,
isc_buffer_init(tcpbuffer, data,
NS_CLIENT_TCP_BUFFER_SIZE);
isc_buffer_init(buffer, data,
NS_CLIENT_TCP_BUFFER_SIZE);
NS_CLIENT_TCP_BUFFER_SIZE);
} else {
isc_buffer_init(buffer, data,
NS_CLIENT_TCP_BUFFER_SIZE);
@@ -1919,7 +1919,6 @@ ns__client_request(void *arg,
LOCK(&mgr->listlock);
ISC_LIST_APPEND(mgr->clients, client, link);
UNLOCK(&mgr->listlock);
}
isc_task_pause(client->task);
if (client->handle == NULL) {
+1 -1
View File
@@ -446,7 +446,7 @@ static isc_result_t
ns_interface_listenudp(ns_interface_t *ifp) {
isc_result_t result;
/* XXXWPK TODO we have to increase refcount on ifp, for both UDP and TCP */
result = isc_nm_udp_listen(ifp->mgr->nm,
result = isc_nm_udp_listen(ifp->mgr->nm,
(isc_nmiface_t*) &ifp->addr, /* XXXWPK TODO! */
ns__client_request,
sizeof(ns_client_t),