Skip to content

A
AutoHealer
Commit 9cc3029a authored by drnull03's avatar drnull03
Browse files
Options

finished coding the project before christmas

parents
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 2097 additions and 0 deletions
.idea/.gitignore 0 → 100644
View file @ 9cc3029a
# Default ignored files
/shelf/
/workspace.xml
.idea/autohealer-exercise2.iml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<module type="JAVA_MODULE" version="4">
<component name="NewModuleRootManager" inherit-compiler-output="true">
<exclude-output />
<content url="file://$MODULE_DIR$" />
<orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" />
</component>
</module>
\ No newline at end of file
.idea/compiler.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="transientworker" />
<module name="autohealer" />
</profile>
</annotationProcessing>
<bytecodeTargetLevel>
<module name="autohealer" target="17" />
<module name="flaky.worker" target="1.8" />
<module name="transientworker" target="17" />
</bytecodeTargetLevel>
</component>
</project>
\ No newline at end of file
.idea/encodings.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/autohealer/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/autohealer/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/transientworker/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/transientworker/src/main/resources" charset="UTF-8" />
</component>
</project>
\ No newline at end of file
.idea/jarRepositories.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://repo.maven.apache.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
.idea/libraries/Maven__ch_qos_logback_logback_classic_1_2_10.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: ch.qos.logback:logback-classic:1.2.10">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/ch/qos/logback/logback-classic/1.2.10/logback-classic-1.2.10.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/ch/qos/logback/logback-classic/1.2.10/logback-classic-1.2.10-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/ch/qos/logback/logback-classic/1.2.10/logback-classic-1.2.10-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__ch_qos_logback_logback_core_1_2_10.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: ch.qos.logback:logback-core:1.2.10">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/ch/qos/logback/logback-core/1.2.10/logback-core-1.2.10.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/ch/qos/logback/logback-core/1.2.10/logback-core-1.2.10-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/ch/qos/logback/logback-core/1.2.10/logback-core-1.2.10-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__commons_io_commons_io_2_11_0.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: commons-io:commons-io:2.11.0">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/commons-io/commons-io/2.11.0/commons-io-2.11.0.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/commons-io/commons-io/2.11.0/commons-io-2.11.0-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/commons-io/commons-io/2.11.0/commons-io-2.11.0-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_buffer_4_1_94_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-buffer:4.1.94.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-buffer/4.1.94.Final/netty-buffer-4.1.94.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-buffer/4.1.94.Final/netty-buffer-4.1.94.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-buffer/4.1.94.Final/netty-buffer-4.1.94.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_codec_4_1_94_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-codec:4.1.94.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-codec/4.1.94.Final/netty-codec-4.1.94.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-codec/4.1.94.Final/netty-codec-4.1.94.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-codec/4.1.94.Final/netty-codec-4.1.94.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_common_4_1_94_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-common:4.1.94.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-common/4.1.94.Final/netty-common-4.1.94.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-common/4.1.94.Final/netty-common-4.1.94.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-common/4.1.94.Final/netty-common-4.1.94.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_handler_4_1_94_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-handler:4.1.94.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-handler/4.1.94.Final/netty-handler-4.1.94.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-handler/4.1.94.Final/netty-handler-4.1.94.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-handler/4.1.94.Final/netty-handler-4.1.94.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_resolver_4_1_94_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-resolver:4.1.94.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-resolver/4.1.94.Final/netty-resolver-4.1.94.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-resolver/4.1.94.Final/netty-resolver-4.1.94.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-resolver/4.1.94.Final/netty-resolver-4.1.94.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_tcnative_boringssl_static_2_0_61_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-tcnative-boringssl-static:2.0.61.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_tcnative_boringssl_static_linux_aarch_64_2_0_61_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-tcnative-boringssl-static:linux-aarch_64:2.0.61.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-linux-aarch_64.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_tcnative_boringssl_static_linux_x86_64_2_0_61_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-tcnative-boringssl-static:linux-x86_64:2.0.61.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-linux-x86_64.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_tcnative_boringssl_static_osx_aarch_64_2_0_61_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-tcnative-boringssl-static:osx-aarch_64:2.0.61.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-osx-aarch_64.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_tcnative_boringssl_static_osx_x86_64_2_0_61_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-tcnative-boringssl-static:osx-x86_64:2.0.61.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-osx-x86_64.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_tcnative_boringssl_static_windows_x86_64_2_0_61_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-tcnative-boringssl-static:windows-x86_64:2.0.61.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-windows-x86_64.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_tcnative_classes_2_0_61_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-tcnative-classes:2.0.61.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-classes/2.0.61.Final/netty-tcnative-classes-2.0.61.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-classes/2.0.61.Final/netty-tcnative-classes-2.0.61.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-tcnative-classes/2.0.61.Final/netty-tcnative-classes-2.0.61.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_transport_4_1_94_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-transport:4.1.94.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport/4.1.94.Final/netty-transport-4.1.94.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport/4.1.94.Final/netty-transport-4.1.94.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport/4.1.94.Final/netty-transport-4.1.94.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_transport_classes_epoll_4_1_94_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-transport-classes-epoll:4.1.94.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport-classes-epoll/4.1.94.Final/netty-transport-classes-epoll-4.1.94.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport-classes-epoll/4.1.94.Final/netty-transport-classes-epoll-4.1.94.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport-classes-epoll/4.1.94.Final/netty-transport-classes-epoll-4.1.94.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_transport_native_epoll_linux_x86_64_4_1_94_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-transport-native-epoll:linux-x86_64:4.1.94.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport-native-epoll/4.1.94.Final/netty-transport-native-epoll-4.1.94.Final-linux-x86_64.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport-native-epoll/4.1.94.Final/netty-transport-native-epoll-4.1.94.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport-native-epoll/4.1.94.Final/netty-transport-native-epoll-4.1.94.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__io_netty_netty_transport_native_unix_common_4_1_94_Final.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: io.netty:netty-transport-native-unix-common:4.1.94.Final">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport-native-unix-common/4.1.94.Final/netty-transport-native-unix-common-4.1.94.Final.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport-native-unix-common/4.1.94.Final/netty-transport-native-unix-common-4.1.94.Final-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/io/netty/netty-transport-native-unix-common/4.1.94.Final/netty-transport-native-unix-common-4.1.94.Final-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__org_apache_yetus_audience_annotations_0_12_0.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: org.apache.yetus:audience-annotations:0.12.0">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/yetus/audience-annotations/0.12.0/audience-annotations-0.12.0.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/yetus/audience-annotations/0.12.0/audience-annotations-0.12.0-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/yetus/audience-annotations/0.12.0/audience-annotations-0.12.0-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__org_apache_zookeeper_zookeeper_3_9_1.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: org.apache.zookeeper:zookeeper:3.9.1">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/zookeeper/zookeeper/3.9.1/zookeeper-3.9.1.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/zookeeper/zookeeper/3.9.1/zookeeper-3.9.1-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/zookeeper/zookeeper/3.9.1/zookeeper-3.9.1-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__org_apache_zookeeper_zookeeper_jute_3_9_1.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: org.apache.zookeeper:zookeeper-jute:3.9.1">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/zookeeper/zookeeper-jute/3.9.1/zookeeper-jute-3.9.1.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/zookeeper/zookeeper-jute/3.9.1/zookeeper-jute-3.9.1-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/apache/zookeeper/zookeeper-jute/3.9.1/zookeeper-jute-3.9.1-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_30.xml 0 → 100644
View file @ 9cc3029a
<component name="libraryTable">
<library name="Maven: org.slf4j:slf4j-api:1.7.30">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/org/slf4j/slf4j-api/1.7.30/slf4j-api-1.7.30.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/org/slf4j/slf4j-api/1.7.30/slf4j-api-1.7.30-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/org/slf4j/slf4j-api/1.7.30/slf4j-api-1.7.30-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
.idea/misc.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/flakyworker/pom.xml" />
<option value="$PROJECT_DIR$/autohealer/pom.xml" />
<option value="$PROJECT_DIR$/transientworker/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
.idea/modules.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ProjectModuleManager">
<modules>
<module fileurl="file://$PROJECT_DIR$/autohealer/autohealer.iml" filepath="$PROJECT_DIR$/autohealer/autohealer.iml" />
<module fileurl="file://$PROJECT_DIR$/transientworker/transientworker.iml" filepath="$PROJECT_DIR$/transientworker/transientworker.iml" />
</modules>
</component>
</project>
\ No newline at end of file
.idea/vcs.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="$PROJECT_DIR$" vcs="Git" />
</component>
</project>
\ No newline at end of file
Homework/conf/zoo1.cfg 0 → 100644
View file @ 9cc3029a
# The number of milliseconds of each tick
#tickTime=2000
# The number of ticks that the initial
# synchronization phase can take
#initLimit=10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
#syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just
# example sakes.
#dataDir=/tmp/zookeeper
# the port at which the clients will connect
#clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the
# administrator guide before turning on autopurge.
#
# https://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1
## Metrics Providers
#
# https://prometheus.io Metrics Exporter
#metricsProvider.className=org.apache.zookeeper.metrics.prometheus.PrometheusMetricsProvider
#metricsProvider.httpHost=0.0.0.0
#metricsProvider.httpPort=7000
#metricsProvider.exportJvmInfo=true
dataDir=/data/zookeeper1
clientPort=2181
tickTime=2000
initLimit=5
syncLimit=2
server.1=localhost:2888:3888
server.2=localhost:2889:3889
server.3=localhost:2890:3890
admin.enableServer=false
Homework/conf/zoo2.cfg 0 → 100644
View file @ 9cc3029a
# The number of milliseconds of each tick
#tickTime=2000
# The number of ticks that the initial
# synchronization phase can take
#initLimit=10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
#syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just
# example sakes.
#dataDir=/tmp/zookeeper
# the port at which the clients will connect
#clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the
# administrator guide before turning on autopurge.
#
# https://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1
## Metrics Providers
#
# https://prometheus.io Metrics Exporter
#metricsProvider.className=org.apache.zookeeper.metrics.prometheus.PrometheusMetricsProvider
#metricsProvider.httpHost=0.0.0.0
#metricsProvider.httpPort=7000
#metricsProvider.exportJvmInfo=true
dataDir=/data/zookeeper2
clientPort=2182
tickTime=2000
initLimit=5
syncLimit=2
server.1=localhost:2888:3888
server.2=localhost:2889:3889
server.3=localhost:2890:3890
admin.enableServer=false
Homework/conf/zoo3.cfg 0 → 100644
View file @ 9cc3029a
# The number of milliseconds of each tick
#tickTime=2000
# The number of ticks that the initial
# synchronization phase can take
#initLimit=10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
#syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just
# example sakes.
#dataDir=/tmp/zookeeper
# the port at which the clients will connect
#clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the
# administrator guide before turning on autopurge.
#
# https://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1
## Metrics Providers
#
# https://prometheus.io Metrics Exporter
#metricsProvider.className=org.apache.zookeeper.metrics.prometheus.PrometheusMetricsProvider
#metricsProvider.httpHost=0.0.0.0
#metricsProvider.httpPort=7000
#metricsProvider.exportJvmInfo=true
dataDir=/data/zookeeper3
clientPort=2183
tickTime=2000
initLimit=5
syncLimit=2
server.1=localhost:2888:3888
server.2=localhost:2889:3889
server.3=localhost:2890:3890
admin.enableServer=false
Homework/part1/launch.sh 0 → 100755
View file @ 9cc3029a
# launch one physical node
/opt/zookeeper/bin/zkServer.sh start ./standalone.cfg
Homework/part1/standalone.cfg 0 → 100644
View file @ 9cc3029a
tickTime=2000
dataDir=/data/zookeeper1
clientPort=2181
initLimit=5
syncLimit=2
Homework/part2/autohealer/.idea/compiler.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="autohealer" />
</profile>
</annotationProcessing>
</component>
</project>
\ No newline at end of file
Homework/part2/autohealer/.idea/encodings.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
</component>
</project>
\ No newline at end of file
Homework/part2/autohealer/.idea/jarRepositories.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://repo.maven.apache.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
Homework/part2/autohealer/.idea/misc.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
Homework/part2/autohealer/.idea/vcs.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="$PROJECT_DIR$/.." vcs="Git" />
</component>
</project>
\ No newline at end of file
Homework/part2/autohealer/.idea/workspace.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="AutoImportSettings">
<option name="autoReloadType" value="SELECTIVE" />
</component>
<component name="ChangeListManager">
<list default="true" id="09c2cdeb-da7c-4fc3-8e7b-a0edfcd38ff5" name="Changes" comment="" />
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
<option name="LAST_RESOLUTION" value="IGNORE" />
</component>
<component name="Git.Settings">
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$/.." />
</component>
<component name="MarkdownSettingsMigration">
<option name="stateVersion" value="1" />
</component>
<component name="MavenImportPreferences">
<option name="generalSettings">
<MavenGeneralSettings>
<option name="useMavenConfig" value="true" />
</MavenGeneralSettings>
</option>
</component>
<component name="ProjectId" id="2aUIDMBn1fiD4OfFEsFyf5ggKq4" />
<component name="ProjectLevelVcsManager" settingsEditedManually="true" />
<component name="ProjectViewState">
<option name="hideEmptyMiddlePackages" value="true" />
<option name="showLibraryContents" value="true" />
</component>
<component name="PropertiesComponent"><![CDATA[{
"keyToString": {
"RunOnceActivity.OpenProjectViewOnStart": "true",
"RunOnceActivity.ShowReadmeOnStart": "true",
"last_opened_file_path": "D:/HIAST Library/Teaching/DS/2024/Lec10/autohealer-exercise/autohealer"
}
}]]></component>
<component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
<component name="TaskManager">
<task active="true" id="Default" summary="Default task">
<changelist id="09c2cdeb-da7c-4fc3-8e7b-a0edfcd38ff5" name="Changes" comment="" />
<created>1704366609391</created>
<option name="number" value="Default" />
<option name="presentableId" value="Default" />
<updated>1704366609391</updated>
</task>
<servers />
</component>
<component name="Vcs.Log.Tabs.Properties">
<option name="TAB_STATES">
<map>
<entry key="MAIN">
<value>
<State />
</value>
</entry>
</map>
</option>
</component>
</project>
\ No newline at end of file
Homework/part2/autohealer/autohealer.iml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">
<component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_17">
<output url="file://$MODULE_DIR$/target/classes" />
<output-test url="file://$MODULE_DIR$/target/test-classes" />
<content url="file://$MODULE_DIR$">
<sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
<sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" />
<excludeFolder url="file://$MODULE_DIR$/target" />
</content>
<orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper:3.9.1" level="project" />
<orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper-jute:3.9.1" level="project" />
<orderEntry type="library" name="Maven: org.apache.yetus:audience-annotations:0.12.0" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-handler:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-common:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-resolver:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-buffer:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport-native-unix-common:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-codec:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport-native-epoll:linux-x86_64:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport-classes-epoll:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-classes:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:linux-x86_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:linux-aarch_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:osx-x86_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:osx-aarch_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:windows-x86_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.30" level="project" />
<orderEntry type="library" name="Maven: ch.qos.logback:logback-core:1.2.10" level="project" />
<orderEntry type="library" name="Maven: ch.qos.logback:logback-classic:1.2.10" level="project" />
<orderEntry type="library" name="Maven: commons-io:commons-io:2.11.0" level="project" />
</component>
</module>
\ No newline at end of file
Homework/part2/autohealer/dependency-reduced-pom.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>autohealer</artifactId>
<version>1.0-SNAPSHOT</version>
<build>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.11.0</version>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<plugin>
<artifactId>maven-shade-plugin</artifactId>
<version>3.5.0</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<transformers>
<transformer>
<mainClass>Application</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
<properties>
<maven.compiler.target>17</maven.compiler.target>
<maven.compiler.source>17</maven.compiler.source>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
</project>
Homework/part2/autohealer/pom.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>autohealer</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- ZooKeeper -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.9.1</version>
</dependency>
<!-- SLF4J API -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>2.0.9</version>
</dependency>
<!-- Logback Classic -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.4.11</version>
</dependency>
<!-- Logback Core (explicitly) -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
<version>1.4.11</version>
</dependency>
</dependencies>
<build>
<plugins>
<!-- Compile with Java 17 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.11.0</version>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<!-- Build executable fat JAR -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<version>3.5.0</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<transformers>
<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
<mainClass>Application</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
Homework/part2/autohealer/src/main/java/Application.java 0 → 100644
View file @ 9cc3029a
import org.apache.zookeeper.KeeperException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
public class Application {
private static final Logger logger = LoggerFactory.getLogger(Application.class);
public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
if (args.length < 2) {
logger.error("Usage: java -jar autohealer.jar <number_of_workers> <path_to_worker_jar>");
System.exit(1);
}
int numWorkers = Integer.parseInt(args[0]);
String workerPath = args[1];
Autohealer autohealer = new Autohealer(numWorkers, workerPath);
autohealer.connectToZookeeper();
autohealer.startWatchingWorkers();
autohealer.run(); // blocks
}
}
Homework/part2/autohealer/src/main/java/Autohealer.java 0 → 100644
View file @ 9cc3029a
import org.apache.zookeeper.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.IOException;
import java.util.*;
public class Autohealer implements Watcher {
private static final Logger logger = LoggerFactory.getLogger(Autohealer.class);
// Update to include all ensemble nodes
private static final String ZOOKEEPER_ADDRESS = "127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183";
private static final int SESSION_TIMEOUT = 3000;
private static final String WORKERS_PATH = "/workers";
private final String pathToWorkerJar;
private final int numberOfWorkers;
private ZooKeeper zooKeeper;
// Simulate multiple physical nodes
private final List<String> physicalNodes = Arrays.asList("node1", "node2", "node3");
public Autohealer(int numberOfWorkers, String pathToWorkerJar) {
this.numberOfWorkers = numberOfWorkers;
this.pathToWorkerJar = pathToWorkerJar;
}
public void connectToZookeeper() throws IOException {
this.zooKeeper = new ZooKeeper(ZOOKEEPER_ADDRESS, SESSION_TIMEOUT, this);
logger.info("Connecting to ZooKeeper ensemble: {}", ZOOKEEPER_ADDRESS);
}
public void startWatchingWorkers() throws KeeperException, InterruptedException {
// Ensure parent znode exists
if (zooKeeper.exists(WORKERS_PATH, false) == null) {
zooKeeper.create(WORKERS_PATH, new byte[]{}, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
logger.info("Created parent znode: {}", WORKERS_PATH);
}
checkAndLaunchWorkers();
zooKeeper.getChildren(WORKERS_PATH, this);
}
public void run() throws InterruptedException {
synchronized (zooKeeper) {
zooKeeper.wait(); // block main thread
}
}
public void close() throws InterruptedException {
zooKeeper.close();
logger.info("ZooKeeper connection closed");
}
@Override
public void process(WatchedEvent event) {
if (event.getType() == Event.EventType.None) {
if (event.getState() == Event.KeeperState.SyncConnected) {
logger.info("Successfully connected to ZooKeeper");
} else {
synchronized (zooKeeper) {
logger.warn("Disconnected from ZooKeeper");
zooKeeper.notifyAll();
}
}
return;
}
if (event.getType() == Event.EventType.NodeChildrenChanged && event.getPath().equals(WORKERS_PATH)) {
try {
logger.info("Workers changed, checking cluster health...");
checkAndLaunchWorkers();
} catch (Exception e) {
logger.error("Error checking/launching workers", e);
}
}
// Re-set the watch
try {
zooKeeper.getChildren(WORKERS_PATH, this);
} catch (Exception e) {
logger.error("Failed to reset watch", e);
}
}
private void checkAndLaunchWorkers() throws KeeperException, InterruptedException {
List<String> children = zooKeeper.getChildren(WORKERS_PATH, false);
int currentWorkers = children.size();
int toLaunch = numberOfWorkers - currentWorkers;
if (toLaunch > 0) {
logger.info("Need to launch {} new worker(s)", toLaunch);
for (int i = 0; i < toLaunch; i++) {
try {
String node = selectNodeForWorker(children);
startNewWorker(node);
} catch (IOException e) {
logger.error("Failed to start new worker", e);
}
}
} else {
logger.debug("All workers are running, no action needed");
}
}
// Simple round-robin assignment of worker to a physical node
private String selectNodeForWorker(List<String> currentWorkers) {
int idx = currentWorkers.size() % physicalNodes.size();
return physicalNodes.get(idx);
}
private void startNewWorker(String node) throws IOException {
File file = new File(pathToWorkerJar);
String command = String.format("ssh %s java -jar %s", node, file.getAbsolutePath());
logger.info("Launching worker on {}: {}", node, command);
Runtime.getRuntime().exec(command, null, file.getParentFile());
}
}
Homework/part2/autohealer/src/main/resources/logback.xml 0 → 100644
View file @ 9cc3029a
<configuration>
<!-- Console logger: minimal -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- File logger -->
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>worker.log</file>
<append>true</append>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Root logger -->
<root level="INFO">
<appender-ref ref="CONSOLE"/>
<appender-ref ref="FILE"/>
</root>
</configuration>
Homework/part2/autohealer/target/classes/logback.xml 0 → 100644
View file @ 9cc3029a
<configuration>
<!-- Console logger: minimal -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- File logger -->
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>worker.log</file>
<append>true</append>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Root logger -->
<root level="INFO">
<appender-ref ref="CONSOLE"/>
<appender-ref ref="FILE"/>
</root>
</configuration>
Homework/part2/autohealer/target/maven-archiver/pom.properties 0 → 100644
View file @ 9cc3029a
#Generated by Maven
#Wed Dec 24 15:01:59 CET 2025
artifactId=autohealer
groupId=org.example
version=1.0-SNAPSHOT
Homework/part2/autohealer/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst 0 → 100644
View file @ 9cc3029a
/home/drnull/UNI/distr/lab9/auto-healer-zookeper-master/Homework/part2/autohealer/src/main/java/Application.java
/home/drnull/UNI/distr/lab9/auto-healer-zookeper-master/Homework/part2/autohealer/src/main/java/Autohealer.java
Homework/part2/autohealer/worker.log 0 → 100644
View file @ 9cc3029a
This diff is collapsed.
Homework/part2/launch.sh 0 → 100755
View file @ 9cc3029a
/opt/zookeeper/bin/zkServer.sh start /opt/zookeeper/conf/zoo1.cfg
/opt/zookeeper/bin/zkServer.sh start /opt/zookeeper/conf/zoo2.cfg
/opt/zookeeper/bin/zkServer.sh start /opt/zookeeper/conf/zoo3.cfg
Homework/part2/transientworker/dependency-reduced-pom.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>transientworker</artifactId>
<version>1.0-SNAPSHOT</version>
<build>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.11.0</version>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<plugin>
<artifactId>maven-shade-plugin</artifactId>
<version>3.5.0</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<transformers>
<transformer>
<mainClass>Application</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
<properties>
<maven.compiler.target>17</maven.compiler.target>
<maven.compiler.source>17</maven.compiler.source>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
</project>
Homework/part2/transientworker/pom.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>transientworker</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- ZooKeeper -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.9.1</version>
</dependency>
<!-- SLF4J API -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>2.0.9</version>
</dependency>
<!-- Logback Classic -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.4.11</version>
</dependency>
<!-- Logback Core (explicit for safety) -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
<version>1.4.11</version>
</dependency>
</dependencies>
<build>
<plugins>
<!-- Compile Java 17 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.11.0</version>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<!-- Build fat JAR -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<version>3.5.0</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<transformers>
<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
<!-- Your main class -->
<mainClass>Application</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
Homework/part2/transientworker/src/main/java/Application.java 0 → 100644
View file @ 9cc3029a
import org.apache.zookeeper.KeeperException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
public class Application {
private static final Logger logger = LoggerFactory.getLogger(Application.class);
public static void main(String[] args) {
logger.info("Starting worker...");
try {
Worker worker = new Worker();
worker.connectToZookeeper();
worker.work();
} catch (IOException | KeeperException | InterruptedException e) {
logger.error("Worker failed with exception", e);
System.exit(1);
} catch (RuntimeException e) {
logger.error("Critical failure, shutting down worker", e);
System.exit(1);
}
}
}
Homework/part2/transientworker/src/main/java/Worker.java 0 → 100644
View file @ 9cc3029a
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.Random;
import java.util.concurrent.locks.LockSupport;
public class Worker {
private static final Logger logger = LoggerFactory.getLogger(Worker.class);
// Update this if you run a cluster
private static final String ZOOKEEPER_ADDRESS = "127.0.0.1:2181";
private static final int SESSION_TIMEOUT = 3000;
private static final String AUTOHEALER_ZNODES_PATH = "/workers";
private static final float CHANCE_TO_FAIL = 0.1F;
private final Random random = new Random();
private ZooKeeper zooKeeper;
public void connectToZookeeper() throws IOException {
this.zooKeeper = new ZooKeeper(ZOOKEEPER_ADDRESS, SESSION_TIMEOUT, event -> {});
logger.info("Connected to ZooKeeper at {}", ZOOKEEPER_ADDRESS);
}
public void work() throws KeeperException, InterruptedException {
addChildZnode();
logger.info("Worker node created, starting work loop...");
while (true) {
// Minimal console output, detailed logs go to file
logger.debug("Working...");
LockSupport.parkNanos(100_000_000); // ~0.1 second
if (random.nextFloat() < CHANCE_TO_FAIL) {
logger.error("Critical error happened, exiting...");
throw new RuntimeException("Worker simulated failure");
}
}
}
private void addChildZnode() throws KeeperException, InterruptedException {
zooKeeper.create(AUTOHEALER_ZNODES_PATH + "/worker_",
new byte[]{},
ZooDefs.Ids.OPEN_ACL_UNSAFE,
CreateMode.EPHEMERAL_SEQUENTIAL);
logger.info("Registered ephemeral znode under {}", AUTOHEALER_ZNODES_PATH);
}
}
Homework/part2/transientworker/src/main/resources/logback.xml 0 → 100644
View file @ 9cc3029a
<configuration>
<!-- Console logger: minimal -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- File logger -->
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>worker.log</file>
<append>true</append>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Root logger -->
<root level="INFO">
<appender-ref ref="CONSOLE"/>
<appender-ref ref="FILE"/>
</root>
</configuration>
Homework/part2/transientworker/target/classes/logback.xml 0 → 100644
View file @ 9cc3029a
<configuration>
<!-- Console logger: minimal -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- File logger -->
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>worker.log</file>
<append>true</append>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Root logger -->
<root level="INFO">
<appender-ref ref="CONSOLE"/>
<appender-ref ref="FILE"/>
</root>
</configuration>
Homework/part2/transientworker/target/maven-archiver/pom.properties 0 → 100644
View file @ 9cc3029a
#Generated by Maven
#Wed Dec 24 15:02:19 CET 2025
artifactId=transientworker
groupId=org.example
version=1.0-SNAPSHOT
Homework/part2/transientworker/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst 0 → 100644
View file @ 9cc3029a
/home/drnull/UNI/distr/lab9/auto-healer-zookeper-master/Homework/part2/transientworker/src/main/java/Worker.java
/home/drnull/UNI/distr/lab9/auto-healer-zookeper-master/Homework/part2/transientworker/src/main/java/Application.java
Homework/part2/transientworker/transientworker.iml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">
<component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_17">
<output url="file://$MODULE_DIR$/target/classes" />
<output-test url="file://$MODULE_DIR$/target/test-classes" />
<content url="file://$MODULE_DIR$">
<sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
<sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" />
<excludeFolder url="file://$MODULE_DIR$/target" />
</content>
<orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper:3.9.1" level="project" />
<orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper-jute:3.9.1" level="project" />
<orderEntry type="library" name="Maven: org.apache.yetus:audience-annotations:0.12.0" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-handler:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-common:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-resolver:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-buffer:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport-native-unix-common:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-codec:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport-native-epoll:linux-x86_64:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport-classes-epoll:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-classes:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:linux-x86_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:linux-aarch_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:osx-x86_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:osx-aarch_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:windows-x86_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.30" level="project" />
<orderEntry type="library" name="Maven: ch.qos.logback:logback-core:1.2.10" level="project" />
<orderEntry type="library" name="Maven: ch.qos.logback:logback-classic:1.2.10" level="project" />
<orderEntry type="library" name="Maven: commons-io:commons-io:2.11.0" level="project" />
</component>
</module>
\ No newline at end of file
README.md 0 → 100644
View file @ 9cc3029a
# Auto-healer using Zookeeper
In cloud computing, auto-healing is a feature used to monitor a cluster and detect faulty application instances.
If a faulty instance is detected, the node is shut down and a new node is created with a healthy application instance.
In this practical assignment we will implement a very basic auto healer which will monitor a group of worker instances.
You are given a worker application
The worker instances are running a very complex computation that tends to crash in a particular edge case that the author did not account for.
Our mission is to maintain at least N worker nodes at any given moment.
If a worker crashes, we need to start a new worker.
### Build the Autohealer as a jar
### Run the autohealer, which in turn would launch and maintain 10 workers
```
java -jar target/autohealer-1.0-SNAPSHOT-jar-with-dependencies.jar <number of workers> <path to woker jar>
```
#### Example:
```
java -jar target/autohealer-1.0-SNAPSHOT-jar-with-dependencies.jar 10 "../transientworker/target/transientworker-1.0-SNAPSHOT-jar-with-dependencies.jar"
```
autohealer/.idea/compiler.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="autohealer" />
</profile>
</annotationProcessing>
</component>
</project>
\ No newline at end of file
autohealer/.idea/encodings.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
</component>
</project>
\ No newline at end of file
autohealer/.idea/jarRepositories.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://repo.maven.apache.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
autohealer/.idea/misc.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
autohealer/.idea/vcs.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="$PROJECT_DIR$/.." vcs="Git" />
</component>
</project>
\ No newline at end of file
autohealer/.idea/workspace.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="AutoImportSettings">
<option name="autoReloadType" value="SELECTIVE" />
</component>
<component name="ChangeListManager">
<list default="true" id="09c2cdeb-da7c-4fc3-8e7b-a0edfcd38ff5" name="Changes" comment="" />
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
<option name="LAST_RESOLUTION" value="IGNORE" />
</component>
<component name="Git.Settings">
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$/.." />
</component>
<component name="MarkdownSettingsMigration">
<option name="stateVersion" value="1" />
</component>
<component name="MavenImportPreferences">
<option name="generalSettings">
<MavenGeneralSettings>
<option name="useMavenConfig" value="true" />
</MavenGeneralSettings>
</option>
</component>
<component name="ProjectId" id="2aUIDMBn1fiD4OfFEsFyf5ggKq4" />
<component name="ProjectLevelVcsManager" settingsEditedManually="true" />
<component name="ProjectViewState">
<option name="hideEmptyMiddlePackages" value="true" />
<option name="showLibraryContents" value="true" />
</component>
<component name="PropertiesComponent"><![CDATA[{
"keyToString": {
"RunOnceActivity.OpenProjectViewOnStart": "true",
"RunOnceActivity.ShowReadmeOnStart": "true",
"last_opened_file_path": "D:/HIAST Library/Teaching/DS/2024/Lec10/autohealer-exercise/autohealer"
}
}]]></component>
<component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
<component name="TaskManager">
<task active="true" id="Default" summary="Default task">
<changelist id="09c2cdeb-da7c-4fc3-8e7b-a0edfcd38ff5" name="Changes" comment="" />
<created>1704366609391</created>
<option name="number" value="Default" />
<option name="presentableId" value="Default" />
<updated>1704366609391</updated>
</task>
<servers />
</component>
<component name="Vcs.Log.Tabs.Properties">
<option name="TAB_STATES">
<map>
<entry key="MAIN">
<value>
<State />
</value>
</entry>
</map>
</option>
</component>
</project>
\ No newline at end of file
autohealer/autohealer.iml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">
<component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_17">
<output url="file://$MODULE_DIR$/target/classes" />
<output-test url="file://$MODULE_DIR$/target/test-classes" />
<content url="file://$MODULE_DIR$">
<sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
<sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
<sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" />
<excludeFolder url="file://$MODULE_DIR$/target" />
</content>
<orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper:3.9.1" level="project" />
<orderEntry type="library" name="Maven: org.apache.zookeeper:zookeeper-jute:3.9.1" level="project" />
<orderEntry type="library" name="Maven: org.apache.yetus:audience-annotations:0.12.0" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-handler:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-common:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-resolver:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-buffer:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport-native-unix-common:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-codec:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport-native-epoll:linux-x86_64:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-transport-classes-epoll:4.1.94.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-classes:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:linux-x86_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:linux-aarch_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:osx-x86_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:osx-aarch_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: io.netty:netty-tcnative-boringssl-static:windows-x86_64:2.0.61.Final" level="project" />
<orderEntry type="library" name="Maven: org.slf4j:slf4j-api:1.7.30" level="project" />
<orderEntry type="library" name="Maven: ch.qos.logback:logback-core:1.2.10" level="project" />
<orderEntry type="library" name="Maven: ch.qos.logback:logback-classic:1.2.10" level="project" />
<orderEntry type="library" name="Maven: commons-io:commons-io:2.11.0" level="project" />
</component>
</module>
\ No newline at end of file
autohealer/dependency-reduced-pom.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>autohealer</artifactId>
<version>1.0-SNAPSHOT</version>
<build>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.11.0</version>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<plugin>
<artifactId>maven-shade-plugin</artifactId>
<version>3.5.0</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<transformers>
<transformer>
<mainClass>Application</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
<properties>
<maven.compiler.target>17</maven.compiler.target>
<maven.compiler.source>17</maven.compiler.source>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
</project>
autohealer/pom.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>autohealer</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- ZooKeeper -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.9.1</version>
</dependency>
<!-- SLF4J API -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>2.0.9</version>
</dependency>
<!-- Logback Classic -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.4.11</version>
</dependency>
<!-- Logback Core (explicitly) -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
<version>1.4.11</version>
</dependency>
</dependencies>
<build>
<plugins>
<!-- Compile with Java 17 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.11.0</version>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<!-- Build executable fat JAR -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<version>3.5.0</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<transformers>
<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
<mainClass>Application</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
autohealer/src/main/java/ApplicationAutohealer.java 0 → 100644
View file @ 9cc3029a
import org.apache.zookeeper.KeeperException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
public class ApplicationAutohealer {
private static final Logger logger = LoggerFactory.getLogger(ApplicationAutohealer.class);
public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
if (args.length < 2) {
logger.error("Usage: java -jar autohealer.jar <num_workers> <path_to_worker_jar>");
System.exit(1);
}
int numWorkers = Integer.parseInt(args[0]);
String workerPath = args[1];
Autohealer autohealer = new Autohealer(numWorkers, workerPath);
autohealer.connectToZookeeper();
autohealer.startWatchingWorkers();
autohealer.run();
}
}
autohealer/src/main/java/Autohealer.java 0 → 100644
View file @ 9cc3029a
import org.apache.zookeeper.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.IOException;
import java.util.List;
public class Autohealer implements Watcher {
private static final Logger logger = LoggerFactory.getLogger(Autohealer.class);
private static final String ZOOKEEPER_ADDRESS = "127.0.0.1:2181";
private static final int SESSION_TIMEOUT = 3000;
private static final String AUTOHEALER_ZNODES_PATH = "/workers";
private final String pathToWorkerJar;
private final int numberOfWorkers;
private ZooKeeper zooKeeper;
public Autohealer(int numberOfWorkers, String pathToWorkerJar) {
this.numberOfWorkers = numberOfWorkers;
this.pathToWorkerJar = pathToWorkerJar;
}
public void connectToZookeeper() throws IOException {
this.zooKeeper = new ZooKeeper(ZOOKEEPER_ADDRESS, SESSION_TIMEOUT, this);
logger.info("Connected to ZooKeeper at {}", ZOOKEEPER_ADDRESS);
}
public void startWatchingWorkers() throws KeeperException, InterruptedException {
if (zooKeeper.exists(AUTOHEALER_ZNODES_PATH, false) == null) {
zooKeeper.create(AUTOHEALER_ZNODES_PATH, new byte[]{},
ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
logger.info("Created parent znode: {}", AUTOHEALER_ZNODES_PATH);
}
checkAndLaunchWorkers();
zooKeeper.getChildren(AUTOHEALER_ZNODES_PATH, this);
}
private void checkAndLaunchWorkers() throws KeeperException, InterruptedException {
List<String> children = zooKeeper.getChildren(AUTOHEALER_ZNODES_PATH, false);
int runningWorkers = children.size();
int toLaunch = numberOfWorkers - runningWorkers;
if (toLaunch > 0) {
logger.info("Launching {} new worker(s)", toLaunch);
for (int i = 0; i < toLaunch; i++) {
try {
startNewWorker();
} catch (IOException e) {
logger.error("Failed to launch worker", e);
}
}
} else {
logger.debug("All workers are running");
}
}
private void startNewWorker() throws IOException {
File file = new File(pathToWorkerJar);
String command = "java -jar " + file.getAbsolutePath();
logger.info("Launching worker: {}", command);
Runtime.getRuntime().exec(command, null, file.getParentFile());
}
@Override
public void process(WatchedEvent event) {
if (event.getType() == Event.EventType.NodeChildrenChanged &&
AUTOHEALER_ZNODES_PATH.equals(event.getPath())) {
try {
logger.info("Detected worker znode change, checking workers...");
checkAndLaunchWorkers();
} catch (Exception e) {
logger.error("Error while handling worker changes", e);
}
}
try {
zooKeeper.getChildren(AUTOHEALER_ZNODES_PATH, this);
} catch (Exception e) {
logger.error("Failed to reset watch", e);
}
}
public void run() throws InterruptedException {
synchronized (zooKeeper) {
zooKeeper.wait();
}
}
}
autohealer/src/main/resources/logback.xml 0 → 100644
View file @ 9cc3029a
<configuration>
<!-- Console logger: minimal -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- File logger -->
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>worker.log</file>
<append>true</append>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Root logger -->
<root level="INFO">
<appender-ref ref="CONSOLE"/>
<appender-ref ref="FILE"/>
</root>
</configuration>
autohealer/target/classes/logback.xml 0 → 100644
View file @ 9cc3029a
<configuration>
<!-- Console logger: minimal -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- File logger -->
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>worker.log</file>
<append>true</append>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Root logger -->
<root level="INFO">
<appender-ref ref="CONSOLE"/>
<appender-ref ref="FILE"/>
</root>
</configuration>
autohealer/target/maven-archiver/pom.properties 0 → 100644
View file @ 9cc3029a
#Generated by Maven
#Wed Dec 24 15:01:59 CET 2025
artifactId=autohealer
groupId=org.example
version=1.0-SNAPSHOT
autohealer/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst 0 → 100644
View file @ 9cc3029a
/home/drnull/UNI/distr/lab9/auto-healer-zookeper-master/Homework/part2/autohealer/src/main/java/Application.java
/home/drnull/UNI/distr/lab9/auto-healer-zookeper-master/Homework/part2/autohealer/src/main/java/Autohealer.java
autohealer/worker.log 0 → 100644
View file @ 9cc3029a
This diff is collapsed.
transientworker/dependency-reduced-pom.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>transientworker</artifactId>
<version>1.0-SNAPSHOT</version>
<build>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.11.0</version>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<plugin>
<artifactId>maven-shade-plugin</artifactId>
<version>3.5.0</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<transformers>
<transformer>
<mainClass>Application</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
<properties>
<maven.compiler.target>17</maven.compiler.target>
<maven.compiler.source>17</maven.compiler.source>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
</project>
transientworker/pom.xml 0 → 100644
View file @ 9cc3029a
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>transientworker</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- ZooKeeper -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.9.1</version>
</dependency>
<!-- SLF4J API -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>2.0.9</version>
</dependency>
<!-- Logback Classic -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.4.11</version>
</dependency>
<!-- Logback Core (explicit for safety) -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
<version>1.4.11</version>
</dependency>
</dependencies>
<build>
<plugins>
<!-- Compile Java 17 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.11.0</version>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<!-- Build fat JAR -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-shade-plugin</artifactId>
<version>3.5.0</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<transformers>
<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
<!-- Your main class -->
<mainClass>Application</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
transientworker/src/main/java/Application.java 0 → 100644
View file @ 9cc3029a
import org.apache.zookeeper.KeeperException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
public class Application {
private static final Logger logger = LoggerFactory.getLogger(Application.class);
public static void main(String[] args) {
logger.info("Starting worker...");
try {
Worker worker = new Worker();
worker.connectToZookeeper();
worker.work();
} catch (IOException | KeeperException | InterruptedException e) {
logger.error("Worker failed due to Zookeeper exception", e);
} catch (RuntimeException e) {
logger.error("Worker crashed due to application error", e);
}
}
}
transientworker/src/main/java/Worker.java 0 → 100644
View file @ 9cc3029a
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.Random;
import java.util.concurrent.locks.LockSupport;
public class Worker {
private static final Logger logger = LoggerFactory.getLogger(Worker.class);
private static final String ZOOKEEPER_ADDRESS = "127.0.0.1:2181";
private static final int SESSION_TIMEOUT = 3000;
private static final String AUTOHEALER_ZNODES_PATH = "/workers";
private static final float CHANCE_TO_FAIL = 0.1F;
private final Random random = new Random();
private ZooKeeper zooKeeper;
public void connectToZookeeper() throws IOException {
this.zooKeeper = new ZooKeeper(ZOOKEEPER_ADDRESS, SESSION_TIMEOUT, event -> {});
logger.info("Connected to ZooKeeper at {}", ZOOKEEPER_ADDRESS);
}
public void work() throws KeeperException, InterruptedException {
addChildZnode();
logger.info("Worker node created, starting work loop...");
while (true) {
logger.debug("Working...");
LockSupport.parkNanos(100_000_000); // 0.1s
if (random.nextFloat() < CHANCE_TO_FAIL) {
logger.error("Application-level failure occurred");
throw new RuntimeException("Simulated worker crash");
}
}
}
private void addChildZnode() throws KeeperException, InterruptedException {
zooKeeper.create(AUTOHEALER_ZNODES_PATH + "/worker_",
new byte[]{},
ZooDefs.Ids.OPEN_ACL_UNSAFE,
CreateMode.EPHEMERAL_SEQUENTIAL);
logger.info("Registered ephemeral znode under {}", AUTOHEALER_ZNODES_PATH);
}
}
transientworker/src/main/resources/logback.xml 0 → 100644
View file @ 9cc3029a
<configuration>
<!-- Console logger: minimal -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- File logger -->
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>worker.log</file>
<append>true</append>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss} %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Root logger -->
<root level="INFO">
<appender-ref ref="CONSOLE"/>
<appender-ref ref="FILE"/>
</root>
</configuration>
transientworker/target/classes/Worker.class 0 → 100644
View file @ 9cc3029a
This diff is collapsed.
transientworker/target/classes/logback.xml 0 → 100644
View file @ 9cc3029a
This diff is collapsed.
transientworker/target/maven-archiver/pom.properties 0 → 100644
View file @ 9cc3029a
This diff is collapsed.
transientworker/target/original-transientworker-1.0-SNAPSHOT.jar 0 → 100644
View file @ 9cc3029a
This diff is collapsed.
transientworker/target/transientworker-1.0-SNAPSHOT.jar 0 → 100644
View file @ 9cc3029a
This diff is collapsed.
transientworker/transientworker.iml 0 → 100644
View file @ 9cc3029a
This diff is collapsed.
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