mconnectorobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MDoorman;

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

public class MConnectorObserver
implements MObserver1
{
private MSession session;
private MConnector connector;
// --------------------------------------------------------------------------------
public MConnectorObserver( MConnector connector, MSession session )
{
this.session = session;
this.connector = connector;
}
// --------------------------------------------------------------------------------
public void update()
{
int state = connector.getState();
if( state == MConnector.CONNECTED )
	{
	try
		{
		Socket socket = connector.getSocket();
		session.setSSocket( socket );
		session.onServerConnected( new BufferedInputStream( socket.getInputStream() ), socket.getOutputStream() );	
		}
	catch( IOException e )
		{
		session.errorClose();
		}
	}
else if( state == MConnector.ERROR )
	{
	session.errorClose();
	}
}
// --------------------------------------------------------------------------------
}