5 #include <ext/standard/php_string.h>
6 #include <ext/spl/spl_iterators.h>
8 static int php_http_request_datashare_compare_handles(void *h1
, void *h2
);
11 static void *php_http_request_datashare_locks_init(void);
12 static void php_http_request_datashare_locks_dtor(void *l
);
13 static void php_http_request_datashare_lock_func(CURL
*handle
, curl_lock_data data
, curl_lock_access locktype
, void *userptr
);
14 static void php_http_request_datashare_unlock_func(CURL
*handle
, curl_lock_data data
, void *userptr
);
15 static MUTEX_T php_http_request_datashare_global_shares_lock
;
17 static HashTable php_http_request_datashare_global_shares
;
18 php_http_request_datashare_t
*php_http_request_datashare_global_get(const char *driver_str
, size_t driver_len TSRMLS_DC
)
20 php_http_request_datashare_t
*s
= NULL
, **s_ptr
;
21 char *lower_str
= php_strtolower(estrndup(driver_str
, driver_len
), driver_len
);
24 tsrm_mutex_lock(php_http_request_datashare_global_shares_lock
);
26 if (zend_hash_find(&php_http_request_datashare_global_shares
, lower_str
, driver_len
+ 1, (void *) &s_ptr
)) {
29 php_http_request_factory_driver_t driver
;
31 if ((SUCCESS
== php_http_request_factory_get_driver(driver_str
, driver_len
, &driver
)) && driver
.request_datashare_ops
) {
32 s
= php_http_request_datashare_init(NULL
, driver
.request_datashare_ops
, NULL
, NULL
, 1 TSRMLS_CC
);
33 zend_hash_add(&php_http_request_datashare_global_shares
, lower_str
, driver_len
+ 1, &s
, sizeof(php_http_request_datashare_t
*), NULL
);
37 tsrm_mutex_unlock(php_http_request_datashare_global_shares_lock
);
44 PHP_HTTP_API php_http_request_datashare_t
*php_http_request_datashare_init(php_http_request_datashare_t
*h
, php_http_request_datashare_ops_t
*ops
, php_http_resource_factory_t
*rf
, void *init_arg
, zend_bool persistent TSRMLS_DC
)
46 php_http_request_datashare_t
*free_h
= NULL
;
49 free_h
= h
= pemalloc(sizeof(*h
), persistent
);
51 memset(h
, sizeof(*h
), 0);
53 if (!(h
->persistent
= persistent
)) {
54 h
->requests
= emalloc(sizeof(*h
->requests
));
55 zend_llist_init(h
->requests
, sizeof(zval
*), ZVAL_PTR_DTOR
, 0);
56 TSRMLS_SET_CTX(h
->ts
);
59 h
->rf
= rf
? rf
: php_http_resource_factory_init(NULL
, h
->ops
->rsrc
, NULL
, NULL
);
62 if (!(h
= h
->ops
->init(h
, init_arg
))) {
64 pefree(free_h
, persistent
);
72 PHP_HTTP_API php_http_request_datashare_t
*php_http_request_datashare_copy(php_http_request_datashare_t
*from
, php_http_request_datashare_t
*to
)
74 if (from
->ops
->copy
) {
75 return from
->ops
->copy(from
, to
);
81 PHP_HTTP_API
void php_http_request_datashare_dtor(php_http_request_datashare_t
*h
)
87 zend_llist_destroy(h
->requests
);
88 pefree(h
->requests
, h
->persistent
);
92 if (h
->persistent_handle_id
) {
93 zval_ptr_dtor(&h
->persistent_handle_id
);
97 PHP_HTTP_API
void php_http_request_datashare_free(php_http_request_datashare_t
**h
)
99 php_http_request_datashare_dtor(*h
);
100 pefree(*h
, (*h
)->persistent
);
104 PHP_HTTP_API STATUS
php_http_request_datashare_attach(php_http_request_datashare_t
*h
, zval
*request
)
106 TSRMLS_FETCH_FROM_CTX(h
->ts
);
108 if (h
->ops
->attach
) {
109 php_http_request_object_t
*obj
= zend_object_store_get_object(request TSRMLS_CC
);
111 if (SUCCESS
== h
->ops
->attach(h
, obj
->request
)) {
113 zend_llist_add_element(PHP_HTTP_REQUEST_DATASHARE_REQUESTS(h
), &request
);
121 static int php_http_request_datashare_compare_handles(void *h1
, void *h2
)
123 return (Z_OBJ_HANDLE_PP((zval
**) h1
) == Z_OBJ_HANDLE_P((zval
*) h2
));
126 PHP_HTTP_API STATUS
php_http_request_datashare_detach(php_http_request_datashare_t
*h
, zval
*request
)
128 TSRMLS_FETCH_FROM_CTX(h
->ts
);
130 if (h
->ops
->detach
) {
131 php_http_request_object_t
*obj
= zend_object_store_get_object(request TSRMLS_CC
);
133 if (SUCCESS
== h
->ops
->detach(h
, obj
->request
)) {
134 zend_llist_del_element(PHP_HTTP_REQUEST_DATASHARE_REQUESTS(h
), request
, php_http_request_datashare_compare_handles
);
141 PHP_HTTP_API STATUS
php_http_request_datashare_setopt(php_http_request_datashare_t
*h
, php_http_request_datashare_setopt_opt_t opt
, void *arg
)
143 if (h
->ops
->setopt
) {
144 return h
->ops
->setopt(h
, opt
, arg
);
149 static void detach(void *r
, void *h TSRMLS_DC
)
151 ((php_http_request_datashare_t
*) h
)->ops
->detach(h
, ((php_http_request_object_t
*) zend_object_store_get_object(*((zval
**) r
) TSRMLS_CC
))->request
);
154 PHP_HTTP_API
void php_http_request_datashare_reset(php_http_request_datashare_t
*h
)
156 TSRMLS_FETCH_FROM_CTX(h
->ts
);
160 } else if (h
->ops
->detach
) {
161 zend_llist_apply_with_argument(PHP_HTTP_REQUEST_DATASHARE_REQUESTS(h
), detach
, h TSRMLS_CC
);
164 zend_llist_clean(PHP_HTTP_REQUEST_DATASHARE_REQUESTS(h
));
167 static void php_http_request_datashare_global_requests_dtor(void *el
)
169 //php_http_request_datashare_detach(php_http_request_datashare_global_get(), *((zval **) el));
173 #define PHP_HTTP_BEGIN_ARGS(method, req_args) PHP_HTTP_BEGIN_ARGS_EX(HttpRequestDataShare, method, 0, req_args)
174 #define PHP_HTTP_EMPTY_ARGS(method) PHP_HTTP_EMPTY_ARGS_EX(HttpRequestDataShare, method, 0)
175 #define PHP_HTTP_RSHARE_ME(method, visibility) PHP_ME(HttpRequestDataShare, method, PHP_HTTP_ARGS(HttpRequestDataShare, method), visibility)
177 PHP_HTTP_EMPTY_ARGS(__construct
);
178 PHP_HTTP_EMPTY_ARGS(__destruct
);
179 PHP_HTTP_EMPTY_ARGS(reset
);
180 PHP_HTTP_EMPTY_ARGS(count
);
182 PHP_HTTP_BEGIN_ARGS(attach
, 1)
183 PHP_HTTP_ARG_OBJ(http
\\Request
, request
, 0)
185 PHP_HTTP_BEGIN_ARGS(detach
, 1)
186 PHP_HTTP_ARG_OBJ(http
\\Request
, request
, 0)
189 static void php_http_request_datashare_object_write_prop(zval
*object
, zval
*member
, zval
*value
, const zend_literal
*literal_key TSRMLS_DC
);
191 #define php_http_request_datashare_class_entry php_http_request_datashare_class_entry
192 zend_class_entry
*php_http_request_datashare_class_entry
;
193 zend_function_entry php_http_request_datashare_method_entry
[] = {
194 PHP_HTTP_RSHARE_ME(__construct
, ZEND_ACC_PRIVATE
|ZEND_ACC_CTOR
)
195 PHP_HTTP_RSHARE_ME(__destruct
, ZEND_ACC_PUBLIC
|ZEND_ACC_DTOR
)
196 PHP_HTTP_RSHARE_ME(count
, ZEND_ACC_PUBLIC
)
197 PHP_HTTP_RSHARE_ME(attach
, ZEND_ACC_PUBLIC
)
198 PHP_HTTP_RSHARE_ME(detach
, ZEND_ACC_PUBLIC
)
199 PHP_HTTP_RSHARE_ME(reset
, ZEND_ACC_PUBLIC
)
202 static zend_object_handlers php_http_request_datashare_object_handlers
;
204 zend_object_value
php_http_request_datashare_object_new(zend_class_entry
*ce TSRMLS_DC
)
206 return php_http_request_datashare_object_new_ex(ce
, NULL
, NULL TSRMLS_CC
);
209 zend_object_value
php_http_request_datashare_object_new_ex(zend_class_entry
*ce
, php_http_request_datashare_t
*share
, php_http_request_datashare_object_t
**ptr TSRMLS_DC
)
211 zend_object_value ov
;
212 php_http_request_datashare_object_t
*o
;
214 o
= ecalloc(1, sizeof(*o
));
215 zend_object_std_init((zend_object
*) o
, ce TSRMLS_CC
);
216 object_properties_init((zend_object
*) o
, ce
);
221 o
->share
= php_http_request_datashare_init(NULL
, NULL
, NULL
, NULL
, 0 TSRMLS_CC
);
228 ov
.handle
= zend_objects_store_put(o
, NULL
, php_http_request_datashare_object_free
, NULL TSRMLS_CC
);
229 ov
.handlers
= &php_http_request_datashare_object_handlers
;
234 void php_http_request_datashare_object_free(void *object TSRMLS_DC
)
236 php_http_request_datashare_object_t
*o
= (php_http_request_datashare_object_t
*) object
;
238 if (!o
->share
->persistent
) {
239 php_http_request_datashare_free(&o
->share
);
241 zend_object_std_dtor((zend_object
*) o TSRMLS_CC
);
245 static void php_http_request_datashare_object_write_prop(zval
*object
, zval
*member
, zval
*value
, const zend_literal
*literal_key TSRMLS_DC
)
247 zend_property_info
*pi
;
249 if ((pi
= zend_get_property_info(php_http_request_datashare_class_entry
, member
, 1 TSRMLS_CC
))) {
250 zend_bool enable
= i_zend_is_true(value
);
251 php_http_request_datashare_setopt_opt_t opt
;
252 php_http_request_datashare_object_t
*obj
= zend_object_store_get_object(object TSRMLS_CC
);
254 if (!strcmp(pi
->name
, "cookie")) {
255 opt
= PHP_HTTP_REQUEST_DATASHARE_OPT_COOKIES
;
256 } else if (!strcmp(pi
->name
, "dns")) {
257 opt
= PHP_HTTP_REQUEST_DATASHARE_OPT_RESOLVER
;
262 if (SUCCESS
!= php_http_request_datashare_setopt(obj
->share
, opt
, &enable
)) {
267 zend_get_std_object_handlers()->write_property(object
, member
, value
, literal_key TSRMLS_CC
);
270 static zval
**php_http_request_datashare_object_get_prop_ptr(zval
*object
, zval
*member
, const zend_literal
*literal_key TSRMLS_DC
)
272 zend_property_info
*pi
;
274 if ((pi
= zend_get_property_info(php_http_request_datashare_class_entry
, member
, 1 TSRMLS_CC
))) {
275 return &php_http_property_proxy_init(NULL
, object
, member TSRMLS_CC
)->myself
;
278 return zend_get_std_object_handlers()->get_property_ptr_ptr(object
, member
, literal_key TSRMLS_CC
);
282 PHP_METHOD(HttpRequestDataShare
, __construct
)
284 with_error_handling(EH_THROW
, php_http_exception_class_entry
) {
285 zend_parse_parameters_none();
286 } end_error_handling();
289 PHP_METHOD(HttpRequestDataShare
, __destruct
)
291 php_http_request_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
293 if (SUCCESS
== zend_parse_parameters_none()) {
294 ; /* we always want to clean up */
297 php_http_request_datashare_reset(obj
->share
);
300 PHP_METHOD(HttpRequestDataShare
, count
)
302 if (SUCCESS
== zend_parse_parameters_none()) {
303 php_http_request_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
305 RETURN_LONG(zend_llist_count(PHP_HTTP_REQUEST_DATASHARE_REQUESTS(obj
->share
)));
311 PHP_METHOD(HttpRequestDataShare
, attach
)
315 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "O", &request
, php_http_request_class_entry
)) {
316 php_http_request_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
318 RETURN_SUCCESS(php_http_request_datashare_attach(obj
->share
, request
));
324 PHP_METHOD(HttpRequestDataShare
, detach
)
328 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "O", &request
, php_http_request_class_entry
)) {
329 php_http_request_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
331 RETURN_SUCCESS(php_http_request_datashare_detach(obj
->share
, request
));
336 PHP_METHOD(HttpRequestDataShare
, reset
)
338 if (SUCCESS
== zend_parse_parameters_none()) {
339 php_http_request_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
341 php_http_request_datashare_reset(obj
->share
);
347 PHP_MINIT_FUNCTION(http_request_datashare
)
349 PHP_HTTP_REGISTER_CLASS(http
\\Request
, DataShare
, http_request_datashare
, php_http_object_class_entry
, 0);
350 php_http_request_datashare_class_entry
->create_object
= php_http_request_datashare_object_new
;
351 memcpy(&php_http_request_datashare_object_handlers
, zend_get_std_object_handlers(), sizeof(zend_object_handlers
));
352 php_http_request_datashare_object_handlers
.clone_obj
= NULL
;
353 php_http_request_datashare_object_handlers
.write_property
= php_http_request_datashare_object_write_prop
;
354 php_http_request_datashare_object_handlers
.get_property_ptr_ptr
= php_http_request_datashare_object_get_prop_ptr
;
356 zend_class_implements(php_http_request_datashare_class_entry TSRMLS_CC
, 1, spl_ce_Countable
);
358 zend_declare_property_null(php_http_request_datashare_class_entry
, ZEND_STRL("instance"), (ZEND_ACC_STATIC
|ZEND_ACC_PRIVATE
) TSRMLS_CC
);
359 zend_declare_property_bool(php_http_request_datashare_class_entry
, ZEND_STRL("cookie"), 0, ZEND_ACC_PUBLIC TSRMLS_CC
);
360 zend_declare_property_bool(php_http_request_datashare_class_entry
, ZEND_STRL("dns"), 0, ZEND_ACC_PUBLIC TSRMLS_CC
);
363 php_http_request_datashare_global_shares_lock
= tsrm_mutex_alloc();
365 zend_hash_init(&php_http_request_datashare_global_shares
, 0, NULL
, (dtor_func_t
) php_http_request_datashare_free
, 1);
370 PHP_MSHUTDOWN_FUNCTION(http_request_datashare
)
372 zend_hash_destroy(&php_http_request_datashare_global_shares
);
374 tsrm_mutex_free(php_http_request_datashare_global_shares_lock
);
380 PHP_RINIT_FUNCTION(http_request_datashare
)
382 zend_llist_init(&PHP_HTTP_G
->request_datashare
.requests
, sizeof(zval
*), php_http_request_datashare_global_requests_dtor
, 0);
387 PHP_RSHUTDOWN_FUNCTION(http_request_datashare
)
389 zend_llist_destroy(&PHP_HTTP_G
->request_datashare
.requests
);