User: mnf999
Date: 01/12/18 23:21:18
Added: src/main/org/jboss/proxy/ejb ListEntityProxy.java
ReadAheadBuffer.java ReadAheadResult.java
Log:
Straight copy of the Oleg Nitz classes
Revision Changes Path
1.1 jboss/src/main/org/jboss/proxy/ejb/ListEntityProxy.java
Index: ListEntityProxy.java
===================================================================
/*
* JBoss, the OpenSource J2EE webOS
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.proxy.ejb;
import java.util.List;
import java.util.HashMap;
import java.util.Map;
import java.io.IOException;
import java.io.ObjectOutput;
import java.io.ObjectInput;
import java.rmi.MarshalledObject;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import javax.naming.InitialContext;
import javax.ejb.EJBObject;
import javax.ejb.EJBHome;
import org.jboss.invocation.Invoker;
import org.jboss.ejb.ListCacheKey;
/**
* An EJB CMP entity bean proxy class holds info about the List that the entity
belongs to,
* is used for reading ahead.
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Oleg Nitz</a>
* @version $Revision: 1.1 $
*/
public class ListEntityProxy
extends EntityProxy
implements InvocationHandler
{
// Constants -----------------------------------------------------
/** Serial Version Identifier. */
// private static final long serialVersionUID = -1523442773137704949L;
protected static final Method GET_READ_AHEAD_VALUES;
// Attributes ----------------------------------------------------
/**
* A List that this entity belongs to (used for reading ahead).
*/
private List list;
/**
* A hash map of read ahead values, maps Methods to values.
*/
private transient HashMap readAheadValues;
// Static --------------------------------------------------------
static {
try {
final Class[] empty = {};
GET_READ_AHEAD_VALUES =
ReadAheadBuffer.class.getMethod("getReadAheadValues", empty);
}
catch (Exception e) {
e.printStackTrace();
throw new ExceptionInInitializerError(e);
}
}
// Constructors --------------------------------------------------
/**
* No-argument constructor for externalization.
*/
public ListEntityProxy() {}
/**
* Construct a <tt>ListEntityProxy</tt>.
*
* @param name The JNDI name of the container that we proxy for.
* @param container The remote interface of the invoker for which
* this is a proxy for.
* @param id The primary key of the entity.
* @param optimize True if the proxy will attempt to optimize
* VM-local calls.
* @param list A List that this entity belongs to (used for reading
ahead).
* @param listId The list id.
* @param index The index of this entity in the list.
*
* @throws NullPointerException Id may not be null.
*/
public ListEntityProxy(String name,
Invoker invoker,
Object id,
List list,
long listId,
int index)
{
super(name, new ListCacheKey(id, listId, index), invoker);
this.list = list;
}
// Public --------------------------------------------------------
public Map getReadAheadValues() {
if (readAheadValues == null) {
readAheadValues = new HashMap();
}
return readAheadValues;
}
/**
* InvocationHandler implementation.
*
* @param proxy The proxy object.
* @param m The method being invoked.
* @param args The arguments for the method.
*
* @throws Throwable Any exception or error thrown while processing.
*/
public final Object invoke(final Object proxy,
final Method m,
Object[] args)
throws Throwable
{
Object result;
ReadAheadResult raResult;
Object[] aheadResult;
int from;
int to;
ReadAheadBuffer buf;
if (m.equals(GET_READ_AHEAD_VALUES)) {
return getReadAheadValues();
}
// have we read ahead the result?
if (readAheadValues != null) {
result = readAheadValues.get(m);
if (readAheadValues.containsKey(m)) {
return readAheadValues.remove(m);
}
}
result = super.invoke(proxy, m, args);
if (result instanceof ReadAheadResult) {
raResult = (ReadAheadResult) result;
aheadResult = raResult.getAheadResult();
from = ((ListCacheKey) cacheKey).getIndex() + 1;
to = Math.min(from + aheadResult.length, list.size());
for (int i = from; i < to; i++) {
buf = (ReadAheadBuffer) list.get(i);
buf.getReadAheadValues().put(m, aheadResult[i - from]);
}
return raResult.getMainResult();
} else {
return result;
}
}
// Package protected ---------------------------------------------
// Protected -----------------------------------------------------
/**
* Externalization support.
*
* @param out
*
* @throws IOException
*/
public void writeExternal(final ObjectOutput out)
throws IOException
{
super.writeExternal(out);
out.writeObject(list);
}
/**
* Externalization support.
*
* @param in
*
* @throws IOException
* @throws ClassNotFoundException
*/
public void readExternal(final ObjectInput in)
throws IOException, ClassNotFoundException
{
super.readExternal(in);
list = (List)in.readObject();
}
// Private -------------------------------------------------------
// Inner classes -------------------------------------------------
}
1.1 jboss/src/main/org/jboss/proxy/ejb/ReadAheadBuffer.java
Index: ReadAheadBuffer.java
===================================================================
/*
* JBoss, the OpenSource J2EE webOS
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.proxy.ejb;
import java.util.Map;
/**
* This interface is used for EJB CMP 2.0 read ahead algorithm for holding read
ahead values.
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Oleg Nitz</a>
* @version $Revision: 1.1 $
*/
public interface ReadAheadBuffer
{
/**
* The map of read ahead values, maps Methods to values.
*/
public Map getReadAheadValues();
}
1.1 jboss/src/main/org/jboss/proxy/ejb/ReadAheadResult.java
Index: ReadAheadResult.java
===================================================================
/*
* JBoss, the OpenSource J2EE webOS
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.proxy.ejb;
import java.io.Externalizable;
import java.io.ObjectOutput;
import java.io.ObjectInput;
import java.io.IOException;
import java.util.ArrayList;
/**
* A result of get-method invocation of CMP 2.0 entity bean in the case where read
ahead is turned on.
* Usage: on server set main result via {@link #setMainResult(java.lang.Object)} and
add ahead results via
* {@link #addAheadResult(java.lang.Object)}. On client get main result via {@link
#getMainResult()} and
* array of ahead results via {@link #getAheadResults()}.
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Oleg Nitz</a>
* @version $Revision: 1.1 $
*/
public class ReadAheadResult
implements Externalizable
{
// Constants -----------------------------------------------------
/** Serial Version Identifier. */
// private static final long serialVersionUID = -1523442773137704949L;
// Attributes ----------------------------------------------------
/**
* A List of read ahead values, during externalization is replaces by array
*/
private ArrayList aheadList = new ArrayList();
/**
* A List of read ahead values, during externalization is replaces by array
*/
private Object[] aheadArray;
/**
* A hash map of read ahead values, maps Methods to values.
*/
private Object mainResult;
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
public ReadAheadResult() {}
// Static --------------------------------------------------------
// Public --------------------------------------------------------
public void setMainResult(Object mainResult) {
this.mainResult = mainResult;
}
public void addAheadResult(Object aheadResult) {
aheadList.add(aheadResult);
}
public Object getMainResult() {
return mainResult;
}
public Object[] getAheadResult() {
if (aheadArray == null) {
aheadArray = aheadList.toArray(new Object[aheadList.size()]);
aheadList = null;
}
return aheadArray;
}
// Package protected ---------------------------------------------
// Protected -----------------------------------------------------
// Private -------------------------------------------------------
public void writeExternal(ObjectOutput out)
throws IOException
{
out.writeObject(mainResult);
out.writeObject(getAheadResult());
}
public void readExternal(ObjectInput in)
throws IOException, ClassNotFoundException
{
mainResult = in.readObject();
aheadArray = (Object[]) in.readObject();
}
// Inner classes -------------------------------------------------
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
