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

Method becomeReady

src/RegionClient.java:663–669  ·  view source on GitHub ↗
(final Channel chan, final byte server_version)

Source from the content-addressed store, hash-verified

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',

Calls 1

sendQueuedRpcsMethod · 0.95