73 }
74 forceEndChunk();
75 socket.close();
76 // Now there should have been traffic on at least two different
77 // interfaces
78 recording.stop();
79
80 Set<String> networkInterfaces = new HashSet<>();
81 List<RecordedEvent> events = Events.fromRecording(recording);
82 Events.hasEvents(events);
83 for (RecordedEvent event : events) {
84 System.out.println(event);
85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE);
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE);
87 Events.assertField(event, "networkInterface").notNull();
88 if (event.getLong("writeRate") > 0) {
89 networkInterfaces.add(event.getString("networkInterface"));
90 }
91 }
92
93 if (Platform.isWindows() || Platform.isSolaris()) {
94 // Windows and Solaris do not track statistics for the loopback
95 // interface
96 Asserts.assertGreaterThanOrEqual(networkInterfaces.size(), 1);
97 } else {
98 Asserts.assertGreaterThanOrEqual(networkInterfaces.size(), 2);
99 }
100 }
101
102 private static void forceEndChunk() {
103 try(Recording r = new Recording()) {
104 r.start();
105 r.stop();
106 }
107 }
108 }
|
73 }
74 forceEndChunk();
75 socket.close();
76 // Now there should have been traffic on at least two different
77 // interfaces
78 recording.stop();
79
80 Set<String> networkInterfaces = new HashSet<>();
81 List<RecordedEvent> events = Events.fromRecording(recording);
82 Events.hasEvents(events);
83 for (RecordedEvent event : events) {
84 System.out.println(event);
85 Events.assertField(event, "writeRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE);
86 Events.assertField(event, "readRate").atLeast(0L).atMost(1000L * Integer.MAX_VALUE);
87 Events.assertField(event, "networkInterface").notNull();
88 if (event.getLong("writeRate") > 0) {
89 networkInterfaces.add(event.getString("networkInterface"));
90 }
91 }
92
93 if (Platform.isWindows()) {
94 // Windows does not track statistics for the loopback
95 // interface
96 Asserts.assertGreaterThanOrEqual(networkInterfaces.size(), 1);
97 } else {
98 Asserts.assertGreaterThanOrEqual(networkInterfaces.size(), 2);
99 }
100 }
101
102 private static void forceEndChunk() {
103 try(Recording r = new Recording()) {
104 r.start();
105 r.stop();
106 }
107 }
108 }
|