in network/benchmarks/netperf/nptest/nptest.go [279:346]
func allocateWorkToClient(workerState *workerState, workItem *WorkItem) {
if !allWorkersIdle() {
workItem.IsIdle = true
return
}
// System is all idle - pick up next work item to allocate to client
for n, v := range testcases {
if v.Finished {
continue
}
if v.SourceNode != workerState.worker {
workItem.IsIdle = true
return
}
if _, ok := workerStateMap[v.DestinationNode]; !ok {
workItem.IsIdle = true
return
}
fmt.Printf("Requesting jobrun '%s' from %s to %s for MSS %d for MsgSize %d\n", v.Label, v.SourceNode, v.DestinationNode, v.MSS, v.MsgSize)
workItem.ClientItem.Type = v.Type
workItem.IsClientItem = true
workerState.idle = false
currentJobIndex = n
if !v.ClusterIP {
workItem.ClientItem.Host = getWorkerPodIP(v.DestinationNode)
} else {
workItem.ClientItem.Host = os.Getenv("NETPERF_W2_SERVICE_HOST")
}
switch {
case v.Type == iperfTCPTest || v.Type == iperfUDPTest || v.Type == iperfSctpTest:
workItem.ClientItem.Port = "5201"
workItem.ClientItem.MSS = v.MSS
v.MSS = v.MSS + mssStepSize
if v.MSS > mssMax {
v.Finished = true
}
return
case v.Type == qperfTCPTest:
workItem.ClientItem.MsgSize = v.MsgSize
v.MsgSize <<= 1
if v.MsgSize > msgSizeMax {
v.Finished = true
}
return
case v.Type == netperfTest:
workItem.ClientItem.Port = "12865"
return
}
}
for _, v := range testcases {
if !v.Finished {
return
}
}
if !datapointsFlushed {
fmt.Println("ALL TESTCASES AND MSS RANGES COMPLETE - GENERATING CSV OUTPUT")
flushDataPointsToCsv()
datapointsFlushed = true
}
workItem.IsIdle = true
}