Skip to content
Snippets Groups Projects
Select Git revision
  • 874f9c9d3be33c94f4161fe7949f72c211e733f0
  • master default protected
  • arm-aarch-platform
  • arm-platform
  • vjpai-patch-3
  • vjpai-patch-1
  • v1.27.x
  • jtattermusch-patch-2
  • jtattermusch-patch-1
  • update-java-worker-example-in-performance-docs
  • revert-21805-revert-21797-reintroduce_21527
  • revert-21804-tls-credentials-1
  • zhen_cleanup_namecheck
  • revert-21806-revert-21767-revert-21725-revert-21680-cq_ordering
  • vjpai-patch-2
  • revert-21766-tls-credentials-1
  • revert-21640-change_local_tcp_security_level
  • revert-21680-cq_ordering
  • revert-21527-unify_boringssl_deps2
  • revert-20803-grpclb_stabilization
  • fix-kokoro-rvm-key
  • v1.27.0
  • v1.27.0-pre2
  • v1.27.0-pre1
  • v1.26.0
  • v1.26.0-pre1
  • v1.25.0
  • v1.25.0-pre1
  • v1.24.3
  • v1.24.2
  • v1.24.1
  • v1.23.1
  • v1.24.0
  • v1.24.0-pre2
  • v1.24.0-pre1
  • v1.22.1
  • v1.23.0
  • v1.23.0-pre1
  • v1.22.0
  • v1.22.0-pre1
  • v1.21.4
41 results

InteropClientServerTest.cs

Blame
  • InteropClientServerTest.cs 3.42 KiB
    #region Copyright notice and license
    
    // 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.
    
    #endregion
    
    using System;
    using System.Collections.Generic;
    using System.Threading;
    using System.Threading.Tasks;
    using Grpc.Core;
    using Grpc.Core.Utils;
    using NUnit.Framework;
    using grpc.testing;
    
    namespace Grpc.IntegrationTesting
    {
        /// <summary>
        /// Runs interop tests in-process.
        /// </summary>
        public class InteropClientServerTest
        {
            string host = "localhost";
            Server server;
            Channel channel;
            TestServiceGrpc.ITestServiceClient client;
    
            [TestFixtureSetUp]
            public void Init()
            {
                GrpcEnvironment.Initialize();
    
                server = new Server();
                server.AddServiceDefinition(TestServiceGrpc.BindService(new TestServiceImpl()));
                int port = server.AddPort(host + ":0");
                server.Start();
                channel = new Channel(host + ":" + port);
                client = TestServiceGrpc.NewStub(channel);
            }
    
            [TestFixtureTearDown]
            public void Cleanup()
            {
                channel.Dispose();
    
                server.ShutdownAsync().Wait();
                GrpcEnvironment.Shutdown();
            }
    
            [Test]
            public void EmptyUnary()
            {
                Client.RunEmptyUnary(client);
            }
    
            [Test]
            public void LargeUnary()
            {
                Client.RunEmptyUnary(client);
            }
    
            [Test]
            public void ClientStreaming()
            {
                Client.RunClientStreaming(client);
            }
    
            [Test]
            public void ServerStreaming()
            {
                Client.RunServerStreaming(client);
            }
    
            [Test]
            public void PingPong()
            {
                Client.RunPingPong(client);
            }
    
            [Test]
            public void EmptyStream()
            {
                Client.RunEmptyStream(client);
            }
    
            // TODO: add cancel_after_begin
    
            // TODO: add cancel_after_first_response
    
        }
    }