OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 library chat_server; | 5 library chat_server; |
6 import 'dart:async'; | 6 import 'dart:async'; |
7 import 'dart:io'; | 7 import 'dart:io'; |
8 import 'dart:isolate'; | 8 import 'dart:isolate'; |
9 import 'dart:json' as json; | 9 import 'dart:json' as json; |
10 import 'dart:math'; | 10 import 'dart:math'; |
(...skipping 607 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
618 // range is split over a number of buckets where each bucket collects | 618 // range is split over a number of buckets where each bucket collects |
619 // the number of events happening in that time sub-range. The first | 619 // the number of events happening in that time sub-range. The first |
620 // constructor arument specifies the time range in milliseconds. The | 620 // constructor arument specifies the time range in milliseconds. The |
621 // buckets are in the list _buckets organized at a circular buffer | 621 // buckets are in the list _buckets organized at a circular buffer |
622 // with _currentBucket marking the bucket where an event was last | 622 // with _currentBucket marking the bucket where an event was last |
623 // recorded. A current sum of the content of all buckets except the | 623 // recorded. A current sum of the content of all buckets except the |
624 // one pointed a by _currentBucket is kept in _sum. | 624 // one pointed a by _currentBucket is kept in _sum. |
625 class Rate { | 625 class Rate { |
626 Rate([int timeRange = 1000, int buckets = 10]) | 626 Rate([int timeRange = 1000, int buckets = 10]) |
627 : _timeRange = timeRange, | 627 : _timeRange = timeRange, |
628 _buckets = new List.fixedLength(buckets + 1), // Current bucket is not
in the sum. | 628 _buckets = new List(buckets + 1), // Current bucket is not in the sum. |
629 _currentBucket = 0, | 629 _currentBucket = 0, |
630 _currentBucketTime = new DateTime.now().millisecondsSinceEpoch, | 630 _currentBucketTime = new DateTime.now().millisecondsSinceEpoch, |
631 _sum = 0 { | 631 _sum = 0 { |
632 _bucketTimeRange = (_timeRange / buckets).toInt(); | 632 _bucketTimeRange = (_timeRange / buckets).toInt(); |
633 for (int i = 0; i < _buckets.length; i++) { | 633 for (int i = 0; i < _buckets.length; i++) { |
634 _buckets[i] = 0; | 634 _buckets[i] = 0; |
635 } | 635 } |
636 } | 636 } |
637 | 637 |
638 // Record the specified number of events. | 638 // Record the specified number of events. |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
671 } | 671 } |
672 } | 672 } |
673 | 673 |
674 int _timeRange; | 674 int _timeRange; |
675 List<int> _buckets; | 675 List<int> _buckets; |
676 int _currentBucket; | 676 int _currentBucket; |
677 int _currentBucketTime; | 677 int _currentBucketTime; |
678 num _bucketTimeRange; | 678 num _bucketTimeRange; |
679 int _sum; | 679 int _sum; |
680 } | 680 } |
OLD | NEW |