(final Channel chan, final byte server_version)
| 661 | } |
| 662 | |
| 663 | void becomeReady(final Channel chan, final byte server_version) { |
| 664 | this.server_version = server_version; |
| 665 | // The following line will make this client no longer queue incoming |
| 666 | // RPCs, as we're now ready to communicate with the server. |
| 667 | this.chan = chan; // Volatile write. |
| 668 | sendQueuedRpcs(); |
| 669 | } |
| 670 | |
| 671 | private static final byte[] GET_CLOSEST_ROW_BEFORE = new byte[] { |
| 672 | 'g', 'e', 't', |