Utilities/cmlibuv/src/uv-common.h - third_party/cmake - Git at Google

 /* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to
  * deal in the Software without restriction, including without limitation the
  * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
  * sell copies of the Software, and to permit persons to whom the Software is
  * furnished to do so, subject to the following conditions:
  *
  * The above copyright notice and this permission notice shall be included in
  * all copies or substantial portions of the Software.
  *
  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
  * IN THE SOFTWARE.
  */

 /*
  * This file is private to libuv. It provides common functionality to both
  * Windows and Unix backends.
  */

 #ifndef UV_COMMON_H_
 #define UV_COMMON_H_

 #include <assert.h>
 #include <stdarg.h>
 #include <stddef.h>

 #if defined(_MSC_VER) && _MSC_VER < 1600
 # include "stdint-msvc2008.h"
 #else
 # include <stdint.h>
 #endif

 #include "uv.h"
 #include "tree.h"
 #include "queue.h"

 #if !defined(snprintf) && defined(_MSC_VER) && _MSC_VER < 1900
 extern int snprintf(char*, size_t, const char*, ...);
 #endif

 #define ARRAY_SIZE(a) (sizeof(a) / sizeof((a)[0]))

 #define container_of(ptr, type, member) \
   ((type *) ((char *) (ptr) - offsetof(type, member)))

 #define STATIC_ASSERT(expr)                                                   \
   void uv__static_assert(int static_assert_failed[1 - 2 * !(expr)])

 #ifndef _WIN32
 enum {
   UV__SIGNAL_ONE_SHOT = 0x80000,  /* On signal reception remove sighandler */
   UV__HANDLE_INTERNAL = 0x8000,
   UV__HANDLE_ACTIVE   = 0x4000,
   UV__HANDLE_REF      = 0x2000,
   UV__HANDLE_CLOSING  = 0 /* no-op on unix */
 };
 #else
 # define UV__SIGNAL_ONE_SHOT_DISPATCHED   0x200
 # define UV__SIGNAL_ONE_SHOT              0x100
 # define UV__HANDLE_INTERNAL              0x80
 # define UV__HANDLE_ACTIVE                0x40
 # define UV__HANDLE_REF                   0x20
 # define UV__HANDLE_CLOSING               0x01
 #endif

 int uv__loop_configure(uv_loop_t* loop, uv_loop_option option, va_list ap);

 void uv__loop_close(uv_loop_t* loop);

 int uv__tcp_bind(uv_tcp_t* tcp,
                  const struct sockaddr* addr,
                  unsigned int addrlen,
                  unsigned int flags);

 int uv__tcp_connect(uv_connect_t* req,
                    uv_tcp_t* handle,
                    const struct sockaddr* addr,
                    unsigned int addrlen,
                    uv_connect_cb cb);

 int uv__udp_bind(uv_udp_t* handle,
                  const struct sockaddr* addr,
                  unsigned int  addrlen,
                  unsigned int flags);

 int uv__udp_send(uv_udp_send_t* req,
                  uv_udp_t* handle,
                  const uv_buf_t bufs[],
                  unsigned int nbufs,
                  const struct sockaddr* addr,
                  unsigned int addrlen,
                  uv_udp_send_cb send_cb);

 int uv__udp_try_send(uv_udp_t* handle,
                      const uv_buf_t bufs[],
                      unsigned int nbufs,
                      const struct sockaddr* addr,
                      unsigned int addrlen);

 int uv__udp_recv_start(uv_udp_t* handle, uv_alloc_cb alloccb,
                        uv_udp_recv_cb recv_cb);

 int uv__udp_recv_stop(uv_udp_t* handle);

 void uv__fs_poll_close(uv_fs_poll_t* handle);

 int uv__getaddrinfo_translate_error(int sys_err);    /* EAI_* error. */

 void uv__work_submit(uv_loop_t* loop,
                      struct uv__work *w,
                      void (*work)(struct uv__work *w),
                      void (*done)(struct uv__work *w, int status));

 void uv__work_done(uv_async_t* handle);

 size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs);

 int uv__socket_sockopt(uv_handle_t* handle, int optname, int* value);

 void uv__fs_scandir_cleanup(uv_fs_t* req);

 #define uv__has_active_reqs(loop)                                             \
   (QUEUE_EMPTY(&(loop)->active_reqs) == 0)

 #define uv__req_register(loop, req)                                           \
   do {                                                                        \
     QUEUE_INSERT_TAIL(&(loop)->active_reqs, &(req)->active_queue);            \
   }                                                                           \
   while (0)

 #define uv__req_unregister(loop, req)                                         \
   do {                                                                        \
     assert(uv__has_active_reqs(loop));                                        \
     QUEUE_REMOVE(&(req)->active_queue);                                       \
   }                                                                           \
   while (0)

 #define uv__has_active_handles(loop)                                          \
   ((loop)->active_handles > 0)

 #define uv__active_handle_add(h)                                              \
   do {                                                                        \
     (h)->loop->active_handles++;                                              \
   }                                                                           \
   while (0)

 #define uv__active_handle_rm(h)                                               \
   do {                                                                        \
     (h)->loop->active_handles--;                                              \
   }                                                                           \
   while (0)

 #define uv__is_active(h)                                                      \
   (((h)->flags & UV__HANDLE_ACTIVE) != 0)

 #define uv__is_closing(h)                                                     \
   (((h)->flags & (UV_CLOSING |  UV_CLOSED)) != 0)

 #define uv__handle_start(h)                                                   \
   do {                                                                        \
     assert(((h)->flags & UV__HANDLE_CLOSING) == 0);                           \
     if (((h)->flags & UV__HANDLE_ACTIVE) != 0) break;                         \
     (h)->flags |= UV__HANDLE_ACTIVE;                                          \
     if (((h)->flags & UV__HANDLE_REF) != 0) uv__active_handle_add(h);         \
   }                                                                           \
   while (0)

 #define uv__handle_stop(h)                                                    \
   do {                                                                        \
     assert(((h)->flags & UV__HANDLE_CLOSING) == 0);                           \
     if (((h)->flags & UV__HANDLE_ACTIVE) == 0) break;                         \
     (h)->flags &= ~UV__HANDLE_ACTIVE;                                         \
     if (((h)->flags & UV__HANDLE_REF) != 0) uv__active_handle_rm(h);          \
   }                                                                           \
   while (0)

 #define uv__handle_ref(h)                                                     \
   do {                                                                        \
     if (((h)->flags & UV__HANDLE_REF) != 0) break;                            \
     (h)->flags |= UV__HANDLE_REF;                                             \
     if (((h)->flags & UV__HANDLE_CLOSING) != 0) break;                        \
     if (((h)->flags & UV__HANDLE_ACTIVE) != 0) uv__active_handle_add(h);      \
   }                                                                           \
   while (0)

 #define uv__handle_unref(h)                                                   \
   do {                                                                        \
     if (((h)->flags & UV__HANDLE_REF) == 0) break;                            \
     (h)->flags &= ~UV__HANDLE_REF;                                            \
     if (((h)->flags & UV__HANDLE_CLOSING) != 0) break;                        \
     if (((h)->flags & UV__HANDLE_ACTIVE) != 0) uv__active_handle_rm(h);       \
   }                                                                           \
   while (0)

 #define uv__has_ref(h)                                                        \
   (((h)->flags & UV__HANDLE_REF) != 0)

 #if defined(_WIN32)
 # define uv__handle_platform_init(h) ((h)->u.fd = -1)
 #else
 # define uv__handle_platform_init(h) ((h)->next_closing = NULL)
 #endif

 #define uv__handle_init(loop_, h, type_)                                      \
   do {                                                                        \
     (h)->loop = (loop_);                                                      \
     (h)->type = (type_);                                                      \
     (h)->flags = UV__HANDLE_REF;  /* Ref the loop when active. */             \
     QUEUE_INSERT_TAIL(&(loop_)->handle_queue, &(h)->handle_queue);            \
     uv__handle_platform_init(h);                                              \
   }                                                                           \
   while (0)

 /* Note: uses an open-coded version of SET_REQ_SUCCESS() because of
  * a circular dependency between src/uv-common.h and src/win/internal.h.
  */
 #if defined(_WIN32)
 # define UV_REQ_INIT(req, typ)                                                \
   do {                                                                        \
     (req)->type = (typ);                                                      \
     (req)->u.io.overlapped.Internal = 0;  /* SET_REQ_SUCCESS() */             \
   }                                                                           \
   while (0)
 #else
 # define UV_REQ_INIT(req, typ)                                                \
   do {                                                                        \
     (req)->type = (typ);                                                      \
   }                                                                           \
   while (0)
 #endif

 #define uv__req_init(loop, req, typ)                                          \
   do {                                                                        \
     UV_REQ_INIT(req, typ);                                                    \
     uv__req_register(loop, req);                                              \
   }                                                                           \
   while (0)

 /* Allocator prototypes */
 void *uv__calloc(size_t count, size_t size);
 char *uv__strdup(const char* s);
 char *uv__strndup(const char* s, size_t n);
 void* uv__malloc(size_t size);
 void uv__free(void* ptr);
 void* uv__realloc(void* ptr, size_t size);

 #endif /* UV_COMMON_H_ */
	/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
	*
	* Permission is hereby granted, free of charge, to any person obtaining a copy
	* of this software and associated documentation files (the "Software"), to
	* deal in the Software without restriction, including without limitation the
	* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
	* sell copies of the Software, and to permit persons to whom the Software is
	* furnished to do so, subject to the following conditions:
	*
	* The above copyright notice and this permission notice shall be included in
	* all copies or substantial portions of the Software.
	*
	* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
	* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
	* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
	* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
	* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
	* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
	* IN THE SOFTWARE.
	*/

	/*
	* This file is private to libuv. It provides common functionality to both
	* Windows and Unix backends.
	*/

	#ifndef UV_COMMON_H_
	#define UV_COMMON_H_

	#include <assert.h>
	#include <stdarg.h>
	#include <stddef.h>

	#if defined(_MSC_VER) && _MSC_VER < 1600
	# include "stdint-msvc2008.h"
	#else
	# include <stdint.h>
	#endif

	#include "uv.h"
	#include "tree.h"
	#include "queue.h"

	#if !defined(snprintf) && defined(_MSC_VER) && _MSC_VER < 1900
	extern int snprintf(char, size_t, const char, ...);
	#endif

	#define ARRAY_SIZE(a) (sizeof(a) / sizeof((a)[0]))

	#define container_of(ptr, type, member) \
	((type ) ((char ) (ptr) - offsetof(type, member)))

	#define STATIC_ASSERT(expr) \
	void uv__static_assert(int static_assert_failed[1 - 2 * !(expr)])

	#ifndef _WIN32
	enum {
	UV__SIGNAL_ONE_SHOT = 0x80000, /* On signal reception remove sighandler */
	UV__HANDLE_INTERNAL = 0x8000,
	UV__HANDLE_ACTIVE = 0x4000,
	UV__HANDLE_REF = 0x2000,
	UV__HANDLE_CLOSING = 0 /* no-op on unix */
	};
	#else
	# define UV__SIGNAL_ONE_SHOT_DISPATCHED 0x200
	# define UV__SIGNAL_ONE_SHOT 0x100
	# define UV__HANDLE_INTERNAL 0x80
	# define UV__HANDLE_ACTIVE 0x40
	# define UV__HANDLE_REF 0x20
	# define UV__HANDLE_CLOSING 0x01
	#endif

	int uv__loop_configure(uv_loop_t* loop, uv_loop_option option, va_list ap);

	void uv__loop_close(uv_loop_t* loop);

	int uv__tcp_bind(uv_tcp_t* tcp,
	const struct sockaddr* addr,
	unsigned int addrlen,
	unsigned int flags);

	int uv__tcp_connect(uv_connect_t* req,
	uv_tcp_t* handle,
	const struct sockaddr* addr,
	unsigned int addrlen,
	uv_connect_cb cb);

	int uv__udp_bind(uv_udp_t* handle,
	const struct sockaddr* addr,
	unsigned int addrlen,
	unsigned int flags);

	int uv__udp_send(uv_udp_send_t* req,
	uv_udp_t* handle,
	const uv_buf_t bufs[],
	unsigned int nbufs,
	const struct sockaddr* addr,
	unsigned int addrlen,
	uv_udp_send_cb send_cb);

	int uv__udp_try_send(uv_udp_t* handle,
	const uv_buf_t bufs[],
	unsigned int nbufs,
	const struct sockaddr* addr,
	unsigned int addrlen);

	int uv__udp_recv_start(uv_udp_t* handle, uv_alloc_cb alloccb,
	uv_udp_recv_cb recv_cb);

	int uv__udp_recv_stop(uv_udp_t* handle);

	void uv__fs_poll_close(uv_fs_poll_t* handle);

	int uv__getaddrinfo_translate_error(int sys_err); /* EAI_* error. */

	void uv__work_submit(uv_loop_t* loop,
	struct uv__work *w,
	void (work)(struct uv__work w),
	void (done)(struct uv__work w, int status));

	void uv__work_done(uv_async_t* handle);

	size_t uv__count_bufs(const uv_buf_t bufs[], unsigned int nbufs);

	int uv__socket_sockopt(uv_handle_t* handle, int optname, int* value);

	void uv__fs_scandir_cleanup(uv_fs_t* req);

	#define uv__has_active_reqs(loop) \
	(QUEUE_EMPTY(&(loop)->active_reqs) == 0)

	#define uv__req_register(loop, req) \
	do { \
	QUEUE_INSERT_TAIL(&(loop)->active_reqs, &(req)->active_queue); \
	} \
	while (0)

	#define uv__req_unregister(loop, req) \
	do { \
	assert(uv__has_active_reqs(loop)); \
	QUEUE_REMOVE(&(req)->active_queue); \
	} \
	while (0)

	#define uv__has_active_handles(loop) \
	((loop)->active_handles > 0)

	#define uv__active_handle_add(h) \
	do { \
	(h)->loop->active_handles++; \
	} \
	while (0)

	#define uv__active_handle_rm(h) \
	do { \
	(h)->loop->active_handles--; \
	} \
	while (0)

	#define uv__is_active(h) \
	(((h)->flags & UV__HANDLE_ACTIVE) != 0)

	#define uv__is_closing(h) \
	(((h)->flags & (UV_CLOSING \| UV_CLOSED)) != 0)

	#define uv__handle_start(h) \
	do { \
	assert(((h)->flags & UV__HANDLE_CLOSING) == 0); \
	if (((h)->flags & UV__HANDLE_ACTIVE) != 0) break; \
	(h)->flags \|= UV__HANDLE_ACTIVE; \
	if (((h)->flags & UV__HANDLE_REF) != 0) uv__active_handle_add(h); \
	} \
	while (0)

	#define uv__handle_stop(h) \
	do { \
	assert(((h)->flags & UV__HANDLE_CLOSING) == 0); \
	if (((h)->flags & UV__HANDLE_ACTIVE) == 0) break; \
	(h)->flags &= ~UV__HANDLE_ACTIVE; \
	if (((h)->flags & UV__HANDLE_REF) != 0) uv__active_handle_rm(h); \
	} \
	while (0)

	#define uv__handle_ref(h) \
	do { \
	if (((h)->flags & UV__HANDLE_REF) != 0) break; \
	(h)->flags \|= UV__HANDLE_REF; \
	if (((h)->flags & UV__HANDLE_CLOSING) != 0) break; \
	if (((h)->flags & UV__HANDLE_ACTIVE) != 0) uv__active_handle_add(h); \
	} \
	while (0)

	#define uv__handle_unref(h) \
	do { \
	if (((h)->flags & UV__HANDLE_REF) == 0) break; \
	(h)->flags &= ~UV__HANDLE_REF; \
	if (((h)->flags & UV__HANDLE_CLOSING) != 0) break; \
	if (((h)->flags & UV__HANDLE_ACTIVE) != 0) uv__active_handle_rm(h); \
	} \
	while (0)

	#define uv__has_ref(h) \
	(((h)->flags & UV__HANDLE_REF) != 0)

	#if defined(_WIN32)
	# define uv__handle_platform_init(h) ((h)->u.fd = -1)
	#else
	# define uv__handle_platform_init(h) ((h)->next_closing = NULL)
	#endif

	#define uv__handle_init(loop_, h, type_) \
	do { \
	(h)->loop = (loop_); \
	(h)->type = (type_); \
	(h)->flags = UV__HANDLE_REF; /* Ref the loop when active. */ \
	QUEUE_INSERT_TAIL(&(loop_)->handle_queue, &(h)->handle_queue); \
	uv__handle_platform_init(h); \
	} \
	while (0)

	/* Note: uses an open-coded version of SET_REQ_SUCCESS() because of
	* a circular dependency between src/uv-common.h and src/win/internal.h.
	*/
	#if defined(_WIN32)
	# define UV_REQ_INIT(req, typ) \
	do { \
	(req)->type = (typ); \
	(req)->u.io.overlapped.Internal = 0; /* SET_REQ_SUCCESS() */ \
	} \
	while (0)
	#else
	# define UV_REQ_INIT(req, typ) \
	do { \
	(req)->type = (typ); \
	} \
	while (0)
	#endif

	#define uv__req_init(loop, req, typ) \
	do { \
	UV_REQ_INIT(req, typ); \
	uv__req_register(loop, req); \
	} \
	while (0)

	/* Allocator prototypes */
	void *uv__calloc(size_t count, size_t size);
	char uv__strdup(const char s);
	char uv__strndup(const char s, size_t n);
	void* uv__malloc(size_t size);
	void uv__free(void* ptr);
	void* uv__realloc(void* ptr, size_t size);

	#endif /* UV_COMMON_H_ */