Class ServerGroupManager

java.lang.Object
org.omg.CORBA.LocalObject
com.sun.corba.ee.impl.folb.ServerGroupManager
All Implemented Interfaces:
GroupInfoServiceObserver, ORBConfigurator, Serializable, Object, IDLEntity, Interceptor, InterceptorOperations, IORInterceptor, IORInterceptorOperations, ORBInitializer, ORBInitializerOperations, ServerRequestInterceptor, ServerRequestInterceptorOperations
public class ServerGroupManager extends LocalObject implements GroupInfoServiceObserver, IORInterceptor, ORBConfigurator, ORBInitializer, ServerRequestInterceptor
See Also:

  • Field Details

  • Constructor Details

    • ServerGroupManager

      public ServerGroupManager()

  • Method Details

    • alreadyInitialized

      @InfoMethod private void alreadyInitialized()

    • initialize

      private void initialize()

    • name

      public String name()
      /////////////////////////////////////////////////
      Specified by:
      name in interface InterceptorOperations
      Returns:
      the name of the interceptor.

    • destroy

      public void destroy()
      Description copied from interface: InterceptorOperations
      Provides an opportunity to destroy this interceptor. The destroy method is called during ORB.destroy. When an application calls ORB.destroy, the ORB:
      1. waits for all requests in progress to complete
      2. calls the Interceptor.destroy operation for each interceptor
      3. completes destruction of the ORB
      Method invocations from within Interceptor.destroy on object references for objects implemented on the ORB being destroyed result in undefined behavior. However, method invocations on objects implemented on an ORB other than the one being destroyed are permitted. (This means that the ORB being destroyed is still capable of acting as a client, but not as a server.)
      Specified by:
      destroy in interface InterceptorOperations

    • adapterName

      @InfoMethod private void adapterName(String[] arr)
      /////////////////////////////////////////////////

    • addingAddresses

      @InfoMethod private void addingAddresses()

    • notAddingAddress

      @InfoMethod private void notAddingAddress()

    • addingMembershipLabel

      @InfoMethod private void addingMembershipLabel(String ml)

    • notAddingMembershipLabel

      @InfoMethod private void notAddingMembershipLabel()

    • skippingEndpoint

      @InfoMethod private void skippingEndpoint(SocketInfo si)

    • includingEndpoint

      @InfoMethod private void includingEndpoint(SocketInfo si)

    • addingInstanceInfoFor

      @InfoMethod private void addingInstanceInfoFor(String name, int weight)

    • establish_components

      public void establish_components(IORInfo iorInfo)
      Description copied from interface: IORInterceptorOperations
      A server side ORB calls the establish_components operation on all registered IORInterceptor instances when it is assembling the list of components that will be included in the profile or profiles of an object reference. This operation is not necessarily called for each individual object reference. In the case of the POA, this operation is called each time POA::create_POA is called. In any case, establish_components is guaranteed to be called at least once for each distinct set of server policies.

      An implementation of establish_components must not throw exceptions. If it does, the ORB shall ignore the exception and proceed to call the next IOR Interceptor's establish_components operation.

      Specified by:
      establish_components in interface IORInterceptorOperations
      Parameters:
      iorInfo - The IORInfo instance used by the ORB service to query applicable policies and add components to be included in the generated IORs.

    • components_established

      public void components_established(IORInfo iorInfo)

    • adapter_manager_state_changed

      public void adapter_manager_state_changed(int managerId, short state)

    • adapter_state_changed

      public void adapter_state_changed(ObjectReferenceTemplate[] templates, short state)

    • alreadyChangingMembership

      @InfoMethod private void alreadyChangingMembership()
      /////////////////////////////////////////////////

    • loopingForMembershipChange

      @InfoMethod private void loopingForMembershipChange()

    • unexpectedStateForMembershipChange

      @InfoMethod private void unexpectedStateForMembershipChange()

    • membershipChange

      public void membershipChange()
      Description copied from interface: GroupInfoServiceObserver
      Called when the GroupInfoService that you register with has a change. You should call the GroupInfoService getClusterInstanceInfo method to get updated info.
      Specified by:
      membershipChange in interface GroupInfoServiceObserver

    • waitingForWorkerTermination

      @InfoMethod private void waitingForWorkerTermination()

    • restartFactories

      private void restartFactories()

    • newMembershipLabel

      @InfoMethod private void newMembershipLabel(String ml)

    • updateMembershipLabel

      private void updateMembershipLabel()

    • receive_request_service_contexts

      public void receive_request_service_contexts(ServerRequestInfo ri)
      /////////////////////////////////////////////////
      Specified by:
      receive_request_service_contexts in interface ServerRequestInterceptorOperations
      Parameters:
      ri - Information about the current request being intercepted.

    • receive_request

      public void receive_request(ServerRequestInfo ri)
      Description copied from interface: ServerRequestInterceptorOperations
      Allows an Interceptor to query request information after all the information, including operation parameters, are available. This interception point shall execute in the same thread as the target invocation.

      In the DSI model, since the parameters are first available when the user code calls arguments, receive_request is called from within arguments. It is possible that arguments is not called in the DSI model. The target may call set_exception before calling arguments. The ORB shall guarantee that receive_request is called once, either through arguments or through set_exception. If it is called through set_exception, requesting the arguments will result in NO_RESOURCES being thrown with a standard minor code of 1.

      This interception point may throw a system exception. If it does, no other Interceptors' receive_request operations are called. Those Interceptors on the Flow Stack are popped and their send_exception interception points are called.

      This interception point may also throw a ForwardRequest exception. If an Interceptor throws this exception, no other Interceptors' receive_request operations are called. Those Interceptors on the Flow Stack are popped and their send_other interception points are called.

      Compliant Interceptors shall properly follow completion_status semantics if they throw a system exception from this interception point. The completion_status shall be COMPLETED_NO.

      Specified by:
      receive_request in interface ServerRequestInterceptorOperations
      Parameters:
      ri - Information about the current request being intercepted.

    • send_reply

      public void send_reply(ServerRequestInfo ri)
      Description copied from interface: ServerRequestInterceptorOperations
      Allows an Interceptor to query reply information and modify the reply service context after the target operation has been invoked and before the reply is returned to the client. This interception point shall execute in the same thread as the target invocation.

      This interception point may throw a system exception. If it does, no other Interceptors' send_reply operations are called. The remaining Interceptors in the Flow Stack shall have their send_exception interception point called.

      Compliant Interceptors shall properly follow completion_status semantics if they throw a system exception from this interception point. The completion_status shall be COMPLETED_YES.

      Specified by:
      send_reply in interface ServerRequestInterceptorOperations
      Parameters:
      ri - Information about the current request being intercepted.

    • send_exception

      public void send_exception(ServerRequestInfo ri)
      Description copied from interface: ServerRequestInterceptorOperations
      Allows an Interceptor to query the exception information and modify the reply service context before the exception is thrown to the client. When an exception occurs, this interception point is called. This interception point shall execute in the same thread as the target invocation.

      This interception point may throw a system exception. This has the effect of changing the exception which successive Interceptors popped from the Flow Stack receive on their calls to send_exception. The exception thrown to the client will be the last exception thrown by an Interceptor, or the original exception if no Interceptor changes the exception.

      This interception point may also throw a ForwardRequest exception. If an Interceptor throws this exception, no other Interceptors' send_exception operations are called. The remaining Interceptors in the Flow Stack shall have their send_other interception points called.

      If the completion_status of the exception is not COMPLETED_NO, then it is inappropriate for this interception point to throw a ForwardRequest exception. The request's at-most-once semantics would be lost.

      Compliant Interceptors shall properly follow completion_status semantics if they throw a system exception from this interception point. If the original exception is a system exception, the completion_status of the new exception shall be the same as on the original. If the original exception is a user exception, then the completion_status of the new exception shall be COMPLETED_YES.

      Specified by:
      send_exception in interface ServerRequestInterceptorOperations
      Parameters:
      ri - Information about the current request being intercepted.

    • send_other

      public void send_other(ServerRequestInfo ri)
      Description copied from interface: ServerRequestInterceptorOperations
      Allows an Interceptor to query the information available when a request results in something other than a normal reply or an exception. For example, a request could result in a retry (e.g., a GIOP Reply with a LOCATION_FORWARD status was received). This interception point shall execute in the same thread as the target invocation.

      This interception point may throw a system exception. If it does, no other Interceptors' send_other operations are called. The remaining Interceptors in the Flow Stack shall have their send_exception interception points called.

      This interception point may also throw a ForwardRequest exception. If an Interceptor throws this exception, successive Interceptors' send_other operations are called with the new information provided by the ForwardRequest exception.

      Compliant Interceptors shall properly follow completion_status semantics if they throw a system exception from this interception point. The completion_status shall be COMPLETED_NO.

      Specified by:
      send_other in interface ServerRequestInterceptorOperations
      Parameters:
      ri - Information about the current request being intercepted.

    • rfmIsHolding

      @InfoMethod private void rfmIsHolding()

    • notManagedByReferenceFactory

      @InfoMethod private void notManagedByReferenceFactory(String[] adapterName)

    • membershipLabelsEqual

      @InfoMethod private void membershipLabelsEqual()

    • membershipLabelsNotEqual

      @InfoMethod private void membershipLabelsNotEqual()

    • membershipLabelsNotPresent

      @InfoMethod private void membershipLabelsNotPresent()

    • sendingUpdatedIOR

      @InfoMethod private void sendingUpdatedIOR(String[] adapterName)

    • send_star

      private void send_star(String point, ServerRequestInfo ri)
      If the request membership label is out-of-date or missing then return an updated IOR.

    • pre_init

      public void pre_init(ORBInitInfo info)
      /////////////////////////////////////////////////
      Specified by:
      pre_init in interface ORBInitializerOperations
      Parameters:
      info - provides initialization attributes and operations by which Interceptors can be registered.

    • post_init

      public void post_init(ORBInitInfo info)
      Description copied from interface: ORBInitializerOperations
      Called during ORB initialization. If a service must resolve initial references as part of its initialization, it can assume that all initial references will be available at this point.

      Calling the post_init operations is not the final task of ORB initialization. The final task, following the post_init calls, is attaching the lists of registered interceptors to the ORB. Therefore, the ORB does not contain the interceptors during calls to post_init. If an ORB-mediated call is made from within post_init, no request interceptors will be invoked on that call. Likewise, if an operation is performed which causes an IOR to be created, no IOR interceptors will be invoked.

      Specified by:
      post_init in interface ORBInitializerOperations
      Parameters:
      info - provides initialization attributes and operations by which Interceptors can be registered.

    • configure

      public void configure(DataCollector collector, ORB orb)
      /////////////////////////////////////////////////
      Specified by:
      configure in interface ORBConfigurator