diff options
Diffstat (limited to 'mm')
-rw-r--r-- | mm/mempolicy.c | 31 |
1 files changed, 19 insertions, 12 deletions
diff --git a/mm/mempolicy.c b/mm/mempolicy.c index 34d566ac147f..c39bd86f4ea0 100644 --- a/mm/mempolicy.c +++ b/mm/mempolicy.c | |||
@@ -180,6 +180,7 @@ static struct mempolicy *mpol_new(int mode, nodemask_t *nodes) | |||
180 | break; | 180 | break; |
181 | } | 181 | } |
182 | policy->policy = mode; | 182 | policy->policy = mode; |
183 | policy->cpuset_mems_allowed = cpuset_mems_allowed(current); | ||
183 | return policy; | 184 | return policy; |
184 | } | 185 | } |
185 | 186 | ||
@@ -1411,25 +1412,31 @@ void numa_default_policy(void) | |||
1411 | } | 1412 | } |
1412 | 1413 | ||
1413 | /* Migrate a policy to a different set of nodes */ | 1414 | /* Migrate a policy to a different set of nodes */ |
1414 | static void rebind_policy(struct mempolicy *pol, const nodemask_t *old, | 1415 | void mpol_rebind_policy(struct mempolicy *pol, const nodemask_t *newmask) |
1415 | const nodemask_t *new) | ||
1416 | { | 1416 | { |
1417 | nodemask_t *mpolmask; | ||
1417 | nodemask_t tmp; | 1418 | nodemask_t tmp; |
1418 | 1419 | ||
1419 | if (!pol) | 1420 | if (!pol) |
1420 | return; | 1421 | return; |
1422 | mpolmask = &pol->cpuset_mems_allowed; | ||
1423 | if (nodes_equal(*mpolmask, *newmask)) | ||
1424 | return; | ||
1421 | 1425 | ||
1422 | switch (pol->policy) { | 1426 | switch (pol->policy) { |
1423 | case MPOL_DEFAULT: | 1427 | case MPOL_DEFAULT: |
1424 | break; | 1428 | break; |
1425 | case MPOL_INTERLEAVE: | 1429 | case MPOL_INTERLEAVE: |
1426 | nodes_remap(tmp, pol->v.nodes, *old, *new); | 1430 | nodes_remap(tmp, pol->v.nodes, *mpolmask, *newmask); |
1427 | pol->v.nodes = tmp; | 1431 | pol->v.nodes = tmp; |
1428 | current->il_next = node_remap(current->il_next, *old, *new); | 1432 | *mpolmask = *newmask; |
1433 | current->il_next = node_remap(current->il_next, | ||
1434 | *mpolmask, *newmask); | ||
1429 | break; | 1435 | break; |
1430 | case MPOL_PREFERRED: | 1436 | case MPOL_PREFERRED: |
1431 | pol->v.preferred_node = node_remap(pol->v.preferred_node, | 1437 | pol->v.preferred_node = node_remap(pol->v.preferred_node, |
1432 | *old, *new); | 1438 | *mpolmask, *newmask); |
1439 | *mpolmask = *newmask; | ||
1433 | break; | 1440 | break; |
1434 | case MPOL_BIND: { | 1441 | case MPOL_BIND: { |
1435 | nodemask_t nodes; | 1442 | nodemask_t nodes; |
@@ -1439,7 +1446,7 @@ static void rebind_policy(struct mempolicy *pol, const nodemask_t *old, | |||
1439 | nodes_clear(nodes); | 1446 | nodes_clear(nodes); |
1440 | for (z = pol->v.zonelist->zones; *z; z++) | 1447 | for (z = pol->v.zonelist->zones; *z; z++) |
1441 | node_set((*z)->zone_pgdat->node_id, nodes); | 1448 | node_set((*z)->zone_pgdat->node_id, nodes); |
1442 | nodes_remap(tmp, nodes, *old, *new); | 1449 | nodes_remap(tmp, nodes, *mpolmask, *newmask); |
1443 | nodes = tmp; | 1450 | nodes = tmp; |
1444 | 1451 | ||
1445 | zonelist = bind_zonelist(&nodes); | 1452 | zonelist = bind_zonelist(&nodes); |
@@ -1454,6 +1461,7 @@ static void rebind_policy(struct mempolicy *pol, const nodemask_t *old, | |||
1454 | kfree(pol->v.zonelist); | 1461 | kfree(pol->v.zonelist); |
1455 | pol->v.zonelist = zonelist; | 1462 | pol->v.zonelist = zonelist; |
1456 | } | 1463 | } |
1464 | *mpolmask = *newmask; | ||
1457 | break; | 1465 | break; |
1458 | } | 1466 | } |
1459 | default: | 1467 | default: |
@@ -1463,14 +1471,13 @@ static void rebind_policy(struct mempolicy *pol, const nodemask_t *old, | |||
1463 | } | 1471 | } |
1464 | 1472 | ||
1465 | /* | 1473 | /* |
1466 | * Someone moved this task to different nodes. Fixup mempolicies. | 1474 | * Wrapper for mpol_rebind_policy() that just requires task |
1467 | * | 1475 | * pointer, and updates task mempolicy. |
1468 | * TODO - fixup current->mm->vma and shmfs/tmpfs/hugetlbfs policies as well, | ||
1469 | * once we have a cpuset mechanism to mark which cpuset subtree is migrating. | ||
1470 | */ | 1476 | */ |
1471 | void numa_policy_rebind(const nodemask_t *old, const nodemask_t *new) | 1477 | |
1478 | void mpol_rebind_task(struct task_struct *tsk, const nodemask_t *new) | ||
1472 | { | 1479 | { |
1473 | rebind_policy(current->mempolicy, old, new); | 1480 | mpol_rebind_policy(tsk->mempolicy, new); |
1474 | } | 1481 | } |
1475 | 1482 | ||
1476 | /* | 1483 | /* |