Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: skydive-project/skydive
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: f74f52ae782c8a28eae286323efa4d11dc842682
Choose a base ref
..
head repository: skydive-project/skydive
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 04e727ab11c1192f1dd1e6b4f387ecd4f452ced8
Choose a head ref
Showing with 1 addition and 2 deletions.
  1. +1 −2 statics/workflows/ping-mesh.yaml
3 changes: 1 addition & 2 deletions statics/workflows/ping-mesh.yaml
Original file line number Diff line number Diff line change
@@ -27,6 +27,7 @@ Source: |
var pktform = {};
client.gremlin.query(src).then(function(nodes) {
nodes.forEach(function(node) {
if (node.Metadata.TID == dst) { return; }
sources.push(node.Metadata.TID);
});
})
@@ -38,7 +39,6 @@ Source: |
return sleep(1000)
}).then(function () {
sources.forEach(function(s) {
if (s == dst) { return; }
var packetInjection = new PacketInjection();
packetInjection.Src = "G.V().Has('TID', '" + s + "')"
packetInjection.Dst = "G.V().Has('TID', '" + dst + "')"
@@ -80,7 +80,6 @@ Source: |
return sleep(1000)
}).then(function () {
sources.forEach(function(s) {
if (s == dst) { return; }
if (protocol == "icmp4") {
client.G.Flows().Has("ICMP.ID", pktform[s].ICMPID, "Network.A", pktform[s].SrcIP).then(function(flows) {
result[s] = {"Connected" : flows.length > 0 && flows[0].Metric.ABPackets > 0, "Replied" : flows.length > 0 && flows[0].Metric.BAPackets > 0};