update grpc cs

Author: man-zhang

jdk_8_maven/cs/rpc/grpc/artificial/grpc-ncs/pom.xml

@@ -67,7 +67,24 @@
                     </execution>
                 </executions>
             </plugin>
+
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                        <configuration>
+                            <finalName>rpc-grpc-ncs</finalName>
+                            <classifier>sut</classifier>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+
         </plugins>
     </build>
 
-</project>
+</project>

jdk_8_maven/cs/rpc/grpc/artificial/grpc-ncs/src/main/java/org/grpc/ncs/NcsServer.java

@@ -15,12 +15,6 @@
  */
 public class NcsServer {
 
-//    public static void main(String[] args) throws IOException, InterruptedException {
-//        Server server = ServerBuilder.forPort(8080).addService(new NcsServiceImplBaseImpl()).build();
-//        server.start();
-//        server.awaitTermination();
-//    }
-
     private static final Logger logger = Logger.getLogger(NcsServer.class.getName());
 
     private final int port;
@@ -38,7 +32,7 @@ public NcsServer(ServerBuilder<?> serverBuilder, int port) {
 
     public void start() throws IOException {
         server.start();
-        logger.info("Server started, listening on " + port);
+        logger.info("NcsServer started, listening on " + port);
         Runtime.getRuntime().addShutdownHook(new Thread() {
             @Override
             public void run() {
@@ -66,7 +60,15 @@ void blockUntilShutdown() throws InterruptedException {
     }
 
     public static void main(String[] args) throws Exception {
-        NcsServer server = new NcsServer(8980);
+        int sutPort = 8980;
+        if (args.length == 1){
+            try{
+                sutPort = Integer.parseInt(args[0]);
+            }catch (Exception NumberFormatException){
+
+            }
+        }
+        NcsServer server = new NcsServer(sutPort);
         server.start();
         server.blockUntilShutdown();
     }

jdk_8_maven/cs/rpc/grpc/artificial/grpc-scs/pom.xml

@@ -66,6 +66,23 @@
                     </execution>
                 </executions>
             </plugin>
+
+
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                        <configuration>
+                            <finalName>rpc-grpc-scs</finalName>
+                            <classifier>sut</classifier>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
         </plugins>
     </build>
-</project>
+</project>

jdk_8_maven/cs/rpc/grpc/artificial/grpc-scs/src/main/java/org/grpc/scs/ScsServer.java

@@ -15,12 +15,6 @@
  */
 public class ScsServer {
 
-//    public static void main(String[] args) throws IOException, InterruptedException {
-//        Server server = ServerBuilder.forPort(8080).addService(new NcsServiceImplBaseImpl()).build();
-//        server.start();
-//        server.awaitTermination();
-//    }
-
     private static final Logger logger = Logger.getLogger(ScsServer.class.getName());
 
     private final int port;
@@ -38,7 +32,7 @@ public ScsServer(ServerBuilder<?> serverBuilder, int port) {
 
     public void start() throws IOException {
         server.start();
-        logger.info("Server started, listening on " + port);
+        logger.info("ScsServer started, listening on " + port);
         Runtime.getRuntime().addShutdownHook(new Thread() {
             @Override
             public void run() {
@@ -66,7 +60,16 @@ void blockUntilShutdown() throws InterruptedException {
     }
 
     public static void main(String[] args) throws Exception {
-        ScsServer server = new ScsServer(8980);
+        int sutPort = 8980;
+        if (args.length == 1){
+            try{
+                sutPort = Integer.parseInt(args[0]);
+            }catch (Exception NumberFormatException){
+
+            }
+        }
+
+        ScsServer server = new ScsServer(sutPort);
         server.start();
         server.blockUntilShutdown();
     }