Increased wait time to make the test stable, but we should do better

Author: xerial

src/test/java/org/fluentd/logger/sender/TestRawSocketSender.java

@@ -66,11 +66,12 @@ public void process(MessagePack msgpack, Socket socket) throws IOException {
         // close sender sockets
         sender.close();
 
+        // wait for unpacking event data on fluentd
+        Thread.sleep(2000);
+
         // close mock server sockets
         fluentd.close();
 
-        // wait for unpacking event data on fluentd
-        Thread.sleep(1000);
 
         // check data
         assertEquals(2, elist.size());
@@ -126,11 +127,12 @@ public void process(MessagePack msgpack, Socket socket) throws IOException {
         // close sender sockets
         sender.close();
 
+        // wait for unpacking event data on fluentd
+        Thread.sleep(2000);
+
         // close mock server sockets
         fluentd.close();
 
-        // wait for unpacking event data on fluentd
-        Thread.sleep(1000);
 
         // check data
         assertEquals(count, elist.size());
@@ -206,12 +208,13 @@ public void process(MessagePack msgpack, Socket socket) throws IOException {
         senders[0].close();
         senders[1].close();
 
+        // wait for unpacking event data on fluentd
+        Thread.sleep(2000);
+
         // close mock server sockets
         fluentds[0].close();
         fluentds[1].close();
 
-        // wait for unpacking event data on fluentd
-        Thread.sleep(1000);
 
         // check data
         assertEquals(counts[0], elists[0].size());