macceptorobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MTcpProxy;

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

public class MAcceptorObserver
implements MObserver1
{
private MMultiAcceptor acceptor;
//----------------------------------------------------------------------------------------
public MAcceptorObserver( MMultiAcceptor in_acceptor )
{
acceptor = in_acceptor;
}
//----------------------------------------------------------------------------------------
public void update()
{
int state = acceptor.getState();
if( state == MMultiAcceptor.ACCEPTED )
	{
	Socket clientSideSocket = acceptor.getSocket();
	
	MTcpProxy.getInstance().connect( clientSideSocket );
	}
else if( state == MMultiAcceptor.ERROR )
	{
	MTcpProxy.getInstance().exit();
	}
}
//----------------------------------------------------------------------------------------
}