| /* |
| * |
| * Copyright 2015, Google Inc. |
| * All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions are |
| * met: |
| * |
| * * Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * * Redistributions in binary form must reproduce the above |
| * copyright notice, this list of conditions and the following disclaimer |
| * in the documentation and/or other materials provided with the |
| * distribution. |
| * * Neither the name of Google Inc. nor the names of its |
| * contributors may be used to endorse or promote products derived from |
| * this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
| * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
| * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
| * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
| * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
| * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
| * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
| * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| * |
| */ |
| |
| #include "timeval.h" |
| |
| #ifdef HAVE_CONFIG_H |
| #include "config.h" |
| #endif |
| |
| #include "php.h" |
| #include "php_ini.h" |
| #include "ext/standard/info.h" |
| #include "ext/spl/spl_exceptions.h" |
| #include "php_grpc.h" |
| |
| #include "zend_exceptions.h" |
| |
| #include <stdbool.h> |
| |
| #include "grpc/grpc.h" |
| #include "grpc/support/time.h" |
| |
| /* Frees and destroys an instance of wrapped_grpc_call */ |
| void free_wrapped_grpc_timeval(void *object TSRMLS_DC) { efree(object); } |
| |
| /* Initializes an instance of wrapped_grpc_timeval to be associated with an |
| * object of a class specified by class_type */ |
| zend_object_value create_wrapped_grpc_timeval(zend_class_entry *class_type |
| TSRMLS_DC) { |
| zend_object_value retval; |
| wrapped_grpc_timeval *intern; |
| intern = (wrapped_grpc_timeval *)emalloc(sizeof(wrapped_grpc_timeval)); |
| memset(intern, 0, sizeof(wrapped_grpc_timeval)); |
| zend_object_std_init(&intern->std, class_type TSRMLS_CC); |
| object_properties_init(&intern->std, class_type); |
| retval.handle = zend_objects_store_put( |
| intern, (zend_objects_store_dtor_t)zend_objects_destroy_object, |
| free_wrapped_grpc_timeval, NULL TSRMLS_CC); |
| retval.handlers = zend_get_std_object_handlers(); |
| return retval; |
| } |
| |
| zval *grpc_php_wrap_timeval(gpr_timespec wrapped) { |
| zval *timeval_object; |
| MAKE_STD_ZVAL(timeval_object); |
| object_init_ex(timeval_object, grpc_ce_timeval); |
| wrapped_grpc_timeval *timeval = |
| (wrapped_grpc_timeval *)zend_object_store_get_object( |
| timeval_object TSRMLS_CC); |
| memcpy(&timeval->wrapped, &wrapped, sizeof(gpr_timespec)); |
| return timeval_object; |
| } |
| |
| /** |
| * Constructs a new instance of the Timeval class |
| * @param long $usec The number of microseconds in the interval |
| */ |
| PHP_METHOD(Timeval, __construct) { |
| wrapped_grpc_timeval *timeval = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(getThis() TSRMLS_CC); |
| long microseconds; |
| /* "l" == 1 long */ |
| if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", µseconds) == |
| FAILURE) { |
| zend_throw_exception(spl_ce_InvalidArgumentException, |
| "Timeval expects a long", 1 TSRMLS_CC); |
| return; |
| } |
| gpr_timespec time = gpr_time_from_micros(microseconds); |
| memcpy(&timeval->wrapped, &time, sizeof(gpr_timespec)); |
| } |
| |
| /** |
| * Adds another Timeval to this one and returns the sum. Calculations saturate |
| * at infinities. |
| * @param Timeval $other The other Timeval object to add |
| * @return Timeval A new Timeval object containing the sum |
| */ |
| PHP_METHOD(Timeval, add) { |
| zval *other_obj; |
| /* "O" == 1 Object */ |
| if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "O", &other_obj, |
| grpc_ce_timeval) == FAILURE) { |
| zend_throw_exception(spl_ce_InvalidArgumentException, |
| "add expects a Timeval", 1 TSRMLS_CC); |
| return; |
| } |
| wrapped_grpc_timeval *self = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(getThis() TSRMLS_CC); |
| wrapped_grpc_timeval *other = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(other_obj TSRMLS_CC); |
| zval *sum = |
| grpc_php_wrap_timeval(gpr_time_add(self->wrapped, other->wrapped)); |
| RETURN_DESTROY_ZVAL(sum); |
| } |
| |
| /** |
| * Subtracts another Timeval from this one and returns the difference. |
| * Calculations saturate at infinities. |
| * @param Timeval $other The other Timeval object to subtract |
| * @param Timeval A new Timeval object containing the sum |
| */ |
| PHP_METHOD(Timeval, subtract) { |
| zval *other_obj; |
| /* "O" == 1 Object */ |
| if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "O", &other_obj, |
| grpc_ce_timeval) == FAILURE) { |
| zend_throw_exception(spl_ce_InvalidArgumentException, |
| "subtract expects a Timeval", 1 TSRMLS_CC); |
| return; |
| } |
| wrapped_grpc_timeval *self = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(getThis() TSRMLS_CC); |
| wrapped_grpc_timeval *other = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(other_obj TSRMLS_CC); |
| zval *diff = |
| grpc_php_wrap_timeval(gpr_time_sub(self->wrapped, other->wrapped)); |
| RETURN_DESTROY_ZVAL(diff); |
| } |
| |
| /** |
| * Return negative, 0, or positive according to whether a < b, a == b, or a > b |
| * respectively. |
| * @param Timeval $a The first time to compare |
| * @param Timeval $b The second time to compare |
| * @return long |
| */ |
| PHP_METHOD(Timeval, compare) { |
| zval *a_obj, *b_obj; |
| /* "OO" == 2 Objects */ |
| if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "OO", &a_obj, |
| grpc_ce_timeval, &b_obj, |
| grpc_ce_timeval) == FAILURE) { |
| zend_throw_exception(spl_ce_InvalidArgumentException, |
| "compare expects two Timevals", 1 TSRMLS_CC); |
| return; |
| } |
| wrapped_grpc_timeval *a = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(a_obj TSRMLS_CC); |
| wrapped_grpc_timeval *b = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(b_obj TSRMLS_CC); |
| long result = gpr_time_cmp(a->wrapped, b->wrapped); |
| RETURN_LONG(result); |
| } |
| |
| /** |
| * Checks whether the two times are within $threshold of each other |
| * @param Timeval $a The first time to compare |
| * @param Timeval $b The second time to compare |
| * @param Timeval $threshold The threshold to check against |
| * @return bool True if $a and $b are within $threshold, False otherwise |
| */ |
| PHP_METHOD(Timeval, similar) { |
| zval *a_obj, *b_obj, *thresh_obj; |
| /* "OOO" == 3 Objects */ |
| if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "OOO", &a_obj, |
| grpc_ce_timeval, &b_obj, grpc_ce_timeval, |
| &thresh_obj, grpc_ce_timeval) == FAILURE) { |
| zend_throw_exception(spl_ce_InvalidArgumentException, |
| "compare expects three Timevals", 1 TSRMLS_CC); |
| return; |
| } |
| wrapped_grpc_timeval *a = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(a_obj TSRMLS_CC); |
| wrapped_grpc_timeval *b = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(b_obj TSRMLS_CC); |
| wrapped_grpc_timeval *thresh = |
| (wrapped_grpc_timeval *)zend_object_store_get_object( |
| thresh_obj TSRMLS_CC); |
| int result = gpr_time_similar(a->wrapped, b->wrapped, thresh->wrapped); |
| RETURN_BOOL(result); |
| } |
| |
| /** |
| * Returns the current time as a timeval object |
| * @return Timeval The current time |
| */ |
| PHP_METHOD(Timeval, now) { |
| zval *now = grpc_php_wrap_timeval(gpr_now()); |
| RETURN_DESTROY_ZVAL(now); |
| } |
| |
| /** |
| * Returns the zero time interval as a timeval object |
| * @return Timeval Zero length time interval |
| */ |
| PHP_METHOD(Timeval, zero) { |
| zval *grpc_php_timeval_zero = grpc_php_wrap_timeval(gpr_time_0); |
| RETURN_ZVAL(grpc_php_timeval_zero, |
| false, /* Copy original before returning? */ |
| true /* Destroy original before returning */); |
| } |
| |
| /** |
| * Returns the infinite future time value as a timeval object |
| * @return Timeval Infinite future time value |
| */ |
| PHP_METHOD(Timeval, inf_future) { |
| zval *grpc_php_timeval_inf_future = grpc_php_wrap_timeval(gpr_inf_future); |
| RETURN_DESTROY_ZVAL(grpc_php_timeval_inf_future); |
| } |
| |
| /** |
| * Returns the infinite past time value as a timeval object |
| * @return Timeval Infinite past time value |
| */ |
| PHP_METHOD(Timeval, inf_past) { |
| zval *grpc_php_timeval_inf_past = grpc_php_wrap_timeval(gpr_inf_past); |
| RETURN_DESTROY_ZVAL(grpc_php_timeval_inf_past); |
| } |
| |
| /** |
| * Sleep until this time, interpreted as an absolute timeout |
| * @return void |
| */ |
| PHP_METHOD(Timeval, sleep_until) { |
| wrapped_grpc_timeval *this = |
| (wrapped_grpc_timeval *)zend_object_store_get_object(getThis() TSRMLS_CC); |
| gpr_sleep_until(this->wrapped); |
| } |
| |
| static zend_function_entry timeval_methods[] = { |
| PHP_ME(Timeval, __construct, NULL, ZEND_ACC_PUBLIC | ZEND_ACC_CTOR) |
| PHP_ME(Timeval, add, NULL, ZEND_ACC_PUBLIC) |
| PHP_ME(Timeval, compare, NULL, ZEND_ACC_PUBLIC | ZEND_ACC_STATIC) |
| PHP_ME(Timeval, inf_future, NULL, ZEND_ACC_PUBLIC | ZEND_ACC_STATIC) |
| PHP_ME(Timeval, inf_past, NULL, ZEND_ACC_PUBLIC | ZEND_ACC_STATIC) |
| PHP_ME(Timeval, now, NULL, ZEND_ACC_PUBLIC | ZEND_ACC_STATIC) |
| PHP_ME(Timeval, similar, NULL, ZEND_ACC_PUBLIC | ZEND_ACC_STATIC) |
| PHP_ME(Timeval, sleep_until, NULL, ZEND_ACC_PUBLIC) |
| PHP_ME(Timeval, subtract, NULL, ZEND_ACC_PUBLIC) |
| PHP_ME(Timeval, zero, NULL, ZEND_ACC_PUBLIC | ZEND_ACC_STATIC) PHP_FE_END}; |
| |
| void grpc_init_timeval(TSRMLS_D) { |
| zend_class_entry ce; |
| INIT_CLASS_ENTRY(ce, "Grpc\\Timeval", timeval_methods); |
| ce.create_object = create_wrapped_grpc_timeval; |
| grpc_ce_timeval = zend_register_internal_class(&ce TSRMLS_CC); |
| } |
| |
| void grpc_shutdown_timeval(TSRMLS_D) {} |