clean up repeated words

pull/18707/head
SataQiu 6 years ago
parent 58c894fb9e
commit 44f92cdd17
  1. 12
      include/grpcpp/impl/codegen/async_stream.h
  2. 2
      src/core/lib/iomgr/ev_epoll1_linux.cc
  3. 2
      src/ruby/ext/grpc/rb_grpc.c
  4. 2
      src/ruby/lib/grpc/generic/bidi_call.rb
  5. 2
      src/ruby/lib/grpc/generic/rpc_server.rb

@ -659,7 +659,7 @@ class ServerAsyncReaderInterface
/// some failure occurred when trying to do so. /// some failure occurred when trying to do so.
/// ///
/// gRPC doesn't take ownership or a reference to \a msg or \a status, so it /// gRPC doesn't take ownership or a reference to \a msg or \a status, so it
/// is safe to to deallocate once Finish returns. /// is safe to deallocate once Finish returns.
/// ///
/// \param[in] tag Tag identifying this request. /// \param[in] tag Tag identifying this request.
/// \param[in] status To be sent to the client as the result of this call. /// \param[in] status To be sent to the client as the result of this call.
@ -733,7 +733,7 @@ class ServerAsyncReader final : public ServerAsyncReaderInterface<W, R> {
/// Note: \a msg is not sent if \a status has a non-OK code. /// Note: \a msg is not sent if \a status has a non-OK code.
/// ///
/// gRPC doesn't take ownership or a reference to \a msg and \a status, so it /// gRPC doesn't take ownership or a reference to \a msg and \a status, so it
/// is safe to to deallocate once Finish returns. /// is safe to deallocate once Finish returns.
void Finish(const W& msg, const Status& status, void* tag) override { void Finish(const W& msg, const Status& status, void* tag) override {
finish_ops_.set_output_tag(tag); finish_ops_.set_output_tag(tag);
if (!ctx_->sent_initial_metadata_) { if (!ctx_->sent_initial_metadata_) {
@ -828,7 +828,7 @@ class ServerAsyncWriterInterface
/// in a single step. /// in a single step.
/// ///
/// gRPC doesn't take ownership or a reference to \a msg and \a status, so it /// gRPC doesn't take ownership or a reference to \a msg and \a status, so it
/// is safe to to deallocate once WriteAndFinish returns. /// is safe to deallocate once WriteAndFinish returns.
/// ///
/// \param[in] msg The message to be written. /// \param[in] msg The message to be written.
/// \param[in] options The WriteOptions to be used to write this message. /// \param[in] options The WriteOptions to be used to write this message.
@ -895,7 +895,7 @@ class ServerAsyncWriter final : public ServerAsyncWriterInterface<W> {
/// Note: \a status must have an OK code. /// Note: \a status must have an OK code.
/// ///
/// gRPC doesn't take ownership or a reference to \a msg and \a status, so it /// gRPC doesn't take ownership or a reference to \a msg and \a status, so it
/// is safe to to deallocate once WriteAndFinish returns. /// is safe to deallocate once WriteAndFinish returns.
void WriteAndFinish(const W& msg, WriteOptions options, const Status& status, void WriteAndFinish(const W& msg, WriteOptions options, const Status& status,
void* tag) override { void* tag) override {
write_ops_.set_output_tag(tag); write_ops_.set_output_tag(tag);
@ -991,7 +991,7 @@ class ServerAsyncReaderWriterInterface
/// single step. /// single step.
/// ///
/// gRPC doesn't take ownership or a reference to \a msg and \a status, so it /// gRPC doesn't take ownership or a reference to \a msg and \a status, so it
/// is safe to to deallocate once WriteAndFinish returns. /// is safe to deallocate once WriteAndFinish returns.
/// ///
/// \param[in] msg The message to be written. /// \param[in] msg The message to be written.
/// \param[in] options The WriteOptions to be used to write this message. /// \param[in] options The WriteOptions to be used to write this message.
@ -1066,7 +1066,7 @@ class ServerAsyncReaderWriter final
/// Note: \a status must have an OK code. /// Note: \a status must have an OK code.
// //
/// gRPC doesn't take ownership or a reference to \a msg and \a status, so it /// gRPC doesn't take ownership or a reference to \a msg and \a status, so it
/// is safe to to deallocate once WriteAndFinish returns. /// is safe to deallocate once WriteAndFinish returns.
void WriteAndFinish(const W& msg, WriteOptions options, const Status& status, void WriteAndFinish(const W& msg, WriteOptions options, const Status& status,
void* tag) override { void* tag) override {
write_ops_.set_output_tag(tag); write_ops_.set_output_tag(tag);

@ -213,7 +213,7 @@ struct grpc_pollset {
poll */ poll */
bool seen_inactive; bool seen_inactive;
bool shutting_down; /* Is the pollset shutting down ? */ bool shutting_down; /* Is the pollset shutting down ? */
grpc_closure* shutdown_closure; /* Called after after shutdown is complete */ grpc_closure* shutdown_closure; /* Called after shutdown is complete */
/* Number of workers who are *about-to* attach themselves to the pollset /* Number of workers who are *about-to* attach themselves to the pollset
* worker list */ * worker list */

@ -304,7 +304,7 @@ static VALUE bg_thread_init_rb_mu = Qundef;
static int bg_thread_init_done = 0; static int bg_thread_init_done = 0;
static void grpc_ruby_init_threads() { static void grpc_ruby_init_threads() {
// Avoid calling calling into ruby library (when creating threads here) // Avoid calling into ruby library (when creating threads here)
// in gpr_once_init. In general, it appears to be unsafe to call // in gpr_once_init. In general, it appears to be unsafe to call
// into the ruby library while holding a non-ruby mutex, because a gil yield // into the ruby library while holding a non-ruby mutex, because a gil yield
// could end up trying to lock onto that same mutex and deadlocking. // could end up trying to lock onto that same mutex and deadlocking.

@ -224,7 +224,7 @@ module GRPC
set_input_stream_done.call set_input_stream_done.call
end end
GRPC.logger.debug('bidi-read-loop: finished') GRPC.logger.debug('bidi-read-loop: finished')
# Make sure that the write loop is done done before finishing the call. # Make sure that the write loop is done before finishing the call.
# Note that blocking is ok at this point because we've already received # Note that blocking is ok at this point because we've already received
# a status # a status
@enq_th.join if is_client @enq_th.join if is_client

@ -202,7 +202,7 @@ module GRPC
# forcing an abrupt exit to each thread. # forcing an abrupt exit to each thread.
# #
# * connect_md_proc: # * connect_md_proc:
# when non-nil is a proc for determining metadata to to send back the client # when non-nil is a proc for determining metadata to send back the client
# on receiving an invocation req. The proc signature is: # on receiving an invocation req. The proc signature is:
# {key: val, ..} func(method_name, {key: val, ...}) # {key: val, ..} func(method_name, {key: val, ...})
# #

Loading…
Cancel
Save