plainchannel.java

来自「Examples to create your Conferencing Sys」· Java 代码 · 共 68 行

/*
 * Copyright 2004 WIT-Software, Lda. 
 * - web: http://www.wit-software.com 
 * - email: [e-mail]
 *
 * All rights reserved. Relased under terms of the 
 * Creative Commons' Attribution-NonCommercial-ShareAlike license.
 */
package handlers;

import io.SelectorThread;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.SocketChannel;

/**
 * @author Nuno Santos
 */
public final class PlainChannel extends Channel {
	/**
	 * @param st
	 * @param sc
	 * @param listener
	 * @throws IOException
	 */
	public PlainChannel(SelectorThread st, SocketChannel sc, ChannelListener listener) throws IOException {
		super(st, sc, listener);		
		st.registerChannelNow(sc, 0, this);
	}

	public int read(ByteBuffer dst) throws IOException {
		return sc.read(dst);
	}

	public int write(ByteBuffer src) throws IOException {
		return sc.write(src);
	}

	public void registerForRead() throws IOException {
    st.addChannelInterestNow(sc, SelectionKey.OP_READ);
	}

	public void registerForWrite() throws IOException {		
		st.addChannelInterestNow(sc, SelectionKey.OP_WRITE);
	}

	public void unregisterForRead() throws IOException {
		st.removeChannelInterestNow(sc, SelectionKey.OP_READ);
	}

	public void unregisterForWrite() throws IOException {
		st.removeChannelInterestNow(sc, SelectionKey.OP_WRITE);
	}
	
	public void close() throws IOException {
		sc.close();		
	}

	public void handleRead() {
		listener.handleRead();		
	}

	public void handleWrite() {
		listener.handleWrite();		
	}
}