Remove ServerInterestRegistrationMessage from CacheClientNotifier
Project: http://git-wip-us.apache.org/repos/asf/geode/repo Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/e10c182b Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/e10c182b Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/e10c182b Branch: refs/heads/feature/GEODE-2632-18 Commit: e10c182bcdc9c81ffbfeeb1ffdd071b9d9283d67 Parents: 7fb189e Author: Kirk Lund <kl...@apache.org> Authored: Wed May 31 13:49:30 2017 -0700 Committer: Kirk Lund <kl...@apache.org> Committed: Wed May 31 13:49:30 2017 -0700 ---------------------------------------------------------------------- .../cache/tier/sockets/CacheClientNotifier.java | 82 -------------------- 1 file changed, 82 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/geode/blob/e10c182b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java index 5ad6267..fd5154f 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java @@ -1932,88 +1932,6 @@ public class CacheClientNotifier { scheduleClientPingTask(); } - /** - * this message is used to send interest registration to another server. Since interest - * registration performs a state-flush operation this message must not transmitted on an ordered - * socket - */ - public static class ServerInterestRegistrationMessage extends HighPriorityDistributionMessage - implements MessageWithReply { - ClientProxyMembershipID clientId; - ClientInterestMessageImpl clientMessage; - int processorId; - - ServerInterestRegistrationMessage(ClientProxyMembershipID clientID, - ClientInterestMessageImpl msg) { - this.clientId = clientID; - this.clientMessage = msg; - } - - public ServerInterestRegistrationMessage() {} - - static void sendInterestChange(DM dm, ClientProxyMembershipID clientID, - ClientInterestMessageImpl msg) { - ServerInterestRegistrationMessage smsg = new ServerInterestRegistrationMessage(clientID, msg); - Set recipients = dm.getOtherDistributionManagerIds(); - smsg.setRecipients(recipients); - ReplyProcessor21 rp = new ReplyProcessor21(dm, recipients); - smsg.processorId = rp.getProcessorId(); - dm.putOutgoing(smsg); - try { - rp.waitForReplies(); - } catch (InterruptedException ie) { - Thread.currentThread().interrupt(); - } - } - - @Override - protected void process(DistributionManager dm) { - // Get the proxy for the proxy id - try { - CacheClientNotifier ccn = CacheClientNotifier.getInstance(); - if (ccn != null) { - CacheClientProxy proxy = ccn.getClientProxy(clientId); - // If this VM contains a proxy for the requested proxy id, forward the - // message on to the proxy for processing - if (proxy != null) { - proxy.processInterestMessage(this.clientMessage); - } - } - } finally { - ReplyMessage reply = new ReplyMessage(); - reply.setProcessorId(this.processorId); - reply.setRecipient(getSender()); - try { - dm.putOutgoing(reply); - } catch (CancelException e) { - // can't send a reply, so ignore the exception - } - } - } - - public int getDSFID() { - return SERVER_INTEREST_REGISTRATION_MESSAGE; - } - - @Override - public void toData(DataOutput out) throws IOException { - super.toData(out); - out.writeInt(this.processorId); - InternalDataSerializer.invokeToData(this.clientId, out); - InternalDataSerializer.invokeToData(this.clientMessage, out); - } - - @Override - public void fromData(DataInput in) throws IOException, ClassNotFoundException { - super.fromData(in); - this.processorId = in.readInt(); - this.clientId = new ClientProxyMembershipID(); - InternalDataSerializer.invokeFromData(this.clientId, in); - this.clientMessage = new ClientInterestMessageImpl(); - InternalDataSerializer.invokeFromData(this.clientMessage, in); - } - } - protected void deliverInterestChange(ClientProxyMembershipID proxyID, ClientInterestMessageImpl message) { DM dm = ((InternalDistributedSystem) this.getCache().getDistributedSystem())