Merge remote-tracking branch 'upstream/master' into service_config

pull/8303/head
Mark D. Roth 8 years ago
commit 499b012103
  1. 2
      src/core/ext/transport/cronet/transport/cronet_transport.c
  2. 8
      src/core/lib/iomgr/error.h
  3. 6
      src/cpp/common/channel_filter.h
  4. 1
      test/cpp/qps/client_async.cc
  5. 8
      tools/run_tests/dockerize/build_docker_and_run_tests.sh
  6. 2
      tools/run_tests/run_tests.py

@ -781,7 +781,7 @@ static enum e_op_result execute_stream_op(grpc_exec_ctx *exec_ctx,
&cronet_callbacks); &cronet_callbacks);
CRONET_LOG(GPR_DEBUG, "%p = cronet_bidirectional_stream_create()", s->cbs); CRONET_LOG(GPR_DEBUG, "%p = cronet_bidirectional_stream_create()", s->cbs);
char *url = NULL; char *url = NULL;
const char *method = NULL; const char *method = "POST";
s->header_array.headers = NULL; s->header_array.headers = NULL;
convert_metadata_to_cronet_headers( convert_metadata_to_cronet_headers(
stream_op->send_initial_metadata->list.head, s->curr_ct.host, &url, stream_op->send_initial_metadata->list.head, s->curr_ct.host, &url,

@ -40,6 +40,10 @@
#include <grpc/status.h> #include <grpc/status.h>
#include <grpc/support/time.h> #include <grpc/support/time.h>
#ifdef __cplusplus
extern "C" {
#endif
/// Opaque representation of an error. /// Opaque representation of an error.
/// Errors are refcounted objects that represent the result of an operation. /// Errors are refcounted objects that represent the result of an operation.
/// Ownership laws: /// Ownership laws:
@ -204,4 +208,8 @@ bool grpc_log_if_error(const char *what, grpc_error *error, const char *file,
#define GRPC_LOG_IF_ERROR(what, error) \ #define GRPC_LOG_IF_ERROR(what, error) \
grpc_log_if_error((what), (error), __FILE__, __LINE__) grpc_log_if_error((what), (error), __FILE__, __LINE__)
#ifdef __cplusplus
}
#endif
#endif /* GRPC_CORE_LIB_IOMGR_ERROR_H */ #endif /* GRPC_CORE_LIB_IOMGR_ERROR_H */

@ -42,6 +42,7 @@
#include <vector> #include <vector>
#include "src/core/lib/channel/channel_stack.h" #include "src/core/lib/channel/channel_stack.h"
#include "src/core/lib/security/context/security_context.h"
#include "src/core/lib/surface/channel_init.h" #include "src/core/lib/surface/channel_init.h"
#include "src/core/lib/transport/metadata_batch.h" #include "src/core/lib/transport/metadata_batch.h"
@ -54,11 +55,6 @@
/// "name-of-filter", GRPC_SERVER_CHANNEL, INT_MAX, nullptr); /// "name-of-filter", GRPC_SERVER_CHANNEL, INT_MAX, nullptr);
/// \endcode /// \endcode
/// Forward declaration to avoid including the file
/// "src/core/lib/security/context/security_context.h"
struct grpc_client_security_context;
struct grpc_server_security_context;
namespace grpc { namespace grpc {
/// A C++ wrapper for the \c grpc_metadata_batch struct. /// A C++ wrapper for the \c grpc_metadata_batch struct.

@ -243,6 +243,7 @@ class AsyncClient : public ClientImpl<StubType, RequestType> {
// this thread isn't supposed to shut down // this thread isn't supposed to shut down
std::lock_guard<std::mutex> l(shutdown_state_[thread_idx]->mutex); std::lock_guard<std::mutex> l(shutdown_state_[thread_idx]->mutex);
if (shutdown_state_[thread_idx]->shutdown) { if (shutdown_state_[thread_idx]->shutdown) {
delete ctx;
return true; return true;
} else if (!ctx->RunNextState(ok, entry)) { } else if (!ctx->RunNextState(ok, entry)) {
// The RPC and callback are done, so clone the ctx // The RPC and callback are done, so clone the ctx

@ -61,6 +61,7 @@ CONTAINER_NAME="run_tests_$(uuidgen)"
docker_instance_git_root=/var/local/jenkins/grpc docker_instance_git_root=/var/local/jenkins/grpc
# Run tests inside docker # Run tests inside docker
DOCKER_EXIT_CODE=0
docker run \ docker run \
-e "RUN_TESTS_COMMAND=$RUN_TESTS_COMMAND" \ -e "RUN_TESTS_COMMAND=$RUN_TESTS_COMMAND" \
-e "config=$config" \ -e "config=$config" \
@ -81,7 +82,7 @@ docker run \
-w /var/local/git/grpc \ -w /var/local/git/grpc \
--name=$CONTAINER_NAME \ --name=$CONTAINER_NAME \
$DOCKER_IMAGE_NAME \ $DOCKER_IMAGE_NAME \
bash -l "/var/local/jenkins/grpc/$DOCKER_RUN_SCRIPT" || DOCKER_FAILED="true" bash -l "/var/local/jenkins/grpc/$DOCKER_RUN_SCRIPT" || DOCKER_EXIT_CODE=$?
# use unique name for reports.zip to prevent clash between concurrent # use unique name for reports.zip to prevent clash between concurrent
# run_tests.py runs # run_tests.py runs
@ -93,7 +94,4 @@ rm -f ${TEMP_REPORTS_ZIP}
# remove the container, possibly killing it first # remove the container, possibly killing it first
docker rm -f $CONTAINER_NAME || true docker rm -f $CONTAINER_NAME || true
if [ "$DOCKER_FAILED" != "" ] && [ "$XML_REPORT" == "" ] exit $DOCKER_EXIT_CODE
then
exit 1
fi

@ -1423,7 +1423,7 @@ else:
exit_code = 0 exit_code = 0
if BuildAndRunError.BUILD in errors: if BuildAndRunError.BUILD in errors:
exit_code |= 1 exit_code |= 1
if BuildAndRunError.TEST in errors and not args.travis: if BuildAndRunError.TEST in errors:
exit_code |= 2 exit_code |= 2
if BuildAndRunError.POST_TEST in errors: if BuildAndRunError.POST_TEST in errors:
exit_code |= 4 exit_code |= 4

Loading…
Cancel
Save