diff options
author | Craig Tiller <craig.tiller@gmail.com> | 2015-08-01 16:12:04 -0700 |
---|---|---|
committer | Craig Tiller <craig.tiller@gmail.com> | 2015-08-01 16:12:04 -0700 |
commit | 6728bef3b1edc9b7f4e4c31b18cd5f5a2747e8f1 (patch) | |
tree | 843a9b5a3a45a3a3aca0e4975b0522c38bc3974c /src | |
parent | fa44f18516747cf6d8a17fe5d8f687b8acf03b5f (diff) | |
parent | 584717758bf0ee9ef165f85b95720d3e4701ff9b (diff) |
Merge branch 'propagate' of github.com:ctiller/grpc into propagate
Conflicts:
src/core/surface/channel.c
Diffstat (limited to 'src')
-rw-r--r-- | src/core/surface/call.c | 6 | ||||
-rw-r--r-- | src/core/surface/call.h | 2 | ||||
-rw-r--r-- | src/core/surface/channel.c | 12 | ||||
-rw-r--r-- | src/csharp/ext/grpc_csharp_ext.c | 2 | ||||
-rw-r--r-- | src/php/ext/grpc/call.c | 2 | ||||
-rw-r--r-- | src/python/grpcio/grpc/_adapter/_c/types/channel.c | 2 | ||||
-rw-r--r-- | src/ruby/ext/grpc/rb_channel.c | 2 |
7 files changed, 14 insertions, 14 deletions
diff --git a/src/core/surface/call.c b/src/core/surface/call.c index e0496df5c6..aa1060aebd 100644 --- a/src/core/surface/call.c +++ b/src/core/surface/call.c @@ -292,7 +292,7 @@ static void lock(grpc_call *call); static void unlock(grpc_call *call); grpc_call *grpc_call_create(grpc_channel *channel, grpc_call *parent_call, - gpr_uint32 inheritance_mask, + gpr_uint32 propagation_mask, grpc_completion_queue *cq, const void *server_transport_data, grpc_mdelem **add_initial_metadata, @@ -319,13 +319,13 @@ grpc_call *grpc_call_create(grpc_channel *channel, grpc_call *parent_call, GPR_ASSERT(call->is_client); GPR_ASSERT(!parent_call->is_client); - if (inheritance_mask & GRPC_INHERIT_DEADLINE) { + if (propagation_mask & GRPC_PROPAGATE_DEADLINE) { send_deadline = gpr_time_min( gpr_convert_clock_type(send_deadline, parent_call->send_deadline.clock_type), parent_call->send_deadline); } - if (inheritance_mask & GRPC_INHERIT_CENSUS_CONTEXT) { + if (propagation_mask & GRPC_PROPAGATE_CENSUS_CONTEXT) { grpc_call_context_set(call, GRPC_CONTEXT_TRACING, parent_call->context[GRPC_CONTEXT_TRACING].value, NULL); diff --git a/src/core/surface/call.h b/src/core/surface/call.h index f2cc8fa352..75bdbce980 100644 --- a/src/core/surface/call.h +++ b/src/core/surface/call.h @@ -86,7 +86,7 @@ typedef void (*grpc_ioreq_completion_func)(grpc_call *call, int success, void *user_data); grpc_call *grpc_call_create(grpc_channel *channel, grpc_call *parent_call, - gpr_uint32 inheritance_mask, + gpr_uint32 propagation_mask, grpc_completion_queue *cq, const void *server_transport_data, grpc_mdelem **add_initial_metadata, diff --git a/src/core/surface/channel.c b/src/core/surface/channel.c index c90b479769..fe71bc0252 100644 --- a/src/core/surface/channel.c +++ b/src/core/surface/channel.c @@ -146,7 +146,7 @@ char *grpc_channel_get_target(grpc_channel *channel) { } static grpc_call *grpc_channel_create_call_internal( - grpc_channel *channel, grpc_call *parent_call, gpr_uint32 inheritance_mask, + grpc_channel *channel, grpc_call *parent_call, gpr_uint32 propagation_mask, grpc_completion_queue *cq, grpc_mdelem *path_mdelem, grpc_mdelem *authority_mdelem, gpr_timespec deadline) { grpc_mdelem *send_metadata[2]; @@ -159,18 +159,18 @@ static grpc_call *grpc_channel_create_call_internal( send_metadata[num_metadata++] = authority_mdelem; } - return grpc_call_create(channel, parent_call, inheritance_mask, cq, NULL, + return grpc_call_create(channel, parent_call, propagation_mask, cq, NULL, send_metadata, num_metadata, deadline); } grpc_call *grpc_channel_create_call(grpc_channel *channel, grpc_call *parent_call, - gpr_uint32 inheritance_mask, + gpr_uint32 propagation_mask, grpc_completion_queue *cq, const char *method, const char *host, gpr_timespec deadline) { return grpc_channel_create_call_internal( - channel, parent_call, inheritance_mask, cq, + channel, parent_call, propagation_mask, cq, grpc_mdelem_from_metadata_strings( channel->metadata_context, GRPC_MDSTR_REF(channel->path_string), grpc_mdstr_from_string(channel->metadata_context, method, 0)), @@ -198,12 +198,12 @@ void *grpc_channel_register_call(grpc_channel *channel, const char *method, } grpc_call *grpc_channel_create_registered_call( - grpc_channel *channel, grpc_call *parent_call, gpr_uint32 inheritance_mask, + grpc_channel *channel, grpc_call *parent_call, gpr_uint32 propagation_mask, grpc_completion_queue *completion_queue, void *registered_call_handle, gpr_timespec deadline) { registered_call *rc = registered_call_handle; return grpc_channel_create_call_internal( - channel, parent_call, inheritance_mask, completion_queue, + channel, parent_call, propagation_mask, completion_queue, GRPC_MDELEM_REF(rc->path), rc->authority ? GRPC_MDELEM_REF(rc->authority) : NULL, deadline); } diff --git a/src/csharp/ext/grpc_csharp_ext.c b/src/csharp/ext/grpc_csharp_ext.c index 425d226bf0..b0612d4592 100644 --- a/src/csharp/ext/grpc_csharp_ext.c +++ b/src/csharp/ext/grpc_csharp_ext.c @@ -379,7 +379,7 @@ GPR_EXPORT grpc_call *GPR_CALLTYPE grpcsharp_channel_create_call(grpc_channel *channel, grpc_completion_queue *cq, const char *method, const char *host, gpr_timespec deadline) { - return grpc_channel_create_call(channel, NULL, GRPC_INHERIT_DEFAULTS, cq, + return grpc_channel_create_call(channel, NULL, GRPC_PROPAGATE_DEFAULTS, cq, method, host, deadline); } diff --git a/src/php/ext/grpc/call.c b/src/php/ext/grpc/call.c index 26499b7615..01ec909b79 100644 --- a/src/php/ext/grpc/call.c +++ b/src/php/ext/grpc/call.c @@ -240,7 +240,7 @@ PHP_METHOD(Call, __construct) { (wrapped_grpc_timeval *)zend_object_store_get_object( deadline_obj TSRMLS_CC); call->wrapped = grpc_channel_create_call( - channel->wrapped, NULL, GRPC_INHERIT_DEFAULTS, completion_queue, method, + channel->wrapped, NULL, GRPC_PROPAGATE_DEFAULTS, completion_queue, method, channel->target, deadline->wrapped); } diff --git a/src/python/grpcio/grpc/_adapter/_c/types/channel.c b/src/python/grpcio/grpc/_adapter/_c/types/channel.c index 68eaea4da6..963104742f 100644 --- a/src/python/grpcio/grpc/_adapter/_c/types/channel.c +++ b/src/python/grpcio/grpc/_adapter/_c/types/channel.c @@ -128,7 +128,7 @@ Call *pygrpc_Channel_create_call( } call = pygrpc_Call_new_empty(cq); call->c_call = grpc_channel_create_call( - self->c_chan, NULL, GRPC_INHERIT_DEFAULTS, cq->c_cq, method, host, + self->c_chan, NULL, GRPC_PROPAGATE_DEFAULTS, cq->c_cq, method, host, pygrpc_cast_double_to_gpr_timespec(deadline)); return call; } diff --git a/src/ruby/ext/grpc/rb_channel.c b/src/ruby/ext/grpc/rb_channel.c index 506e7cdee7..a0663607c2 100644 --- a/src/ruby/ext/grpc/rb_channel.c +++ b/src/ruby/ext/grpc/rb_channel.c @@ -212,7 +212,7 @@ static VALUE grpc_rb_channel_create_call(VALUE self, VALUE cqueue, VALUE method, return Qnil; } - call = grpc_channel_create_call(ch, NULL, GRPC_INHERIT_DEFAULTS, cq, + call = grpc_channel_create_call(ch, NULL, GRPC_PROPAGATE_DEFAULTS, cq, method_chars, host_chars, grpc_rb_time_timeval(deadline, /* absolute time */ 0)); |