aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/channel/channel_stack.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/channel/channel_stack.c')
-rw-r--r--src/core/channel/channel_stack.c33
1 files changed, 17 insertions, 16 deletions
diff --git a/src/core/channel/channel_stack.c b/src/core/channel/channel_stack.c
index 10fbd520c3..47f1f8e828 100644
--- a/src/core/channel/channel_stack.c
+++ b/src/core/channel/channel_stack.c
@@ -106,7 +106,7 @@ void grpc_channel_stack_init(const grpc_channel_filter **filters,
const grpc_channel_args *args,
grpc_mdctx *metadata_context,
grpc_channel_stack *stack,
- grpc_call_list *call_list) {
+ grpc_closure_list *closure_list) {
size_t call_size =
ROUND_UP_TO_ALIGNMENT_SIZE(sizeof(grpc_call_stack)) +
ROUND_UP_TO_ALIGNMENT_SIZE(filter_count * sizeof(grpc_call_element));
@@ -126,7 +126,7 @@ void grpc_channel_stack_init(const grpc_channel_filter **filters,
elems[i].channel_data = user_data;
elems[i].filter->init_channel_elem(&elems[i], master, args,
metadata_context, i == 0,
- i == (filter_count - 1), call_list);
+ i == (filter_count - 1), closure_list);
user_data += ROUND_UP_TO_ALIGNMENT_SIZE(filters[i]->sizeof_channel_data);
call_size += ROUND_UP_TO_ALIGNMENT_SIZE(filters[i]->sizeof_call_data);
}
@@ -139,14 +139,15 @@ void grpc_channel_stack_init(const grpc_channel_filter **filters,
}
void grpc_channel_stack_destroy(grpc_channel_stack *stack,
- grpc_call_list *call_list) {
+ grpc_closure_list *closure_list) {
grpc_channel_element *channel_elems = CHANNEL_ELEMS_FROM_STACK(stack);
size_t count = stack->count;
size_t i;
/* destroy per-filter data */
for (i = 0; i < count; i++) {
- channel_elems[i].filter->destroy_channel_elem(&channel_elems[i], call_list);
+ channel_elems[i].filter->destroy_channel_elem(&channel_elems[i],
+ closure_list);
}
}
@@ -154,7 +155,7 @@ void grpc_call_stack_init(grpc_channel_stack *channel_stack,
const void *transport_server_data,
grpc_transport_stream_op *initial_op,
grpc_call_stack *call_stack,
- grpc_call_list *call_list) {
+ grpc_closure_list *closure_list) {
grpc_channel_element *channel_elems = CHANNEL_ELEMS_FROM_STACK(channel_stack);
size_t count = channel_stack->count;
grpc_call_element *call_elems;
@@ -172,40 +173,40 @@ void grpc_call_stack_init(grpc_channel_stack *channel_stack,
call_elems[i].channel_data = channel_elems[i].channel_data;
call_elems[i].call_data = user_data;
call_elems[i].filter->init_call_elem(&call_elems[i], transport_server_data,
- initial_op, call_list);
+ initial_op, closure_list);
user_data +=
ROUND_UP_TO_ALIGNMENT_SIZE(call_elems[i].filter->sizeof_call_data);
}
}
void grpc_call_stack_destroy(grpc_call_stack *stack,
- grpc_call_list *call_list) {
+ grpc_closure_list *closure_list) {
grpc_call_element *elems = CALL_ELEMS_FROM_STACK(stack);
size_t count = stack->count;
size_t i;
/* destroy per-filter data */
for (i = 0; i < count; i++) {
- elems[i].filter->destroy_call_elem(&elems[i], call_list);
+ elems[i].filter->destroy_call_elem(&elems[i], closure_list);
}
}
void grpc_call_next_op(grpc_call_element *elem, grpc_transport_stream_op *op,
- grpc_call_list *call_list) {
+ grpc_closure_list *closure_list) {
grpc_call_element *next_elem = elem + 1;
- next_elem->filter->start_transport_stream_op(next_elem, op, call_list);
+ next_elem->filter->start_transport_stream_op(next_elem, op, closure_list);
}
char *grpc_call_next_get_peer(grpc_call_element *elem,
- grpc_call_list *call_list) {
+ grpc_closure_list *closure_list) {
grpc_call_element *next_elem = elem + 1;
- return next_elem->filter->get_peer(next_elem, call_list);
+ return next_elem->filter->get_peer(next_elem, closure_list);
}
void grpc_channel_next_op(grpc_channel_element *elem, grpc_transport_op *op,
- grpc_call_list *call_list) {
+ grpc_closure_list *closure_list) {
grpc_channel_element *next_elem = elem + 1;
- next_elem->filter->start_transport_op(next_elem, op, call_list);
+ next_elem->filter->start_transport_op(next_elem, op, closure_list);
}
grpc_channel_stack *grpc_channel_stack_from_top_element(
@@ -220,9 +221,9 @@ grpc_call_stack *grpc_call_stack_from_top_element(grpc_call_element *elem) {
}
void grpc_call_element_send_cancel(grpc_call_element *cur_elem,
- grpc_call_list *call_list) {
+ grpc_closure_list *closure_list) {
grpc_transport_stream_op op;
memset(&op, 0, sizeof(op));
op.cancel_with_status = GRPC_STATUS_CANCELLED;
- grpc_call_next_op(cur_elem, &op, call_list);
+ grpc_call_next_op(cur_elem, &op, closure_list);
}