requestdispatcherregistryimpl.java

来自「JAVA 所有包」· Java 代码 · 共 166 行

/*
 * @(#)RequestDispatcherRegistryImpl.java	1.23 05/11/17
 *
 * Copyright 2006 Sun Microsystems, Inc. All rights reserved.
 * SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
 */

package com.sun.corba.se.impl.protocol;

import java.util.Set;
import java.util.HashSet;
import java.util.Map;
import java.util.HashMap;
import java.util.Collections;

import com.sun.corba.se.pept.protocol.ClientRequestDispatcher ;

import com.sun.corba.se.spi.protocol.LocalClientRequestDispatcher ;
import com.sun.corba.se.spi.protocol.LocalClientRequestDispatcherFactory ;
import com.sun.corba.se.spi.protocol.CorbaServerRequestDispatcher ;
import com.sun.corba.se.spi.protocol.RequestDispatcherRegistry ;

import com.sun.corba.se.spi.oa.ObjectAdapterFactory ;

import com.sun.corba.se.spi.orb.ORB ;

import com.sun.corba.se.impl.orbutil.ORBConstants ;
import com.sun.corba.se.impl.orbutil.DenseIntMapImpl ;

/**
 * This is a registry of all subcontract ID dependent objects.  This includes:
 * LocalClientRequestDispatcherFactory, ClientRequestDispatcher, ServerSubcontract, and 
 * ObjectAdapterFactory. 
 */
public class RequestDispatcherRegistryImpl implements RequestDispatcherRegistry {
    private ORB orb;

    protected int defaultId;			// The default subcontract ID to use if 
						// there is no more specific ID available.
						// This happens when invoking a foreign IOR.
    private DenseIntMapImpl SDRegistry ;	// ServerRequestDispatcher registry
    private DenseIntMapImpl CSRegistry ;	// ClientRequestDispatcher registry
    private DenseIntMapImpl OAFRegistry ;	// ObjectAdapterFactory registry
    private DenseIntMapImpl LCSFRegistry ;	// LocalClientRequestDispatcherFactory registry
    private Set objectAdapterFactories ;	// Set of all ObjectAdapterFactory instances
    private Set objectAdapterFactoriesView ;	// Read-only view of oaf instances
    private Map stringToServerSubcontract ;	// Map from obect key string to 
						// ServerSubcontract
						// for special bootstrap IORs

    public RequestDispatcherRegistryImpl(ORB orb, int defaultId ) 
    {
	this.orb = orb;
        this.defaultId = defaultId;
        SDRegistry = new DenseIntMapImpl() ;
        CSRegistry = new DenseIntMapImpl() ;
	OAFRegistry = new DenseIntMapImpl() ;
	LCSFRegistry = new DenseIntMapImpl() ;
	objectAdapterFactories = new HashSet() ;
	objectAdapterFactoriesView = Collections.unmodifiableSet( objectAdapterFactories ) ;
	stringToServerSubcontract = new HashMap() ;
    }

    public synchronized void registerClientRequestDispatcher( 
	ClientRequestDispatcher csc, int scid)
    {
	CSRegistry.set( scid, csc ) ;
    }

    public synchronized void registerLocalClientRequestDispatcherFactory( 
	LocalClientRequestDispatcherFactory csc, int scid)
    {
	LCSFRegistry.set( scid, csc ) ;
    }

    public synchronized void registerServerRequestDispatcher( 
	CorbaServerRequestDispatcher ssc, int scid)
    {
	SDRegistry.set( scid, ssc ) ;
    }

    public synchronized void registerServerRequestDispatcher(
	CorbaServerRequestDispatcher scc, String name )
    {
	stringToServerSubcontract.put( name, scc ) ;
    }

    public synchronized void registerObjectAdapterFactory( 
	ObjectAdapterFactory oaf, int scid)
    {
	objectAdapterFactories.add( oaf ) ;
	OAFRegistry.set( scid, oaf ) ;
    }

    // **************************************************
    // Methods to find the subcontract side subcontract
    // **************************************************

    // Note that both forms of getServerRequestDispatcher need to return
    // the default server delegate if no other match is found.
    // This is essential to proper handling of errors for 
    // malformed requests.  In particular, a bad MAGIC will
    // result in a lookup in the named key table (stringToServerSubcontract),
    // which must return a valid ServerRequestDispatcher.  A bad subcontract ID
    // will similarly need to return the default ServerRequestDispatcher.
    
    public CorbaServerRequestDispatcher getServerRequestDispatcher(int scid)
    {
	CorbaServerRequestDispatcher sdel =
	    (CorbaServerRequestDispatcher)(SDRegistry.get(scid)) ;
	if ( sdel == null )
            sdel = (CorbaServerRequestDispatcher)(SDRegistry.get(defaultId)) ;

	return sdel;
    }

    public CorbaServerRequestDispatcher getServerRequestDispatcher( String name ) 
    {
	CorbaServerRequestDispatcher sdel =
	    (CorbaServerRequestDispatcher)stringToServerSubcontract.get( name ) ;

	if ( sdel == null )
            sdel = (CorbaServerRequestDispatcher)(SDRegistry.get(defaultId)) ;

	return sdel;
    }

    public LocalClientRequestDispatcherFactory getLocalClientRequestDispatcherFactory( 
	int scid )
    {
	LocalClientRequestDispatcherFactory factory = 
	    (LocalClientRequestDispatcherFactory)(LCSFRegistry.get(scid)) ;
	if (factory == null) {
	    factory = (LocalClientRequestDispatcherFactory)(LCSFRegistry.get(defaultId)) ;
	}

	return factory ;
    }

    public ClientRequestDispatcher getClientRequestDispatcher( int scid )
    {
	ClientRequestDispatcher subcontract = 
	    (ClientRequestDispatcher)(CSRegistry.get(scid)) ;
	if (subcontract == null) {
	    subcontract = (ClientRequestDispatcher)(CSRegistry.get(defaultId)) ;
	}

	return subcontract ;
    }

    public ObjectAdapterFactory getObjectAdapterFactory( int scid )
    {
	ObjectAdapterFactory oaf =
            (ObjectAdapterFactory)(OAFRegistry.get(scid)) ;
	if ( oaf == null )
            oaf = (ObjectAdapterFactory)(OAFRegistry.get(defaultId)) ;

	return oaf;
    }

    public Set getObjectAdapterFactories() 
    {
	return objectAdapterFactoriesView ;
    }
}