import io.undertow.websockets.core.StreamSourceFrameChannel; //导入依赖的package包/类
@Override
public StreamSourceFrameChannel getChannel(Pooled<ByteBuffer> pooled) {
    StreamSourceFrameChannel channel = createChannel(pooled);
    if (frameFinalFlag) {
        channel.finalFrame();
    } else {
        fragmentedChannel = channel;
    }
    return channel;
}
 

import io.undertow.websockets.core.StreamSourceFrameChannel; //导入依赖的package包/类
@Override
public AbstractFramedStreamSourceChannel<?, ?, ?> getExistingChannel() {
    if (frameOpcode == OPCODE_CONT) {
        StreamSourceFrameChannel ret = fragmentedChannel;
        if(frameFinalFlag) {
            fragmentedChannel = null;
        }
        return ret;
    }
    return null;
}
 

import io.undertow.websockets.core.StreamSourceFrameChannel; //导入依赖的package包/类
@Override
protected void onClose(WebSocketChannel webSocketChannel, StreamSourceFrameChannel ssfchannel) throws IOException {
  LOGGER.info("onClose: " + this);
  myChannel.getReceiveSetter().set(null);
  unregisterSession(WebSocketSession.this);
  super.onClose(webSocketChannel, ssfchannel);
}
 

import io.undertow.websockets.core.StreamSourceFrameChannel; //导入依赖的package包/类
public StreamSourceFrameChannel createChannel(Pooled<ByteBuffer> pooled) {


            // Processing ping/pong/close frames because they cannot be
            // fragmented as per spec
            if (frameOpcode == OPCODE_PING) {
                if (frameMasked) {
                    return new WebSocket07PingFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, new Masker(maskingKey), pooled, framePayloadLength);
                } else {
                    return new WebSocket07PingFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, pooled, framePayloadLength);
                }
            }
            if (frameOpcode == OPCODE_PONG) {
                if (frameMasked) {
                    return new WebSocket07PongFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, new Masker(maskingKey), pooled, framePayloadLength);
                } else {
                    return new WebSocket07PongFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, pooled, framePayloadLength);
                }
            }
            if (frameOpcode == OPCODE_CLOSE) {
                if (frameMasked) {
                    return new WebSocket07CloseFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, new Masker(maskingKey), pooled, framePayloadLength);
                } else {
                    return new WebSocket07CloseFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, pooled, framePayloadLength);
                }
            }

            if (frameOpcode == OPCODE_TEXT) {
                // try to grab the checker which was used before
                UTF8Checker checker = WebSocket07Channel.this.checker;
                if (checker == null) {
                    checker = new UTF8Checker();
                }

                if (!frameFinalFlag) {
                    // if this is not the final fragment store the used checker to use it in later fragments also
                    WebSocket07Channel.this.checker = checker;
                } else {
                    // was the final fragment reset the checker to null
                    WebSocket07Channel.this.checker = null;
                }

                if (frameMasked) {
                    return new WebSocket07TextFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, frameFinalFlag, new Masker(maskingKey), checker, pooled, framePayloadLength);
                } else {
                    return new WebSocket07TextFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, frameFinalFlag, checker, pooled, framePayloadLength);
                }
            } else if (frameOpcode == OPCODE_BINARY) {
                if (frameMasked) {
                    return new WebSocket07BinaryFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, frameFinalFlag, new Masker(maskingKey), pooled, framePayloadLength);
                } else {
                    return new WebSocket07BinaryFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, frameFinalFlag, pooled, framePayloadLength);
                }
            } else if (frameOpcode == OPCODE_CONT) {
                final ChannelFunction[] functions;
                if (frameMasked && checker != null) {
                    functions = new ChannelFunction[2];
                    functions[0] = new Masker(maskingKey);
                    functions[1] = checker;
                } else if (frameMasked) {
                    functions = new ChannelFunction[1];
                    functions[0] = new Masker(maskingKey);
                } else if (checker != null) {
                    functions = new ChannelFunction[1];
                    functions[0] = checker;
                } else {
                    functions = EMPTY_FUNCTIONS;
                }
                if (frameMasked) {
                    return new WebSocket07ContinuationFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, frameFinalFlag, pooled, framePayloadLength, functions);
                } else {
                    return new WebSocket07ContinuationFrameSourceChannel(WebSocket07Channel.this, framePayloadLength, frameRsv, frameFinalFlag, pooled, framePayloadLength, functions);
                }
            } else {
                throw WebSocketMessages.MESSAGES.unsupportedOpCode(frameOpcode);
            }
        }
 

import io.undertow.websockets.core.StreamSourceFrameChannel; //导入依赖的package包/类
@Override
protected void onClose(WebSocketChannel webSocketChannel, StreamSourceFrameChannel channel)
    throws IOException {
  activeChannels.remove(webSocketChannel);
  super.onClose(webSocketChannel, channel);
}
 

import io.undertow.websockets.core.StreamSourceFrameChannel; //导入依赖的package包/类
@Override
protected void onClose(final WebSocketChannel webSocketChannel, final StreamSourceFrameChannel channel) throws IOException {
    super.onClose(webSocketChannel, channel);

    UaiWebSocketContext.removeClosed();
}
 

import io.undertow.websockets.core.StreamSourceFrameChannel; //导入依赖的package包/类
@Test
public void isClosingWithoutError() throws IOException {
    final UaiWebSocketListenerTest uaiWebSocketListenerTest = new UaiWebSocketListenerTest();

    uaiWebSocketListenerTest.onClose(Mockito.mock(WebSocket07Channel.class), Mockito.mock(StreamSourceFrameChannel.class));
}
 

import io.undertow.websockets.core.StreamSourceFrameChannel; //导入依赖的package包/类
@Override
protected void onClose(WebSocketChannel socket, StreamSourceFrameChannel channel) throws IOException {
    super.onClose(socket, channel);
    if (this.chan.remove(socket))
        onDisconnected(socket);
}