2 +--------------------------------------------------------------------+
4 +--------------------------------------------------------------------+
5 | Redistribution and use in source and binary forms, with or without |
6 | modification, are permitted provided that the conditions mentioned |
7 | in the accompanying LICENSE file are met. |
8 +--------------------------------------------------------------------+
9 | Copyright (c) 2004-2011, Michael Wallner <mike@php.net> |
10 +--------------------------------------------------------------------+
13 #include "php_http_api.h"
14 #include "php_http_client_datashare.h"
16 static int php_http_client_datashare_compare_handles(void *h1
, void *h2
);
18 PHP_HTTP_API php_http_client_datashare_t
*php_http_client_datashare_init(php_http_client_datashare_t
*h
, php_http_client_datashare_ops_t
*ops
, php_resource_factory_t
*rf
, void *init_arg TSRMLS_DC
)
20 php_http_client_datashare_t
*free_h
= NULL
;
23 free_h
= h
= emalloc(sizeof(*h
));
25 memset(h
, 0, sizeof(*h
));
27 zend_llist_init(&h
->clients
, sizeof(zval
*), ZVAL_PTR_DTOR
, 0);
31 } else if (ops
->rsrc
) {
32 h
->rf
= php_resource_factory_init(NULL
, h
->ops
->rsrc
, h
, NULL
);
34 TSRMLS_SET_CTX(h
->ts
);
37 if (!(h
= h
->ops
->init(h
, init_arg
))) {
47 PHP_HTTP_API php_http_client_datashare_t
*php_http_client_datashare_copy(php_http_client_datashare_t
*from
, php_http_client_datashare_t
*to
)
49 if (from
->ops
->copy
) {
50 return from
->ops
->copy(from
, to
);
56 PHP_HTTP_API
void php_http_client_datashare_dtor(php_http_client_datashare_t
*h
)
61 zend_llist_destroy(&h
->clients
);
62 php_resource_factory_free(&h
->rf
);
65 PHP_HTTP_API
void php_http_client_datashare_free(php_http_client_datashare_t
**h
)
67 php_http_client_datashare_dtor(*h
);
72 PHP_HTTP_API STATUS
php_http_client_datashare_attach(php_http_client_datashare_t
*h
, zval
*client
)
74 TSRMLS_FETCH_FROM_CTX(h
->ts
);
77 php_http_client_object_t
*obj
= zend_object_store_get_object(client TSRMLS_CC
);
79 if (SUCCESS
== h
->ops
->attach(h
, obj
->client
)) {
81 zend_llist_add_element(&h
->clients
, &client
);
89 static int php_http_client_datashare_compare_handles(void *h1
, void *h2
)
91 return (Z_OBJ_HANDLE_PP((zval
**) h1
) == Z_OBJ_HANDLE_P((zval
*) h2
));
94 PHP_HTTP_API STATUS
php_http_client_datashare_detach(php_http_client_datashare_t
*h
, zval
*client
)
96 TSRMLS_FETCH_FROM_CTX(h
->ts
);
99 php_http_client_object_t
*obj
= zend_object_store_get_object(client TSRMLS_CC
);
101 if (SUCCESS
== h
->ops
->detach(h
, obj
->client
)) {
102 zend_llist_del_element(&h
->clients
, client
, php_http_client_datashare_compare_handles
);
109 PHP_HTTP_API STATUS
php_http_client_datashare_setopt(php_http_client_datashare_t
*h
, php_http_client_datashare_setopt_opt_t opt
, void *arg
)
111 if (h
->ops
->setopt
) {
112 return h
->ops
->setopt(h
, opt
, arg
);
117 static void detach(void *r
, void *h TSRMLS_DC
)
119 ((php_http_client_datashare_t
*) h
)->ops
->detach(h
, ((php_http_client_object_t
*) zend_object_store_get_object(*((zval
**) r
) TSRMLS_CC
))->client
);
122 PHP_HTTP_API
void php_http_client_datashare_reset(php_http_client_datashare_t
*h
)
124 TSRMLS_FETCH_FROM_CTX(h
->ts
);
128 } else if (h
->ops
->detach
) {
129 zend_llist_apply_with_argument(&h
->clients
, detach
, h TSRMLS_CC
);
132 zend_llist_clean(&h
->clients
);
135 #define PHP_HTTP_BEGIN_ARGS(method, req_args) PHP_HTTP_BEGIN_ARGS_EX(HttpClientDataShare, method, 0, req_args)
136 #define PHP_HTTP_EMPTY_ARGS(method) PHP_HTTP_EMPTY_ARGS_EX(HttpClientDataShare, method, 0)
137 #define PHP_HTTP_RSHARE_ME(method, visibility) PHP_ME(HttpClientDataShare, method, PHP_HTTP_ARGS(HttpClientDataShare, method), visibility)
139 PHP_HTTP_EMPTY_ARGS(__destruct
);
140 PHP_HTTP_EMPTY_ARGS(reset
);
141 PHP_HTTP_EMPTY_ARGS(count
);
143 PHP_HTTP_BEGIN_ARGS(attach
, 1)
144 PHP_HTTP_ARG_OBJ(http
\\Client
, client
, 0)
146 PHP_HTTP_BEGIN_ARGS(detach
, 1)
147 PHP_HTTP_ARG_OBJ(http
\\Client
, client
, 0)
150 static void php_http_client_datashare_object_write_prop(zval
*object
, zval
*member
, zval
*value PHP_HTTP_ZEND_LITERAL_DC TSRMLS_DC
);
152 static zend_class_entry
*php_http_client_datashare_class_entry
;
154 zend_class_entry
*php_http_client_datashare_get_class_entry(void)
156 return php_http_client_datashare_class_entry
;
159 static zend_function_entry php_http_client_datashare_method_entry
[] = {
160 PHP_HTTP_RSHARE_ME(__destruct
, ZEND_ACC_PUBLIC
|ZEND_ACC_DTOR
)
161 PHP_HTTP_RSHARE_ME(count
, ZEND_ACC_PUBLIC
)
162 PHP_HTTP_RSHARE_ME(attach
, ZEND_ACC_PUBLIC
)
163 PHP_HTTP_RSHARE_ME(detach
, ZEND_ACC_PUBLIC
)
164 PHP_HTTP_RSHARE_ME(reset
, ZEND_ACC_PUBLIC
)
168 static zend_object_handlers php_http_client_datashare_object_handlers
;
170 zend_object_handlers
*php_http_client_datashare_get_object_handlers(void)
172 return &php_http_client_datashare_object_handlers
;
174 static STATUS
setopt(struct php_http_client_datashare
*h
, php_http_client_datashare_setopt_opt_t opt
, void *arg
)
179 static php_http_client_datashare_ops_t php_http_client_datashare_user_ops
= {
188 (php_http_new_t
) php_http_client_datashare_object_new_ex
,
189 php_http_client_datashare_get_class_entry
192 zend_object_value
php_http_client_datashare_object_new(zend_class_entry
*ce TSRMLS_DC
)
194 return php_http_client_datashare_object_new_ex(ce
, NULL
, NULL TSRMLS_CC
);
197 zend_object_value
php_http_client_datashare_object_new_ex(zend_class_entry
*ce
, php_http_client_datashare_t
*share
, php_http_client_datashare_object_t
**ptr TSRMLS_DC
)
199 zend_object_value ov
;
200 php_http_client_datashare_object_t
*o
;
202 o
= ecalloc(1, sizeof(*o
));
203 zend_object_std_init((zend_object
*) o
, ce TSRMLS_CC
);
204 object_properties_init((zend_object
*) o
, ce
);
206 ov
.handle
= zend_objects_store_put(o
, NULL
, php_http_client_datashare_object_free
, NULL TSRMLS_CC
);
207 ov
.handlers
= &php_http_client_datashare_object_handlers
;
209 if (!(o
->share
= share
)) {
210 o
->share
= php_http_client_datashare_init(NULL
, &php_http_client_datashare_user_ops
, NULL
, &ov TSRMLS_CC
);
220 void php_http_client_datashare_object_free(void *object TSRMLS_DC
)
222 php_http_client_datashare_object_t
*o
= (php_http_client_datashare_object_t
*) object
;
224 php_http_client_datashare_free(&o
->share
);
225 zend_object_std_dtor((zend_object
*) o TSRMLS_CC
);
229 static zval
*php_http_client_datashare_object_read_prop(zval
*object
, zval
*member
, int type PHP_HTTP_ZEND_LITERAL_DC TSRMLS_DC
)
231 zend_property_info
*pi
;
233 if ((pi
= zend_get_property_info(php_http_client_datashare_class_entry
, member
, 1 TSRMLS_CC
))) {
234 if (type
!= BP_VAR_R
) {
236 php_property_proxy_t
*proxy
;
238 proxy
= php_property_proxy_init(object
, pi
->name
, pi
->name_length TSRMLS_CC
);
240 MAKE_STD_ZVAL(zproxy
);
241 #ifdef Z_SET_REFCOUNT_P
242 Z_SET_REFCOUNT_P(zproxy
, 0);
244 zproxy
->refcount
= 0;
246 ZVAL_OBJVAL(zproxy
, php_property_proxy_object_new_ex(php_property_proxy_get_class_entry(), proxy
, NULL TSRMLS_CC
), 0);
250 return zend_get_std_object_handlers()->read_property(object
, member
, type PHP_HTTP_ZEND_LITERAL_CC TSRMLS_CC
);
253 static void php_http_client_datashare_object_write_prop(zval
*object
, zval
*member
, zval
*value PHP_HTTP_ZEND_LITERAL_DC TSRMLS_DC
)
255 zend_property_info
*pi
;
257 if ((pi
= zend_get_property_info(php_http_client_datashare_class_entry
, member
, 1 TSRMLS_CC
))) {
258 zend_bool enable
= i_zend_is_true(value
);
259 php_http_client_datashare_setopt_opt_t opt
;
260 php_http_client_datashare_object_t
*obj
= zend_object_store_get_object(object TSRMLS_CC
);
262 if (!strcmp(pi
->name
, "cookie")) {
263 opt
= PHP_HTTP_CLIENT_DATASHARE_OPT_COOKIES
;
264 } else if (!strcmp(pi
->name
, "dns")) {
265 opt
= PHP_HTTP_CLIENT_DATASHARE_OPT_RESOLVER
;
266 } else if (!strcmp(pi
->name
, "ssl")) {
267 opt
= PHP_HTTP_CLIENT_DATASHARE_OPT_SSLSESSIONS
;
272 if (SUCCESS
!= php_http_client_datashare_setopt(obj
->share
, opt
, &enable
)) {
277 zend_get_std_object_handlers()->write_property(object
, member
, value PHP_HTTP_ZEND_LITERAL_CC TSRMLS_CC
);
280 PHP_METHOD(HttpClientDataShare
, __destruct
)
282 php_http_client_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
283 /* FIXME: move to php_http_client_datashare_dtor */
284 if (SUCCESS
== zend_parse_parameters_none()) {
285 ; /* we always want to clean up */
288 php_http_client_datashare_reset(obj
->share
);
291 PHP_METHOD(HttpClientDataShare
, count
)
293 if (SUCCESS
== zend_parse_parameters_none()) {
294 php_http_client_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
296 RETURN_LONG(zend_llist_count(&obj
->share
->clients
));
302 PHP_METHOD(HttpClientDataShare
, attach
)
306 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "O", &client
, php_http_client_get_class_entry())) {
307 php_http_client_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
309 RETURN_SUCCESS(php_http_client_datashare_attach(obj
->share
, client
));
315 PHP_METHOD(HttpClientDataShare
, detach
)
319 if (SUCCESS
== zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC
, "O", &client
, php_http_client_get_class_entry())) {
320 php_http_client_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
322 RETURN_SUCCESS(php_http_client_datashare_detach(obj
->share
, client
));
327 PHP_METHOD(HttpClientDataShare
, reset
)
329 if (SUCCESS
== zend_parse_parameters_none()) {
330 php_http_client_datashare_object_t
*obj
= zend_object_store_get_object(getThis() TSRMLS_CC
);
332 php_http_client_datashare_reset(obj
->share
);
338 PHP_METHOD(HttpClientDataShare
, __sleep
)
340 php_http_error(HE_THROW
, PHP_HTTP_E_CLIENT_DATASHARE
, "cannot serialize a client datashare");
343 PHP_MINIT_FUNCTION(http_client_datashare
)
345 PHP_HTTP_REGISTER_CLASS(http
\\Client
\\DataShare
, AbstractDataShare
, http_client_datashare
, php_http_object_get_class_entry(), ZEND_ACC_EXPLICIT_ABSTRACT_CLASS
);
346 php_http_client_datashare_class_entry
->create_object
= php_http_client_datashare_object_new
;
347 memcpy(&php_http_client_datashare_object_handlers
, zend_get_std_object_handlers(), sizeof(zend_object_handlers
));
348 php_http_client_datashare_object_handlers
.clone_obj
= NULL
;
349 php_http_client_datashare_object_handlers
.read_property
= php_http_client_datashare_object_read_prop
;
350 php_http_client_datashare_object_handlers
.write_property
= php_http_client_datashare_object_write_prop
;
351 php_http_client_datashare_object_handlers
.get_property_ptr_ptr
= NULL
;
353 zend_class_implements(php_http_client_datashare_class_entry TSRMLS_CC
, 1, spl_ce_Countable
);
355 zend_declare_property_bool(php_http_client_datashare_class_entry
, ZEND_STRL("cookie"), 0, ZEND_ACC_PUBLIC TSRMLS_CC
);
356 zend_declare_property_bool(php_http_client_datashare_class_entry
, ZEND_STRL("dns"), 0, ZEND_ACC_PUBLIC TSRMLS_CC
);
357 zend_declare_property_bool(php_http_client_datashare_class_entry
, ZEND_STRL("ssl"), 0, ZEND_ACC_PUBLIC TSRMLS_CC
);
367 * vim600: noet sw=4 ts=4 fdm=marker
368 * vim<600: noet sw=4 ts=4