mirror of
https://github.com/danog/ext-uv.git
synced 2024-11-30 04:29:01 +01:00
226 lines
4.5 KiB
C
Executable File
226 lines
4.5 KiB
C
Executable File
#ifndef PHP_UV_H
|
|
|
|
#define PHP_UV_H
|
|
|
|
#define PHP_UV_EXTNAME "uv"
|
|
#define PHP_UV_EXTVER "0.0.2"
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
#include "config.h"
|
|
#endif
|
|
|
|
#ifdef PHP_WIN32
|
|
#include <Winsock2.h>
|
|
#include <Mswsock.h>
|
|
#include <psapi.h>
|
|
#include <Iphlpapi.h>
|
|
#endif
|
|
|
|
#ifndef PHP_UV_DTRACE
|
|
#define PHP_UV_DTRACE 0
|
|
#endif
|
|
|
|
#if PHP_UV_DTRACE >= 1
|
|
#include <dtrace.h>
|
|
#include <sys/sdt.h>
|
|
#include "phpuv_dtrace.h"
|
|
#define PHP_UV_PROBE(PROBE) PHPUV_TRACE_##PROBE();
|
|
#else
|
|
#define PHP_UV_PROBE(PROBE)
|
|
#endif
|
|
|
|
#include "php.h"
|
|
#include "uv.h"
|
|
|
|
#ifdef ENABLE_HTTPPARSER
|
|
#include "uv_http_parser.h"
|
|
#endif
|
|
|
|
#include "php_network.h"
|
|
#include "php_streams.h"
|
|
|
|
#ifdef HAVE_SOCKETS
|
|
#include "ext/sockets/php_sockets.h"
|
|
#elif !defined(PHP_WIN32)
|
|
typedef struct {
|
|
int bsd_socket;
|
|
/* other fields are not interesting... */
|
|
} php_socket;
|
|
#endif
|
|
|
|
#include <Zend/zend.h>
|
|
#include <Zend/zend_compile.h>
|
|
#include <Zend/zend_exceptions.h>
|
|
#include <Zend/zend_extensions.h>
|
|
#include <Zend/zend_globals.h>
|
|
#include <Zend/zend_hash.h>
|
|
#include <Zend/zend_ts_hash.h>
|
|
#include <Zend/zend_interfaces.h>
|
|
#include <Zend/zend_list.h>
|
|
#include <Zend/zend_object_handlers.h>
|
|
#include <Zend/zend_variables.h>
|
|
#include <Zend/zend_vm.h>
|
|
|
|
/* Define the entry point symbol
|
|
* Zend will use when loading this module
|
|
*/
|
|
extern zend_module_entry uv_module_entry;
|
|
#define phpext_uv_ptr &uv_module_entry
|
|
|
|
extern zend_class_entry *uv_class_entry;
|
|
|
|
enum php_uv_lock_type{
|
|
IS_UV_RWLOCK = 1,
|
|
IS_UV_RWLOCK_RD = 2,
|
|
IS_UV_RWLOCK_WR = 3,
|
|
IS_UV_MUTEX = 4,
|
|
IS_UV_SEMAPHORE = 5,
|
|
};
|
|
|
|
enum php_uv_resource_type{
|
|
IS_UV_TCP = 0,
|
|
IS_UV_UDP = 1,
|
|
IS_UV_PIPE = 2,
|
|
IS_UV_IDLE = 3,
|
|
IS_UV_TIMER = 4,
|
|
IS_UV_ASYNC = 5,
|
|
IS_UV_LOOP = 6,
|
|
IS_UV_HANDLE = 7,
|
|
IS_UV_STREAM = 8,
|
|
IS_UV_ADDRINFO = 9,
|
|
IS_UV_PROCESS = 10,
|
|
IS_UV_PREPARE = 11,
|
|
IS_UV_CHECK = 12,
|
|
IS_UV_WORK = 13,
|
|
IS_UV_FS = 14,
|
|
IS_UV_FS_EVENT = 15,
|
|
IS_UV_TTY = 16,
|
|
IS_UV_FS_POLL = 17,
|
|
IS_UV_POLL = 18,
|
|
IS_UV_SIGNAL = 19,
|
|
IS_UV_MAX = 20
|
|
};
|
|
|
|
enum php_uv_callback_type{
|
|
PHP_UV_LISTEN_CB = 0,
|
|
PHP_UV_READ_CB = 1,
|
|
PHP_UV_READ2_CB = 2,
|
|
PHP_UV_WRITE_CB = 3,
|
|
PHP_UV_SHUTDOWN_CB = 4,
|
|
PHP_UV_CLOSE_CB = 5,
|
|
PHP_UV_TIMER_CB = 6,
|
|
PHP_UV_IDLE_CB = 7,
|
|
PHP_UV_CONNECT_CB = 8,
|
|
PHP_UV_GETADDR_CB = 9,
|
|
PHP_UV_RECV_CB = 10,
|
|
PHP_UV_SEND_CB = 11,
|
|
PHP_UV_PIPE_CONNECT_CB = 12,
|
|
PHP_UV_PROC_CLOSE_CB = 13,
|
|
PHP_UV_PREPARE_CB = 14,
|
|
PHP_UV_CHECK_CB = 15,
|
|
PHP_UV_ASYNC_CB = 16,
|
|
PHP_UV_WORK_CB = 17,
|
|
PHP_UV_AFTER_WORK_CB = 18,
|
|
PHP_UV_FS_CB = 19,
|
|
PHP_UV_FS_EVENT_CB = 20,
|
|
PHP_UV_FS_POLL_CB = 21,
|
|
PHP_UV_POLL_CB = 22,
|
|
PHP_UV_SIGNAL_CB = 23,
|
|
PHP_UV_CB_MAX = 24
|
|
};
|
|
|
|
typedef struct {
|
|
zend_fcall_info fci;
|
|
zend_fcall_info_cache fcc;
|
|
} php_uv_cb_t;
|
|
|
|
typedef struct {
|
|
int in_free;
|
|
#ifdef ZTS
|
|
void ***thread_ctx;
|
|
#endif
|
|
zend_resource *resource_id;
|
|
int type;
|
|
uv_os_sock_t sock;
|
|
union {
|
|
uv_tcp_t tcp;
|
|
uv_udp_t udp;
|
|
uv_pipe_t pipe;
|
|
uv_idle_t idle;
|
|
uv_timer_t timer;
|
|
uv_async_t async;
|
|
uv_loop_t loop;
|
|
uv_handle_t handle;
|
|
uv_req_t req;
|
|
uv_stream_t stream;
|
|
uv_getaddrinfo_t addrinfo;
|
|
uv_prepare_t prepare;
|
|
uv_check_t check;
|
|
uv_process_t process;
|
|
uv_work_t work;
|
|
uv_fs_t fs;
|
|
uv_fs_event_t fs_event;
|
|
uv_tty_t tty;
|
|
uv_fs_poll_t fs_poll;
|
|
uv_poll_t poll;
|
|
uv_signal_t signal;
|
|
} uv;
|
|
char *buffer;
|
|
zend_resource *fs_fd;
|
|
php_uv_cb_t *callback[PHP_UV_CB_MAX];
|
|
} php_uv_t;
|
|
|
|
typedef struct {
|
|
int is_ipv4;
|
|
zend_resource *resource_id;
|
|
union {
|
|
struct sockaddr_in ipv4;
|
|
struct sockaddr_in6 ipv6;
|
|
} addr;
|
|
} php_uv_sockaddr_t;
|
|
|
|
typedef struct {
|
|
int locked;
|
|
enum php_uv_lock_type type;
|
|
zend_resource *resource_id;
|
|
union {
|
|
uv_rwlock_t rwlock;
|
|
uv_mutex_t mutex;
|
|
uv_sem_t semaphore;
|
|
} lock;
|
|
} php_uv_lock_t;
|
|
|
|
typedef struct {
|
|
zend_resource *resource_id;
|
|
int fd;
|
|
zend_resource *stream;
|
|
int flags;
|
|
} php_uv_stdio_t;
|
|
|
|
#define PHP_UV_RESOURCE_NAME "uv"
|
|
#define PHP_UV_SOCKADDR_RESOURCE_NAME "uv_sockaddr"
|
|
#define PHP_UV_LOOP_RESOURCE_NAME "uv_loop"
|
|
#define PHP_UV_ARES_RESOURCE_NAME "uv_ares"
|
|
#define PHP_UV_LOCK_RESOURCE_NAME "uv_lock"
|
|
#define PHP_UV_MUTEX_RESOURCE_NAME "uv_mutex"
|
|
#define PHP_UV_STDIO_RESOURCE_NAME "uv_stdio"
|
|
|
|
|
|
#define PHP_UV_LIST_INSERT(type, handle) Z_RES_P(zend_list_insert(type, handle))
|
|
|
|
|
|
/* File/directory stat mode constants*/
|
|
#ifdef PHP_WIN32
|
|
#define S_IFDIR _S_IFDIR
|
|
#define S_IFREG _S_IFREG
|
|
#else
|
|
#ifndef S_IFDIR
|
|
#define S_IFDIR 0040000
|
|
#endif
|
|
#ifndef S_IFREG
|
|
#define S_IFREG 0100000
|
|
#endif
|
|
#endif
|
|
|
|
#endif /* PHP_UV_H */
|