Method failOrRetryRpcs

src/RegionClient.java:1207–1222

Fail all RPCs in a collection or attempt to reschedule them if possible. @param rpcs A possibly empty but non-null collection of RPCs. @param exception The exception with which to fail RPCs that can't be retried.

(final Collection<HBaseRpc> rpcs,
                               final ConnectionResetException exception)

   * retried.
   */
  private void failOrRetryRpcs(final Collection<HBaseRpc> rpcs,
                               final ConnectionResetException exception) {
    for (final HBaseRpc rpc : rpcs) {
      final RegionInfo region = rpc.getRegion();
      if (region == null  // Can't retry, dunno where this RPC should go.
          || rpc.failfast()) {
        rpc.callback(exception);
      } else {
        final NotServingRegionException nsre =
          new NotServingRegionException("Connection reset: "
                                        + exception.getMessage(), rpc);
        // Re-schedule the RPC by (ab)using the NSRE handling mechanism.
        hbase_client.handleNSRE(rpc, region.name(), nsre);
      }
    }
  }

  @Override
  public void handleUpstream(final ChannelHandlerContext ctx,