(final Object msg, final HBaseRpc rpc)
| 114 | } |
| 115 | |
| 116 | @Override |
| 117 | PleaseThrottleException make(final Object msg, final HBaseRpc rpc) { |
| 118 | // This is only called from HBaseClient.sendRpcToRegion(), more precisely |
| 119 | // from RetryRpc.call(), where we need to report the correct RPC that has |
| 120 | // failed when it's a META or ROOT lookup that failed. |
| 121 | if (msg instanceof PleaseThrottleException) { |
| 122 | final PleaseThrottleException e = (PleaseThrottleException) msg; |
| 123 | return new PleaseThrottleException(e.getMessage(), e, rpc, |
| 124 | e.getDeferred()); |
| 125 | } |
| 126 | // Thus we never expect to be here since the only call site is passing us |
| 127 | // a PleaseThrottleException in argument. Not very clean, I agree. |
| 128 | throw new AssertionError("Should never be here!"); |
| 129 | } |
| 130 | |
| 131 | private static final long serialVersionUID = 1286782542; |
| 132 |
nothing calls this directly
no test coverage detected