Skip to content

Commit

Permalink
Add frameType method to Http2Frame.
Browse files Browse the repository at this point in the history
  • Loading branch information
He-Pin committed Apr 21, 2024
1 parent ffdb7c7 commit 445dd3f
Show file tree
Hide file tree
Showing 13 changed files with 62 additions and 0 deletions.
Expand Up @@ -87,6 +87,11 @@ public DefaultHttp2DataFrame stream(Http2FrameStream stream) {
return this;
}

@Override
public byte frameType() {
return Http2FrameTypes.DATA;
}

@Override
public String name() {
return "DATA";
Expand Down
Expand Up @@ -83,6 +83,11 @@ public DefaultHttp2GoAwayFrame(long errorCode, ByteBuf content) {
this.lastStreamId = lastStreamId;
}

@Override
public byte frameType() {
return Http2FrameTypes.GO_AWAY;
}

@Override
public String name() {
return "GOAWAY";
Expand Down
Expand Up @@ -69,6 +69,11 @@ public DefaultHttp2HeadersFrame stream(Http2FrameStream stream) {
return this;
}

@Override
public byte frameType() {
return Http2FrameTypes.HEADERS;
}

@Override
public String name() {
return "HEADERS";
Expand Down
Expand Up @@ -42,6 +42,11 @@ public boolean ack() {
return ack;
}

@Override
public byte frameType() {
return Http2FrameTypes.PING;
}

@Override
public String name() {
return "PING";
Expand Down
Expand Up @@ -54,6 +54,11 @@ public DefaultHttp2PriorityFrame stream(Http2FrameStream stream) {
return this;
}

@Override
public byte frameType() {
return Http2FrameTypes.PRIORITY;
}

@Override
public String name() {
return "PRIORITY_FRAME";
Expand Down
Expand Up @@ -84,6 +84,11 @@ public Http2FrameStream stream() {
return streamFrame;
}

@Override
public byte frameType() {
return Http2FrameTypes.PUSH_PROMISE;
}

@Override
public String name() {
return "PUSH_PROMISE_FRAME";
Expand Down
Expand Up @@ -52,6 +52,11 @@ public DefaultHttp2ResetFrame stream(Http2FrameStream stream) {
return this;
}

@Override
public byte frameType() {
return Http2FrameTypes.RST_STREAM;
}

@Override
public String name() {
return "RST_STREAM";
Expand Down
Expand Up @@ -21,6 +21,12 @@
* The default {@link Http2SettingsAckFrame} implementation.
*/
final class DefaultHttp2SettingsAckFrame implements Http2SettingsAckFrame {

@Override
public byte frameType() {
return Http2FrameTypes.SETTINGS;
}

@Override
public String name() {
return "SETTINGS(ACK)";
Expand Down
Expand Up @@ -37,6 +37,11 @@ public Http2Settings settings() {
return settings;
}

@Override
public byte frameType() {
return Http2FrameTypes.SETTINGS;
}

@Override
public String name() {
return "SETTINGS";
Expand Down
Expand Up @@ -36,6 +36,11 @@ public DefaultHttp2WindowUpdateFrame stream(Http2FrameStream stream) {
return this;
}

@Override
public byte frameType() {
return Http2FrameTypes.WINDOW_UPDATE;
}

@Override
public String name() {
return "WINDOW_UPDATE";
Expand Down
Expand Up @@ -21,6 +21,11 @@
@UnstableApi
public interface Http2Frame {

/**
* Returns the type of the HTTP/2 frame e.g. DATA, GOAWAY, etc.
*/
byte frameType();

/**
* Returns the name of the HTTP/2 frame e.g. DATA, GOAWAY, etc.
*/
Expand Down
Expand Up @@ -28,6 +28,7 @@ public interface Http2UnknownFrame extends Http2StreamFrame, ByteBufHolder {
@Override
Http2UnknownFrame stream(Http2FrameStream stream);

@Override
byte frameType();

Http2Flags flags();
Expand Down
Expand Up @@ -352,6 +352,11 @@ public void receiveGoaway() throws Exception {
@Test
public void unknownFrameTypeShouldThrowAndBeReleased() throws Exception {
class UnknownHttp2Frame extends AbstractReferenceCounted implements Http2Frame {
@Override
public byte frameType() {
return 0xA;
}

@Override
public String name() {
return "UNKNOWN";
Expand Down

0 comments on commit 445dd3f

Please sign in to comment.