-
Notifications
You must be signed in to change notification settings - Fork 3.2k
/
Copy pathcoroutine_system.h
55 lines (52 loc) · 2.52 KB
/
coroutine_system.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
/*
+----------------------------------------------------------------------+
| Swoole |
+----------------------------------------------------------------------+
| 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 |
| [email protected] so we can mail you a copy immediately. |
+----------------------------------------------------------------------+
| Author: Tianfeng Han <[email protected]> |
| Twosee <[email protected]> |
+----------------------------------------------------------------------+
*/
#pragma once
#include "coroutine.h"
#include <string>
#include <vector>
namespace swoole { namespace coroutine {
//-------------------------------------------------------------------------------
class System
{
public:
static void init_reactor(swReactor *reactor);
/* sleep */
static int sleep(double sec);
/* file */
static swString* read_file(const char *file, bool lock = false);
static ssize_t write_file(const char *file, char *buf, size_t length, bool lock = 0, int flags = 0);
/* dns */
static std::string gethostbyname(const std::string &hostname, int domain, double timeout = -1);
static std::vector<std::string> getaddrinfo(
const std::string &hostname, int family = AF_INET, int socktype = SOCK_STREAM, int protocol = IPPROTO_TCP,
const std::string &service = "", double timeout = -1
);
static void set_dns_cache_expire(time_t expire);
static void set_dns_cache_capacity(size_t capacity);
static void clear_dns_cache();
/* multiplexing */
static bool socket_poll(std::unordered_map<int, socket_poll_fd> &fds, double timeout);
/* wait */
static pid_t wait(int *__stat_loc, double timeout = -1);
static pid_t waitpid(pid_t __pid, int *__stat_loc, int __options, double timeout = -1);
/* signal */
static bool wait_signal(int signo, double timeout = -1);
/* event */
static int wait_event(int fd, int events, double timeout);
};
//-------------------------------------------------------------------------------
}}