From 8c1109737f835f23056325e366aced23fa24db37 Mon Sep 17 00:00:00 2001
From: Chen Wang <chenw@google.com>
Date: Thu, 22 Jan 2015 14:11:42 -0800
Subject: [PATCH] Remove unecessary files which was added by mistake.
---
examples/tips/messages.proto | 94 --------------
examples/tips/server.cc | 231 -----------------------------------
examples/tips/test.proto | 42 -------
3 files changed, 367 deletions(-)
delete mode 100644 examples/tips/messages.proto
delete mode 100644 examples/tips/server.cc
delete mode 100644 examples/tips/test.proto
diff --git a/examples/tips/messages.proto b/examples/tips/messages.proto
deleted file mode 100644
index 29db0dd8b1..0000000000
--- a/examples/tips/messages.proto
+++ /dev/null
@@ -1,94 +0,0 @@
-// Message definitions to be used by integration test service definitions.
-
-syntax = "proto2";
-
-package grpc.testing;
-
-// The type of payload that should be returned.
-enum PayloadType {
- // Compressable text format.
- COMPRESSABLE = 0;
-
- // Uncompressable binary format.
- UNCOMPRESSABLE = 1;
-
- // Randomly chosen from all other formats defined in this enum.
- RANDOM = 2;
-}
-
-// A block of data, to simply increase gRPC message size.
-message Payload {
- // The type of data in body.
- optional PayloadType type = 1;
- // Primary contents of payload.
- optional bytes body = 2;
-}
-
-// Unary request.
-message SimpleRequest {
- // Desired payload type in the response from the server.
- // If response_type is RANDOM, server randomly chooses one from other formats.
- optional PayloadType response_type = 1;
-
- // Desired payload size in the response from the server.
- // If response_type is COMPRESSABLE, this denotes the size before compression.
- optional int32 response_size = 2;
-
- // Optional input payload sent along with the request.
- optional Payload payload = 3;
-}
-
-// Unary response, as configured by the request.
-message SimpleResponse {
- // Payload to increase message size.
- optional Payload payload = 1;
- // The user the request came from, for verifying authentication was
- // successful when the client expected it.
- optional int64 effective_gaia_user_id = 2;
-}
-
-// Client-streaming request.
-message StreamingInputCallRequest {
- // Optional input payload sent along with the request.
- optional Payload payload = 1;
-
- // Not expecting any payload from the response.
-}
-
-// Client-streaming response.
-message StreamingInputCallResponse {
- // Aggregated size of payloads received from the client.
- optional int32 aggregated_payload_size = 1;
-}
-
-// Configuration for a particular response.
-message ResponseParameters {
- // Desired payload sizes in responses from the server.
- // If response_type is COMPRESSABLE, this denotes the size before compression.
- optional int32 size = 1;
-
- // Desired interval between consecutive responses in the response stream in
- // microseconds.
- optional int32 interval_us = 2;
-}
-
-// Server-streaming request.
-message StreamingOutputCallRequest {
- // Desired payload type in the response from the server.
- // If response_type is RANDOM, the payload from each response in the stream
- // might be of different types. This is to simulate a mixed type of payload
- // stream.
- optional PayloadType response_type = 1;
-
- // Configuration for each expected response message.
- repeated ResponseParameters response_parameters = 2;
-
- // Optional input payload sent along with the request.
- optional Payload payload = 3;
-}
-
-// Server-streaming response, as configured by the request and parameters.
-message StreamingOutputCallResponse {
- // Payload to increase response size.
- optional Payload payload = 1;
-}
diff --git a/examples/tips/server.cc b/examples/tips/server.cc
deleted file mode 100644
index 2171a6aac0..0000000000
--- a/examples/tips/server.cc
+++ /dev/null
@@ -1,231 +0,0 @@
-/*
- *
- * Copyright 2014, 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 <memory>
-#include <sstream>
-#include <thread>
-
-#include <google/gflags.h>
-#include <grpc/grpc.h>
-#include <grpc/support/log.h>
-#include "test/core/end2end/data/ssl_test_data.h"
-#include <grpc++/config.h>
-#include <grpc++/server.h>
-#include <grpc++/server_builder.h>
-#include <grpc++/server_context.h>
-#include <grpc++/server_credentials.h>
-#include <grpc++/status.h>
-#include <grpc++/stream.h>
-#include "examples/tips/test.pb.h"
-#include "examples/tips/empty.pb.h"
-#include "examples/tips/messages.pb.h"
-
-DEFINE_bool(enable_ssl, false, "Whether to use ssl/tls.");
-DEFINE_int32(port, 0, "Server port.");
-
-using grpc::Server;
-using grpc::ServerBuilder;
-using grpc::ServerContext;
-using grpc::ServerCredentials;
-using grpc::ServerCredentialsFactory;
-using grpc::ServerReader;
-using grpc::ServerReaderWriter;
-using grpc::ServerWriter;
-using grpc::SslServerCredentialsOptions;
-using grpc::testing::Payload;
-using grpc::testing::PayloadType;
-using grpc::testing::SimpleRequest;
-using grpc::testing::SimpleResponse;
-using grpc::testing::StreamingInputCallRequest;
-using grpc::testing::StreamingInputCallResponse;
-using grpc::testing::StreamingOutputCallRequest;
-using grpc::testing::StreamingOutputCallResponse;
-using grpc::testing::TestService;
-using grpc::Status;
-
-bool SetPayload(PayloadType type, int size, Payload* payload) {
- PayloadType response_type = type;
- // TODO(yangg): Support UNCOMPRESSABLE payload.
- if (type != PayloadType::COMPRESSABLE) {
- return false;
- }
- payload->set_type(response_type);
- std::unique_ptr<char[]> body(new char[size]());
- payload->set_body(body.get(), size);
- return true;
-}
-
-class TestServiceImpl : public TestService::Service {
- public:
- Status EmptyCall(ServerContext* context, const grpc::testing::Empty* request,
- grpc::testing::Empty* response) {
- return Status::OK;
- }
-
- Status UnaryCall(ServerContext* context, const SimpleRequest* request,
- SimpleResponse* response) {
- if (request->has_response_size() && request->response_size() > 0) {
- if (!SetPayload(request->response_type(), request->response_size(),
- response->mutable_payload())) {
- return Status(grpc::StatusCode::INTERNAL, "Error creating payload.");
- }
- }
- return Status::OK;
- }
-
- Status StreamingOutputCall(
- ServerContext* context, const StreamingOutputCallRequest* request,
- ServerWriter<StreamingOutputCallResponse>* writer) {
- StreamingOutputCallResponse response;
- bool write_success = true;
- response.mutable_payload()->set_type(request->response_type());
- for (int i = 0; write_success && i < request->response_parameters_size();
- i++) {
- response.mutable_payload()->set_body(
- grpc::string(request->response_parameters(i).size(), '\0'));
- write_success = writer->Write(response);
- }
- if (write_success) {
- return Status::OK;
- } else {
- return Status(grpc::StatusCode::INTERNAL, "Error writing response.");
- }
- }
-
- Status StreamingInputCall(ServerContext* context,
- ServerReader<StreamingInputCallRequest>* reader,
- StreamingInputCallResponse* response) {
- StreamingInputCallRequest request;
- int aggregated_payload_size = 0;
- while (reader->Read(&request)) {
- if (request.has_payload() && request.payload().has_body()) {
- aggregated_payload_size += request.payload().body().size();
- }
- }
- response->set_aggregated_payload_size(aggregated_payload_size);
- return Status::OK;
- }
-
- Status FullDuplexCall(
- ServerContext* context,
- ServerReaderWriter<StreamingOutputCallResponse,
- StreamingOutputCallRequest>* stream) {
- StreamingOutputCallRequest request;
- StreamingOutputCallResponse response;
- bool write_success = true;
- while (write_success && stream->Read(&request)) {
- response.mutable_payload()->set_type(request.payload().type());
- if (request.response_parameters_size() == 0) {
- return Status(grpc::StatusCode::INTERNAL,
- "Request does not have response parameters.");
- }
- response.mutable_payload()->set_body(
- grpc::string(request.response_parameters(0).size(), '\0'));
- write_success = stream->Write(response);
- }
- if (write_success) {
- return Status::OK;
- } else {
- return Status(grpc::StatusCode::INTERNAL, "Error writing response.");
- }
- }
-
- Status HalfDuplexCall(
- ServerContext* context,
- ServerReaderWriter<StreamingOutputCallResponse,
- StreamingOutputCallRequest>* stream) {
- std::vector<StreamingOutputCallRequest> requests;
- StreamingOutputCallRequest request;
- while (stream->Read(&request)) {
- requests.push_back(request);
- }
-
- StreamingOutputCallResponse response;
- bool write_success = true;
- for (unsigned int i = 0; write_success && i < requests.size(); i++) {
- response.mutable_payload()->set_type(requests[i].payload().type());
- if (requests[i].response_parameters_size() == 0) {
- return Status(grpc::StatusCode::INTERNAL,
- "Request does not have response parameters.");
- }
- response.mutable_payload()->set_body(
- grpc::string(requests[i].response_parameters(0).size(), '\0'));
- write_success = stream->Write(response);
- }
- if (write_success) {
- return Status::OK;
- } else {
- return Status(grpc::StatusCode::INTERNAL, "Error writing response.");
- }
- }
-};
-
-void RunServer() {
- std::ostringstream server_address;
- server_address << "localhost:" << FLAGS_port;
- TestServiceImpl service;
-
- SimpleRequest request;
- SimpleResponse response;
-
- ServerBuilder builder;
- builder.AddPort(server_address.str());
- builder.RegisterService(service.service());
- if (FLAGS_enable_ssl) {
- SslServerCredentialsOptions ssl_opts = {
- "",
- {reinterpret_cast<const char*>(test_server1_key),
- test_server1_key_size},
- {reinterpret_cast<const char*>(test_server1_cert),
- test_server1_cert_size}};
- std::shared_ptr<ServerCredentials> creds =
- ServerCredentialsFactory::SslCredentials(ssl_opts);
- builder.SetCredentials(creds);
- }
- std::unique_ptr<Server> server(builder.BuildAndStart());
- gpr_log(GPR_INFO, "Server listening on %s", server_address.str().c_str());
- while (true) {
- std::this_thread::sleep_for(std::chrono::seconds(5));
- }
-}
-
-int main(int argc, char** argv) {
- grpc_init();
- google::ParseCommandLineFlags(&argc, &argv, true);
-
- GPR_ASSERT(FLAGS_port != 0);
- RunServer();
-
- grpc_shutdown();
- return 0;
-}
diff --git a/examples/tips/test.proto b/examples/tips/test.proto
deleted file mode 100644
index 807a3fe677..0000000000
--- a/examples/tips/test.proto
+++ /dev/null
@@ -1,42 +0,0 @@
-// An integration test service that covers all the method signature permutations
-// of unary/streaming requests/responses.
-syntax = "proto2";
-
-import "examples/tips/empty.proto";
-import "examples/tips/messages.proto";
-
-package grpc.testing;
-
-// A simple service to test the various types of RPCs and experiment with
-// performance with various types of payload.
-service TestService {
- // One empty request followed by one empty response.
- rpc EmptyCall(grpc.testing.Empty) returns (grpc.testing.Empty);
-
- // One request followed by one response.
- // The server returns the client payload as-is.
- rpc UnaryCall(SimpleRequest) returns (SimpleResponse);
-
- // One request followed by a sequence of responses (streamed download).
- // The server returns the payload with client desired type and sizes.
- rpc StreamingOutputCall(StreamingOutputCallRequest)
- returns (stream StreamingOutputCallResponse);
-
- // A sequence of requests followed by one response (streamed upload).
- // The server returns the aggregated size of client payload as the result.
- rpc StreamingInputCall(stream StreamingInputCallRequest)
- returns (StreamingInputCallResponse);
-
- // A sequence of requests with each request served by the server immediately.
- // As one request could lead to multiple responses, this interface
- // demonstrates the idea of full duplexing.
- rpc FullDuplexCall(stream StreamingOutputCallRequest)
- returns (stream StreamingOutputCallResponse);
-
- // A sequence of requests followed by a sequence of responses.
- // The server buffers all the client requests and then serves them in order. A
- // stream of responses are returned to the client when the server starts with
- // first request.
- rpc HalfDuplexCall(stream StreamingOutputCallRequest)
- returns (stream StreamingOutputCallResponse);
-}
--
GitLab