Skip to content
Snippets Groups Projects
Select Git revision
  • ffae01769418fc96cdc29afa33dbb11fa2eec254
  • 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

setup.py

Blame
  • greeter_async_client.cc 3.27 KiB
    /*
     *
     * 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.
     *
     */
    
    #include <iostream>
    #include <memory>
    #include <string>
    
    #include <grpc/grpc.h>
    #include <grpc/support/log.h>
    #include <grpc++/async_unary_call.h>
    #include <grpc++/channel_arguments.h>
    #include <grpc++/channel_interface.h>
    #include <grpc++/client_context.h>
    #include <grpc++/completion_queue.h>
    #include <grpc++/create_channel.h>
    #include <grpc++/credentials.h>
    #include <grpc++/status.h>
    #include "helloworld.grpc.pb.h"
    
    using grpc::ChannelArguments;
    using grpc::ChannelInterface;
    using grpc::ClientAsyncResponseReader;
    using grpc::ClientContext;
    using grpc::CompletionQueue;
    using grpc::Status;
    using helloworld::HelloRequest;
    using helloworld::HelloReply;
    using helloworld::Greeter;
    
    class GreeterClient {
     public:
      explicit GreeterClient(std::shared_ptr<ChannelInterface> channel)
          : stub_(Greeter::NewStub(channel)) {}
    
      std::string SayHello(const std::string& user) {
        HelloRequest request;
        request.set_name(user);
        HelloReply reply;
        ClientContext context;
        CompletionQueue cq;
        Status status;
    
        std::unique_ptr<ClientAsyncResponseReader<HelloReply> > rpc(
            stub_->AsyncSayHello(&context, request, &cq));
        rpc->Finish(&reply, &status, (void*)1);
        void* got_tag;
        bool ok = false;
        cq.Next(&got_tag, &ok);
        GPR_ASSERT(ok);
        GPR_ASSERT(got_tag == (void*)1);
    
        if (status.ok()) {
          return reply.message();
        } else {
          return "Rpc failed";
        }
      }
    
     private:
      std::unique_ptr<Greeter::Stub> stub_;
    };
    
    int main(int argc, char** argv) {
      GreeterClient greeter(grpc::CreateChannel(
          "localhost:50051", grpc::InsecureCredentials(), ChannelArguments()));
      std::string user("world");
      std::string reply = greeter.SayHello(user);
      std::cout << "Greeter received: " << reply << std::endl;
    
      return 0;
    }