Package org.jgroups.protocols.upgrade

Class UPGRADE

  • public class UPGRADE
extends org.jgroups.stack.Protocol
    Relays application messages to the UpgradeServer (when active). Should be the top protocol in a stack.
    Since:
    1.0
    Author:
    Bela Ban

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected boolean active  
      protected org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceStub asyncStub  
      protected io.grpc.ManagedChannel channel  
      protected String cluster  
      protected org.jgroups.View global_view  
      protected org.jgroups.Address local_addr  
      protected org.jgroups.View local_view  
      protected io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Request> send_stream  
      protected String server_address  
      protected int server_port  

      • Fields inherited from class org.jgroups.stack.Protocol

        after_creation_hook, down_prot, ergonomics, id, log, name, stack, stats, up_prot

    • Constructor Summary

      Constructors 
      Constructor Description
      UPGRADE()  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void activate()  
      protected void connect​(String cluster)  
      void deactivate()  
      protected void disconnect()  
      Object down​(org.jgroups.Event evt)  
      protected void handleMessage​(org.jgroups.upgrade_server.Message m)  
      protected void handleView​(org.jgroups.upgrade_server.View view)  
      protected static org.jgroups.upgrade_server.Address jgroupsAddressToProtobufAddress​(org.jgroups.Address jgroups_addr)  
      protected static org.jgroups.upgrade_server.Message jgroupsMessageToProtobufMessage​(String cluster, org.jgroups.Message jgroups_msg)  
      protected static String print​(org.jgroups.upgrade_server.Message msg)  
      static String print​(org.jgroups.upgrade_server.View v)  
      protected static org.jgroups.Address protobufAddressToJGroupsAddress​(org.jgroups.upgrade_server.Address pbuf_addr)  
      protected static org.jgroups.Message protobufMessageToJGroupsMessage​(org.jgroups.upgrade_server.Message msg)  
      protected static org.jgroups.View protobufViewToJGroupsView​(org.jgroups.upgrade_server.View v)  
      void start()  
      void stop()  
      Object up​(org.jgroups.Event evt)  

      • Methods inherited from class org.jgroups.stack.Protocol

        accept, afterCreationHook, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, init, isErgonomics, level, parse, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, resetStats, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled, up

    • Field Detail

      • active

        protected volatile boolean active

      • server_address

        protected String server_address

      • server_port

        protected int server_port

      • local_addr

        protected org.jgroups.Address local_addr

      • local_view

        protected org.jgroups.View local_view

      • global_view

        protected org.jgroups.View global_view

      • cluster

        protected String cluster

      • channel

        protected io.grpc.ManagedChannel channel

      • asyncStub

        protected org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceStub asyncStub

      • send_stream

        protected io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Request> send_stream

    • Constructor Detail

      • UPGRADE

        public UPGRADE()

    • Method Detail

      • activate

        public void activate()

      • deactivate

        public void deactivate()

      • start

        public void start()
           throws Exception
        Overrides:
        start in class org.jgroups.stack.Protocol
        Throws:
        Exception

      • stop

        public void stop()
        Overrides:
        stop in class org.jgroups.stack.Protocol

      • down

        public Object down​(org.jgroups.Event evt)
        Overrides:
        down in class org.jgroups.stack.Protocol

      • up

        public Object up​(org.jgroups.Event evt)
        Overrides:
        up in class org.jgroups.stack.Protocol

      • connect

        protected void connect​(String cluster)

      • disconnect

        protected void disconnect()

      • handleView

        protected void handleView​(org.jgroups.upgrade_server.View view)

      • handleMessage

        protected void handleMessage​(org.jgroups.upgrade_server.Message m)

      • jgroupsAddressToProtobufAddress

        protected static org.jgroups.upgrade_server.Address jgroupsAddressToProtobufAddress​(org.jgroups.Address jgroups_addr)

      • protobufAddressToJGroupsAddress

        protected static org.jgroups.Address protobufAddressToJGroupsAddress​(org.jgroups.upgrade_server.Address pbuf_addr)

      • jgroupsMessageToProtobufMessage

        protected static org.jgroups.upgrade_server.Message jgroupsMessageToProtobufMessage​(String cluster,
                                                                                    org.jgroups.Message jgroups_msg)

      • protobufMessageToJGroupsMessage

        protected static org.jgroups.Message protobufMessageToJGroupsMessage​(org.jgroups.upgrade_server.Message msg)

      • protobufViewToJGroupsView

        protected static org.jgroups.View protobufViewToJGroupsView​(org.jgroups.upgrade_server.View v)

      • print

        protected static String print​(org.jgroups.upgrade_server.Message msg)

      • print

        public static String print​(org.jgroups.upgrade_server.View v)