decoderregistryimp.java

Java Communicating Agents是一个用于开发网络反应式信息agent的框架

/*
 * $Source: /home/data/cvsroot/src/jacomma/icm/io/imp/DecoderRegistryImp.java,v $
 * $Revision: 1.5 $
 * $Date: 2000/10/28 20:09:07 $
 *
 * This file is part of the jacomma framework
 * Copyright (c) 2000 	Dimitrios Vyzovitis
 *			mailto:[e-mail]
 *			
 *
 *			
 *			
 *			
 *
 *	This library is free software; you can redistribute it and/or modify
 *	it under the terms of the GNU Library General Public License as published by
 *	the Free Software Foundation; either version 2 of the License, or
 *	(at your option) any later version.
 *
 *	This library is distributed in the hope that it will be useful,
 *	but WITHOUT ANY WARRANTY; without even the implied warranty of
 *	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *	GNU Library General Public License for more details.
 *
 *	You should have received a copy of the GNU Library General Public License
 *	along with this library; if not, write to the Free Software
 *	Foundation, Inc., 59 Temple Place, Suite 330, 
 *	Boston, MA  02111-1307  USA
 */

package jacomma.icm.io.imp;

import jacomma.icm.io.EncObjectDecoder;
import jacomma.icm.io.EncObject;
import jacomma.icm.io.EncObjectType;

import jacomma.util.Environment;
import jacomma.util.RdWrMap;
import jacomma.util.CheckedException;
import jacomma.util.TypeIterator;
import jacomma.util.ArrayTypeIterator;

import java.util.Iterator;
import java.util.Map;
import java.util.StringTokenizer;
import java.util.ArrayList;
import java.util.List;

import java.lang.reflect.Array;

/**
 * TBA
 **/
public class DecoderRegistryImp implements EncObjectDecoder.Registry {

	RdWrMap all_ = new RdWrMap();
	RdWrMap some_ = new RdWrMap();
		
	public DecoderRegistryImp() {}

	public void load( java.util.Properties prop ) {
		for ( Iterator it = prop.entrySet().iterator();
			  it.hasNext(); ) try {
				  Map.Entry next = (Map.Entry)it.next();
				  String key = (String)next.getKey();
				  if ( "registry".equals( key ) ) continue;
				  
				  ArrayList types = new ArrayList();
				  for ( StringTokenizer tok = new StringTokenizer( (String)next.getValue() );
						tok.hasMoreTokens();
						types.add( EncObjectType.typeOf( tok.nextToken() ) ) );
								   
				  registerDecoder( types, Class.forName( key ) );
			  } catch ( Exception exc ) {
				  exc.printStackTrace();
			  }
	}

	public EncObjectDecoder getDecoder( EncObject obj ) {
		return getDecoder( obj, null );
	}

	public EncObjectDecoder getDecoder( EncObject obj, Object hint ) {
		// Check for specially suited Decoders
		List l = (List)some_.get( obj.getType() );
		EncObjectDecoder dec = null;
		
		if ( l != null )
			for( Iterator it = l.iterator(); dec == null && it.hasNext(); ) {
				dec = (EncObjectDecoder)it.next();
				if ( !dec.canHandle( obj, hint ) ) 
					dec = null;
			}
		
		if ( dec == null ) // nothing specially tuned for the object
			dec = getDecoder( obj.getType() ); // grab the default
		
		return dec;
	}

	public EncObjectDecoder getDecoder( EncObjectType target ) {
		return (EncObjectDecoder)all_.get( target );
	}


	public void registerDecoder( java.util.Collection types, Class c ) {
		try {
			EncObjectDecoder dec = (EncObjectDecoder)c.newInstance();
			for ( Iterator it = types.iterator();
				  it.hasNext();
				  registerDecoder( (EncObjectType)it.next(), dec ) );
		} catch ( InstantiationException exc ) {
			throw new CheckedException( exc );
		} catch ( IllegalAccessException exc ) {
			throw new CheckedException( exc );
		}
	}

	public void registerDecoder( EncObjectType t, EncObjectDecoder dec ) {
		if ( dec.canHandle( t ) )
			all_.put( t, dec );
		else if ( dec.canHandleSome( t ) ) {
			some_.lock.wrlock();
			try {
				List l = (List)some_.get( t );
				if ( l == null ) {
					l = new ArrayList();
					some_.put( t, l );
				}
				if ( !l.contains( dec ) )
					l.add( dec );
			} finally {
				some_.lock.unlock();
			}
		} else
			throw new IllegalArgumentException( "Bad Decoder: " + dec
												+ "[" + t + "]" );
	}

	public void unregisterDecoder( EncObjectType t, EncObjectDecoder dec ) {
		// Only partial encoders.
		some_.lock.wrlock();
		try {
			List l;
			if ( (l = (List)some_.get( t )) != null )
				some_.remove( dec );
		} finally {
			some_.lock.unlock();
		}
	}
	
	public void dump() {
		all_.dump();
		some_.dump();
	}
	

}