Skip to content

Commit 7c8d0d9

Browse files
committed
Resolve server binding protocol type dissector even when origin is ephemeral
1 parent 153aac1 commit 7c8d0d9

File tree

1 file changed

+9
-4
lines changed
  • incubator/command-dump/src/main/java/io/aklivity/zilla/runtime/command/dump/internal/airline

1 file changed

+9
-4
lines changed

incubator/command-dump/src/main/java/io/aklivity/zilla/runtime/command/dump/internal/airline/ZillaDumpCommand.java

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -777,22 +777,27 @@ private int resolveProtocolTypeId(
777777
long routedId)
778778
{
779779
int protocolTypeLabelId = 0;
780-
long[] origin = lookupBindingInfo.apply(originId);
781-
long[] routed = lookupBindingInfo.apply(routedId);
782780

783-
if (origin != null && routed != null)
781+
long[] routed = lookupBindingInfo.apply(routedId);
782+
if (routed != null)
784783
{
785784
String routedBindingKind = lookupLabel.apply(localId(routed[KIND_ID_INDEX]));
786785
if (SERVER_KIND.equals(routedBindingKind))
787786
{
788787
protocolTypeLabelId = localId(routed[ROUTED_TYPE_ID_INDEX]);
789788
}
790-
String originBindingKind = lookupLabel.apply(localId(routed[KIND_ID_INDEX]));
789+
}
790+
791+
long[] origin = lookupBindingInfo.apply(originId);
792+
if (origin != null)
793+
{
794+
String originBindingKind = lookupLabel.apply(localId(origin[KIND_ID_INDEX]));
791795
if (protocolTypeLabelId == 0 && CLIENT_KIND.equals(originBindingKind))
792796
{
793797
protocolTypeLabelId = localId(origin[ORIGIN_TYPE_ID_INDEX]);
794798
}
795799
}
800+
796801
return supplyLabelCrc(protocolTypeLabelId);
797802
}
798803

0 commit comments

Comments
 (0)