mresponsesenderobserver.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.httptunnel.MREYE;

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

public final class MResponseSenderObserver
implements MObserver1
{
private MSender sender;
private Socket socket;
private MResponse response;
//-------------------------------------------------------------------------------------------
public MResponseSenderObserver( MSender in_sender, Socket in_socket, MResponse in_response )
{
sender		= in_sender;
socket		= in_socket;
response	= in_response;
}
//-------------------------------------------------------------------------------------------
public final void update()
{
int state = sender.getState();
if( state == MSender.SUCCESS )
	{
	if( !socket.isClosed() )
		{
		try
			{
			socket.close();
			}
		catch( IOException e )
			{
			}
		}
	}
else
	{
	String sessionName = response.getTunnelData().getSessionName();
	MSession session = MSessionManager.getInstance().getSession( sessionName );
	MREYE.getInstance().endLocalSession( session );
	}
}
//-------------------------------------------------------------------------------------------
}