X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=http_message_object.c;h=c642754c73641b81bf4182bee3a71d25ebc7f658;hb=7904ebbfd747d11f0821d2b2712600ab07a36ff6;hp=d275004a3b7669cfa8820bfb6841243544c032f6;hpb=1a0dbb96fbe46a2edec1c813798cef7b0898eebe;p=m6w6%2Fext-http diff --git a/http_message_object.c b/http_message_object.c index d275004..c642754 100644 --- a/http_message_object.c +++ b/http_message_object.c @@ -121,6 +121,7 @@ HTTP_EMPTY_ARGS(detach); HTTP_BEGIN_ARGS(prepend, 1) HTTP_ARG_OBJ(HttpMessage, message, 0) HTTP_END_ARGS; +HTTP_EMPTY_ARGS(reverse); #define http_message_object_declare_default_properties() _http_message_object_declare_default_properties(TSRMLS_C) static inline void _http_message_object_declare_default_properties(TSRMLS_D); @@ -176,6 +177,7 @@ zend_function_entry http_message_object_fe[] = { HTTP_MESSAGE_ME(detach, ZEND_ACC_PUBLIC) HTTP_MESSAGE_ME(prepend, ZEND_ACC_PUBLIC) + HTTP_MESSAGE_ME(reverse, ZEND_ACC_PUBLIC) EMPTY_FUNCTION_ENTRY }; @@ -207,6 +209,96 @@ PHP_MINIT_FUNCTION(http_message_object) return SUCCESS; } +void _http_message_object_reverse(zval *this_ptr, zval *return_value TSRMLS_DC) +{ + int i; + getObject(http_message_object, obj); + + /* count */ + http_message_count(i, obj->message); + + if (i > 1) { + zval o; + zend_object_value *ovalues = NULL; + http_message_object **objects = NULL; + int last = i - 1; + + objects = ecalloc(i, sizeof(http_message_object *)); + ovalues = ecalloc(i, sizeof(zend_object_value)); + + /* we are the first message */ + objects[0] = obj; + ovalues[0] = getThis()->value.obj; + + /* fetch parents */ + INIT_PZVAL(&o); + o.type = IS_OBJECT; + for (i = 1; obj->parent.handle; ++i) { + o.value.obj = obj->parent; + ovalues[i] = o.value.obj; + objects[i] = obj = zend_object_store_get_object(&o TSRMLS_CC); + } + + /* reorder parents */ + for (last = --i; i; --i) { + objects[i]->message->parent = objects[i-1]->message; + objects[i]->parent = ovalues[i-1]; + } + objects[0]->message->parent = NULL; + objects[0]->parent.handle = 0; + objects[0]->parent.handlers = NULL; + + /* add ref (why?) */ + Z_OBJ_ADDREF_P(getThis()); + RETVAL_OBJVAL(ovalues[last], 1); + + efree(objects); + efree(ovalues); + } else { + RETURN_ZVAL(getThis(), 1, 0); + } +} + +void _http_message_object_prepend_ex(zval *this_ptr, zval *prepend, zend_bool top TSRMLS_DC) +{ + zval m; + http_message *save_parent_msg; + zend_object_value save_parent_obj; + getObject(http_message_object, obj); + getObjectEx(http_message_object, prepend_obj, prepend); + + INIT_PZVAL(&m); + m.type = IS_OBJECT; + + if (!top) { + save_parent_obj = obj->parent; + save_parent_msg = obj->message->parent; + } else { + /* iterate to the most parent object */ + while (obj->parent.handle) { + m.value.obj = obj->parent; + obj = zend_object_store_get_object(&m TSRMLS_CC); + } + } + + /* prepend */ + obj->parent = prepend->value.obj; + obj->message->parent = prepend_obj->message; + + /* add ref */ + zend_objects_store_add_ref(prepend TSRMLS_CC); + while (prepend_obj->parent.handle) { + m.value.obj = prepend_obj->parent; + zend_objects_store_add_ref(&m TSRMLS_CC); + prepend_obj = zend_object_store_get_object(&m TSRMLS_CC); + } + + if (!top) { + prepend_obj->parent = save_parent_obj; + prepend_obj->message->parent = save_parent_msg; + } +} + zend_object_value _http_message_object_new(zend_class_entry *ce TSRMLS_DC) { return http_message_object_new_ex(ce, NULL, NULL); @@ -1241,10 +1333,9 @@ PHP_METHOD(HttpMessage, count) { NO_ARGS { long i; - http_message *msg; getObject(http_message_object, obj); - for (i = 0, msg = obj->message; msg; msg = msg->parent, ++i); + http_message_count(i, obj->message); RETURN_LONG(i); } } @@ -1328,42 +1419,21 @@ PHP_METHOD(HttpMessage, prepend) zend_bool top = 1; if (SUCCESS == zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "O|b", &prepend, http_message_object_ce, &top)) { - zval m; - http_message *save_parent_msg; - zend_object_value save_parent_obj; - getObject(http_message_object, obj); - getObjectEx(http_message_object, prepend_obj, prepend); - - INIT_PZVAL(&m); - m.type = IS_OBJECT; - - if (!top) { - save_parent_obj = obj->parent; - save_parent_msg = obj->message->parent; - } else { - /* iterate to the most parent object */ - while (obj->parent.handle) { - m.value.obj = obj->parent; - obj = zend_object_store_get_object(&m TSRMLS_CC); - } - } - - /* prepend */ - obj->parent = prepend->value.obj; - obj->message->parent = prepend_obj->message; - - /* add ref */ - zend_objects_store_add_ref(prepend TSRMLS_CC); - while (prepend_obj->parent.handle) { - m.value.obj = prepend_obj->parent; - zend_objects_store_add_ref(&m TSRMLS_CC); - prepend_obj = zend_object_store_get_object(&m TSRMLS_CC); - } - - if (!top) { - prepend_obj->parent = save_parent_obj; - prepend_obj->message->parent = save_parent_msg; - } + http_message_object_prepend_ex(getThis(), prepend, top); + } +} +/* }}} */ + +/* {{{ proto HttpMessage HttpMessage::reverse() + * + * Reorders the message chain in reverse order. + * + * Returns the most parent HttpMessage object. + */ +PHP_METHOD(HttpMessage, reverse) +{ + NO_ARGS { + http_message_object_reverse(getThis(), return_value); } } /* }}} */