diff --git a/tests/netperf.py b/tests/netperf.py
index e30323e3364b8d4cec1069d001f8ea542c126ff9..e84462452a1fdd33c703a42b80407479de563681 100644
--- a/tests/netperf.py
+++ b/tests/netperf.py
@@ -100,7 +100,7 @@ def run_netperf(test, params, env):
         if node:
             if not isinstance(node, utils_misc.NumaNode):
                 node = utils_misc.NumaNode(int(node))
-            utils_test.pin_vm_threads(vm, node)
+            utils_test.qemu.pin_vm_threads(vm, node)
 
         return node
 
diff --git a/tests/ntttcp.py b/tests/ntttcp.py
index bdc2bcf7ced70bf4f055ddb5daaf338761afcba7..e7d81f689e2b194a07e5c9b049dbe80a47a6be60 100644
--- a/tests/ntttcp.py
+++ b/tests/ntttcp.py
@@ -45,7 +45,7 @@ def run_ntttcp(test, params, env):
     if params.get('numa_node'):
         numa_node = int(params.get('numa_node'))
         node = utils_misc.NumaNode(numa_node)
-        utils_test.pin_vm_threads(vm_sender, node)
+        utils_test.qemu.pin_vm_threads(vm_sender, node)
 
     if not receiver_addr:
         vm_receiver = env.get_vm("vm2")
@@ -58,7 +58,7 @@ def run_ntttcp(test, params, env):
                 raise error.TestError("Can't get receiver(%s) ip address" %
                                       vm_sender.name)
             if params.get('numa_node'):
-                utils_test.pin_vm_threads(vm_receiver, node)
+                utils_test.qemu.pin_vm_threads(vm_receiver, node)
         finally:
             if sess:
                 sess.close()