func allocateWorkToClient()

in network/benchmarks/netperf/nptest/nptest.go [279:346]
60 lines of code
17 McCabe index (conditional complexity)

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
}