Lines Matching +full:persist +full:- +full:credentials
9 * http://www.apache.org/licenses/LICENSE-2.0
49 if (free_channel && channel->wrapped) { in free_grpc_channel_wrapper()
50 grpc_channel_destroy(channel->wrapped); in free_grpc_channel_wrapper()
51 channel->wrapped = NULL; in free_grpc_channel_wrapper()
53 free(channel->target); in free_grpc_channel_wrapper()
54 free(channel->args_hashstr); in free_grpc_channel_wrapper()
55 free(channel->creds_hashstr); in free_grpc_channel_wrapper()
56 free(channel->key); in free_grpc_channel_wrapper()
57 channel->target = NULL; in free_grpc_channel_wrapper()
58 channel->args_hashstr = NULL; in free_grpc_channel_wrapper()
59 channel->creds_hashstr = NULL; in free_grpc_channel_wrapper()
60 channel->key = NULL; in free_grpc_channel_wrapper()
64 gpr_mu_lock(&wrapper->mu); in php_grpc_channel_ref()
65 wrapper->ref_count += 1; in php_grpc_channel_ref()
66 gpr_mu_unlock(&wrapper->mu); in php_grpc_channel_ref()
70 gpr_mu_lock(&wrapper->mu); in php_grpc_channel_unref()
71 wrapper->ref_count -= 1; in php_grpc_channel_unref()
72 if (wrapper->ref_count == 0) { in php_grpc_channel_unref()
74 gpr_mu_unlock(&wrapper->mu); in php_grpc_channel_unref()
79 gpr_mu_unlock(&wrapper->mu); in php_grpc_channel_unref()
86 if (p->wrapper != NULL) {
87 php_grpc_channel_unref(p->wrapper);
88 p->wrapper = NULL;
97 zend_object_std_init(&intern->std, class_type TSRMLS_CC); in PHP_GRPC_FREE_WRAPPED_FUNC_END()
98 object_properties_init(&intern->std, class_type); in PHP_GRPC_FREE_WRAPPED_FUNC_END()
104 "credentials", in php_grpc_not_channel_arg_key()
128 args->args = ecalloc(zend_hash_num_elements(array_hash), sizeof(grpc_arg)); in php_grpc_read_args_array()
146 args->args[args_index].key = key; in php_grpc_read_args_array()
149 args->args[args_index].value.integer = (int)Z_LVAL_P(data); in php_grpc_read_args_array()
150 args->args[args_index].type = GRPC_ARG_INTEGER; in php_grpc_read_args_array()
153 args->args[args_index].value.string = Z_STRVAL_P(data); in php_grpc_read_args_array()
154 args->args[args_index].type = GRPC_ARG_STRING; in php_grpc_read_args_array()
163 args->num_args = args_index; in php_grpc_read_args_array()
186 channel_persistent_le_t* le = rsrc->ptr; in php_grpc_persistent_list_delete_unused_channel()
188 if (strcmp(le->channel->target, target) == 0) { in php_grpc_persistent_list_delete_unused_channel()
190 if (le->channel->ref_count == 1) { in php_grpc_persistent_list_delete_unused_channel()
191 php_grpc_delete_persistent_list_entry(le->channel->key, in php_grpc_persistent_list_delete_unused_channel()
192 strlen(le->channel->key) in php_grpc_persistent_list_delete_unused_channel()
194 target_bound_status->current_count -= 1; in php_grpc_persistent_list_delete_unused_channel()
195 if (target_bound_status->current_count < target_bound_status->upper_bound) { in php_grpc_persistent_list_delete_unused_channel()
213 if (bound == -1) { in update_and_get_target_upper_bound()
217 target_bound_status->upper_bound = bound; in update_and_get_target_upper_bound()
220 target_bound_status->current_count = 0; in update_and_get_target_upper_bound()
230 target_bound_status = (target_bound_le_t *)rsrc->ptr; in update_and_get_target_upper_bound()
231 if (bound != -1) { in update_and_get_target_upper_bound()
232 target_bound_status->upper_bound = bound; in update_and_get_target_upper_bound()
245 channel->wrapper->wrapped = grpc_channel_create(target, insecure_creds, &args); in create_channel()
248 channel->wrapper->wrapped = in create_channel()
249 grpc_channel_create(target, creds->wrapped, &args); in create_channel()
252 php_grpc_channel_ref(channel->wrapper); in create_channel()
267 if (target_bound_status->current_count >= in create_and_add_channel_to_persistent_list()
268 target_bound_status->upper_bound) { in create_and_add_channel_to_persistent_list()
272 // do not persist this one. in create_and_add_channel_to_persistent_list()
277 target_bound_status->upper_bound, in create_and_add_channel_to_persistent_list()
278 target_bound_status->current_count); in create_and_add_channel_to_persistent_list()
291 target_bound_status->current_count += 1; in create_and_add_channel_to_persistent_list()
293 le->channel = channel->wrapper; in create_and_add_channel_to_persistent_list()
299 php_grpc_channel_ref(channel->wrapper); in create_and_add_channel_to_persistent_list()
310 * If the $args array contains a "credentials" key mapping to a
312 * credentials.
334 int target_upper_bound = -1; in PHP_METHOD()
344 if (php_grpc_zend_hash_find(array_hash, "credentials", sizeof("credentials"), in PHP_METHOD()
351 "credentials must be a ChannelCredentials object", in PHP_METHOD()
386 // 2. hash value of the channel args (args_array excluding "credentials", in PHP_METHOD()
413 if (creds != NULL && creds->hashstr != NULL) { in PHP_METHOD()
414 key_len += strlen(creds->hashstr); in PHP_METHOD()
419 if (creds != NULL && creds->hashstr != NULL) { in PHP_METHOD()
420 strcat(key, creds->hashstr); in PHP_METHOD()
422 channel->wrapper = malloc(sizeof(grpc_channel_wrapper)); in PHP_METHOD()
423 channel->wrapper->ref_count = 0; in PHP_METHOD()
424 channel->wrapper->key = key; in PHP_METHOD()
425 channel->wrapper->target = strdup(target); in PHP_METHOD()
426 channel->wrapper->args_hashstr = strdup(sha1str); in PHP_METHOD()
427 channel->wrapper->creds_hashstr = NULL; in PHP_METHOD()
428 channel->wrapper->creds = creds; in PHP_METHOD()
429 channel->wrapper->args = args; in PHP_METHOD()
430 if (creds != NULL && creds->hashstr != NULL) { in PHP_METHOD()
431 php_grpc_int creds_hashstr_len = strlen(creds->hashstr); in PHP_METHOD()
433 strcpy(channel_creds_hashstr, creds->hashstr); in PHP_METHOD()
434 channel->wrapper->creds_hashstr = channel_creds_hashstr; in PHP_METHOD()
437 gpr_mu_init(&channel->wrapper->mu); in PHP_METHOD()
438 if (force_new || (creds != NULL && creds->has_call_creds)) { in PHP_METHOD()
440 // object, there is no way we can tell them apart. Do NOT persist in PHP_METHOD()
449 channel_persistent_le_t *le = (channel_persistent_le_t *)rsrc->ptr; in PHP_METHOD()
450 if (strcmp(target, le->channel->target) != 0 || in PHP_METHOD()
451 strcmp(sha1str, le->channel->args_hashstr) != 0 || in PHP_METHOD()
452 (creds != NULL && creds->hashstr != NULL && in PHP_METHOD()
453 strcmp(creds->hashstr, le->channel->creds_hashstr) != 0)) { in PHP_METHOD()
459 free_grpc_channel_wrapper(channel->wrapper, false); in PHP_METHOD()
460 gpr_mu_destroy(&channel->wrapper->mu); in PHP_METHOD()
461 free(channel->wrapper); in PHP_METHOD()
462 channel->wrapper = NULL; in PHP_METHOD()
463 channel->wrapper = le->channel; in PHP_METHOD()
465 php_grpc_channel_ref(channel->wrapper); in PHP_METHOD()
478 if (channel->wrapper == NULL) { in PHP_METHOD()
484 gpr_mu_lock(&channel->wrapper->mu); in PHP_METHOD()
485 char *target = grpc_channel_get_target(channel->wrapper->wrapped); in PHP_METHOD()
486 gpr_mu_unlock(&channel->wrapper->mu); in PHP_METHOD()
499 if (channel->wrapper == NULL) { in PHP_METHOD()
505 gpr_mu_lock(&channel->wrapper->mu); in PHP_METHOD()
512 gpr_mu_unlock(&channel->wrapper->mu); in PHP_METHOD()
515 int state = grpc_channel_check_connectivity_state(channel->wrapper->wrapped, in PHP_METHOD()
517 gpr_mu_unlock(&channel->wrapper->mu); in PHP_METHOD()
531 if (channel->wrapper == NULL) { in PHP_METHOD()
537 gpr_mu_lock(&channel->wrapper->mu); in PHP_METHOD()
548 gpr_mu_unlock(&channel->wrapper->mu); in PHP_METHOD()
554 grpc_channel_watch_connectivity_state(channel->wrapper->wrapped, in PHP_METHOD()
556 deadline->wrapped, completion_queue, in PHP_METHOD()
561 gpr_mu_unlock(&channel->wrapper->mu); in PHP_METHOD()
572 if (channel->wrapper != NULL) { in PHP_METHOD()
573 php_grpc_channel_unref(channel->wrapper); in PHP_METHOD()
574 channel->wrapper = NULL; in PHP_METHOD()
594 channel_persistent_le_t *le = (channel_persistent_le_t *)rsrc->ptr; in php_grpc_channel_plink_dtor()
598 if (le->channel != NULL) { in php_grpc_channel_plink_dtor()
599 php_grpc_channel_unref(le->channel); in php_grpc_channel_plink_dtor()
600 le->channel = NULL; in php_grpc_channel_plink_dtor()
609 target_bound_le_t *le = (target_bound_le_t *) rsrc->ptr; in php_grpc_target_bound_dtor()
654 sizeof("target"), channel->wrapper->target, true); in PHP_METHOD()
657 update_and_get_target_upper_bound(channel->wrapper->target, -1); in PHP_METHOD()
659 sizeof("target_upper_bound"), target_bound_status->upper_bound); in PHP_METHOD()
661 sizeof("target_current_size"), target_bound_status->current_count); in PHP_METHOD()
664 sizeof("key"), channel->wrapper->key, true); in PHP_METHOD()
667 sizeof("ref_count"), channel->wrapper->ref_count); in PHP_METHOD()
670 grpc_channel_check_connectivity_state(channel->wrapper->wrapped, (int)0); in PHP_METHOD()
679 sizeof("is_valid"), (channel->wrapper == NULL)); in PHP_METHOD()
695 channel_persistent_le_t* le = rsrc->ptr; in PHP_METHOD()
701 sizeof("target"), le->channel->target, true); in PHP_METHOD()
704 update_and_get_target_upper_bound(le->channel->target, -1); in PHP_METHOD()
706 sizeof("target_upper_bound"), target_bound_status->upper_bound); in PHP_METHOD()
708 sizeof("target_current_size"), target_bound_status->current_count); in PHP_METHOD()
711 sizeof("key"), le->channel->key, true); in PHP_METHOD()
714 sizeof("ref_count"), le->channel->ref_count); in PHP_METHOD()
717 grpc_channel_check_connectivity_state(le->channel->wrapped, (int)0); in PHP_METHOD()
724 add_assoc_zval(return_value, le->channel->key, ret_arr); in PHP_METHOD()
794 // Register the target->upper_bound map. in GRPC_STARTUP_FUNCTION()