| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980 | /* * * 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 <grpc++/client_context.h>#include <grpc/grpc.h>#include "src/cpp/util/time.h"using std::chrono::system_clock;namespace grpc {ClientContext::ClientContext()    : call_(nullptr), cq_(nullptr), absolute_deadline_(gpr_inf_future) {}ClientContext::~ClientContext() {  if (call_) {    grpc_call_destroy(call_);  }  if (cq_) {    grpc_completion_queue_shutdown(cq_);    // Drain cq_.    grpc_event *ev;    grpc_completion_type t;    do {      ev = grpc_completion_queue_next(cq_, gpr_inf_future);      t = ev->type;      grpc_event_finish(ev);    } while (t != GRPC_QUEUE_SHUTDOWN);    grpc_completion_queue_destroy(cq_);  }}void ClientContext::set_absolute_deadline(    const system_clock::time_point &deadline) {  Timepoint2Timespec(deadline, &absolute_deadline_);}system_clock::time_point ClientContext::absolute_deadline() {  return Timespec2Timepoint(absolute_deadline_);}void ClientContext::AddMetadata(const grpc::string &meta_key,                                const grpc::string &meta_value) {  return;}void ClientContext::StartCancel() {}}  // namespace grpc
 |