forked from swoole/php-cp
-
Notifications
You must be signed in to change notification settings - Fork 1
/
php_connect_pool.h
executable file
·187 lines (149 loc) · 5.25 KB
/
php_connect_pool.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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
/*
+----------------------------------------------------------------------+
| common con pool |
+----------------------------------------------------------------------+
| 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@php.net so we can mail you a copy immediately. |
+----------------------------------------------------------------------+
| Author: Xinhua Guo <woshiguo35@sina.com> |
+----------------------------------------------------------------------+
*/
/* $Id$ */
#ifndef PHP_CON_PROXY_H
#define PHP_CON_PROXY_H
#include "php.h"
#include "php_ini.h"
#include "php_globals.h"
#include "php_main.h"
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include <sys/epoll.h> //todo
#ifndef EPOLLRDHUP
#define EPOLLRDHUP 0x2000
#define NO_EPOLLRDHUP
#endif
#if defined(MAP_ANON) && !defined(MAP_ANONYMOUS)
#define MAP_ANONYMOUS MAP_ANON
#endif
#ifndef SOCK_NONBLOCK
#define SOCK_NONBLOCK O_NONBLOCK
#endif
typedef unsigned long int uint64_t;
#include <sys/poll.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <signal.h>
#include <assert.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include "cpMemory.h"
#include "cpFunction.h"
#include "cpWorker.h"
#include "cpServer.h"
#include "cpNetWork.h"
#include "cpClientNet.h"
#include "ext/pdo/php_pdo_driver.h"
#include "ext/standard/php_smart_str.h"
#include "ext/standard/php_var.h"
#include "zend_exceptions.h"
#include "msgpack/php_msgpack.h"
/**
* PHP5.2
*/
#ifndef PHP_FE_END
#define PHP_FE_END {NULL,NULL,NULL}
#endif
#ifndef ZEND_MOD_END
#define ZEND_MOD_END {NULL,NULL,NULL}
#endif
#define CP_HOST_SIZE 128
extern zend_module_entry connect_pool_module_entry;
#define phpext_connect_pool_ptr &connect_pool_module_entry
#ifdef PHP_WIN32
#define PHP_CONNECT_POOL_API __declspec(dllexport)
#elif defined(__GNUC__) && __GNUC__ >= 4
#define PHP_CONNECT_POOL_API __attribute__ ((visibility("default")))
#else
#define PHP_CONNECT_POOL_API
#endif
#ifdef ZTS
#include "TSRM.h"
#endif
#define CP_CHECK_RETURN(s) if(s<0){RETURN_FALSE;}else{RETURN_TRUE;}return
#define CP_SIG_EVENT (SIGRTMIN+1)
#define CP_TCPEVENT_GET 1
#define CP_TCPEVENT_RELEASE 2
#define CP_SIGEVENT_TURE 1//01
#define CP_SIGEVENT_EXCEPTION 2//10
#define CP_SIGEVENT_PDO 3//11
#define CP_EVENTLEN_ADD_TYPE(len,__type) \
len = len <<2;\
len = len | __type;
#define CP_EVENTLEN_GET_TYPE(len,type) type = len&3;
#define CP_EVENTLEN_GET_LEN(len) len = len>>2;
#define CP_RES_SERVER_NAME "ConPoolServer"
#define CP_RES_CLIENT_NAME "ConPoolClient"
#define CP_PROCESS_MASTER 1
#define CP_PROCESS_WORKER 2
#define CP_PROCESS_MANAGER 3
#define CP_PIPE_MOD O_RDWR
#define CP_TYPE_SIZE sizeof(uint8_t)
#define CP_GROUP_LEN 1000 //
#define CP_GROUP_NUM 100 //the max group num of proxy process . todo check it
extern int le_cli_connect_pool;
extern zend_class_entry *redis_connect_pool_class_entry_ptr;
extern zend_class_entry *pdo_connect_pool_class_entry_ptr;
extern zend_class_entry *pdo_connect_pool_PDOStatement_class_entry_ptr;
PHP_MINIT_FUNCTION(connect_pool);
PHP_MSHUTDOWN_FUNCTION(connect_pool);
PHP_RINIT_FUNCTION(connect_pool);
PHP_RSHUTDOWN_FUNCTION(connect_pool);
PHP_MINFO_FUNCTION(connect_pool);
PHP_FUNCTION(pool_server_create);
PHP_FUNCTION(pool_server_shutdown);
PHP_FUNCTION(pool_server_reload);
PHP_FUNCTION(pool_server_version);
PHP_FUNCTION(get_disable_list);
PHP_FUNCTION(set_disable_list);
PHP_FUNCTION(shit_pdo_warning_function);
PHP_FUNCTION(client_close);
PHP_METHOD(pdo_connect_pool, __construct);
PHP_METHOD(pdo_connect_pool, __destruct);
PHP_METHOD(pdo_connect_pool, __call);
PHP_METHOD(pdo_connect_pool, release);
//PHP_METHOD(pdo_connect_pool, quote);
PHP_METHOD(pdo_connect_pool_PDOStatement, __call);
PHP_METHOD(redis_connect_pool, __construct);
PHP_METHOD(redis_connect_pool, __destruct);
PHP_METHOD(redis_connect_pool, __call);
PHP_METHOD(redis_connect_pool, release);
PHP_METHOD(redis_connect_pool, select);
PHP_FUNCTION(redis_connect);
void send_oob2proxy(zend_rsrc_list_entry *rsrc TSRMLS_DC);
extern void cp_serialize(smart_str *ser_data, zval *array);
extern zval * cp_unserialize(char *data, int len);
int worker_onReceive(zval *data);
CPINLINE int CP_INTERNAL_SERIALIZE_SEND_MEM(zval *ret_value, uint8_t __type);
CPINLINE int CP_CLIENT_SERIALIZE_SEND_MEM(zval *ret_value, int pid, int max, int semid);
extern cpServerG ConProxyG;
extern cpServerGS *ConProxyGS;
extern cpWorkerG ConProxyWG;
extern cpMasterInfo pdo_info;
extern cpMasterInfo redis_info;
extern FILE *cp_log_fn;
extern char * cpArgv0;
#endif /* PHP_CON_PROXY_H */