Added license header

code/hpdos_server/.idea/copyright/apache.xml

+<component name="CopyrightManager">
+  <copyright>
+    <option name="notice" value="Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay&#10;&#10;Licensed under the Apache License, Version 2.0 (the &quot;License&quot;);&#10;you may not use this file except in compliance with the License.&#10;You may obtain a copy of the License at&#10;&#10;    http://www.apache.org/licenses/LICENSE-2.0&#10;&#10;Unless required by applicable law or agreed to in writing, software&#10;distributed under the License is distributed on an &quot;AS IS&quot; BASIS,&#10;WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.&#10;See the License for the specific language governing permissions and&#10;limitations under the License." />
+    <option name="myName" value="apache" />
+  </copyright>
+</component>
\ No newline at end of file

code/hpdos_server/.idea/copyright/profiles_settings.xml

+<component name="CopyrightManager">
+  <settings>
+    <module2copyright>
+      <element module="All" copyright="apache" />
+    </module2copyright>
+  </settings>
+</component>
\ No newline at end of file

code/hpdos_server/app/build.gradle

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 /*
  * This file was generated by the Gradle 'init' task.
  *

code/hpdos_server/app/src/main/java/hpdos/ConfigConstants.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos;
 
 public class ConfigConstants {

code/hpdos_server/app/src/main/java/hpdos/MetadataServer.java

+
 /*
- * This Java source file was generated by the Gradle 'init' task.
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
+
 package hpdos;
 
 import hpdos.grpc.HeartbeatRequest;
@@ -21,6 +35,7 @@ import java.io.FileInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.util.*;
+import java.util.concurrent.Executors;
 
 public class MetadataServer {
     private Server server;
@@ -52,6 +67,7 @@ public class MetadataServer {
         this.server = ServerBuilder.forPort(ConfigConstants.PORT)
                 .addService(new NetworkHandler(this.ioHandler, this.replicationService))
                 .addService(new HeartbeatHandler(followers, serverID))
+                .executor(Executors.newFixedThreadPool(80))
                 .build();
         try {
             this.server.start();
@@ -68,6 +84,7 @@ public class MetadataServer {
         this.server = ServerBuilder.forPort(port)
                 .addService(new NetworkHandler(this.ioHandler, this.replicationService))
                 .addService(new ReplicateHandler(this.ioHandler))
+                .executor(Executors.newFixedThreadPool(80))
                 .build();
         try {
             this.server.start();

code/hpdos_server/app/src/main/java/hpdos/handler/HeartbeatHandler.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.handler;
 
 import hpdos.grpc.HeartbeatRequest;

code/hpdos_server/app/src/main/java/hpdos/handler/IOHandler.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.handler;
 
 import hpdos.grpc.Ack;

code/hpdos_server/app/src/main/java/hpdos/handler/NetworkHandler.java

+
+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.handler;
 
 import com.google.common.base.Stopwatch;

code/hpdos_server/app/src/main/java/hpdos/handler/ReplicateHandler.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.handler;
 
 import com.google.common.base.Stopwatch;

code/hpdos_server/app/src/main/java/hpdos/lib/InlineReplicationService.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.lib;
 
 import com.google.common.base.Stopwatch;

code/hpdos_server/app/src/main/java/hpdos/lib/MasterFollower.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.lib;
 
 import java.time.Instant;

code/hpdos_server/app/src/main/java/hpdos/lib/MemoryStorageService.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.lib;
 
 import hpdos.message.MessageConstants;

code/hpdos_server/app/src/main/java/hpdos/lib/ReplicationService.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.lib;
 
 import hpdos.grpc.ReplicationRequest;

code/hpdos_server/app/src/main/java/hpdos/lib/StorageModel.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.lib;
 
 import java.util.zip.CRC32;

code/hpdos_server/app/src/main/java/hpdos/lib/StoredModel.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.lib;
 
 public class StoredModel {

code/hpdos_server/app/src/main/java/hpdos/message/MessageConstants.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.message;
 
 public class MessageConstants {

code/hpdos_server/app/src/main/java/hpdos/message/RequestBuilder.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.message;
 
 import hpdos.grpc.Packet;

code/hpdos_server/app/src/main/java/hpdos/message/ResponseBuilder.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package hpdos.message;
 import hpdos.grpc.*;
 

code/hpdos_server/app/src/test/java/hpdos/AppTest.java

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 /*
  * This Java source file was generated by the Gradle 'init' task.
  */
@@ -7,7 +23,7 @@ import org.junit.Test;
 
 import java.io.IOException;
 
-import static org.junit.Assert.*;
+import static org.junit.Assert.assertNotNull;
 
 public class AppTest {
     @Test public void testAppHasAGreeting() throws IOException {

code/hpdos_server/gradle/wrapper/gradle-wrapper.properties

+#
+# Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 distributionUrl=https\://services.gradle.org/distributions/gradle-6.8.3-bin.zip

code/hpdos_server/gradlew

 #!/usr/bin/env sh
 
 #
-# Copyright 2015 the original author or authors.
+# Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
 # You may obtain a copy of the License at
 #
-#      https://www.apache.org/licenses/LICENSE-2.0
+#     http://www.apache.org/licenses/LICENSE-2.0
 #
 # Unless required by applicable law or agreed to in writing, software
 # distributed under the License is distributed on an "AS IS" BASIS,

code/hpdos_server/settings.gradle

+/*
+ * Copyright 2021 Nilanjan Daw, Synerg Lab, Department of CSE, IIT Bombay
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 /*
  * This file was generated by the Gradle 'init' task.
  *