Revision 5440c877 htools/Ganeti/HTools/Cluster.hs
| b/htools/Ganeti/HTools/Cluster.hs | ||
|---|---|---|
| 110 | 110 |
-- type consists of actual opcodes (a restricted subset) that are |
| 111 | 111 |
-- transmitted back to Ganeti. |
| 112 | 112 |
data EvacSolution = EvacSolution |
| 113 |
{ esMoved :: [String] -- ^ Instance moved successfully
|
|
| 114 |
, esFailed :: [String] -- ^ Instance which were not
|
|
| 113 |
{ esMoved :: [(Idx, Gdx, [Ndx])] -- ^ Instances moved successfully
|
|
| 114 |
, esFailed :: [(Idx, String)] -- ^ Instances which were not
|
|
| 115 | 115 |
-- relocated |
| 116 | 116 |
, esOpCodes :: [[[OpCodes.OpCode]]] -- ^ List of lists of jobs |
| 117 | 117 |
} |
| ... | ... | |
| 1063 | 1063 |
-- | Updates the evac solution with the results of an instance |
| 1064 | 1064 |
-- evacuation. |
| 1065 | 1065 |
updateEvacSolution :: (Node.List, Instance.List, EvacSolution) |
| 1066 |
-> Instance.Instance
|
|
| 1066 |
-> Idx
|
|
| 1067 | 1067 |
-> Result (Node.List, Instance.List, [OpCodes.OpCode]) |
| 1068 | 1068 |
-> (Node.List, Instance.List, EvacSolution) |
| 1069 |
updateEvacSolution (nl, il, es) inst (Bad msg) =
|
|
| 1070 |
(nl, il, es { esFailed = (Instance.name inst ++ ": " ++ msg):esFailed es})
|
|
| 1071 |
updateEvacSolution (_, _, es) inst (Ok (nl, il, opcodes)) =
|
|
| 1072 |
(nl, il, es { esMoved = Instance.name inst:esMoved es
|
|
| 1069 |
updateEvacSolution (nl, il, es) idx (Bad msg) =
|
|
| 1070 |
(nl, il, es { esFailed = (idx, msg):esFailed es})
|
|
| 1071 |
updateEvacSolution (_, _, es) idx (Ok (nl, il, opcodes)) =
|
|
| 1072 |
(nl, il, es { esMoved = new_elem:esMoved es
|
|
| 1073 | 1073 |
, esOpCodes = [opcodes]:esOpCodes es }) |
| 1074 |
where inst = Container.find idx il |
|
| 1075 |
new_elem = (idx, |
|
| 1076 |
instancePriGroup nl inst, |
|
| 1077 |
Instance.allNodes inst) |
|
| 1074 | 1078 |
|
| 1075 | 1079 |
-- | Node-evacuation IAllocator mode main function. |
| 1076 | 1080 |
tryNodeEvac :: Group.List -- ^ The cluster groups |
| ... | ... | |
| 1088 | 1092 |
splitCluster ini_nl ini_il |
| 1089 | 1093 |
(_, _, esol) = |
| 1090 | 1094 |
foldl' (\state@(nl, il, _) inst -> |
| 1091 |
updateEvacSolution state inst $
|
|
| 1095 |
updateEvacSolution state (Instance.idx inst) $
|
|
| 1092 | 1096 |
availableGroupNodes group_ndx |
| 1093 | 1097 |
excl_ndx (instancePriGroup nl inst) >>= |
| 1094 | 1098 |
nodeEvacInstance nl il mode inst |
| ... | ... | |
| 1144 | 1148 |
av_nodes <- availableGroupNodes group_ndx |
| 1145 | 1149 |
excl_ndx gdx |
| 1146 | 1150 |
nodeEvacInstance nl il ChangeAll inst av_nodes |
| 1147 |
in updateEvacSolution state inst solution |
|
| 1151 |
in updateEvacSolution state |
|
| 1152 |
(Instance.idx inst) solution |
|
| 1148 | 1153 |
) |
| 1149 | 1154 |
(ini_nl, ini_il, emptyEvacSolution) |
| 1150 | 1155 |
(map (`Container.find` ini_il) idxs) |
| 1151 | 1156 |
in return $ reverseEvacSolution esol |
| 1152 | 1157 |
|
| 1153 |
|
|
| 1154 | 1158 |
-- | Recursively place instances on the cluster until we're out of space. |
| 1155 | 1159 |
iterateAlloc :: Node.List |
| 1156 | 1160 |
-> Instance.List |
Also available in: Unified diff