D7net
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
proc
/
self
/
root
/
proc
/
self
/
root
/
opt
/
alt
/
php81
/
usr
/
include
/
php
/
ext
/
swoole
/
include
/
Filename :
swoole_async.h
back
Copy
/* +----------------------------------------------------------------------+ | Swoole | +----------------------------------------------------------------------+ | Copyright (c) 2012-2018 The Swoole Group | +----------------------------------------------------------------------+ | This source file is subject to version 2.0 of the Apache license, | | that is bundled with this package in the file LICENSE, and is | | available through the world-wide-web at the following url: | | http://www.apache.org/licenses/LICENSE-2.0.html | | If you did not receive a copy of the Apache2.0 license and are unable| | to obtain it through the world-wide-web, please send a note to | | license@swoole.com so we can mail you a copy immediately. | +----------------------------------------------------------------------+ | Author: Tianfeng Han <rango@swoole.com> | +----------------------------------------------------------------------+ */ #pragma once #include <vector> #include <string> #include <mutex> #include <atomic> #ifndef O_DIRECT #define O_DIRECT 040000 #endif namespace swoole { enum AsyncFlag { SW_AIO_WRITE_FSYNC = 1u << 1, SW_AIO_EOF = 1u << 2, }; struct AsyncEvent { size_t task_id; uint8_t canceled; /** * input & output */ void *data; /** * output */ ssize_t retval; int error; /** * internal use only */ network::Socket *pipe_socket; double timestamp; void *object; void (*handler)(AsyncEvent *event); void (*callback)(AsyncEvent *event); bool catch_error() { return (error == SW_ERROR_AIO_TIMEOUT || error == SW_ERROR_AIO_CANCELED); } }; struct GethostbynameRequest { const char *name; int family; char *addr; size_t addr_len; GethostbynameRequest(const char *_name, int _family) : name(_name), family(_family) { addr_len = _family == AF_INET6 ? INET6_ADDRSTRLEN : INET_ADDRSTRLEN; addr = new char[addr_len]; } ~GethostbynameRequest() { delete[] addr; } }; class AsyncThreads { public: bool schedule = false; size_t task_num = 0; Pipe *pipe = nullptr; async::ThreadPool *pool = nullptr; network::Socket *read_socket = nullptr; network::Socket *write_socket = nullptr; AsyncThreads(); ~AsyncThreads(); size_t get_task_num() { return task_num; } size_t get_queue_size(); size_t get_worker_num(); void notify_one(); static int callback(Reactor *reactor, Event *event); private: std::mutex init_lock; }; namespace async { typedef void (*Handler)(AsyncEvent *event); AsyncEvent *dispatch(const AsyncEvent *request); void handler_gethostbyname(AsyncEvent *event); void handler_getaddrinfo(AsyncEvent *event); } // namespace async }; // namespace swoole