merge with tip
This commit is contained in:
@@ -261,7 +261,7 @@ Experiment::SelectSrcDest (NodeContainer c)
|
||||
|
||||
for (uint32_t i=0; i < totalNodes/3; i++)
|
||||
{
|
||||
ApplicationSetup (c.Get(uvSrc.GetValue()), c.Get(uvDest.GetValue()) , 1, totalTime);
|
||||
ApplicationSetup (c.Get(uvSrc.RandomVariable::GetInteger()), c.Get(uvDest.RandomVariable::GetInteger()) , 1, totalTime);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
7
test.py
7
test.py
@@ -21,7 +21,6 @@ import os
|
||||
import sys
|
||||
import optparse
|
||||
import subprocess
|
||||
import multiprocessing
|
||||
import threading
|
||||
import Queue
|
||||
import signal
|
||||
@@ -625,7 +624,11 @@ def run_tests():
|
||||
jobs = 0
|
||||
threads=[]
|
||||
|
||||
processors = multiprocessing.cpu_count()
|
||||
try:
|
||||
import multiprocessing
|
||||
processors = multiprocessing.cpu_count()
|
||||
except ImportError:
|
||||
processors = 1
|
||||
for i in range(processors):
|
||||
thread = worker_thread(input_queue, output_queue)
|
||||
threads.append(thread)
|
||||
|
||||
Reference in New Issue
Block a user