From: Michael Wallner Date: Wed, 7 Feb 2018 11:45:52 +0000 (+0100) Subject: refactor for 7.2 X-Git-Tag: RELEASE_3_2_0_RC1~44 X-Git-Url: https://git.m6w6.name/?a=commitdiff_plain;h=7a492dc2544d408eb65fd38cb644fd6adde3bbe9;p=m6w6%2Fext-http refactor for 7.2 --- diff --git a/scripts/gen_stubs.php b/scripts/gen_stubs.php index 20a1f0f..5f28545 100755 --- a/scripts/gen_stubs.php +++ b/scripts/gen_stubs.php @@ -1,8 +1,11 @@ #!/usr/bin/env php isInterface()) { + $m ^= ReflectionMethod::IS_ABSTRACT; + } foreach (Reflection::getModifierNames($m) as $mn) { $n .= $mn . " "; } @@ -169,7 +172,7 @@ foreach ($namespaces as $ns) { foreach ($c->getMethods() as $m) { if ($m->getDeclaringClass()->getName() == $c->getName()) { - fprintf($out, "\t\t%sfunction %s(", m($m->getModifiers()), + fprintf($out, "\t\t%sfunction %s(", m($m->getModifiers(), $c), $m->getName()); $ps = array(); foreach ($m->getParameters() as $p) { diff --git a/src/php_http_message.c b/src/php_http_message.c index 413edab..d076b6a 100644 --- a/src/php_http_message.c +++ b/src/php_http_message.c @@ -75,7 +75,7 @@ php_http_message_t *php_http_message_init_env(php_http_message_t *message, php_h break; case PHP_HTTP_RESPONSE: - message = php_http_message_init(NULL, type, NULL); + message = php_http_message_init(message, type, NULL); if (!SG(sapi_headers).http_status_line || !php_http_info_parse((php_http_info_t *) &message->http, SG(sapi_headers).http_status_line)) { if (!(message->http.info.response.code = SG(sapi_headers).http_response_code)) { message->http.info.response.code = 200; @@ -538,12 +538,14 @@ static php_http_message_object_prophandler_t *php_http_message_object_get_propha return zend_hash_str_find_ptr(&php_http_message_object_prophandlers, name_str->val, name_str->len); } static void php_http_message_object_prophandler_get_type(php_http_message_object_t *obj, zval *return_value) { + zval_ptr_dtor(return_value); RETVAL_LONG(obj->message->type); } static void php_http_message_object_prophandler_set_type(php_http_message_object_t *obj, zval *value) { php_http_message_set_type(obj->message, zval_get_long(value)); } static void php_http_message_object_prophandler_get_request_method(php_http_message_object_t *obj, zval *return_value) { + zval_ptr_dtor(return_value); if (PHP_HTTP_MESSAGE_TYPE(REQUEST, obj->message) && obj->message->http.info.request.method) { RETVAL_STRING(obj->message->http.info.request.method); } else { @@ -561,6 +563,7 @@ static void php_http_message_object_prophandler_get_request_url(php_http_message char *url_str; size_t url_len; + zval_ptr_dtor(return_value); if (PHP_HTTP_MESSAGE_TYPE(REQUEST, obj->message) && obj->message->http.info.request.url && php_http_url_to_string(obj->message->http.info.request.url, &url_str, &url_len, 0)) { RETVAL_STR(php_http_cs2zs(url_str, url_len)); } else { @@ -573,6 +576,7 @@ static void php_http_message_object_prophandler_set_request_url(php_http_message } } static void php_http_message_object_prophandler_get_response_status(php_http_message_object_t *obj, zval *return_value) { + zval_ptr_dtor(return_value); if (PHP_HTTP_MESSAGE_TYPE(RESPONSE, obj->message) && obj->message->http.info.response.status) { RETVAL_STRING(obj->message->http.info.response.status); } else { @@ -587,6 +591,7 @@ static void php_http_message_object_prophandler_set_response_status(php_http_mes } } static void php_http_message_object_prophandler_get_response_code(php_http_message_object_t *obj, zval *return_value) { + zval_ptr_dtor(return_value); if (PHP_HTTP_MESSAGE_TYPE(RESPONSE, obj->message)) { RETVAL_LONG(obj->message->http.info.response.code); } else { @@ -603,6 +608,7 @@ static void php_http_message_object_prophandler_get_http_version(php_http_messag char *version_str; size_t version_len; + zval_ptr_dtor(return_value); php_http_version_to_string(&obj->message->http.version, &version_str, &version_len, NULL, NULL); RETVAL_STR(php_http_cs2zs(version_str, version_len)); } @@ -612,28 +618,43 @@ static void php_http_message_object_prophandler_set_http_version(php_http_messag zend_string_release(zs); } static void php_http_message_object_prophandler_get_headers(php_http_message_object_t *obj, zval *return_value ) { + zval tmp; + + ZVAL_COPY_VALUE(&tmp, return_value); array_init(return_value); array_copy(&obj->message->hdrs, Z_ARRVAL_P(return_value)); + zval_ptr_dtor(&tmp); } static void php_http_message_object_prophandler_set_headers(php_http_message_object_t *obj, zval *value) { int converted = 0; + HashTable garbage, *src; if (Z_TYPE_P(value) != IS_ARRAY && Z_TYPE_P(value) != IS_OBJECT) { converted = 1; SEPARATE_ZVAL(value); convert_to_array(value); } + src = HASH_OF(value); - zend_hash_clean(&obj->message->hdrs); + garbage = obj->message->hdrs; + zend_hash_init(&obj->message->hdrs, zend_hash_num_elements(src), NULL, ZVAL_PTR_DTOR, 0); array_copy(HASH_OF(value), &obj->message->hdrs); + if (GC_REFCOUNT(&garbage) <= 1 && (garbage.u.flags & HASH_FLAG_INITIALIZED)) { + efree(HT_GET_DATA_ADDR(&garbage)); + } + if (converted) { zval_ptr_dtor(value); } } static void php_http_message_object_prophandler_get_body(php_http_message_object_t *obj, zval *return_value) { if (obj->body) { + zval tmp; + + ZVAL_COPY_VALUE(&tmp, return_value); RETVAL_OBJECT(&obj->body->zo, 1); + zval_ptr_dtor(&tmp); } else { RETVAL_NULL(); } @@ -643,7 +664,11 @@ static void php_http_message_object_prophandler_set_body(php_http_message_object } static void php_http_message_object_prophandler_get_parent_message(php_http_message_object_t *obj, zval *return_value) { if (obj->message->parent) { + zval tmp; + + ZVAL_COPY_VALUE(&tmp, return_value); RETVAL_OBJECT(&obj->parent->zo, 1); + zval_ptr_dtor(&tmp); } else { RETVAL_NULL(); } @@ -652,10 +677,10 @@ static void php_http_message_object_prophandler_set_parent_message(php_http_mess if (Z_TYPE_P(value) == IS_OBJECT && instanceof_function(Z_OBJCE_P(value), php_http_message_class_entry)) { php_http_message_object_t *parent_obj = PHP_HTTP_OBJ(NULL, value); + Z_ADDREF_P(value); if (obj->message->parent) { zend_object_release(&obj->parent->zo); } - Z_ADDREF_P(value); obj->parent = parent_obj; obj->message->parent = parent_obj->message; } @@ -785,7 +810,6 @@ ZEND_RESULT_CODE php_http_message_object_set_body(php_http_message_object_t *msg if (!body_obj->body) { body_obj->body = php_http_message_body_init(NULL, NULL); - php_stream_to_zval(php_http_message_body_stream(body_obj->body), body_obj->gc); } if (msg_obj->body) { zend_object_release(&msg_obj->body->zo); @@ -878,32 +902,27 @@ static zval *php_http_message_object_read_prop(zval *object, zval *member, int t zend_string *member_name = zval_get_string(member); php_http_message_object_prophandler_t *handler = php_http_message_object_get_prophandler(member_name); - if (!handler || type == BP_VAR_R || type == BP_VAR_IS) { - return_value = zend_get_std_object_handlers()->read_property(object, member, type, cache_slot, tmp); + return_value = zend_get_std_object_handlers()->read_property(object, member, type, cache_slot, tmp); - if (handler) { + if (handler && handler->read) { + if (type == BP_VAR_R || type == BP_VAR_IS) { php_http_message_object_t *obj = PHP_HTTP_OBJ(NULL, object); - zval tmp2; - PHP_HTTP_MESSAGE_OBJECT_INIT(obj); - handler->read(obj, &tmp2); - - zval_ptr_dtor(return_value); - ZVAL_COPY_VALUE(return_value, &tmp2); - } - zend_string_release(member_name); - return return_value; - } else { - php_property_proxy_t *proxy; - php_property_proxy_object_t *proxy_obj; + handler->read(obj, return_value); + } else { + php_property_proxy_t *proxy; + php_property_proxy_object_t *proxy_obj; - proxy = php_property_proxy_init(object, member_name); - proxy_obj = php_property_proxy_object_new_ex(NULL, proxy); + proxy = php_property_proxy_init(object, member_name); + proxy_obj = php_property_proxy_object_new_ex(NULL, proxy); - ZVAL_OBJ(tmp, &proxy_obj->zo); - zend_string_release(member_name); - return tmp; + ZVAL_OBJ(tmp, &proxy_obj->zo); + return_value = tmp; + } } + + zend_string_release(member_name); + return return_value; } static void php_http_message_object_write_prop(zval *object, zval *member, zval *value, void **cache_slot) diff --git a/src/php_http_message_body.c b/src/php_http_message_body.c index 18ff936..e630176 100644 --- a/src/php_http_message_body.c +++ b/src/php_http_message_body.c @@ -91,7 +91,7 @@ void php_http_message_body_free(php_http_message_body_t **body_ptr) if (*body_ptr) { php_http_message_body_t *body = *body_ptr; if (!--body->refcount) { - zend_list_close(body->res); + zend_list_delete(body->res); body->res = NULL; PTR_FREE(body->boundary); efree(body); diff --git a/src/php_http_misc.c b/src/php_http_misc.c index 064598c..467988b 100644 --- a/src/php_http_misc.c +++ b/src/php_http_misc.c @@ -87,7 +87,7 @@ int php_http_match(const char *haystack_str, const char *needle_str, int flags) return result; } -char *php_http_pretty_key(register char *key, size_t key_len, zend_bool uctitle, zend_bool xhyphen) +char *php_http_pretty_key(char *key, size_t key_len, zend_bool uctitle, zend_bool xhyphen) { size_t i = 1; int wasalpha; diff --git a/src/php_http_url.c b/src/php_http_url.c index 361e61c..0e3b2ee 100644 --- a/src/php_http_url.c +++ b/src/php_http_url.c @@ -663,7 +663,7 @@ php_http_url_t *php_http_url_copy(const php_http_url_t *url, zend_bool persisten return cpy; } -static size_t parse_mb_utf8(unsigned *wc, const char *ptr, const char *end) +static inline size_t parse_mb_utf8(unsigned *wc, const char *ptr, const char *end) { unsigned wchar; size_t consumed = utf8towc(&wchar, (const unsigned char *) ptr, end - ptr); @@ -679,7 +679,7 @@ static size_t parse_mb_utf8(unsigned *wc, const char *ptr, const char *end) } #if PHP_HTTP_HAVE_WCHAR -static size_t parse_mb_loc(unsigned *wc, const char *ptr, const char *end) +static inline size_t parse_mb_loc(unsigned *wc, const char *ptr, const char *end) { wchar_t wchar; size_t consumed = 0; @@ -723,7 +723,7 @@ static const char * const parse_what[] = { static const char parse_xdigits[] = "0123456789ABCDEF"; -static size_t parse_mb(struct parse_state *state, parse_mb_what_t what, const char *ptr, const char *end, const char *begin, zend_bool force_silent) +static inline size_t parse_mb(struct parse_state *state, parse_mb_what_t what, const char *ptr, const char *end, const char *begin, zend_bool force_silent) { unsigned wchar; size_t consumed = 0; diff --git a/tests/bug66388.phpt b/tests/bug66388.phpt index 97f8419..df53d9c 100644 --- a/tests/bug66388.phpt +++ b/tests/bug66388.phpt @@ -25,6 +25,7 @@ server("proxy.inc", function($port) { 'Content-Length' => 0 ) ); + $client->setOptions(["timeout" => 30]); $client->enqueue($request); echo $client->send()->getResponse()->getResponseCode(); }); diff --git a/tests/helper/server.inc b/tests/helper/server.inc index 78a63ee..af71a0e 100644 --- a/tests/helper/server.inc +++ b/tests/helper/server.inc @@ -95,9 +95,9 @@ function nghttpd($cb) { $stdout = $pipes[1]; $stderr = $pipes[2]; - usleep(50000); + sleep(1); $status = proc_get_status($proc); - + logger("nghttpd: %s", new http\Params($status)); if (!$status["running"]) { continue; } @@ -121,6 +121,7 @@ function nghttpd($cb) { function proc($bin, $args, $cb) { $spec = array(array("pipe","r"), array("pipe","w"), array("pipe","w")); $comm = escapeshellcmd($bin) . " ". implode(" ", array_map("escapeshellarg", $args)); + logger("proc: %s %s", $bin, implode(" ", $args)); if (($proc = proc_open($comm, $spec, $pipes, __DIR__))) { $stdin = $pipes[0]; $stdout = $pipes[1]; diff --git a/tests/skipif.inc b/tests/skipif.inc index 4844def..a9e161a 100644 --- a/tests/skipif.inc +++ b/tests/skipif.inc @@ -1,7 +1,23 @@ diff --git a/tests/urlparser006.phpt b/tests/urlparser006.phpt index d701bf5..e047ada 100644 --- a/tests/urlparser006.phpt +++ b/tests/urlparser006.phpt @@ -5,7 +5,7 @@ url parser multibyte/locale/idna include "skipif.inc"; if (!defined("http\\Url::PARSE_MBLOC") or !defined("http\\Url::PARSE_TOIDN_2003") or - !stristr(setlocale(LC_CTYPE, "C.UTF-8"), ".utf")) { + !utf8locale()) { die("skip need http\\Url::PARSE_MBLOC|http\\Url::PARSE_TOIDN_2003 support and LC_CTYPE=*.UTF-8"); } ?> diff --git a/tests/urlparser010.phpt b/tests/urlparser010.phpt index e1675ce..f538208 100644 --- a/tests/urlparser010.phpt +++ b/tests/urlparser010.phpt @@ -4,7 +4,7 @@ url parser multibyte/locale/topct