Merge branch 'master' into stress_tests_metrics

wqx081 · Nov 19, 2015 · 87f5166 · 87f5166
2 parents cffb1c2 + 507587f
commit 87f5166
Show file tree

Hide file tree

Showing 320 changed files with 18,732 additions and 7,104 deletions.
diff --git a/BUILD b/BUILD
@@ -160,6 +160,7 @@ cc_library(
     "src/core/channel/http_client_filter.h",
     "src/core/channel/http_server_filter.h",
     "src/core/channel/noop_filter.h",
+    "src/core/channel/subchannel_call_holder.h",
     "src/core/client_config/client_config.h",
     "src/core/client_config/connector.h",
     "src/core/client_config/lb_policies/pick_first.h",
@@ -226,7 +227,6 @@ cc_library(
     "src/core/statistics/census_interface.h",
     "src/core/statistics/census_rpc_stats.h",
     "src/core/surface/api_trace.h",
-    "src/core/surface/byte_buffer_queue.h",
     "src/core/surface/call.h",
     "src/core/surface/call_test_only.h",
     "src/core/surface/channel.h",
@@ -235,6 +235,7 @@ cc_library(
     "src/core/surface/init.h",
     "src/core/surface/server.h",
     "src/core/surface/surface_trace.h",
+    "src/core/transport/byte_stream.h",
     "src/core/transport/chttp2/alpn.h",
     "src/core/transport/chttp2/bin_encoder.h",
     "src/core/transport/chttp2/frame.h",
@@ -244,21 +245,21 @@ cc_library(
     "src/core/transport/chttp2/frame_rst_stream.h",
     "src/core/transport/chttp2/frame_settings.h",
     "src/core/transport/chttp2/frame_window_update.h",
+    "src/core/transport/chttp2/hpack_encoder.h",
     "src/core/transport/chttp2/hpack_parser.h",
     "src/core/transport/chttp2/hpack_table.h",
     "src/core/transport/chttp2/http2_errors.h",
     "src/core/transport/chttp2/huffsyms.h",
     "src/core/transport/chttp2/incoming_metadata.h",
     "src/core/transport/chttp2/internal.h",
     "src/core/transport/chttp2/status_conversion.h",
-    "src/core/transport/chttp2/stream_encoder.h",
     "src/core/transport/chttp2/stream_map.h",
     "src/core/transport/chttp2/timeout_encoding.h",
     "src/core/transport/chttp2/varint.h",
     "src/core/transport/chttp2_transport.h",
     "src/core/transport/connectivity_state.h",
     "src/core/transport/metadata.h",
-    "src/core/transport/stream_op.h",
+    "src/core/transport/metadata_batch.h",
     "src/core/transport/transport.h",
     "src/core/transport/transport_impl.h",
     "src/core/census/aggregation.h",
@@ -296,6 +297,7 @@ cc_library(
     "src/core/channel/http_client_filter.c",
     "src/core/channel/http_server_filter.c",
     "src/core/channel/noop_filter.c",
+    "src/core/channel/subchannel_call_holder.c",
     "src/core/client_config/client_config.c",
     "src/core/client_config/connector.c",
     "src/core/client_config/lb_policies/pick_first.c",
@@ -365,7 +367,6 @@ cc_library(
     "src/core/json/json_writer.c",
     "src/core/surface/api_trace.c",
     "src/core/surface/byte_buffer.c",
-    "src/core/surface/byte_buffer_queue.c",
     "src/core/surface/byte_buffer_reader.c",
     "src/core/surface/call.c",
     "src/core/surface/call_details.c",
@@ -382,6 +383,7 @@ cc_library(
     "src/core/surface/server_chttp2.c",
     "src/core/surface/server_create.c",
     "src/core/surface/version.c",
+    "src/core/transport/byte_stream.c",
     "src/core/transport/chttp2/alpn.c",
     "src/core/transport/chttp2/bin_encoder.c",
     "src/core/transport/chttp2/frame_data.c",
@@ -390,13 +392,13 @@ cc_library(
     "src/core/transport/chttp2/frame_rst_stream.c",
     "src/core/transport/chttp2/frame_settings.c",
     "src/core/transport/chttp2/frame_window_update.c",
+    "src/core/transport/chttp2/hpack_encoder.c",
     "src/core/transport/chttp2/hpack_parser.c",
     "src/core/transport/chttp2/hpack_table.c",
     "src/core/transport/chttp2/huffsyms.c",
     "src/core/transport/chttp2/incoming_metadata.c",
     "src/core/transport/chttp2/parsing.c",
     "src/core/transport/chttp2/status_conversion.c",
-    "src/core/transport/chttp2/stream_encoder.c",
     "src/core/transport/chttp2/stream_lists.c",
     "src/core/transport/chttp2/stream_map.c",
     "src/core/transport/chttp2/timeout_encoding.c",
@@ -405,7 +407,7 @@ cc_library(
     "src/core/transport/chttp2_transport.c",
     "src/core/transport/connectivity_state.c",
     "src/core/transport/metadata.c",
-    "src/core/transport/stream_op.c",
+    "src/core/transport/metadata_batch.c",
     "src/core/transport/transport.c",
     "src/core/transport/transport_op_string.c",
     "src/core/census/context.c",
@@ -448,6 +450,7 @@ cc_library(
     "src/core/channel/http_client_filter.h",
     "src/core/channel/http_server_filter.h",
     "src/core/channel/noop_filter.h",
+    "src/core/channel/subchannel_call_holder.h",
     "src/core/client_config/client_config.h",
     "src/core/client_config/connector.h",
     "src/core/client_config/lb_policies/pick_first.h",
@@ -514,7 +517,6 @@ cc_library(
     "src/core/statistics/census_interface.h",
     "src/core/statistics/census_rpc_stats.h",
     "src/core/surface/api_trace.h",
-    "src/core/surface/byte_buffer_queue.h",
     "src/core/surface/call.h",
     "src/core/surface/call_test_only.h",
     "src/core/surface/channel.h",
@@ -523,6 +525,7 @@ cc_library(
     "src/core/surface/init.h",
     "src/core/surface/server.h",
     "src/core/surface/surface_trace.h",
+    "src/core/transport/byte_stream.h",
     "src/core/transport/chttp2/alpn.h",
     "src/core/transport/chttp2/bin_encoder.h",
     "src/core/transport/chttp2/frame.h",
@@ -532,21 +535,21 @@ cc_library(
     "src/core/transport/chttp2/frame_rst_stream.h",
     "src/core/transport/chttp2/frame_settings.h",
     "src/core/transport/chttp2/frame_window_update.h",
+    "src/core/transport/chttp2/hpack_encoder.h",
     "src/core/transport/chttp2/hpack_parser.h",
     "src/core/transport/chttp2/hpack_table.h",
     "src/core/transport/chttp2/http2_errors.h",
     "src/core/transport/chttp2/huffsyms.h",
     "src/core/transport/chttp2/incoming_metadata.h",
     "src/core/transport/chttp2/internal.h",
     "src/core/transport/chttp2/status_conversion.h",
-    "src/core/transport/chttp2/stream_encoder.h",
     "src/core/transport/chttp2/stream_map.h",
     "src/core/transport/chttp2/timeout_encoding.h",
     "src/core/transport/chttp2/varint.h",
     "src/core/transport/chttp2_transport.h",
     "src/core/transport/connectivity_state.h",
     "src/core/transport/metadata.h",
-    "src/core/transport/stream_op.h",
+    "src/core/transport/metadata_batch.h",
     "src/core/transport/transport.h",
     "src/core/transport/transport_impl.h",
     "src/core/census/aggregation.h",
@@ -564,6 +567,7 @@ cc_library(
     "src/core/channel/http_client_filter.c",
     "src/core/channel/http_server_filter.c",
     "src/core/channel/noop_filter.c",
+    "src/core/channel/subchannel_call_holder.c",
     "src/core/client_config/client_config.c",
     "src/core/client_config/connector.c",
     "src/core/client_config/lb_policies/pick_first.c",
@@ -633,7 +637,6 @@ cc_library(
     "src/core/json/json_writer.c",
     "src/core/surface/api_trace.c",
     "src/core/surface/byte_buffer.c",
-    "src/core/surface/byte_buffer_queue.c",
     "src/core/surface/byte_buffer_reader.c",
     "src/core/surface/call.c",
     "src/core/surface/call_details.c",
@@ -650,6 +653,7 @@ cc_library(
     "src/core/surface/server_chttp2.c",
     "src/core/surface/server_create.c",
     "src/core/surface/version.c",
+    "src/core/transport/byte_stream.c",
     "src/core/transport/chttp2/alpn.c",
     "src/core/transport/chttp2/bin_encoder.c",
     "src/core/transport/chttp2/frame_data.c",
@@ -658,13 +662,13 @@ cc_library(
     "src/core/transport/chttp2/frame_rst_stream.c",
     "src/core/transport/chttp2/frame_settings.c",
     "src/core/transport/chttp2/frame_window_update.c",
+    "src/core/transport/chttp2/hpack_encoder.c",
     "src/core/transport/chttp2/hpack_parser.c",
     "src/core/transport/chttp2/hpack_table.c",
     "src/core/transport/chttp2/huffsyms.c",
     "src/core/transport/chttp2/incoming_metadata.c",
     "src/core/transport/chttp2/parsing.c",
     "src/core/transport/chttp2/status_conversion.c",
-    "src/core/transport/chttp2/stream_encoder.c",
     "src/core/transport/chttp2/stream_lists.c",
     "src/core/transport/chttp2/stream_map.c",
     "src/core/transport/chttp2/timeout_encoding.c",
@@ -673,7 +677,7 @@ cc_library(
     "src/core/transport/chttp2_transport.c",
     "src/core/transport/connectivity_state.c",
     "src/core/transport/metadata.c",
-    "src/core/transport/stream_op.c",
+    "src/core/transport/metadata_batch.c",
     "src/core/transport/transport.c",
     "src/core/transport/transport_op_string.c",
     "src/core/census/context.c",
@@ -1092,6 +1096,7 @@ objc_library(
     "src/core/channel/http_client_filter.c",
     "src/core/channel/http_server_filter.c",
     "src/core/channel/noop_filter.c",
+    "src/core/channel/subchannel_call_holder.c",
     "src/core/client_config/client_config.c",
     "src/core/client_config/connector.c",
     "src/core/client_config/lb_policies/pick_first.c",
@@ -1161,7 +1166,6 @@ objc_library(
     "src/core/json/json_writer.c",
     "src/core/surface/api_trace.c",
     "src/core/surface/byte_buffer.c",
-    "src/core/surface/byte_buffer_queue.c",
     "src/core/surface/byte_buffer_reader.c",
     "src/core/surface/call.c",
     "src/core/surface/call_details.c",
@@ -1178,6 +1182,7 @@ objc_library(
     "src/core/surface/server_chttp2.c",
     "src/core/surface/server_create.c",
     "src/core/surface/version.c",
+    "src/core/transport/byte_stream.c",
     "src/core/transport/chttp2/alpn.c",
     "src/core/transport/chttp2/bin_encoder.c",
     "src/core/transport/chttp2/frame_data.c",
@@ -1186,13 +1191,13 @@ objc_library(
     "src/core/transport/chttp2/frame_rst_stream.c",
     "src/core/transport/chttp2/frame_settings.c",
     "src/core/transport/chttp2/frame_window_update.c",
+    "src/core/transport/chttp2/hpack_encoder.c",
     "src/core/transport/chttp2/hpack_parser.c",
     "src/core/transport/chttp2/hpack_table.c",
     "src/core/transport/chttp2/huffsyms.c",
     "src/core/transport/chttp2/incoming_metadata.c",
     "src/core/transport/chttp2/parsing.c",
     "src/core/transport/chttp2/status_conversion.c",
-    "src/core/transport/chttp2/stream_encoder.c",
     "src/core/transport/chttp2/stream_lists.c",
     "src/core/transport/chttp2/stream_map.c",
     "src/core/transport/chttp2/timeout_encoding.c",
@@ -1201,7 +1206,7 @@ objc_library(
     "src/core/transport/chttp2_transport.c",
     "src/core/transport/connectivity_state.c",
     "src/core/transport/metadata.c",
-    "src/core/transport/stream_op.c",
+    "src/core/transport/metadata_batch.c",
     "src/core/transport/transport.c",
     "src/core/transport/transport_op_string.c",
     "src/core/census/context.c",
@@ -1241,6 +1246,7 @@ objc_library(
     "src/core/channel/http_client_filter.h",
     "src/core/channel/http_server_filter.h",
     "src/core/channel/noop_filter.h",
+    "src/core/channel/subchannel_call_holder.h",
     "src/core/client_config/client_config.h",
     "src/core/client_config/connector.h",
     "src/core/client_config/lb_policies/pick_first.h",
@@ -1307,7 +1313,6 @@ objc_library(
     "src/core/statistics/census_interface.h",
     "src/core/statistics/census_rpc_stats.h",
     "src/core/surface/api_trace.h",
-    "src/core/surface/byte_buffer_queue.h",
     "src/core/surface/call.h",
     "src/core/surface/call_test_only.h",
     "src/core/surface/channel.h",
@@ -1316,6 +1321,7 @@ objc_library(
     "src/core/surface/init.h",
     "src/core/surface/server.h",
     "src/core/surface/surface_trace.h",
+    "src/core/transport/byte_stream.h",
     "src/core/transport/chttp2/alpn.h",
     "src/core/transport/chttp2/bin_encoder.h",
     "src/core/transport/chttp2/frame.h",
@@ -1325,21 +1331,21 @@ objc_library(
     "src/core/transport/chttp2/frame_rst_stream.h",
     "src/core/transport/chttp2/frame_settings.h",
     "src/core/transport/chttp2/frame_window_update.h",
+    "src/core/transport/chttp2/hpack_encoder.h",
     "src/core/transport/chttp2/hpack_parser.h",
     "src/core/transport/chttp2/hpack_table.h",
     "src/core/transport/chttp2/http2_errors.h",
     "src/core/transport/chttp2/huffsyms.h",
     "src/core/transport/chttp2/incoming_metadata.h",
     "src/core/transport/chttp2/internal.h",
     "src/core/transport/chttp2/status_conversion.h",
-    "src/core/transport/chttp2/stream_encoder.h",
     "src/core/transport/chttp2/stream_map.h",
     "src/core/transport/chttp2/timeout_encoding.h",
     "src/core/transport/chttp2/varint.h",
     "src/core/transport/chttp2_transport.h",
     "src/core/transport/connectivity_state.h",
     "src/core/transport/metadata.h",
-    "src/core/transport/stream_op.h",
+    "src/core/transport/metadata_batch.h",
     "src/core/transport/transport.h",
     "src/core/transport/transport_impl.h",
     "src/core/census/aggregation.h",