mconnectorobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.httptunnel.MREYE;

import java.io.*;
import net.jumperz.util.*;
import net.jumperz.net.*;
import net.jumperz.app.httptunnel.*;

public final class MConnectorObserver
implements MObserver1
{
private MConnector connector;
private MSession session;
//--------------------------------------------------------------------------
public MConnectorObserver( MConnector in_connector, MSession in_session )
{
connector = in_connector;
session = in_session;
}
//--------------------------------------------------------------------------
public final void update()
{
int state = connector.getState();
if( state == MConnector.CONNECTED )
	{
	session.setSocket( connector.getSocket() );
	MREYE.getInstance().startSession( session );

	try
		{
		MREYE.getInstance().checkData( session );
		}
	catch( IOException e )
		{
		e.printStackTrace();
		MREYE.getInstance().endSession( session );
		}
	}
else if( state == MConnector.ERROR )
	{
	MREYE.getInstance().endSession( session );
	}
}
//--------------------------------------------------------------------------
}