macceptorobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MTCPS_cui;

import net.jumperz.util.*;
import net.jumperz.net.*;
import java.net.*;

public class MAcceptorObserver
implements MObserver1
{
private MSingleAcceptor acceptor;
private MTCPS_cui TCPS_cui;
//---------------------------------------------------------------------------
public MAcceptorObserver( MSingleAcceptor IN_acceptor, MTCPS_cui IN_TCPS_cui )
{
acceptor = IN_acceptor;
TCPS_cui = IN_TCPS_cui;
}
//---------------------------------------------------------------------------
public void update()
{
int state = acceptor.getState();
if( state == MSingleAcceptor.CONNECTED )
	{
	Socket socket = acceptor.getSocket();
	TCPS_cui.startSession( socket );
	}
else if( state == MSingleAcceptor.ERROR )
	{
	TCPS_cui.exit();
	}
}
//---------------------------------------------------------------------------
}