import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public void active(int serverId, Server server) throws ServerNotRegistered
{
    ServerTableEntry entry;
    Integer key = new Integer(serverId);

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

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

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

            entry.register(server);
        }
    }
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public void uninstall( int serverId )
    throws ServerNotRegistered, ServerHeldDown, ServerAlreadyUninstalled
{
    ServerTableEntry entry =
        (ServerTableEntry) serverTable.get( new Integer(serverId) );

    if (entry != null) {

        entry =
            (ServerTableEntry) serverTable.remove(new Integer(serverId));

        if (entry == null) {
            if (debug)
                System.out.println( "ServerManagerImpl: shutdown for server Id " +
                                serverId + " throws ServerNotActive." ) ;

            throw new ServerHeldDown( serverId );
        }

        entry.uninstall();
    }
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public void unregisterServer(int serverId) throws ServerNotRegistered {

        DBServerDef server = null;
        Integer id = new Integer(serverId);

        synchronized (db) {

            // check to see if the server is registered
            server = (DBServerDef) db.serverTable.get(id);
            if (server == null)  {
                if (debug)
                    System.out.println(
                                       "RepositoryImpl: unregisterServer for serverId " +
                                       serverId + " called: server not registered" ) ;

                throw (new ServerNotRegistered());
            }

            // remove server from the database
            db.serverTable.remove(id);
            db.flush();
        }

        if (debug)
            System.out.println(
                               "RepositoryImpl: unregisterServer for serverId " + serverId +
                               " called" ) ;
    }
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
private DBServerDef getDBServerDef(int serverId) throws ServerNotRegistered
{
    Integer id = new Integer(serverId);
    DBServerDef server = (DBServerDef) db.serverTable.get(id);

    if (server == null)
        throw new ServerNotRegistered( serverId );

    return server ;
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public ServerDef getServer(int serverId) throws ServerNotRegistered
{
    DBServerDef server = getDBServerDef( serverId ) ;

    ServerDef serverDef = new ServerDef(server.applicationName, server.name,
                                        server.classPath, server.args, server.vmArgs);

    if (debug)
        System.out.println(
                           "RepositoryImpl: getServer for serverId " + serverId +
                           " returns " + printServerDef( serverDef ) ) ;

    return serverDef;
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public void install( int serverId )
    throws ServerNotRegistered, ServerAlreadyInstalled
{
    DBServerDef server = getDBServerDef( serverId ) ;

    if (server.isInstalled)
        throw new ServerAlreadyInstalled( serverId ) ;
    else {
        server.isInstalled = true ;
        db.flush() ;
    }
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public void uninstall( int serverId )
    throws ServerNotRegistered, ServerAlreadyUninstalled
{
    DBServerDef server = getDBServerDef( serverId ) ;

    if (!server.isInstalled)
        throw new ServerAlreadyUninstalled( serverId ) ;
    else {
        server.isInstalled = false ;
        db.flush() ;
    }
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public int getServerID(String applicationName) throws ServerNotRegistered {
    synchronized (db) {
        int result = -1 ;

        for (Enumeration serverIds = db.serverTable.keys();
             serverIds.hasMoreElements();)
            {
                Integer nextServerId = (Integer) serverIds.nextElement();
                DBServerDef dbServerDef =
                    (DBServerDef) db.serverTable.get(nextServerId);

                if (dbServerDef.applicationName.equals(applicationName)) {
                    result = nextServerId.intValue();
                    break ;
                }
            }

        if (debug)
            System.out.println("RepositoryImpl: getServerID for " +
                               applicationName + " is " + result ) ;

        if (result == -1) {
            throw (new ServerNotRegistered());
        } else {
            return result ;
        }
    }
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的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.ServerNotRegistered; //导入依赖的package包/类
private ServerTableEntry getEntry( int serverId )
    throws ServerNotRegistered
{
    Integer key = new Integer(serverId);
    ServerTableEntry entry = null ;

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

        if (debug)
            if (entry == null) {
                System.out.println( "ServerManagerImpl: getEntry: " +
                                    "no active server found." ) ;
            } else {
                System.out.println( "ServerManagerImpl: getEntry: " +
                                    " active server found " + entry + "." ) ;
            }

        if ((entry != null) && (!entry.isValid())) {
            serverTable.remove(key);
            entry = null;
        }

        if (entry == null) {
            ServerDef serverDef = repository.getServer(serverId);

            entry = new ServerTableEntry( wrapper,
                serverId, serverDef, initialPort, dbDirName, false, debug);
            serverTable.put(key, entry);
            entry.activate() ;
        }
    }

    return entry ;
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public String[] getORBNames(int serverId)
    throws ServerNotRegistered
{
    try {
        ServerTableEntry entry = getEntry( serverId ) ;
        return (entry.getORBList());
    } catch (Exception ex) {
        throw new ServerNotRegistered(serverId);
    }
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
private ServerTableEntry getRunningEntry( int serverId )
    throws ServerNotRegistered
{
    ServerTableEntry entry = getEntry( serverId ) ;

    try {
        // this is to see if the server has any listeners
        ORBPortInfo [] serverORBAndPortList = entry.lookup(IIOP_CLEAR_TEXT.value) ;
    } catch (Exception exc) {
        return null ;
    }
    return entry;

}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public void install( int serverId )
    throws ServerNotRegistered, ServerHeldDown, ServerAlreadyInstalled
{
    ServerTableEntry entry = getRunningEntry( serverId ) ;
    if (entry != null) {
        repository.install( serverId ) ;
        entry.install() ;
    }
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
public ServerLocation locateServer (int serverId, String endpointType)
    throws NoSuchEndPoint, ServerNotRegistered, ServerHeldDown
{
    ServerTableEntry entry = getEntry( serverId ) ;
    if (debug)
        System.out.println( "ServerManagerImpl: locateServer called with " +
                            " serverId=" + serverId + " endpointType=" +
                            endpointType + " block=true" ) ;

    // passing in entry to eliminate multiple lookups for
    // the same entry in some cases

    return locateServer(entry, endpointType, true);
}
 

import com.sun.corba.se.spi.activation.ServerNotRegistered; //导入依赖的package包/类
/** This method is used to obtain the registered ports for an ORB.
* This is useful for custom Bad server ID handlers in ORBD.
*/
public ServerLocationPerORB locateServerForORB (int serverId, String orbId)
    throws InvalidORBid, ServerNotRegistered, ServerHeldDown
{
    ServerTableEntry entry = getEntry( serverId ) ;

    // passing in entry to eliminate multiple lookups for
    // the same entry in some cases

    if (debug)
        System.out.println( "ServerManagerImpl: locateServerForORB called with " +
                            " serverId=" + serverId + " orbId=" + orbId +
                            " block=true" ) ;
    return locateServerForORB(entry, orbId, true);
}