mirror of https://github.com/grpc/grpc.git
Vijay Pai
9 years ago
commit
ddf694cc62
32 changed files with 10566 additions and 3284 deletions
@ -0,0 +1,35 @@ |
||||
#!/bin/bash |
||||
# Copyright 2015, Google Inc. |
||||
# All rights reserved. |
||||
# |
||||
# Redistribution and use in source and binary forms, with or without |
||||
# modification, are permitted provided that the following conditions are |
||||
# met: |
||||
# |
||||
# * Redistributions of source code must retain the above copyright |
||||
# notice, this list of conditions and the following disclaimer. |
||||
# * Redistributions in binary form must reproduce the above |
||||
# copyright notice, this list of conditions and the following disclaimer |
||||
# in the documentation and/or other materials provided with the |
||||
# distribution. |
||||
# * Neither the name of Google Inc. nor the names of its |
||||
# contributors may be used to endorse or promote products derived from |
||||
# this software without specific prior written permission. |
||||
# |
||||
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
set -e |
||||
cd $(dirname $0) |
||||
source ./determine_extension_dir.sh |
||||
php $extension_dir -d max_execution_time=300 \ |
||||
../tests/interop/stress_client.php $@ 1>&2 |
||||
@ -0,0 +1,104 @@ |
||||
# Copyright 2016, Google Inc. |
||||
# All rights reserved. |
||||
# |
||||
# Redistribution and use in source and binary forms, with or without |
||||
# modification, are permitted provided that the following conditions are |
||||
# met: |
||||
# |
||||
# * Redistributions of source code must retain the above copyright |
||||
# notice, this list of conditions and the following disclaimer. |
||||
# * Redistributions in binary form must reproduce the above |
||||
# copyright notice, this list of conditions and the following disclaimer |
||||
# in the documentation and/or other materials provided with the |
||||
# distribution. |
||||
# * Neither the name of Google Inc. nor the names of its |
||||
# contributors may be used to endorse or promote products derived from |
||||
# this software without specific prior written permission. |
||||
# |
||||
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
"""Test of gRPC Python's application-layer API.""" |
||||
|
||||
import unittest |
||||
|
||||
import six |
||||
|
||||
import grpc |
||||
|
||||
from tests.unit import _from_grpc_import_star |
||||
|
||||
|
||||
class AllTest(unittest.TestCase): |
||||
|
||||
def testAll(self): |
||||
expected_grpc_code_elements = ( |
||||
'FutureTimeoutError', |
||||
'FutureCancelledError', |
||||
'Future', |
||||
'ChannelConnectivity', |
||||
'StatusCode', |
||||
'RpcError', |
||||
'RpcContext', |
||||
'Call', |
||||
'ChannelCredentials', |
||||
'CallCredentials', |
||||
'AuthMetadataContext', |
||||
'AuthMetadataPluginCallback', |
||||
'AuthMetadataPlugin', |
||||
'ServerCredentials', |
||||
'UnaryUnaryMultiCallable', |
||||
'UnaryStreamMultiCallable', |
||||
'StreamUnaryMultiCallable', |
||||
'StreamStreamMultiCallable', |
||||
'Channel', |
||||
'ServicerContext', |
||||
'RpcMethodHandler', |
||||
'HandlerCallDetails', |
||||
'GenericRpcHandler', |
||||
'Server', |
||||
'unary_unary_rpc_method_handler', |
||||
'unary_stream_rpc_method_handler', |
||||
'stream_unary_rpc_method_handler', |
||||
'stream_stream_rpc_method_handler', |
||||
'method_handlers_generic_handler', |
||||
'ssl_channel_credentials', |
||||
'metadata_call_credentials', |
||||
'access_token_call_credentials', |
||||
'composite_call_credentials', |
||||
'composite_channel_credentials', |
||||
'ssl_server_credentials', |
||||
'channel_ready_future', |
||||
'insecure_channel', |
||||
'secure_channel', |
||||
'server', |
||||
) |
||||
|
||||
six.assertCountEqual( |
||||
self, expected_grpc_code_elements, |
||||
_from_grpc_import_star.GRPC_ELEMENTS) |
||||
|
||||
|
||||
class ChannelConnectivityTest(unittest.TestCase): |
||||
|
||||
def testChannelConnectivity(self): |
||||
self.assertSequenceEqual( |
||||
(grpc.ChannelConnectivity.IDLE, |
||||
grpc.ChannelConnectivity.CONNECTING, |
||||
grpc.ChannelConnectivity.READY, |
||||
grpc.ChannelConnectivity.TRANSIENT_FAILURE, |
||||
grpc.ChannelConnectivity.SHUTDOWN,), |
||||
tuple(grpc.ChannelConnectivity)) |
||||
|
||||
|
||||
if __name__ == '__main__': |
||||
unittest.main(verbosity=2) |
||||
@ -0,0 +1,38 @@ |
||||
# Copyright 2016, Google Inc. |
||||
# All rights reserved. |
||||
# |
||||
# Redistribution and use in source and binary forms, with or without |
||||
# modification, are permitted provided that the following conditions are |
||||
# met: |
||||
# |
||||
# * Redistributions of source code must retain the above copyright |
||||
# notice, this list of conditions and the following disclaimer. |
||||
# * Redistributions in binary form must reproduce the above |
||||
# copyright notice, this list of conditions and the following disclaimer |
||||
# in the documentation and/or other materials provided with the |
||||
# distribution. |
||||
# * Neither the name of Google Inc. nor the names of its |
||||
# contributors may be used to endorse or promote products derived from |
||||
# this software without specific prior written permission. |
||||
# |
||||
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
_BEFORE_IMPORT = tuple(globals()) |
||||
|
||||
from grpc import * |
||||
|
||||
_AFTER_IMPORT = tuple(globals()) |
||||
|
||||
GRPC_ELEMENTS = tuple( |
||||
element for element in _AFTER_IMPORT |
||||
if element not in _BEFORE_IMPORT and element != '_BEFORE_IMPORT') |
||||
@ -0,0 +1,216 @@ |
||||
# Copyright 2016, Google Inc. |
||||
# All rights reserved. |
||||
# |
||||
# Redistribution and use in source and binary forms, with or without |
||||
# modification, are permitted provided that the following conditions are |
||||
# met: |
||||
# |
||||
# * Redistributions of source code must retain the above copyright |
||||
# notice, this list of conditions and the following disclaimer. |
||||
# * Redistributions in binary form must reproduce the above |
||||
# copyright notice, this list of conditions and the following disclaimer |
||||
# in the documentation and/or other materials provided with the |
||||
# distribution. |
||||
# * Neither the name of Google Inc. nor the names of its |
||||
# contributors may be used to endorse or promote products derived from |
||||
# this software without specific prior written permission. |
||||
# |
||||
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
"""Tests server and client side metadata API.""" |
||||
|
||||
import unittest |
||||
import weakref |
||||
|
||||
import grpc |
||||
from grpc import _grpcio_metadata |
||||
from grpc.framework.foundation import logging_pool |
||||
|
||||
from tests.unit import test_common |
||||
from tests.unit.framework.common import test_constants |
||||
|
||||
_CHANNEL_ARGS = (('grpc.primary_user_agent', 'primary-agent'), |
||||
('grpc.secondary_user_agent', 'secondary-agent')) |
||||
|
||||
_REQUEST = b'\x00\x00\x00' |
||||
_RESPONSE = b'\x00\x00\x00' |
||||
|
||||
_UNARY_UNARY = b'/test/UnaryUnary' |
||||
_UNARY_STREAM = b'/test/UnaryStream' |
||||
_STREAM_UNARY = b'/test/StreamUnary' |
||||
_STREAM_STREAM = b'/test/StreamStream' |
||||
|
||||
_USER_AGENT = 'Python-gRPC-{}'.format(_grpcio_metadata.__version__) |
||||
|
||||
_CLIENT_METADATA = ( |
||||
(b'client-md-key', b'client-md-key'), |
||||
(b'client-md-key-bin', b'\x00\x01') |
||||
) |
||||
|
||||
_SERVER_INITIAL_METADATA = ( |
||||
(b'server-initial-md-key', b'server-initial-md-value'), |
||||
(b'server-initial-md-key-bin', b'\x00\x02') |
||||
) |
||||
|
||||
_SERVER_TRAILING_METADATA = ( |
||||
(b'server-trailing-md-key', b'server-trailing-md-value'), |
||||
(b'server-trailing-md-key-bin', b'\x00\x03') |
||||
) |
||||
|
||||
|
||||
def user_agent(metadata): |
||||
for key, val in metadata: |
||||
if key == b'user-agent': |
||||
return val.decode('ascii') |
||||
raise KeyError('No user agent!') |
||||
|
||||
|
||||
def validate_client_metadata(test, servicer_context): |
||||
test.assertTrue(test_common.metadata_transmitted( |
||||
_CLIENT_METADATA, servicer_context.invocation_metadata())) |
||||
test.assertTrue(user_agent(servicer_context.invocation_metadata()) |
||||
.startswith('primary-agent ' + _USER_AGENT)) |
||||
test.assertTrue(user_agent(servicer_context.invocation_metadata()) |
||||
.endswith('secondary-agent')) |
||||
|
||||
|
||||
def handle_unary_unary(test, request, servicer_context): |
||||
validate_client_metadata(test, servicer_context) |
||||
servicer_context.send_initial_metadata(_SERVER_INITIAL_METADATA) |
||||
servicer_context.set_trailing_metadata(_SERVER_TRAILING_METADATA) |
||||
return _RESPONSE |
||||
|
||||
|
||||
def handle_unary_stream(test, request, servicer_context): |
||||
validate_client_metadata(test, servicer_context) |
||||
servicer_context.send_initial_metadata(_SERVER_INITIAL_METADATA) |
||||
servicer_context.set_trailing_metadata(_SERVER_TRAILING_METADATA) |
||||
for _ in range(test_constants.STREAM_LENGTH): |
||||
yield _RESPONSE |
||||
|
||||
|
||||
def handle_stream_unary(test, request_iterator, servicer_context): |
||||
validate_client_metadata(test, servicer_context) |
||||
servicer_context.send_initial_metadata(_SERVER_INITIAL_METADATA) |
||||
servicer_context.set_trailing_metadata(_SERVER_TRAILING_METADATA) |
||||
# TODO(issue:#6891) We should be able to remove this loop |
||||
for request in request_iterator: |
||||
pass |
||||
return _RESPONSE |
||||
|
||||
|
||||
def handle_stream_stream(test, request_iterator, servicer_context): |
||||
validate_client_metadata(test, servicer_context) |
||||
servicer_context.send_initial_metadata(_SERVER_INITIAL_METADATA) |
||||
servicer_context.set_trailing_metadata(_SERVER_TRAILING_METADATA) |
||||
# TODO(issue:#6891) We should be able to remove this loop, |
||||
# and replace with return; yield |
||||
for request in request_iterator: |
||||
yield _RESPONSE |
||||
|
||||
|
||||
class _MethodHandler(grpc.RpcMethodHandler): |
||||
|
||||
def __init__(self, test, request_streaming, response_streaming): |
||||
self.request_streaming = request_streaming |
||||
self.response_streaming = response_streaming |
||||
self.request_deserializer = None |
||||
self.response_serializer = None |
||||
self.unary_unary = None |
||||
self.unary_stream = None |
||||
self.stream_unary = None |
||||
self.stream_stream = None |
||||
if self.request_streaming and self.response_streaming: |
||||
self.stream_stream = lambda x, y: handle_stream_stream(test, x, y) |
||||
elif self.request_streaming: |
||||
self.stream_unary = lambda x, y: handle_stream_unary(test, x, y) |
||||
elif self.response_streaming: |
||||
self.unary_stream = lambda x, y: handle_unary_stream(test, x, y) |
||||
else: |
||||
self.unary_unary = lambda x, y: handle_unary_unary(test, x, y) |
||||
|
||||
|
||||
class _GenericHandler(grpc.GenericRpcHandler): |
||||
|
||||
def __init__(self, test): |
||||
self._test = test |
||||
|
||||
def service(self, handler_call_details): |
||||
if handler_call_details.method == _UNARY_UNARY: |
||||
return _MethodHandler(self._test, False, False) |
||||
elif handler_call_details.method == _UNARY_STREAM: |
||||
return _MethodHandler(self._test, False, True) |
||||
elif handler_call_details.method == _STREAM_UNARY: |
||||
return _MethodHandler(self._test, True, False) |
||||
elif handler_call_details.method == _STREAM_STREAM: |
||||
return _MethodHandler(self._test, True, True) |
||||
else: |
||||
return None |
||||
|
||||
|
||||
class MetadataTest(unittest.TestCase): |
||||
|
||||
def setUp(self): |
||||
self._server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY) |
||||
self._server = grpc.server((_GenericHandler(weakref.proxy(self)),), |
||||
self._server_pool) |
||||
port = self._server.add_insecure_port('[::]:0') |
||||
self._server.start() |
||||
self._channel = grpc.insecure_channel('localhost:%d' % port, |
||||
options=_CHANNEL_ARGS) |
||||
|
||||
def tearDown(self): |
||||
self._server.stop(0) |
||||
|
||||
def testUnaryUnary(self): |
||||
multi_callable = self._channel.unary_unary(_UNARY_UNARY) |
||||
unused_response, call = multi_callable( |
||||
_REQUEST, metadata=_CLIENT_METADATA, with_call=True) |
||||
self.assertTrue(test_common.metadata_transmitted( |
||||
_SERVER_INITIAL_METADATA, call.initial_metadata())) |
||||
self.assertTrue(test_common.metadata_transmitted( |
||||
_SERVER_TRAILING_METADATA, call.trailing_metadata())) |
||||
|
||||
def testUnaryStream(self): |
||||
multi_callable = self._channel.unary_stream(_UNARY_STREAM) |
||||
call = multi_callable(_REQUEST, metadata=_CLIENT_METADATA) |
||||
self.assertTrue(test_common.metadata_transmitted( |
||||
_SERVER_INITIAL_METADATA, call.initial_metadata())) |
||||
for _ in call: |
||||
pass |
||||
self.assertTrue(test_common.metadata_transmitted( |
||||
_SERVER_TRAILING_METADATA, call.trailing_metadata())) |
||||
|
||||
def testStreamUnary(self): |
||||
multi_callable = self._channel.stream_unary(_STREAM_UNARY) |
||||
unused_response, call = multi_callable( |
||||
[_REQUEST] * test_constants.STREAM_LENGTH, |
||||
metadata=_CLIENT_METADATA, with_call=True) |
||||
self.assertTrue(test_common.metadata_transmitted( |
||||
_SERVER_INITIAL_METADATA, call.initial_metadata())) |
||||
self.assertTrue(test_common.metadata_transmitted( |
||||
_SERVER_TRAILING_METADATA, call.trailing_metadata())) |
||||
|
||||
def testStreamStream(self): |
||||
multi_callable = self._channel.stream_stream(_STREAM_STREAM) |
||||
call = multi_callable([_REQUEST] * test_constants.STREAM_LENGTH, |
||||
metadata=_CLIENT_METADATA) |
||||
self.assertTrue(test_common.metadata_transmitted( |
||||
_SERVER_INITIAL_METADATA, call.initial_metadata())) |
||||
for _ in call: |
||||
pass |
||||
self.assertTrue(test_common.metadata_transmitted( |
||||
_SERVER_TRAILING_METADATA, call.trailing_metadata())) |
||||
|
||||
|
||||
if __name__ == '__main__': |
||||
unittest.main(verbosity=2) |
||||
@ -1,7 +1,2 @@ |
||||
<%include file="ccache_setup.include"/> |
||||
#====================== |
||||
# Zookeeper dependencies |
||||
# TODO(jtattermusch): is zookeeper still needed? |
||||
RUN apt-get install -y libzookeeper-mt-dev |
||||
|
||||
RUN mkdir /var/local/jenkins |
||||
<%include file="run_tests_addons_nocache.include"/> |
||||
@ -0,0 +1,6 @@ |
||||
#====================== |
||||
# Zookeeper dependencies |
||||
# TODO(jtattermusch): is zookeeper still needed? |
||||
RUN apt-get install -y libzookeeper-mt-dev |
||||
|
||||
RUN mkdir /var/local/jenkins |
||||
@ -0,0 +1,65 @@ |
||||
%YAML 1.2 |
||||
--- | |
||||
# Copyright 2015, Google Inc. |
||||
# All rights reserved. |
||||
# |
||||
# Redistribution and use in source and binary forms, with or without |
||||
# modification, are permitted provided that the following conditions are |
||||
# met: |
||||
# |
||||
# * Redistributions of source code must retain the above copyright |
||||
# notice, this list of conditions and the following disclaimer. |
||||
# * Redistributions in binary form must reproduce the above |
||||
# copyright notice, this list of conditions and the following disclaimer |
||||
# in the documentation and/or other materials provided with the |
||||
# distribution. |
||||
# * Neither the name of Google Inc. nor the names of its |
||||
# contributors may be used to endorse or promote products derived from |
||||
# this software without specific prior written permission. |
||||
# |
||||
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
FROM debian:jessie |
||||
|
||||
<%include file="../../apt_get_basic.include"/> |
||||
<%include file="../../ruby_deps.include"/> |
||||
<%include file="../../gcp_api_libraries.include"/> |
||||
<%include file="../../php_deps.include"/> |
||||
<%include file="../../run_tests_addons.include"/> |
||||
# ronn: a ruby tool used to convert markdown to man pages, used during the |
||||
# install of Protobuf extensions |
||||
# |
||||
# rake: a ruby version of make used to build the PHP Protobuf extension |
||||
RUN /bin/bash -l -c "rvm all do gem install ronn rake" |
||||
|
||||
# Install composer |
||||
RUN curl -sS https://getcomposer.org/installer | php |
||||
RUN mv composer.phar /usr/local/bin/composer |
||||
|
||||
# As an attempt to work around #4212, try to prefetch Protobuf-PHP dependency |
||||
# into composer cache to prevent "composer install" from cloning on each build. |
||||
RUN git clone --mirror https://github.com/stanley-cheung/Protobuf-PHP.git ${'\\'} |
||||
/root/.composer/cache/vcs/git-github.com-stanley-cheung-Protobuf-PHP.git/ |
||||
|
||||
# Download the patched PHP protobuf so that PHP gRPC clients can be generated |
||||
# from proto3 schemas. |
||||
RUN git clone https://github.com/stanley-cheung/Protobuf-PHP.git /var/local/git/protobuf-php |
||||
|
||||
RUN /bin/bash -l -c "rvm use ruby-2.1 ${'\\'} |
||||
&& cd /var/local/git/protobuf-php ${'\\'} |
||||
&& rvm all do rake pear:package version=1.0 ${'\\'} |
||||
&& pear install Protobuf-1.0.tgz" |
||||
|
||||
# Define the default command. |
||||
CMD ["bash"] |
||||
|
||||
@ -1 +1 @@ |
||||
Subproject commit 3470b6895aa659b7559ed678e029a5338e535f14 |
||||
Subproject commit d4d13a4349e4e59d67f311185ddcc1890d956d7a |
||||
@ -0,0 +1,140 @@ |
||||
# Copyright 2015, Google Inc. |
||||
# All rights reserved. |
||||
# |
||||
# Redistribution and use in source and binary forms, with or without |
||||
# modification, are permitted provided that the following conditions are |
||||
# met: |
||||
# |
||||
# * Redistributions of source code must retain the above copyright |
||||
# notice, this list of conditions and the following disclaimer. |
||||
# * Redistributions in binary form must reproduce the above |
||||
# copyright notice, this list of conditions and the following disclaimer |
||||
# in the documentation and/or other materials provided with the |
||||
# distribution. |
||||
# * Neither the name of Google Inc. nor the names of its |
||||
# contributors may be used to endorse or promote products derived from |
||||
# this software without specific prior written permission. |
||||
# |
||||
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
|
||||
FROM debian:jessie |
||||
|
||||
# Install Git and basic packages. |
||||
RUN apt-get update && apt-get install -y \ |
||||
autoconf \ |
||||
autotools-dev \ |
||||
build-essential \ |
||||
bzip2 \ |
||||
ccache \ |
||||
curl \ |
||||
gcc \ |
||||
gcc-multilib \ |
||||
git \ |
||||
golang \ |
||||
gyp \ |
||||
lcov \ |
||||
libc6 \ |
||||
libc6-dbg \ |
||||
libc6-dev \ |
||||
libgtest-dev \ |
||||
libtool \ |
||||
make \ |
||||
perl \ |
||||
strace \ |
||||
python-dev \ |
||||
python-setuptools \ |
||||
python-yaml \ |
||||
telnet \ |
||||
unzip \ |
||||
wget \ |
||||
zip && apt-get clean |
||||
|
||||
#================ |
||||
# Build profiling |
||||
RUN apt-get update && apt-get install -y time && apt-get clean |
||||
|
||||
#================== |
||||
# Ruby dependencies |
||||
|
||||
# Install rvm |
||||
RUN gpg --keyserver hkp://keys.gnupg.net --recv-keys 409B6B1796C275462A1703113804BB82D39DC0E3 |
||||
RUN \curl -sSL https://get.rvm.io | bash -s stable |
||||
|
||||
# Install Ruby 2.1 |
||||
RUN /bin/bash -l -c "rvm install ruby-2.1" |
||||
RUN /bin/bash -l -c "rvm use --default ruby-2.1" |
||||
RUN /bin/bash -l -c "echo 'gem: --no-ri --no-rdoc' > ~/.gemrc" |
||||
RUN /bin/bash -l -c "echo 'export PATH=/usr/local/rvm/bin:$PATH' >> ~/.bashrc" |
||||
RUN /bin/bash -l -c "echo 'rvm --default use ruby-2.1' >> ~/.bashrc" |
||||
RUN /bin/bash -l -c "gem install bundler --no-ri --no-rdoc" |
||||
|
||||
# Google Cloud platform API libraries |
||||
RUN apt-get update && apt-get install -y python-pip && apt-get clean |
||||
RUN pip install --upgrade google-api-python-client |
||||
|
||||
|
||||
#================= |
||||
# PHP dependencies |
||||
|
||||
# Install dependencies |
||||
|
||||
RUN /bin/bash -l -c "echo 'deb http://packages.dotdeb.org wheezy-php55 all' \ |
||||
>> /etc/apt/sources.list.d/dotdeb.list" |
||||
RUN /bin/bash -l -c "echo 'deb-src http://packages.dotdeb.org wheezy-php55 all' \ |
||||
>> /etc/apt/sources.list.d/dotdeb.list" |
||||
RUN wget http://www.dotdeb.org/dotdeb.gpg -O- | apt-key add - |
||||
|
||||
RUN apt-get update && apt-get install -y \ |
||||
git php5 php5-dev phpunit unzip |
||||
|
||||
# Prepare ccache |
||||
RUN ln -s /usr/bin/ccache /usr/local/bin/gcc |
||||
RUN ln -s /usr/bin/ccache /usr/local/bin/g++ |
||||
RUN ln -s /usr/bin/ccache /usr/local/bin/cc |
||||
RUN ln -s /usr/bin/ccache /usr/local/bin/c++ |
||||
RUN ln -s /usr/bin/ccache /usr/local/bin/clang |
||||
RUN ln -s /usr/bin/ccache /usr/local/bin/clang++ |
||||
|
||||
#====================== |
||||
# Zookeeper dependencies |
||||
# TODO(jtattermusch): is zookeeper still needed? |
||||
RUN apt-get install -y libzookeeper-mt-dev |
||||
|
||||
RUN mkdir /var/local/jenkins |
||||
|
||||
# ronn: a ruby tool used to convert markdown to man pages, used during the |
||||
# install of Protobuf extensions |
||||
# |
||||
# rake: a ruby version of make used to build the PHP Protobuf extension |
||||
RUN /bin/bash -l -c "rvm all do gem install ronn rake" |
||||
|
||||
# Install composer |
||||
RUN curl -sS https://getcomposer.org/installer | php |
||||
RUN mv composer.phar /usr/local/bin/composer |
||||
|
||||
# As an attempt to work around #4212, try to prefetch Protobuf-PHP dependency |
||||
# into composer cache to prevent "composer install" from cloning on each build. |
||||
RUN git clone --mirror https://github.com/stanley-cheung/Protobuf-PHP.git \ |
||||
/root/.composer/cache/vcs/git-github.com-stanley-cheung-Protobuf-PHP.git/ |
||||
|
||||
# Download the patched PHP protobuf so that PHP gRPC clients can be generated |
||||
# from proto3 schemas. |
||||
RUN git clone https://github.com/stanley-cheung/Protobuf-PHP.git /var/local/git/protobuf-php |
||||
|
||||
RUN /bin/bash -l -c "rvm use ruby-2.1 \ |
||||
&& cd /var/local/git/protobuf-php \ |
||||
&& rvm all do rake pear:package version=1.0 \ |
||||
&& pear install Protobuf-1.0.tgz" |
||||
|
||||
# Define the default command. |
||||
CMD ["bash"] |
||||
@ -0,0 +1,54 @@ |
||||
#!/bin/bash |
||||
# Copyright 2015, Google Inc. |
||||
# All rights reserved. |
||||
# |
||||
# Redistribution and use in source and binary forms, with or without |
||||
# modification, are permitted provided that the following conditions are |
||||
# met: |
||||
# |
||||
# * Redistributions of source code must retain the above copyright |
||||
# notice, this list of conditions and the following disclaimer. |
||||
# * Redistributions in binary form must reproduce the above |
||||
# copyright notice, this list of conditions and the following disclaimer |
||||
# in the documentation and/or other materials provided with the |
||||
# distribution. |
||||
# * Neither the name of Google Inc. nor the names of its |
||||
# contributors may be used to endorse or promote products derived from |
||||
# this software without specific prior written permission. |
||||
# |
||||
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
# |
||||
# Builds PHP interop server and client in a base image. |
||||
set -ex |
||||
|
||||
mkdir -p /var/local/git |
||||
git clone --recursive /var/local/jenkins/grpc /var/local/git/grpc |
||||
|
||||
# copy service account keys if available |
||||
cp -r /var/local/jenkins/service_account $HOME || true |
||||
|
||||
cd /var/local/git/grpc |
||||
rvm --default use ruby-2.1 |
||||
|
||||
make install-certs |
||||
|
||||
# gRPC core and protobuf need to be installed |
||||
make install |
||||
|
||||
(cd src/php/ext/grpc && phpize && ./configure && make) |
||||
|
||||
(cd third_party/protobuf && make install) |
||||
|
||||
(cd src/php && composer install) |
||||
|
||||
(cd src/php && protoc-gen-php -i tests/interop/ -o tests/interop/ tests/interop/test.proto) |
||||
@ -0,0 +1,93 @@ |
||||
{ |
||||
"dockerImages": { |
||||
"grpc_stress_cxx_opt" : { |
||||
"buildScript": "tools/run_tests/dockerize/build_interop_stress_image.sh", |
||||
"dockerFileDir": "grpc_interop_stress_cxx", |
||||
"buildType": "opt" |
||||
}, |
||||
"grpc_stress_php": { |
||||
"buildScript": "tools/run_tests/dockerize/build_interop_stress_image.sh", |
||||
"dockerFileDir": "grpc_interop_stress_php" |
||||
} |
||||
}, |
||||
|
||||
"clientTemplates": { |
||||
"baseTemplates": { |
||||
"default": { |
||||
"wrapperScriptPath": "/var/local/git/grpc/tools/gcp/stress_test/run_client.py", |
||||
"pollIntervalSecs": 60, |
||||
"clientArgs": { |
||||
"num_channels_per_server":5, |
||||
"num_stubs_per_channel":10, |
||||
"test_cases": "empty_unary:1,large_unary:1,client_streaming:1,server_streaming:1,empty_stream:1", |
||||
"metrics_port": 8081 |
||||
}, |
||||
"metricsPort": 8081, |
||||
"metricsArgs": { |
||||
"metrics_server_address": "localhost:8081" |
||||
} |
||||
} |
||||
}, |
||||
"templates": { |
||||
"php_client": { |
||||
"baseTemplate": "default", |
||||
"stressClientCmd": [ |
||||
"/var/local/git/grpc/src/php/bin/stress_client.sh" |
||||
], |
||||
"metricsClientCmd": [ |
||||
"php", |
||||
"/var/local/git/grpc/src/php/tests/interop/metrics_client.php" |
||||
] |
||||
} |
||||
} |
||||
}, |
||||
|
||||
"serverTemplates": { |
||||
"baseTemplates":{ |
||||
"default": { |
||||
"wrapperScriptPath": "/var/local/git/grpc/tools/gcp/stress_test/run_server.py", |
||||
"serverPort": 8080, |
||||
"serverArgs": { |
||||
"port": 8080 |
||||
} |
||||
} |
||||
}, |
||||
"templates": { |
||||
"cxx_server_opt": { |
||||
"baseTemplate": "default", |
||||
"stressServerCmd": ["/var/local/git/grpc/bins/opt/interop_server"] |
||||
} |
||||
} |
||||
}, |
||||
|
||||
"testMatrix": { |
||||
"serverPodSpecs": { |
||||
"stress-server-cxx-php": { |
||||
"serverTemplate": "cxx_server_opt", |
||||
"dockerImage": "grpc_stress_cxx_opt", |
||||
"numInstances": 1 |
||||
} |
||||
}, |
||||
|
||||
"clientPodSpecs": { |
||||
"stress-client-php": { |
||||
"clientTemplate": "php_client", |
||||
"dockerImage": "grpc_stress_php", |
||||
"numInstances": 20, |
||||
"serverPodSpec": "stress-server-cxx-php" |
||||
} |
||||
} |
||||
}, |
||||
|
||||
"globalSettings": { |
||||
"buildDockerImages": true, |
||||
"pollIntervalSecs": 60, |
||||
"testDurationSecs": 7200, |
||||
"kubernetesProxyPort": 8010, |
||||
"datasetIdNamePrefix": "stress_test_php_cxx_opt", |
||||
"summaryTableId": "summary", |
||||
"qpsTableId": "qps", |
||||
"podWarmupSecs": 60 |
||||
} |
||||
} |
||||
|
||||
File diff suppressed because it is too large
Load Diff
Loading…
Reference in new issue