← Back to branch summary

~kirkland/eucalyptus/label-metadata

« back to all changes in this revision

Viewing changes to clc/modules/wsstack/src/main/java/com/eucalyptus/ws/handlers/ChannelStateMonitor.java

  • Committer: Neil
  • Date: 2010-06-18 23:43:02 UTC
  • mfrom: (1195.1.47 main)
  • Revision ID: neil@pall-20100618234302-ylt6pznuzk7j09pw
latest merge from main.

Show diffs side-by-side

added added

removed removed

Lines of Context:
clc/modules/wsstack/src/main/java/com/eucalyptus/ws/handlers/ChannelStateMonitor.java
10
10
import org.jboss.netty.channel.SimpleChannelHandler;
11
11
import com.eucalyptus.http.MappingHttpMessage;
12
12
import com.eucalyptus.records.EventType;
13
 
import edu.ucsb.eucalyptus.msgs.EucalyptusMessage;
14
 
import edu.ucsb.eucalyptus.msgs.EventRecord;
 
13
import edu.ucsb.eucalyptus.msgs.BaseMessage;
 
14
import com.eucalyptus.records.EventRecord;
15
15
 
16
16
@ChannelPipelineCoverage( "one" )
17
17
public class ChannelStateMonitor extends SimpleChannelHandler {
41
41
  @Override
42
42
  public void channelConnected( ChannelHandlerContext ctx, ChannelStateEvent e ) throws Exception {
43
43
    openTime.getAndSet( System.currentTimeMillis( ) );
44
 
    LOG.trace( EventRecord.here( ctx.getPipeline( ).getLast( ).getClass( ), EventType.SOCKET_OPEN, ctx.getChannel( ).getLocalAddress( ).toString( ), ctx.getChannel( ).getRemoteAddress( ).toString( ) ) );
 
44
    EventRecord.here( ctx.getPipeline( ).getLast( ).getClass( ), EventType.SOCKET_OPEN, ctx.getChannel( ).getLocalAddress( ).toString( ), ctx.getChannel( ).getRemoteAddress( ).toString( ) ).trace( );
45
45
    super.channelConnected( ctx, e );
46
46
  }
47
47
  
62
62
    if ( e.getMessage( ) instanceof MappingHttpMessage ) {
63
63
      MappingHttpMessage msg = ( MappingHttpMessage ) e.getMessage( );
64
64
      writeBytes.addAndGet( msg.getContent( ).readableBytes( ) );
65
 
      if ( msg.getMessage( ) != null && msg.getMessage( ) instanceof EucalyptusMessage ) {
66
 
        this.correlationId = ( ( EucalyptusMessage ) msg.getMessage( ) ).getCorrelationId( );
67
 
        this.eventUserId = ( ( EucalyptusMessage ) msg.getMessage( ) ).getUserId( );
 
65
      if ( msg.getMessage( ) != null && msg.getMessage( ) instanceof BaseMessage ) {
 
66
        this.correlationId = ( ( BaseMessage ) msg.getMessage( ) ).getCorrelationId( );
 
67
        this.eventUserId = ( ( BaseMessage ) msg.getMessage( ) ).getUserId( );
68
68
      }
69
69
    } else if ( e.getMessage( ) instanceof ChannelBuffer ) {
70
70
      ChannelBuffer msg = ( ChannelBuffer ) e.getMessage( );