async.c File Reference

#include <assert.h>
#include "uv.h"
#include "internal.h"
#include "atomicops-inl.h"
#include "handle-inl.h"
#include "req-inl.h"

Go to the source code of this file.

Functions
void	uv_async_endgame (uv_loop_t *loop, uv_async_t *handle)
int	uv_async_init (uv_loop_t *loop, uv_async_t *handle, uv_async_cb async_cb)
void	uv_async_close (uv_loop_t *loop, uv_async_t *handle)
int	uv_async_send (uv_async_t *handle)
void	uv_process_async_wakeup_req (uv_loop_t *loop, uv_async_t *handle, uv_req_t *req)

Function Documentation

uv_async_close()

void uv_async_close	(	uv_loop_t *	loop,
		uv_async_t *	handle
	)

Definition at line 57 of file async.c.

                                                         {
  if (!((uv_async_t*)handle)->async_sent) {
    uv_want_endgame(loop, (uv_handle_t*) handle);
  }
 
  uv__handle_closing(handle);
}

References handle, loop, uv__handle_closing, and uv_want_endgame().

Referenced by uv_close().

uv_async_endgame()

void uv_async_endgame	(	uv_loop_t *	loop,
		uv_async_t *	handle
	)

Definition at line 31 of file async.c.

                                                           {
  if (handle->flags & UV_HANDLE_CLOSING &&
      !handle->async_sent) {
    assert(!(handle->flags & UV_HANDLE_CLOSED));
    uv__handle_close(handle);
  }
}

References assert(), handle, uv__handle_close, UV_HANDLE_CLOSED, and UV_HANDLE_CLOSING.

Referenced by uv_process_endgames().

uv_async_init()

int uv_async_init	(	uv_loop_t *	loop,
		uv_async_t *	handle,
		uv_async_cb	async_cb
	)

Definition at line 40 of file async.c.

                                                                             {
  uv_req_t* req;
 
  uv__handle_init(loop, (uv_handle_t*) handle, UV_ASYNC);
  handle->async_sent = 0;
  handle->async_cb = async_cb;
 
  req = &handle->async_req;
  UV_REQ_INIT(req, UV_WAKEUP);
  req->data = handle;
 
  uv__handle_start(handle);
 
  return 0;
}

References err, handle, loop, QUEUE_INSERT_TAIL, req, uv__async_start(), uv__handle_init, uv__handle_start, and UV_REQ_INIT.

Referenced by main(), and uv_loop_init().

uv_async_send()

int uv_async_send

(

uv_async_t *

handle

)

Definition at line 66 of file async.c.

                                      {
  uv_loop_t* loop = handle->loop;
 
  if (handle->type != UV_ASYNC) {
    /* Can't set errno because that's not thread-safe. */
    return -1;
  }
 
  /* The user should make sure never to call uv_async_send to a closing or
   * closed handle. */
  assert(!(handle->flags & UV_HANDLE_CLOSING));
 
  if (!uv__atomic_exchange_set(&handle->async_sent)) {
    POST_COMPLETION_FOR_REQ(loop, &handle->async_req);
  }
 
  return 0;
}

References ACCESS_ONCE, assert(), handle, loop, POST_COMPLETION_FOR_REQ, uv__async_send(), uv__atomic_exchange_set(), and UV_HANDLE_CLOSING.

Referenced by fake_download(), uv__work_cancel(), and worker().

uv_process_async_wakeup_req()

void uv_process_async_wakeup_req	(	uv_loop_t *	loop,
		uv_async_t *	handle,
		uv_req_t *	req
	)

Definition at line 86 of file async.c.

                   {
  assert(handle->type == UV_ASYNC);
  assert(req->type == UV_WAKEUP);
 
  handle->async_sent = 0;
 
  if (handle->flags & UV_HANDLE_CLOSING) {
    uv_want_endgame(loop, (uv_handle_t*)handle);
  } else if (handle->async_cb != NULL) {
    handle->async_cb(handle);
  }
}

References assert(), handle, loop, NULL, req, UV_HANDLE_CLOSING, and uv_want_endgame().

Referenced by uv_process_reqs().