import com.sun.corba.se.spi.activation.EndPointInfo; //导入依赖的package包/类
public void registerEndpoints( int serverId, String orbId,
    EndPointInfo [] endpointList ) throws NoSuchEndPoint, ServerNotRegistered,
    ORBAlreadyRegistered
{
    // orbId is ignored for now
    ServerTableEntry entry;
    Integer key = new Integer(serverId);

    synchronized (serverTable) {
        entry = (ServerTableEntry) serverTable.get(key);

        if (entry == null) {
            if (debug)
                System.out.println(
                    "ServerManagerImpl: registerEndpoint for server Id " +
                    serverId + " called, but no such server is registered." ) ;

            throw wrapper.serverNotExpectedToRegister() ;
        } else {
            if (debug)
                System.out.println(
                    "ServerManagerImpl: registerEndpoints for server Id " +
                    serverId + " called.  This server is now active." ) ;

            entry.registerPorts( orbId, endpointList );

        }
    }
}
 

import com.sun.corba.se.spi.activation.EndPointInfo; //导入依赖的package包/类
public int getServerPortForType(ServerLocationPerORB location,
                                String endPointType)
    throws NoSuchEndPoint
{
    EndPointInfo[] listenerPorts = location.ports;
    for (int i = 0; i < listenerPorts.length; i++) {
        if ((listenerPorts[i].endpointType).equals(endPointType)) {
            return listenerPorts[i].port;
        }
    }
    throw new NoSuchEndPoint();
}
 

import com.sun.corba.se.spi.activation.EndPointInfo; //导入依赖的package包/类
synchronized void registerPorts( String orbId, EndPointInfo [] endpointList)
    throws ORBAlreadyRegistered
{

    // find if the ORB is already registered, then throw an exception
    if (orbAndPortInfo.containsKey(orbId)) {
        throw new ORBAlreadyRegistered(orbId);
    }

    // store all listener ports and their types
    int numListenerPorts = endpointList.length;
    EndPointInfo [] serverListenerPorts = new EndPointInfo[numListenerPorts];

    for (int i = 0; i < numListenerPorts; i++) {
        serverListenerPorts[i] = new EndPointInfo (endpointList[i].endpointType, endpointList[i].port);
    if (debug)
        System.out.println("registering type: " + serverListenerPorts[i].endpointType  +  "  port  " + serverListenerPorts[i].port);
    }

    // put this set of listener ports in the HashMap associated
    // with the orbId
    orbAndPortInfo.put(orbId, serverListenerPorts);
    if (state == ACTIVATED) {
        state = RUNNING;
        notifyAll();
    }
    // _REVISIT_, If the state is not equal to ACTIVATED then it is a bug
    // need to log that error, once the Logging framework is in place
    // for rip-int.
    if (debug)
        printDebug("registerPorts", "process registered Ports");
}
 

import com.sun.corba.se.spi.activation.EndPointInfo; //导入依赖的package包/类
private void persistentServerInitialization( ORB orb )
{
    ORBData data = orb.getORBData() ;

    // determine the ORBD port so that persistent objrefs can be
    // created.
    if (data.getServerIsORBActivated()) {
        try {
            Locator locator = LocatorHelper.narrow(
                orb.resolve_initial_references(
                    ORBConstants.SERVER_LOCATOR_NAME )) ;
            Activator activator = ActivatorHelper.narrow(
                orb.resolve_initial_references(
                    ORBConstants.SERVER_ACTIVATOR_NAME )) ;
            Collection serverEndpoints =
                orb.getCorbaTransportManager().getAcceptors(null, null);
            EndPointInfo[] endpointList =
                new EndPointInfo[serverEndpoints.size()];
            Iterator iterator = serverEndpoints.iterator();
            int i = 0 ;
            while (iterator.hasNext()) {
                Object n = iterator.next();
                if (! (n instanceof LegacyServerSocketEndPointInfo)) {
                    continue;
                }
                LegacyServerSocketEndPointInfo ep =
                    (LegacyServerSocketEndPointInfo) n;
                // REVISIT - use exception instead of -1.
                int port = locator.getEndpoint(ep.getType());
                if (port == -1) {
                    port = locator.getEndpoint(SocketInfo.IIOP_CLEAR_TEXT);
                    if (port == -1) {
                        throw new Exception(
                            "ORBD must support IIOP_CLEAR_TEXT");
                    }
                }

                ep.setLocatorPort(port);

                endpointList[i++] =
                    new EndPointInfo(ep.getType(), ep.getPort());
            }

            activator.registerEndpoints(
                data.getPersistentServerId(), data.getORBId(),
                    endpointList);
        } catch (Exception ex) {
            throw wrapper.persistentServerInitError(
                CompletionStatus.COMPLETED_MAYBE, ex ) ;
        }
    }
}