mrequestreceiverobserver2.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MDoorman;

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

public final class MRequestReceiverObserver2
implements MObserver1
{
private MRequestReceiver receiver;
private MSession session;
private Socket socket;
// --------------------------------------------------------------------------------
public MRequestReceiverObserver2( MRequestReceiver receiver, MSession session, Socket socket )
{
this.receiver = receiver;
this.session = session;
this.socket = socket;
}
// --------------------------------------------------------------------------------
public void update()
{
int state = receiver.getState();
if( state == MRequestReceiver.SUCCESS )
	{
	MHttpRequest request = receiver.getRequest();
	if( request.getMethodType() == MHttpRequest.CONNECT )
		{
		session.closeServerSide();
		MSslInitializer initializer = new MSslInitializer( request, receiver.getInputStream(), socket );
		initializer.execute();
		}
	else
		{
		session.onRequestReceived( request );	
		}
	}
else if( state == MRequestReceiver.ERROR )
	{
	session.errorClose();
	}
}
// --------------------------------------------------------------------------------
}