quickserver/src/main/org/quickserver/util/pool/ByteBufferObjectFactory.java

/*
 * This file is part of the QuickServer library 
 * Copyright (C) QuickServer.org
 *
 * Use, modification, copying and distribution of this software is subject to
 * the terms and conditions of the GNU Lesser General Public License. 
 * You should have received a copy of the GNU LGP License along with this 
 * library; if not, you can download a copy from <http://www.quickserver.org/>.
 *
 * For questions, suggestions, bug-reports, enhancement-requests etc.
 * visit http://www.quickserver.org
 *
 */

package org.quickserver.util.pool;

import java.nio.ByteBuffer;
import org.apache.commons.pool.BasePoolableObjectFactory; 

/**
 * A factory for creating java.nio.ByteBuffer instances. 
 * @author Akshathkumar Shetty
 * @since 1.3
 */
public class ByteBufferObjectFactory extends BasePoolableObjectFactory {
	int bufferSize = -1;
	boolean useDirectByteBuffer = true;

	public ByteBufferObjectFactory(int bufferSize, boolean useDirectByteBuffer) {
		this.bufferSize = bufferSize;
		this.useDirectByteBuffer = useDirectByteBuffer;
	}

	//Creates an instance that can be returned by the pool. 
	public Object makeObject() { 
		if(useDirectByteBuffer)
	        return ByteBuffer.allocateDirect(bufferSize);
		else
			return ByteBuffer.allocate(bufferSize);
	} 

	//Uninitialize an instance to be returned to the pool. 
    public void passivateObject(Object obj) {
		ByteBuffer ch = (ByteBuffer)obj;
		ch.clear();
    } 

	//Reinitialize an instance to be returned by the pool. 
    public void activateObject(Object obj) {
	}
	
	//Destroys an instance no longer needed by the pool. 
	public void destroyObject(Object obj) {
		if(obj==null) return;
		passivateObject(obj);
		obj = null;
	}

	//Ensures that the instance is safe to be returned by the pool. 
	public boolean validateObject(Object obj) {
		if(obj==null) 
			return false;
		else
			return true;
	}
}