[corelib] dart:developer timeline flow events

runtime/observatory/tests/service/get_vm_timeline_rpc_test.dart

 // Copyright (c) 2015, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 // VMOptions=--error_on_bad_type --error_on_bad_override --complete_timeline
 
 import 'dart:developer';
 import 'package:observatory/service_io.dart';
 import 'package:unittest/unittest.dart';
 
 import 'test_helper.dart';
 
 primeTimeline() {
   Timeline.startSync('apple');
   Timeline.instantSync('ISYNC', arguments: {'fruit': 'banana'});
   Timeline.finishSync();
   TimelineTask task = new TimelineTask();
   task.start('TASK1');
   task.instant('ITASK');
   task.finish();
+
+  Flow flow = Flow.begin();
+  Timeline.startSync('peach', flow: flow);
+  Timeline.finishSync();
+  Timeline.startSync('watermelon', flow: Flow.step(flow.id));
+  Timeline.finishSync();
+  Timeline.startSync('pear', flow: Flow.end(flow.id));
+  Timeline.finishSync();
 }
 
 List<Map> filterForDartEvents(List<Map> events) {
   return events.where((event) => event['cat'] == 'Dart').toList();
 }
 
 bool eventsContains(List<Map> events, String phase, String name) {
   for (Map event in events) {
     if ((event['ph'] == phase) && (event['name'] == name)) {
       return true;
@@ skipping 55 matching lines @@
   }
 }
 
 var tests = [
   (VM vm) async {
     Map result = await vm.invokeRpcNoUpgrade('_getVMTimeline', {});
     expect(result['type'], equals('_Timeline'));
     expect(result['traceEvents'], new isInstanceOf<List>());
     final int numEvents = result['traceEvents'].length;
     List<Map> dartEvents = filterForDartEvents(result['traceEvents']);
-    expect(dartEvents.length, equals(5));
+    expect(dartEvents.length, equals(11));
     allEventsHaveIsolateNumber(dartEvents);
     allEventsHaveIsolateNumber(result['traceEvents']);
     expect(eventsContains(dartEvents, 'I', 'ISYNC'), isTrue);
     expect(eventsContains(dartEvents, 'X', 'apple'), isTrue);
     expect(eventsContains(dartEvents, 'b', 'TASK1'), isTrue);
     expect(eventsContains(dartEvents, 'e', 'TASK1'), isTrue);
     expect(eventsContains(dartEvents, 'n', 'ITASK'), isTrue);
     expect(eventsContains(dartEvents, 'q', 'ITASK'), isFalse);
+    expect(eventsContains(dartEvents, 's', 'peach'), isTrue);
+    expect(eventsContains(dartEvents, 't', 'watermelon'), isTrue);
+    expect(eventsContains(dartEvents, 'f', 'pear'), isTrue);
     // Calculate the time Window of Dart events.
     int origin = timeOrigin(dartEvents);
     int extent = timeDuration(dartEvents, origin);
     // Query for the timeline with the time window for Dart events.
     result = await vm.invokeRpcNoUpgrade('_getVMTimeline',
         {'timeOriginMicros': origin, 'timeExtentMicros': extent});
     // Verify that we received fewer events than before.
     expect(result['traceEvents'].length, lessThan(numEvents));
     // Verify that we have the same number of Dart events.
     List<Map> dartEvents2 = filterForDartEvents(result['traceEvents']);
     expect(dartEvents2.length, dartEvents.length);
   },
 ];
 
 main(args) async => runVMTests(args, tests, testeeBefore: primeTimeline);