mconnectorobserver.java

来自「httptunnel.jar httptunnel java 源码」· Java 代码 · 共 41 行

package net.jumperz.app.MTCPC;

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

public class MConnectorObserver
implements MObserver1
{
private MConnector Connector;
private MTCPC TCPC;
//-----------------------------------------------------------------------------
public MConnectorObserver( MConnector IN_Connector, MTCPC IN_TCPC )
{
Connector = IN_Connector;
TCPC = IN_TCPC;
}
//-----------------------------------------------------------------------------
public void update()
{
int state = Connector.getState();
if( state == MConnector.CONNECTED )
	{
	TCPC.startSession( Connector.getSocket() );
	}
else if( state == MConnector.ERROR )
	{
	int error_code = Connector.getErrorCode();
	if( error_code == MConnector.UNKNOWNHOST )
		{
		System.out.println( "Unknown Host." );
		}
	else if( error_code == MConnector.IOERROR )
		{
		System.out.println( "Connect Error." );
		}
	TCPC.stopSession();
	}
}
//-----------------------------------------------------------------------------
}