Sends the queued RPCs to the server, once we're connected to it. This gets called after #channelConnected, once we were able to handshake with the server and find out which version it's running. @see #helloRpc
()
| 1137 | * @see #helloRpc |
| 1138 | */ |
| 1139 | private void sendQueuedRpcs() { |
| 1140 | ArrayList<HBaseRpc> rpcs; |
| 1141 | synchronized (this) { |
| 1142 | rpcs = pending_rpcs; |
| 1143 | pending_rpcs = null; |
| 1144 | } |
| 1145 | if (rpcs != null) { |
| 1146 | for (final HBaseRpc rpc : rpcs) { |
| 1147 | LOG.debug("Executing RPC queued: {}", rpc); |
| 1148 | sendRpc(rpc); |
| 1149 | } |
| 1150 | } |
| 1151 | } |
| 1152 | |
| 1153 | @Override |
| 1154 | public void channelDisconnected(final ChannelHandlerContext ctx, |