clientsideproxy.java

real-time design patterns in Real-time java

package designPatterns.Proxy;

import java.util.Iterator;
import java.util.LinkedList;
import javax.realtime.LTMemory;
import designPatterns.Data;
import rtComm.LinkQueue;


public class ClientSideProxy extends Proxy implements ProxyClient {

	private LinkQueue commBus;
	
	// Logic of notify method encapsulated into a scoped class 
	ScopedNotify sNotify;
	
	public ClientSideProxy(Data data, LinkQueue commBus) {
		super(data);
		this.commBus = commBus;
		sNotify = new ScopedNotify(clientsList, this.data);
	}

	private LTMemory mem = new LTMemory(1024*16);	

	static class ScopedNotify implements Runnable {
		private LinkedList clients;
		private Data data;
		public ScopedNotify(LinkedList clients, Data data) {
			this.clients = clients;
			this.data = data;
		}
		public void run() {
			Iterator i = clients.iterator();
			while (i.hasNext()) {
				ProxyClient cl = (ProxyClient)i.next();
				cl.accept(data);
			}
		}
	}
	
	protected void notifyClients() {
		mem.enter(sNotify);
	}

	public LinkQueue getCommBus() {
		return commBus;
	}
	
	public void checkData(boolean pend) {
		Data data = commBus.deQueue(pend); 
		accept(data);
		commBus.recycle(data);
	}
}