MCPcopy Create free account
hub / github.com/OpenTSDB/asynchbase / make

Method make

src/PleaseThrottleException.java:116–129  ·  view source on GitHub ↗
(final Object msg, final HBaseRpc rpc)

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls 2

getDeferredMethod · 0.95
getMessageMethod · 0.45

Tested by

no test coverage detected