Forráskód Böngészése

numa node can be used to transfer data on disk

Corentin Salingue 8 éve
szülő
commit
ccffe0783e
1 módosított fájl, 6 hozzáadás és 9 törlés
  1. 6 9
      src/datawizard/memalloc.c

+ 6 - 9
src/datawizard/memalloc.c

@@ -1608,7 +1608,7 @@ get_better_disk_can_accept_size(starpu_data_handle_t handle, unsigned node)
 	int target = -1;
 	unsigned nnodes = starpu_memory_nodes_get_count();
 	unsigned int i;
-	double time_disk = 0;
+	double time_disk = 0.0;
 
 	for (i = 0; i < nnodes; i++)
 	{
@@ -1623,15 +1623,12 @@ get_better_disk_can_accept_size(starpu_data_handle_t handle, unsigned node)
 				unsigned nnumas = _starpu_get_nb_numa_nodes();
 				for (numa = 0; numa < nnumas; numa++)
 				{
-					if (numa != i && numa != node)
+					/* TODO : check if starpu_transfer_predict(node, i,...) is the same */
+					double time_tmp = starpu_transfer_predict(node, numa, _starpu_data_get_size(handle)) + starpu_transfer_predict(i, numa, _starpu_data_get_size(handle));
+					if (target == -1 || time_disk > time_tmp)
 					{
-						/* TODO : check if starpu_transfer_predict(node, i,...) is the same */
-						double time_tmp = starpu_transfer_predict(node, numa, _starpu_data_get_size(handle)) + starpu_transfer_predict(i, numa, _starpu_data_get_size(handle));
-						if (target == -1 || time_disk > time_tmp)
-						{
-							target = i;
-							time_disk = time_tmp;
-						}
+						target = i;
+						time_disk = time_tmp;
 					}
 				}
 			}