netty-codec-socks-4.1.29.Final.jar
登录
|
io.netty:netty-codec-socks:4.1.29.Final
io
netty
handler
codec
socks
SocksAuthRequestDecoder.java
SocksSubnegotiationVersion.java
package-info.java
SocksResponseType.java
UnknownSocksResponse.java
SocksCmdRequestDecoder.java
SocksRequestType.java
SocksCmdType.java
SocksCmdResponse.java
SocksAuthRequest.java
SocksCommonUtils.java
SocksMessageType.java
SocksCmdRequest.java
SocksRequest.java
SocksInitRequestDecoder.java
SocksAuthResponse.java
SocksAuthScheme.java
SocksAddressType.java
SocksMessage.java
SocksProtocolVersion.java
SocksInitResponse.java
SocksInitRequest.java
SocksInitResponseDecoder.java
SocksAuthStatus.java
SocksMessageEncoder.java
UnknownSocksRequest.java
SocksAuthResponseDecoder.java
SocksCmdResponseDecoder.java
SocksResponse.java
SocksCmdStatus.java
socksx
META-INF
SocksInitResponseDecoder.java
清空
类结构
/* * Copyright 2012 The Netty Project * * The Netty Project licenses this file to you under the Apache License, * version 2.0 (the "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at: * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the * License for the specific language governing permissions and limitations * under the License. */ package io.netty.handler.codec.socks; import io.netty.buffer.
ByteBuf
; import io.netty.channel.
ChannelHandlerContext
; import io.netty.handler.codec.
ReplayingDecoder
; import io.netty.handler.codec.socks.
SocksInitResponseDecoder
.
State
; import java.util.
List
; /** * Decodes {@link ByteBuf}s into {@link SocksInitResponse}. * Before returning SocksResponse decoder removes itself from pipeline. */ public class
SocksInitResponseDecoder
extends
ReplayingDecoder
<
State
> { public
SocksInitResponseDecoder
() { super(
State
.
CHECK_PROTOCOL_VERSION
); } @
Override
protected void
decode
(
ChannelHandlerContext
ctx
,
ByteBuf
byteBuf
,
List
<
Object
>
out
) throws
Exception
{ switch (
state
()) { case
CHECK_PROTOCOL_VERSION
: { if (
byteBuf
.
readByte
() !=
SocksProtocolVersion
.
SOCKS5
.
byteValue
()) {
out
.
add
(
SocksCommonUtils
.
UNKNOWN_SOCKS_RESPONSE
); break; }
checkpoint
(
State
.
READ_PREFERRED_AUTH_TYPE
); } case
READ_PREFERRED_AUTH_TYPE
: {
SocksAuthScheme
authScheme
=
SocksAuthScheme
.
valueOf
(
byteBuf
.
readByte
());
out
.
add
(new
SocksInitResponse
(
authScheme
)); break; } default: { throw new
Error
(); } }
ctx
.
pipeline
().
remove
(this); } enum
State
{ CHECK_PROTOCOL_VERSION, READ_PREFERRED_AUTH_TYPE } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口