cfresource.java

CoolFace是基于jxta的P2P系统

package com.cn.darkblue.util;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Queue;
import java.util.Vector;
import java.util.concurrent.DelayQueue;

import net.jxta.peergroup.PeerGroup;
import net.jxta.platform.NetworkManager;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.eclipse.swt.widgets.Shell;

import com.cn.darkblue.cache.ICache;
import com.cn.darkblue.cache.ImplCache;
import com.cn.darkblue.helper.IGroupChat;
import com.cn.darkblue.helper.IViewControl;


public class CFResource {
	public static CFResource res;
	//private static final Log log = LogFactory.getLog(CFResource.class);
	NetworkManager manager = null;
	PeerGroup worldGroup = null;
	IViewControl mUIControl = null;
	
	String LMName = null;//机器名称
	String LMIPAddress = null;//机器IP
	
	//String defaultUser;
	//String defaultPsw;
	
	Vector <PeerGroup> groupCache = null;
	//Vector<PeerGroup> currSearchGroup = null;
	Vector<Shell> shellCache = null;
	HashMap joinPGMap = null;
	
	Queue CMDqueue = null;//请求命令队列
	Vector<IGroupChat> groupItrtWins = null;
	private CFResource(){
		groupCache = new Vector<PeerGroup>();
		//currSearchGroup = new Vector<PeerGroup>();
		shellCache = new Vector<Shell>();
		joinPGMap = new HashMap();
		
		CMDqueue = new DelayQueue();
		
		groupItrtWins = new Vector<IGroupChat>();
	}
	
	public static CFResource getInstance() {
		if (res == null)
			res = new CFResource();
		return res;
	}

	public Vector getGroupCache() {
		return groupCache;
	}

	public void setGroupCache(Vector groupCache) {
		this.groupCache = groupCache;
	}

	public NetworkManager getManager() {
		return manager;
	}

	public void setManager(NetworkManager manager) {
		this.manager = manager;
	}

	public PeerGroup getWorldGroup() {
		return worldGroup;
	}

	public void setWorldGroup(PeerGroup worldGroup) {
		this.worldGroup = worldGroup;
	}

	public String getLMIPAddress() {
		return LMIPAddress;
	}

	public void setLMIPAddress(String address) {
		LMIPAddress = address;
	}

	public String getLMName() {
		return LMName;
	}

	public void setLMName(String name) {
		LMName = name;
	}

	public IViewControl getMUIControl() {
		return mUIControl;
	}

	public void setMUIControl(IViewControl control) {
		mUIControl = control;
	}

	public Vector<Shell> getShellCache() {
		return shellCache;
	}
	
	public PeerGroup getCachePeerGroup(String id){
		PeerGroup pg = null;
		
		for(int i=0;i<groupCache.size();i++){
			pg = groupCache.get(i);
			if(id.equals(pg.getPeerGroupID().toString()))
				return pg;
		}
		return null;
	}

//	public Vector<PeerGroup> getCurrSearchGroup() {
//		return currSearchGroup;
//	}
//
//	public void setCurrSearchGroup(Vector<PeerGroup> currSearchGroup) {
//		this.currSearchGroup = currSearchGroup;
//	}

	public HashMap getJoinPGMap() {
		return joinPGMap;
	}

	public void setJoinPGMap(HashMap joinPGMap) {
		this.joinPGMap = joinPGMap;
	}

	public Queue getCMDqueue() {
		return CMDqueue;
	}

	public void setCMDqueue(Queue dqueue) {
		CMDqueue = dqueue;
	}

	public Vector<IGroupChat> getGroupItrtWins() {
		return groupItrtWins;
	}

	public void setGroupItrtWins(Vector<IGroupChat> groupItrtWins) {
		this.groupItrtWins = groupItrtWins;
	}
}