|
Packit |
b5b901 |
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
Packit |
b5b901 |
* of this software and associated documentation files (the "Software"), to
|
|
Packit |
b5b901 |
* deal in the Software without restriction, including without limitation the
|
|
Packit |
b5b901 |
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
|
|
Packit |
b5b901 |
* sell copies of the Software, and to permit persons to whom the Software is
|
|
Packit |
b5b901 |
* furnished to do so, subject to the following conditions:
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* The above copyright notice and this permission notice shall be included in
|
|
Packit |
b5b901 |
* all copies or substantial portions of the Software.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
Packit |
b5b901 |
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
Packit |
b5b901 |
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
Packit |
b5b901 |
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
Packit |
b5b901 |
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
Packit |
b5b901 |
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
|
|
Packit |
b5b901 |
* IN THE SOFTWARE.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include "uv-common.h"
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if !defined(_WIN32)
|
|
Packit |
b5b901 |
# include "unix/internal.h"
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include <stdlib.h>
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
#define MAX_THREADPOOL_SIZE 1024
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static uv_once_t once = UV_ONCE_INIT;
|
|
Packit |
b5b901 |
static uv_cond_t cond;
|
|
Packit |
b5b901 |
static uv_mutex_t mutex;
|
|
Packit |
b5b901 |
static unsigned int idle_threads;
|
|
Packit |
b5b901 |
static unsigned int slow_io_work_running;
|
|
Packit |
b5b901 |
static unsigned int nthreads;
|
|
Packit |
b5b901 |
static uv_thread_t* threads;
|
|
Packit |
b5b901 |
static uv_thread_t default_threads[4];
|
|
Packit |
b5b901 |
static QUEUE exit_message;
|
|
Packit |
b5b901 |
static QUEUE wq;
|
|
Packit |
b5b901 |
static QUEUE run_slow_work_message;
|
|
Packit |
b5b901 |
static QUEUE slow_io_pending_wq;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static unsigned int slow_work_thread_threshold(void) {
|
|
Packit |
b5b901 |
return (nthreads + 1) / 2;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void uv__cancelled(struct uv__work* w) {
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* To avoid deadlock with uv_cancel() it's crucial that the worker
|
|
Packit |
b5b901 |
* never holds the global mutex and the loop-local mutex at the same time.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
static void worker(void* arg) {
|
|
Packit |
b5b901 |
struct uv__work* w;
|
|
Packit |
b5b901 |
QUEUE* q;
|
|
Packit |
b5b901 |
int is_slow_work;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_sem_post((uv_sem_t*) arg);
|
|
Packit |
b5b901 |
arg = NULL;
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
uv_mutex_lock(&mutex);
|
|
Packit |
b5b901 |
for (;;) {
|
|
Packit Service |
e08953 |
/* `mutex` should always be locked at this point. */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Keep waiting while either no work is present or only slow I/O
|
|
Packit |
b5b901 |
and we're at the threshold for that. */
|
|
Packit |
b5b901 |
while (QUEUE_EMPTY(&wq) ||
|
|
Packit |
b5b901 |
(QUEUE_HEAD(&wq) == &run_slow_work_message &&
|
|
Packit |
b5b901 |
QUEUE_NEXT(&run_slow_work_message) == &wq &&
|
|
Packit |
b5b901 |
slow_io_work_running >= slow_work_thread_threshold())) {
|
|
Packit |
b5b901 |
idle_threads += 1;
|
|
Packit |
b5b901 |
uv_cond_wait(&cond, &mutex);
|
|
Packit |
b5b901 |
idle_threads -= 1;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
q = QUEUE_HEAD(&wq;;
|
|
Packit |
b5b901 |
if (q == &exit_message) {
|
|
Packit |
b5b901 |
uv_cond_signal(&cond;;
|
|
Packit |
b5b901 |
uv_mutex_unlock(&mutex);
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
QUEUE_REMOVE(q);
|
|
Packit |
b5b901 |
QUEUE_INIT(q); /* Signal uv_cancel() that the work req is executing. */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
is_slow_work = 0;
|
|
Packit |
b5b901 |
if (q == &run_slow_work_message) {
|
|
Packit |
b5b901 |
/* If we're at the slow I/O threshold, re-schedule until after all
|
|
Packit |
b5b901 |
other work in the queue is done. */
|
|
Packit |
b5b901 |
if (slow_io_work_running >= slow_work_thread_threshold()) {
|
|
Packit |
b5b901 |
QUEUE_INSERT_TAIL(&wq, q);
|
|
Packit Service |
e08953 |
continue;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* If we encountered a request to run slow I/O work but there is none
|
|
Packit |
b5b901 |
to run, that means it's cancelled => Start over. */
|
|
Packit |
b5b901 |
if (QUEUE_EMPTY(&slow_io_pending_wq))
|
|
Packit Service |
e08953 |
continue;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
is_slow_work = 1;
|
|
Packit |
b5b901 |
slow_io_work_running++;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
q = QUEUE_HEAD(&slow_io_pending_wq);
|
|
Packit |
b5b901 |
QUEUE_REMOVE(q);
|
|
Packit |
b5b901 |
QUEUE_INIT(q);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* If there is more slow I/O work, schedule it to be run as well. */
|
|
Packit |
b5b901 |
if (!QUEUE_EMPTY(&slow_io_pending_wq)) {
|
|
Packit |
b5b901 |
QUEUE_INSERT_TAIL(&wq, &run_slow_work_message);
|
|
Packit |
b5b901 |
if (idle_threads > 0)
|
|
Packit |
b5b901 |
uv_cond_signal(&cond;;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_mutex_unlock(&mutex);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
w = QUEUE_DATA(q, struct uv__work, wq);
|
|
Packit |
b5b901 |
w->work(w);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_mutex_lock(&w->loop->wq_mutex);
|
|
Packit |
b5b901 |
w->work = NULL; /* Signal uv_cancel() that the work req is done
|
|
Packit |
b5b901 |
executing. */
|
|
Packit |
b5b901 |
QUEUE_INSERT_TAIL(&w->loop->wq, &w->wq);
|
|
Packit |
b5b901 |
uv_async_send(&w->loop->wq_async);
|
|
Packit |
b5b901 |
uv_mutex_unlock(&w->loop->wq_mutex);
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
/* Lock `mutex` since that is expected at the start of the next
|
|
Packit Service |
e08953 |
* iteration. */
|
|
Packit Service |
e08953 |
uv_mutex_lock(&mutex);
|
|
Packit Service |
e08953 |
if (is_slow_work) {
|
|
Packit Service |
e08953 |
/* `slow_io_work_running` is protected by `mutex`. */
|
|
Packit Service |
e08953 |
slow_io_work_running--;
|
|
Packit Service |
e08953 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void post(QUEUE* q, enum uv__work_kind kind) {
|
|
Packit |
b5b901 |
uv_mutex_lock(&mutex);
|
|
Packit |
b5b901 |
if (kind == UV__WORK_SLOW_IO) {
|
|
Packit |
b5b901 |
/* Insert into a separate queue. */
|
|
Packit |
b5b901 |
QUEUE_INSERT_TAIL(&slow_io_pending_wq, q);
|
|
Packit |
b5b901 |
if (!QUEUE_EMPTY(&run_slow_work_message)) {
|
|
Packit |
b5b901 |
/* Running slow I/O tasks is already scheduled => Nothing to do here.
|
|
Packit |
b5b901 |
The worker that runs said other task will schedule this one as well. */
|
|
Packit |
b5b901 |
uv_mutex_unlock(&mutex);
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
q = &run_slow_work_message;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
QUEUE_INSERT_TAIL(&wq, q);
|
|
Packit |
b5b901 |
if (idle_threads > 0)
|
|
Packit |
b5b901 |
uv_cond_signal(&cond;;
|
|
Packit |
b5b901 |
uv_mutex_unlock(&mutex);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
void uv__threadpool_cleanup(void) {
|
|
Packit |
b5b901 |
#ifndef _WIN32
|
|
Packit |
b5b901 |
unsigned int i;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (nthreads == 0)
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
post(&exit_message, UV__WORK_CPU);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
for (i = 0; i < nthreads; i++)
|
|
Packit |
b5b901 |
if (uv_thread_join(threads + i))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (threads != default_threads)
|
|
Packit |
b5b901 |
uv__free(threads);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_mutex_destroy(&mutex);
|
|
Packit |
b5b901 |
uv_cond_destroy(&cond;;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
threads = NULL;
|
|
Packit |
b5b901 |
nthreads = 0;
|
|
Packit |
b5b901 |
#endif
|
|
Packit Service |
e08953 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void init_threads(void) {
|
|
Packit |
b5b901 |
unsigned int i;
|
|
Packit |
b5b901 |
const char* val;
|
|
Packit |
b5b901 |
uv_sem_t sem;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
nthreads = ARRAY_SIZE(default_threads);
|
|
Packit |
b5b901 |
val = getenv("UV_THREADPOOL_SIZE");
|
|
Packit |
b5b901 |
if (val != NULL)
|
|
Packit |
b5b901 |
nthreads = atoi(val);
|
|
Packit |
b5b901 |
if (nthreads == 0)
|
|
Packit |
b5b901 |
nthreads = 1;
|
|
Packit |
b5b901 |
if (nthreads > MAX_THREADPOOL_SIZE)
|
|
Packit |
b5b901 |
nthreads = MAX_THREADPOOL_SIZE;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
threads = default_threads;
|
|
Packit |
b5b901 |
if (nthreads > ARRAY_SIZE(default_threads)) {
|
|
Packit |
b5b901 |
threads = uv__malloc(nthreads * sizeof(threads[0]));
|
|
Packit |
b5b901 |
if (threads == NULL) {
|
|
Packit |
b5b901 |
nthreads = ARRAY_SIZE(default_threads);
|
|
Packit |
b5b901 |
threads = default_threads;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (uv_cond_init(&cond))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (uv_mutex_init(&mutex))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
QUEUE_INIT(&wq;;
|
|
Packit |
b5b901 |
QUEUE_INIT(&slow_io_pending_wq);
|
|
Packit |
b5b901 |
QUEUE_INIT(&run_slow_work_message);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (uv_sem_init(&sem, 0))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
for (i = 0; i < nthreads; i++)
|
|
Packit |
b5b901 |
if (uv_thread_create(threads + i, worker, &sem))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
for (i = 0; i < nthreads; i++)
|
|
Packit |
b5b901 |
uv_sem_wait(&sem);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_sem_destroy(&sem);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifndef _WIN32
|
|
Packit |
b5b901 |
static void reset_once(void) {
|
|
Packit |
b5b901 |
uv_once_t child_once = UV_ONCE_INIT;
|
|
Packit |
b5b901 |
memcpy(&once, &child_once, sizeof(child_once));
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void init_once(void) {
|
|
Packit |
b5b901 |
#ifndef _WIN32
|
|
Packit |
b5b901 |
/* Re-initialize the threadpool after fork.
|
|
Packit |
b5b901 |
* Note that this discards the global mutex and condition as well
|
|
Packit |
b5b901 |
* as the work queue.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (pthread_atfork(NULL, NULL, &reset_once))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
init_threads();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv__work_submit(uv_loop_t* loop,
|
|
Packit |
b5b901 |
struct uv__work* w,
|
|
Packit |
b5b901 |
enum uv__work_kind kind,
|
|
Packit |
b5b901 |
void (*work)(struct uv__work* w),
|
|
Packit |
b5b901 |
void (*done)(struct uv__work* w, int status)) {
|
|
Packit |
b5b901 |
uv_once(&once, init_once);
|
|
Packit |
b5b901 |
w->loop = loop;
|
|
Packit |
b5b901 |
w->work = work;
|
|
Packit |
b5b901 |
w->done = done;
|
|
Packit |
b5b901 |
post(&w->wq, kind);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int uv__work_cancel(uv_loop_t* loop, uv_req_t* req, struct uv__work* w) {
|
|
Packit |
b5b901 |
int cancelled;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_mutex_lock(&mutex);
|
|
Packit |
b5b901 |
uv_mutex_lock(&w->loop->wq_mutex);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
cancelled = !QUEUE_EMPTY(&w->wq) && w->work != NULL;
|
|
Packit |
b5b901 |
if (cancelled)
|
|
Packit |
b5b901 |
QUEUE_REMOVE(&w->wq);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv_mutex_unlock(&w->loop->wq_mutex);
|
|
Packit |
b5b901 |
uv_mutex_unlock(&mutex);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (!cancelled)
|
|
Packit |
b5b901 |
return UV_EBUSY;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
w->work = uv__cancelled;
|
|
Packit |
b5b901 |
uv_mutex_lock(&loop->wq_mutex);
|
|
Packit |
b5b901 |
QUEUE_INSERT_TAIL(&loop->wq, &w->wq);
|
|
Packit |
b5b901 |
uv_async_send(&loop->wq_async);
|
|
Packit |
b5b901 |
uv_mutex_unlock(&loop->wq_mutex);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv__work_done(uv_async_t* handle) {
|
|
Packit |
b5b901 |
struct uv__work* w;
|
|
Packit |
b5b901 |
uv_loop_t* loop;
|
|
Packit |
b5b901 |
QUEUE* q;
|
|
Packit |
b5b901 |
QUEUE wq;
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
loop = container_of(handle, uv_loop_t, wq_async);
|
|
Packit |
b5b901 |
uv_mutex_lock(&loop->wq_mutex);
|
|
Packit |
b5b901 |
QUEUE_MOVE(&loop->wq, &wq;;
|
|
Packit |
b5b901 |
uv_mutex_unlock(&loop->wq_mutex);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
while (!QUEUE_EMPTY(&wq)) {
|
|
Packit |
b5b901 |
q = QUEUE_HEAD(&wq;;
|
|
Packit |
b5b901 |
QUEUE_REMOVE(q);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
w = container_of(q, struct uv__work, wq);
|
|
Packit |
b5b901 |
err = (w->work == uv__cancelled) ? UV_ECANCELED : 0;
|
|
Packit |
b5b901 |
w->done(w, err);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void uv__queue_work(struct uv__work* w) {
|
|
Packit |
b5b901 |
uv_work_t* req = container_of(w, uv_work_t, work_req);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
req->work_cb(req);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void uv__queue_done(struct uv__work* w, int err) {
|
|
Packit |
b5b901 |
uv_work_t* req;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
req = container_of(w, uv_work_t, work_req);
|
|
Packit |
b5b901 |
uv__req_unregister(req->loop, req);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (req->after_work_cb == NULL)
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
req->after_work_cb(req, err);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_queue_work(uv_loop_t* loop,
|
|
Packit |
b5b901 |
uv_work_t* req,
|
|
Packit |
b5b901 |
uv_work_cb work_cb,
|
|
Packit |
b5b901 |
uv_after_work_cb after_work_cb) {
|
|
Packit |
b5b901 |
if (work_cb == NULL)
|
|
Packit |
b5b901 |
return UV_EINVAL;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv__req_init(loop, req, UV_WORK);
|
|
Packit |
b5b901 |
req->loop = loop;
|
|
Packit |
b5b901 |
req->work_cb = work_cb;
|
|
Packit |
b5b901 |
req->after_work_cb = after_work_cb;
|
|
Packit |
b5b901 |
uv__work_submit(loop,
|
|
Packit |
b5b901 |
&req->work_req,
|
|
Packit |
b5b901 |
UV__WORK_CPU,
|
|
Packit |
b5b901 |
uv__queue_work,
|
|
Packit |
b5b901 |
uv__queue_done);
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_cancel(uv_req_t* req) {
|
|
Packit |
b5b901 |
struct uv__work* wreq;
|
|
Packit |
b5b901 |
uv_loop_t* loop;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
switch (req->type) {
|
|
Packit |
b5b901 |
case UV_FS:
|
|
Packit |
b5b901 |
loop = ((uv_fs_t*) req)->loop;
|
|
Packit |
b5b901 |
wreq = &((uv_fs_t*) req)->work_req;
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
case UV_GETADDRINFO:
|
|
Packit |
b5b901 |
loop = ((uv_getaddrinfo_t*) req)->loop;
|
|
Packit |
b5b901 |
wreq = &((uv_getaddrinfo_t*) req)->work_req;
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
case UV_GETNAMEINFO:
|
|
Packit |
b5b901 |
loop = ((uv_getnameinfo_t*) req)->loop;
|
|
Packit |
b5b901 |
wreq = &((uv_getnameinfo_t*) req)->work_req;
|
|
Packit |
b5b901 |
break;
|
|
Packit Service |
e08953 |
case UV_RANDOM:
|
|
Packit Service |
e08953 |
loop = ((uv_random_t*) req)->loop;
|
|
Packit Service |
e08953 |
wreq = &((uv_random_t*) req)->work_req;
|
|
Packit Service |
e08953 |
break;
|
|
Packit |
b5b901 |
case UV_WORK:
|
|
Packit |
b5b901 |
loop = ((uv_work_t*) req)->loop;
|
|
Packit |
b5b901 |
wreq = &((uv_work_t*) req)->work_req;
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
default:
|
|
Packit |
b5b901 |
return UV_EINVAL;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return uv__work_cancel(loop, req, wreq);
|
|
Packit |
b5b901 |
}
|