Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(322)

Side by Side Diff: runtime/observatory/tests/service/udp_socket_service_test.dart

Issue 1680593004: dart:developer service extension fixes (Closed) Base URL: git@github.com:dart-lang/sdk.git@master
Patch Set: Created 4 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 import 'dart:async'; 5 import 'dart:async';
6 import 'dart:convert'; 6 import 'dart:convert';
7 import 'dart:io' as io; 7 import 'dart:io' as io;
8 import 'package:observatory/service_io.dart'; 8 import 'package:observatory/service_io.dart';
9 import 'package:unittest/unittest.dart'; 9 import 'package:unittest/unittest.dart';
10 import 'test_helper.dart'; 10 import 'test_helper.dart';
11 11
12 Future setupUDP() async { 12 Future setupUDP() async {
13 var server = await io.RawDatagramSocket.bind('127.0.0.1', 0); 13 var server = await io.RawDatagramSocket.bind('127.0.0.1', 0);
14 server.listen((io.RawSocketEvent event) { 14 server.listen((io.RawSocketEvent event) {
15 if(event == io.RawSocketEvent.READ) { 15 if(event == io.RawSocketEvent.READ) {
16 io.Datagram dg = server.receive(); 16 io.Datagram dg = server.receive();
17 dg.data.forEach((x) => true); 17 dg.data.forEach((x) => true);
18 } 18 }
19 }); 19 });
20 var client = await io.RawDatagramSocket.bind('127.0.0.1', 0); 20 var client = await io.RawDatagramSocket.bind('127.0.0.1', 0);
21 client.send(UTF8.encoder.convert('foobar'), 21 client.send(UTF8.encoder.convert('foobar'),
22 new io.InternetAddress('127.0.0.1'), server.port); 22 new io.InternetAddress('127.0.0.1'), server.port);
23 } 23 }
24 24
25 var udpTests = [ 25 var udpTests = [
26 // Initial. 26 // Initial.
27 (Isolate isolate) async { 27 (Isolate isolate) async {
28 var result = await isolate.invokeRpcNoUpgrade('__getOpenSockets', {}); 28 var result =
29 await isolate.invokeRpcNoUpgrade('ext.dart.io.getOpenSockets', {});
29 expect(result['type'], equals('_opensockets')); 30 expect(result['type'], equals('_opensockets'));
30 // We expect 2 sockets to be open (in this order): 31 // We expect 2 sockets to be open (in this order):
31 // The server socket accepting connections, on port X 32 // The server socket accepting connections, on port X
32 // The client socket on port Y 33 // The client socket on port Y
33 expect(result['data'].length, equals(2)); 34 expect(result['data'].length, equals(2));
34 // The first socket will have a name like listening:127.0.0.1:X 35 // The first socket will have a name like listening:127.0.0.1:X
35 // The second will have a name like 127.0.0.1:Y 36 // The second will have a name like 127.0.0.1:Y
36 // The third will have a name like 127.0.0.1:X 37 // The third will have a name like 127.0.0.1:X
37 expect(result['data'][0]['name'].startsWith('127.0.0.1'), isTrue); 38 expect(result['data'][0]['name'].startsWith('127.0.0.1'), isTrue);
38 expect(result['data'][1]['name'].startsWith('127.0.0.1:'), isTrue); 39 expect(result['data'][1]['name'].startsWith('127.0.0.1:'), isTrue);
39 40
40 var server = await isolate.invokeRpcNoUpgrade( 41 var server = await isolate.invokeRpcNoUpgrade(
41 '__getSocketByID', { 'id' : result['data'][0]['id'] }); 42 'ext.dart.io.getSocketByID', { 'id' : result['data'][0]['id'] });
42 expect(server['id'], equals(result['data'][0]['id'])); 43 expect(server['id'], equals(result['data'][0]['id']));
43 expect(server['remotePort'], equals('NA')); 44 expect(server['remotePort'], equals('NA'));
44 expect(server['remoteHost'], equals('NA')); 45 expect(server['remoteHost'], equals('NA'));
45 expect(server['listening'], isFalse); 46 expect(server['listening'], isFalse);
46 expect(server['socketType'], equals('UDP')); 47 expect(server['socketType'], equals('UDP'));
47 expect(server['port'], greaterThanOrEqualTo(1024)); 48 expect(server['port'], greaterThanOrEqualTo(1024));
48 // Stopwatch resolution on windows makes us sometimes report 0; 49 // Stopwatch resolution on windows makes us sometimes report 0;
49 if (io.Platform.isWindows) { 50 if (io.Platform.isWindows) {
50 expect(server['lastRead'], greaterThanOrEqualTo(0)); 51 expect(server['lastRead'], greaterThanOrEqualTo(0));
51 } else { 52 } else {
52 expect(server['lastRead'], greaterThan(0)); 53 expect(server['lastRead'], greaterThan(0));
53 } 54 }
54 expect(server['totalRead'], equals(6)); 55 expect(server['totalRead'], equals(6));
55 expect(server['lastWrite'], equals(0)); 56 expect(server['lastWrite'], equals(0));
56 expect(server['totalWritten'], equals(0)); 57 expect(server['totalWritten'], equals(0));
57 expect(server['writeCount'], equals(0)); 58 expect(server['writeCount'], equals(0));
58 expect(server['readCount'], greaterThanOrEqualTo(1)); 59 expect(server['readCount'], greaterThanOrEqualTo(1));
59 60
60 var client = await isolate.invokeRpcNoUpgrade( 61 var client = await isolate.invokeRpcNoUpgrade(
61 '__getSocketByID', { 'id' : result['data'][1]['id'] }); 62 'ext.dart.io.getSocketByID', { 'id' : result['data'][1]['id'] });
62 expect(client['id'], equals(result['data'][1]['id'])); 63 expect(client['id'], equals(result['data'][1]['id']));
63 expect(client['remotePort'], equals('NA')); 64 expect(client['remotePort'], equals('NA'));
64 expect(client['remoteHost'], equals('NA')); 65 expect(client['remoteHost'], equals('NA'));
65 expect(client['listening'], isFalse); 66 expect(client['listening'], isFalse);
66 expect(client['socketType'], equals('UDP')); 67 expect(client['socketType'], equals('UDP'));
67 expect(client['port'], greaterThanOrEqualTo(1024)); 68 expect(client['port'], greaterThanOrEqualTo(1024));
68 expect(client['lastRead'], equals(0)); 69 expect(client['lastRead'], equals(0));
69 expect(client['totalRead'], equals(0)); 70 expect(client['totalRead'], equals(0));
70 // Stopwatch resolution on windows makes us sometimes report 0; 71 // Stopwatch resolution on windows makes us sometimes report 0;
71 if (io.Platform.isWindows) { 72 if (io.Platform.isWindows) {
72 expect(client['lastWrite'], greaterThanOrEqualTo(0)); 73 expect(client['lastWrite'], greaterThanOrEqualTo(0));
73 } else { 74 } else {
74 expect(client['lastWrite'], greaterThan(0)); 75 expect(client['lastWrite'], greaterThan(0));
75 } 76 }
76 expect(client['totalWritten'], equals(6)); 77 expect(client['totalWritten'], equals(6));
77 expect(client['writeCount'], greaterThanOrEqualTo(1)); 78 expect(client['writeCount'], greaterThanOrEqualTo(1));
78 expect(client['readCount'], equals(0)); 79 expect(client['readCount'], equals(0));
79 }, 80 },
80 ]; 81 ];
81 82
82 main(args) async => runIsolateTests(args, udpTests, testeeBefore:setupUDP); 83 main(args) async => runIsolateTests(args, udpTests, testeeBefore:setupUDP);
OLDNEW
« no previous file with comments | « runtime/observatory/tests/service/tcp_socket_service_test.dart ('k') | sdk/lib/developer/extension.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698