mconnectorobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MDragonfly;

import java.io.*;
import java.net.*;

import javax.net.ssl.SSLSocket;

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

public final class MConnectorObserver
implements MObserver1
{
private MConnector connector;
private SSLSocket clientSideSocket;
//--------------------------------------------------------------------------
public MConnectorObserver( MConnector in_connector, SSLSocket in_clientSideSocket )
{
connector = in_connector;
clientSideSocket = in_clientSideSocket;
}
//--------------------------------------------------------------------------
public final void update()
{
int state = connector.getState();
if( state == MConnector.CONNECTED )
	{
	Socket serverSideSocket = connector.getSocket();
	MDragonfly.getInstance().startSession( clientSideSocket, serverSideSocket );
	}
else if( state == MConnector.ERROR )
	{
	try
		{
		clientSideSocket.close();
		}
	catch( IOException e )
		{
		e.printStackTrace();
		}
	}
}
//--------------------------------------------------------------------------
}