We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6151641 commit ec81cb1Copy full SHA for ec81cb1
1 file changed
agent/src/flow_generator/protocol_logs/rpc/dubbo.rs
@@ -1181,12 +1181,20 @@ impl DubboHeader {
1181
self.status_code = payload[3];
1182
self.request_id = read_u64_be(&payload[4..]) as i64;
1183
self.data_length = read_u32_be(&payload[12..]) as i32;
1184
+ if self.is_event() {
1185
+ return Err(Error::DubboHeaderParseFailed);
1186
+ }
1187
+
1188
Ok(())
1189
}
1190
1191
+ pub fn is_event(&self) -> bool {
1192
+ self.event == 1
1193
1194
1195
pub fn check(&self) -> bool {
- // 不通过响应识别Dubbo
- if self.data_type == 0 {
1196
+ // 不通过响应和事件识别Dubbo
1197
+ if self.data_type == 0 || self.is_event() {
1198
return false;
1199
1200
// 请求时状态码一定是0
0 commit comments