Skip to content

Z
Zookeeper-AutoHealer-DS06
Commit c6037594 authored by mohammad.salama's avatar mohammad.salama
Browse files
Options

AutoHealer with Worker Ready

parent 0dd9439b
Hide whitespace changes
Inline Side-by-side
Showing with 39 additions and 34 deletions
.idea/workspace.xml
View file @ c6037594
...@@ -3,27 +3,24 @@ ...@@ -3,27 +3,24 @@
<component name="ArtifactsWorkspaceSettings"> <component name="ArtifactsWorkspaceSettings">
<artifacts-to-build> <artifacts-to-build>
<artifact name="AutoHealer:jar" /> <artifact name="AutoHealer:jar" />
<artifact name="Worker:jar" />
</artifacts-to-build> </artifacts-to-build>
</component> </component>
<component name="ChangeListManager"> <component name="ChangeListManager">
<list default="true" id="d4a0b476-92e2-4923-ba69-0da7a4ae9e1f" name="Changes" comment=""> <list default="true" id="d4a0b476-92e2-4923-ba69-0da7a4ae9e1f" name="Changes" comment="">
<change afterPath="$PROJECT_DIR$/.gitignore" afterDir="false" /> <change afterPath="$PROJECT_DIR$/AutoHealer.jar" afterDir="false" />
<change afterPath="$PROJECT_DIR$/.idea/artifacts/AutoHealer_jar.xml" afterDir="false" /> <change afterPath="$PROJECT_DIR$/Jars/AutoHealer-Thread.jar" afterDir="false" />
<change afterPath="$PROJECT_DIR$/.idea/artifacts/Worker_jar.xml" afterDir="false" /> <change afterPath="$PROJECT_DIR$/Worker.jar" afterDir="false" />
<change afterPath="$PROJECT_DIR$/.idea/misc.xml" afterDir="false" /> <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
<change afterPath="$PROJECT_DIR$/.idea/modules.xml" afterDir="false" /> <change beforePath="$PROJECT_DIR$/Jars/AutoHealer.jar" beforeDir="false" afterPath="$PROJECT_DIR$/Jars/AutoHealer.jar" afterDir="false" />
<change afterPath="$PROJECT_DIR$/.idea/vcs.xml" afterDir="false" /> <change beforePath="$PROJECT_DIR$/Jars/zcommand.txt" beforeDir="false" afterPath="$PROJECT_DIR$/Jars/zcommand.txt" afterDir="false" />
<change afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" /> <change beforePath="$PROJECT_DIR$/Read Me.txt" beforeDir="false" afterPath="$PROJECT_DIR$/Read Me.txt" afterDir="false" />
<change afterPath="$PROJECT_DIR$/Jars/AutoHealer.jar" afterDir="false" /> <change beforePath="$PROJECT_DIR$/out/artifacts/AutoHealer_jar/ZooKeeper-AutoHealer.jar" beforeDir="false" afterPath="$PROJECT_DIR$/out/artifacts/AutoHealer_jar/ZooKeeper-AutoHealer.jar" afterDir="false" />
<change afterPath="$PROJECT_DIR$/Jars/Worker.jar" afterDir="false" /> <change beforePath="$PROJECT_DIR$/out/production/ZooKeeper-AutoHealer/AutoHealer.class" beforeDir="false" afterPath="$PROJECT_DIR$/out/production/ZooKeeper-AutoHealer/AutoHealer.class" afterDir="false" />
<change afterPath="$PROJECT_DIR$/Jars/zcommand.txt" afterDir="false" /> <change beforePath="$PROJECT_DIR$/out/production/ZooKeeper-AutoHealer/AutoHealerApplication.class" beforeDir="false" afterPath="$PROJECT_DIR$/out/production/ZooKeeper-AutoHealer/AutoHealerApplication.class" afterDir="false" />
<change afterPath="$PROJECT_DIR$/ZooKeeper-AutoHealer.iml" afterDir="false" /> <change beforePath="$PROJECT_DIR$/out/production/ZooKeeper-AutoHealer/Worker.class" beforeDir="false" afterPath="$PROJECT_DIR$/out/production/ZooKeeper-AutoHealer/Worker.class" afterDir="false" />
<change afterPath="$PROJECT_DIR$/src/AutoHealer.java" afterDir="false" /> <change beforePath="$PROJECT_DIR$/src/AutoHealer.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/AutoHealer.java" afterDir="false" />
<change afterPath="$PROJECT_DIR$/src/AutoHealerApplication.java" afterDir="false" /> <change beforePath="$PROJECT_DIR$/src/AutoHealerApplication.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/AutoHealerApplication.java" afterDir="false" />
<change afterPath="$PROJECT_DIR$/src/META-INF/MANIFEST.MF" afterDir="false" /> <change beforePath="$PROJECT_DIR$/src/Worker.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/Worker.java" afterDir="false" />
<change afterPath="$PROJECT_DIR$/src/Worker.java" afterDir="false" />
<change afterPath="$PROJECT_DIR$/src/WorkerApplication.java" afterDir="false" />
</list> </list>
<option name="SHOW_DIALOG" value="false" /> <option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" /> <option name="HIGHLIGHT_CONFLICTS" value="true" />
......
AutoHealer.jar 0 → 100644
View file @ c6037594
File added
Jars/AutoHealer.jar
View file @ c6037594
No preview for this file type
Jars/zcommand.txt
View file @ c6037594
D: D:
cd HIAST\FIY\FS\Distributed Systems\Lab\6\ZooKeeper-AutoHealer\Jars cd HIAST\FIY\FS\Distributed Systems\Lab\6\ZooKeeper-AutoHealer\Jars
java -Dorg.slf4j.simpleLogger.defaultLogLevel=off -jar AutoHealer.jar 10 ".\Worker.jar" java -Dorg.slf4j.simpleLogger.defaultLogLevel=off -jar AutoHealer.jar 10 ".\Worker.jar"
java -Dorg.slf4j.simpleLogger.defaultLogLevel=off -jar AutoHealer.jar 10 ".Jars\Worker.jar"
Read Me.txt
View file @ c6037594
Open "Jars" Folder, inside there are two jars and command.txt java -Dorg.slf4j.simpleLogger.defaultLogLevel=off -jar .\AutoHealer.jar 10 ".\Worker.jar"
command.txt has the commands to run the jars.
\ No newline at end of file
or
java -jar .\AutoHealer.jar 10 ".\Worker.jar"
\ No newline at end of file
Worker.jar 0 → 100644
View file @ c6037594
File added
src/AutoHealer.java
View file @ c6037594
...@@ -86,12 +86,12 @@ public class AutoHealer implements Watcher ...@@ -86,12 +86,12 @@ public class AutoHealer implements Watcher
private void launchWorkersIfNecessary() throws KeeperException, InterruptedException private void launchWorkersIfNecessary() throws KeeperException, InterruptedException
{ {
List<String> workerZnodes = zooKeeper.getChildren(AUTOHEALER_ZNODES_PATH, this); List<String> workerZnodes = zooKeeper.getChildren(AUTOHEALER_ZNODES_PATH, this);
AtomicInteger existingWorkersNumber = new AtomicInteger(workerZnodes.size()); int existingWorkersNumber = workerZnodes.size();
if (existingWorkersNumber.get() > 0) if (existingWorkersNumber > 0)
{ {
System.out.println("Last Child Znode Now is : " + workerZnodes.get(existingWorkersNumber.get() -1)); System.out.println("Last Child Znode Now is : " + workerZnodes.get(existingWorkersNumber -1));
} }
while (existingWorkersNumber.get() < numberOfWorkers ) /*while (existingWorkersNumber.get() < numberOfWorkers )
{ {
Thread thread = new Thread(()-> Thread thread = new Thread(()->
{ {
...@@ -103,23 +103,25 @@ public class AutoHealer implements Watcher ...@@ -103,23 +103,25 @@ public class AutoHealer implements Watcher
} }
}); });
thread.start(); thread.start();
} }*/
/*while (existingWorkersNumber < numberOfWorkers ) while (existingWorkersNumber < numberOfWorkers )
{ {
try { try
{
System.out.println("Increasing Workers !!");
startNewWorker(); startNewWorker();
existingWorkersNumber++; existingWorkersNumber++;
} catch (IOException e) { } catch (IOException e) {
//throw new RuntimeException(e); //throw new RuntimeException(e);
} }
}*/ }
while (existingWorkersNumber.get() > numberOfWorkers) while (existingWorkersNumber > numberOfWorkers)
{ {
String worker = workerZnodes.get(0); String worker = workerZnodes.get(0);
String workerPath = AUTOHEALER_ZNODES_PATH + "/" + worker; String workerPath = AUTOHEALER_ZNODES_PATH + "/" + worker;
System.out.println("delete node: " + AUTOHEALER_ZNODES_PATH + "/" + worker); System.out.println("delete node: " + AUTOHEALER_ZNODES_PATH + "/" + worker);
zooKeeper.delete(workerPath, -1); zooKeeper.delete(workerPath, -1);
existingWorkersNumber.getAndDecrement(); existingWorkersNumber--;
workerZnodes.remove(0); workerZnodes.remove(0);
} }
} }
...@@ -128,7 +130,8 @@ public class AutoHealer implements Watcher ...@@ -128,7 +130,8 @@ public class AutoHealer implements Watcher
* Helper method to start a single worker * Helper method to start a single worker
* @throws IOException * @throws IOException
*/ */
private void startNewWorker() throws IOException { private void startNewWorker() throws IOException
{
File file = new File(pathToProgram); File file = new File(pathToProgram);
String command = "java -Dorg.slf4j.simpleLogger.defaultLogLevel=off -jar " + file.getName(); String command = "java -Dorg.slf4j.simpleLogger.defaultLogLevel=off -jar " + file.getName();
System.out.println(String.format("Launching worker instance : %s ", command)); System.out.println(String.format("Launching worker instance : %s ", command));
......
src/AutoHealerApplication.java
View file @ c6037594
...@@ -13,6 +13,7 @@ public class AutoHealerApplication ...@@ -13,6 +13,7 @@ public class AutoHealerApplication
int numberOfWorkers = Integer.parseInt(args[0]); int numberOfWorkers = Integer.parseInt(args[0]);
String pathToWorkerProgram = args[1]; String pathToWorkerProgram = args[1];
AutoHealer autohealer = new AutoHealer(numberOfWorkers, pathToWorkerProgram); AutoHealer autohealer = new AutoHealer(numberOfWorkers, pathToWorkerProgram);
//AutoHealer autohealer = new AutoHealer(10, ".\\Worker.jar");
autohealer.connectToZookeeper(); autohealer.connectToZookeeper();
autohealer.startWatchingWorkers(); autohealer.startWatchingWorkers();
autohealer.run(); autohealer.run();
......
src/Worker.java
View file @ c6037594
...@@ -27,9 +27,8 @@ public class Worker ...@@ -27,9 +27,8 @@ public class Worker
public void work() throws KeeperException, InterruptedException { public void work() throws KeeperException, InterruptedException {
addChildZnode(); addChildZnode();
while (true)
{
while (true) {
System.out.println(myName + " is Working..."); System.out.println(myName + " is Working...");
LockSupport.parkNanos(1000L); LockSupport.parkNanos(1000L);
if (random.nextFloat() < CHANCE_TO_FAIL) { if (random.nextFloat() < CHANCE_TO_FAIL) {
...@@ -44,7 +43,6 @@ public class Worker ...@@ -44,7 +43,6 @@ public class Worker
new byte[]{}, new byte[]{},
ZooDefs.Ids.OPEN_ACL_UNSAFE, ZooDefs.Ids.OPEN_ACL_UNSAFE,
CreateMode.EPHEMERAL_SEQUENTIAL); CreateMode.EPHEMERAL_SEQUENTIAL);
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

HIAST - GitLab