aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/php/ext/grpc/event.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/php/ext/grpc/event.c')
-rw-r--r--[-rwxr-xr-x]src/php/ext/grpc/event.c63
1 files changed, 26 insertions, 37 deletions
diff --git a/src/php/ext/grpc/event.c b/src/php/ext/grpc/event.c
index c15f479448..b4069f72f0 100755..100644
--- a/src/php/ext/grpc/event.c
+++ b/src/php/ext/grpc/event.c
@@ -32,24 +32,25 @@ zval *grpc_php_convert_event(grpc_event *event) {
zval *event_object;
- if(event == NULL) {
+ if (event == NULL) {
return NULL;
}
MAKE_STD_ZVAL(event_object);
object_init(event_object);
- add_property_zval(event_object,
- "call",
- grpc_php_wrap_call(event->call,
- event->type==GRPC_SERVER_RPC_NEW));
+ add_property_zval(
+ event_object, "call",
+ grpc_php_wrap_call(event->call, event->type == GRPC_SERVER_RPC_NEW));
add_property_long(event_object, "type", event->type);
add_property_long(event_object, "tag", (long)event->tag);
- switch(event->type){
- case GRPC_QUEUE_SHUTDOWN: add_property_null(event_object, "data"); break;
+ switch (event->type) {
+ case GRPC_QUEUE_SHUTDOWN:
+ add_property_null(event_object, "data");
+ break;
case GRPC_READ:
- if(event->data.read == NULL){
+ if (event->data.read == NULL) {
add_property_null(event_object, "data");
} else {
byte_buffer_to_string(event->data.read, &read_string, &read_len);
@@ -57,16 +58,14 @@ zval *grpc_php_convert_event(grpc_event *event) {
}
break;
case GRPC_INVOKE_ACCEPTED:
- add_property_long(event_object,
- "data",
+ add_property_long(event_object, "data",
(long)event->data.invoke_accepted);
break;
case GRPC_WRITE_ACCEPTED:
add_property_long(event_object, "data", (long)event->data.write_accepted);
break;
case GRPC_FINISH_ACCEPTED:
- add_property_long(event_object,
- "data",
+ add_property_long(event_object, "data",
(long)event->data.finish_accepted);
break;
case GRPC_CLIENT_METADATA_READ:
@@ -79,19 +78,15 @@ zval *grpc_php_convert_event(grpc_event *event) {
MAKE_STD_ZVAL(data_object);
object_init(data_object);
add_property_long(data_object, "code", event->data.finished.status);
- if(event->data.finished.details == NULL){
+ if (event->data.finished.details == NULL) {
add_property_null(data_object, "details");
} else {
detail_len = strlen(event->data.finished.details);
- detail_string = ecalloc(detail_len+1, sizeof(char));
+ detail_string = ecalloc(detail_len + 1, sizeof(char));
memcpy(detail_string, event->data.finished.details, detail_len);
- add_property_string(data_object,
- "details",
- detail_string,
- true);
+ add_property_string(data_object, "details", detail_string, true);
}
- add_property_zval(data_object,
- "metadata",
+ add_property_zval(data_object, "metadata",
grpc_call_create_metadata_array(
event->data.finished.metadata_count,
event->data.finished.metadata_elements));
@@ -101,31 +96,25 @@ zval *grpc_php_convert_event(grpc_event *event) {
MAKE_STD_ZVAL(data_object);
object_init(data_object);
method_len = strlen(event->data.server_rpc_new.method);
- method_string = ecalloc(method_len+1, sizeof(char));
+ method_string = ecalloc(method_len + 1, sizeof(char));
memcpy(method_string, event->data.server_rpc_new.method, method_len);
- add_property_string(data_object,
- "method",
- method_string,
- false);
+ add_property_string(data_object, "method", method_string, false);
host_len = strlen(event->data.server_rpc_new.host);
- host_string = ecalloc(host_len+1, sizeof(char));
+ host_string = ecalloc(host_len + 1, sizeof(char));
memcpy(host_string, event->data.server_rpc_new.host, host_len);
- add_property_string(data_object,
- "host",
- host_string,
- false);
- add_property_zval(data_object,
- "absolute_timeout",
- grpc_php_wrap_timeval(
- event->data.server_rpc_new.deadline));
- add_property_zval(data_object,
- "metadata",
+ add_property_string(data_object, "host", host_string, false);
+ add_property_zval(
+ data_object, "absolute_timeout",
+ grpc_php_wrap_timeval(event->data.server_rpc_new.deadline));
+ add_property_zval(data_object, "metadata",
grpc_call_create_metadata_array(
event->data.server_rpc_new.metadata_count,
event->data.server_rpc_new.metadata_elements));
add_property_zval(event_object, "data", data_object);
break;
- default: add_property_null(event_object, "data"); break;
+ default:
+ add_property_null(event_object, "data");
+ break;
}
grpc_event_finish(event);
return event_object;