-
Notifications
You must be signed in to change notification settings - Fork 3.2k
/
Copy pathphp_swoole_server.h
83 lines (76 loc) · 3.96 KB
/
php_swoole_server.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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
/*
+----------------------------------------------------------------------+
| Swoole |
+----------------------------------------------------------------------+
| Copyright (c) 2012-2015 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 |
| [email protected] so we can mail you a copy immediately. |
+----------------------------------------------------------------------+
| Author: Tianfeng Han <[email protected]> |
+----------------------------------------------------------------------+
*/
#pragma once
#include "php_swoole_cxx.h"
#include "swoole_server.h"
//--------------------------------------------------------
enum php_swoole_server_callback_type {
SW_SERVER_CB_onStart, // master
SW_SERVER_CB_onShutdown, // master
SW_SERVER_CB_onWorkerStart, // worker(event & task)
SW_SERVER_CB_onWorkerStop, // worker(event & task)
SW_SERVER_CB_onBeforeReload, // manager
SW_SERVER_CB_onAfterReload, // manager
SW_SERVER_CB_onTask, // worker(task)
SW_SERVER_CB_onFinish, // worker(event & task)
SW_SERVER_CB_onWorkerExit, // worker(event)
SW_SERVER_CB_onWorkerError, // manager
SW_SERVER_CB_onManagerStart, // manager
SW_SERVER_CB_onManagerStop, // manager
SW_SERVER_CB_onPipeMessage, // worker(event & task)
};
//--------------------------------------------------------
enum php_swoole_server_port_callback_type {
SW_SERVER_CB_onConnect, // worker(event)
SW_SERVER_CB_onReceive, // worker(event)
SW_SERVER_CB_onClose, // worker(event)
SW_SERVER_CB_onPacket, // worker(event)
SW_SERVER_CB_onRequest, // http server
SW_SERVER_CB_onHandShake, // worker(event)
SW_SERVER_CB_onOpen, // worker(event)
SW_SERVER_CB_onMessage, // worker(event)
SW_SERVER_CB_onBufferFull, // worker(event)
SW_SERVER_CB_onBufferEmpty, // worker(event)
};
#define PHP_SWOOLE_SERVER_CALLBACK_NUM (SW_SERVER_CB_onPipeMessage + 1)
#define PHP_SWOOLE_SERVER_PORT_CALLBACK_NUM (SW_SERVER_CB_onBufferEmpty + 1)
struct php_swoole_server_port_property {
zval *callbacks[PHP_SWOOLE_SERVER_PORT_CALLBACK_NUM];
zend_fcall_info_cache *caches[PHP_SWOOLE_SERVER_PORT_CALLBACK_NUM];
zval _callbacks[PHP_SWOOLE_SERVER_PORT_CALLBACK_NUM];
swServer *serv;
swListenPort *port;
zval *zsetting;
};
void php_swoole_server_register_callbacks(swServer *serv);
zend_fcall_info_cache *php_swoole_server_get_fci_cache(swServer *serv, int server_fd, int event_type);
int php_swoole_create_dir(const char *path, size_t length);
void php_swoole_server_before_start(swServer *serv, zval *zobject);
void php_swoole_http_server_init_global_variant();
void php_swoole_server_send_yield(swServer *serv, int fd, zval *zdata, zval *return_value);
void php_swoole_get_recv_data(swServer *serv, zval *zdata, swRecvData *req);
void php_swoole_onConnect(swServer *, swDataHead *);
int php_swoole_onReceive(swServer *, swRecvData *);
int php_swoole_http_onReceive(swServer *, swRecvData *);
void php_swoole_http_onClose(swServer *, swDataHead *);
int php_swoole_onPacket(swServer *, swRecvData *);
void php_swoole_onClose(swServer *, swDataHead *);
void php_swoole_onBufferFull(swServer *, swDataHead *);
void php_swoole_onBufferEmpty(swServer *, swDataHead *);
swServer *php_swoole_server_get_and_check_server(zval *zobject);
void php_swoole_server_port_deref(zend_object *object);