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

Unified Diff: pkg/dev_compiler/tool/input_sdk/lib/io/http_session.dart

Issue 2698353003: unfork DDC's copy of most SDK libraries (Closed)
Patch Set: revert core_patch Created 3 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 side-by-side diff with in-line comments
Download patch
Index: pkg/dev_compiler/tool/input_sdk/lib/io/http_session.dart
diff --git a/pkg/dev_compiler/tool/input_sdk/lib/io/http_session.dart b/pkg/dev_compiler/tool/input_sdk/lib/io/http_session.dart
deleted file mode 100644
index 90075a5377d7a0efeb87bb39eefa482ed405faf3..0000000000000000000000000000000000000000
--- a/pkg/dev_compiler/tool/input_sdk/lib/io/http_session.dart
+++ /dev/null
@@ -1,174 +0,0 @@
-// Copyright (c) 2013, 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.
-
-part of dart.io;
-
-const String _DART_SESSION_ID = "DARTSESSID";
-
-// A _HttpSession is a node in a double-linked list, with _next and _prev being
-// the previous and next pointers.
-class _HttpSession implements HttpSession {
- // Destroyed marked. Used by the http connection to see if a session is valid.
- bool _destroyed = false;
- bool _isNew = true;
- DateTime _lastSeen;
- Function _timeoutCallback;
- _HttpSessionManager _sessionManager;
- // Pointers in timeout queue.
- _HttpSession _prev;
- _HttpSession _next;
- final String id;
-
- final Map _data = new HashMap();
-
- _HttpSession(this._sessionManager, this.id) : _lastSeen = new DateTime.now();
-
- void destroy() {
- _destroyed = true;
- _sessionManager._removeFromTimeoutQueue(this);
- _sessionManager._sessions.remove(id);
- }
-
- // Mark the session as seen. This will reset the timeout and move the node to
- // the end of the timeout queue.
- void _markSeen() {
- _lastSeen = new DateTime.now();
- _sessionManager._bumpToEnd(this);
- }
-
- DateTime get lastSeen => _lastSeen;
-
- bool get isNew => _isNew;
-
- void set onTimeout(void callback()) {
- _timeoutCallback = callback;
- }
-
- // Map implementation:
- bool containsValue(value) => _data.containsValue(value);
- bool containsKey(key) => _data.containsKey(key);
- operator [](key) => _data[key];
- void operator []=(key, value) { _data[key] = value; }
- putIfAbsent(key, ifAbsent) => _data.putIfAbsent(key, ifAbsent);
- addAll(Map other) => _data.addAll(other);
- remove(key) => _data.remove(key);
- void clear() { _data.clear(); }
- void forEach(void f(key, value)) { _data.forEach(f); }
- Iterable get keys => _data.keys;
- Iterable get values => _data.values;
- int get length => _data.length;
- bool get isEmpty => _data.isEmpty;
- bool get isNotEmpty => _data.isNotEmpty;
-
- String toString() => 'HttpSession id:$id $_data';
-}
-
-// Private class used to manage all the active sessions. The sessions are stored
-// in two ways:
-//
-// * In a map, mapping from ID to HttpSession.
-// * In a linked list, used as a timeout queue.
-class _HttpSessionManager {
- Map<String, _HttpSession> _sessions;
- int _sessionTimeout = 20 * 60; // 20 mins.
- _HttpSession _head;
- _HttpSession _tail;
- Timer _timer;
-
- _HttpSessionManager() : _sessions = {};
-
- String createSessionId() {
- const int _KEY_LENGTH = 16; // 128 bits.
- var data = _IOCrypto.getRandomBytes(_KEY_LENGTH);
- return _CryptoUtils.bytesToHex(data);
- }
-
- _HttpSession getSession(String id) => _sessions[id];
-
- _HttpSession createSession() {
- var id = createSessionId();
- // TODO(ajohnsen): Consider adding a limit and throwing an exception.
- // Should be very unlikely however.
- while (_sessions.containsKey(id)) {
- id = createSessionId();
- }
- var session = _sessions[id] = new _HttpSession(this, id);
- _addToTimeoutQueue(session);
- return session;
- }
-
- void set sessionTimeout(int timeout) {
- _sessionTimeout = timeout;
- _stopTimer();
- _startTimer();
- }
-
- void close() { _stopTimer(); }
-
- void _bumpToEnd(_HttpSession session) {
- _removeFromTimeoutQueue(session);
- _addToTimeoutQueue(session);
- }
-
- void _addToTimeoutQueue(_HttpSession session) {
- if (_head == null) {
- assert(_tail == null);
- _tail = _head = session;
- _startTimer();
- } else {
- assert(_timer != null);
- assert(_tail != null);
- // Add to end.
- _tail._next = session;
- session._prev = _tail;
- _tail = session;
- }
- }
-
- void _removeFromTimeoutQueue(_HttpSession session) {
- if (session._next != null) {
- session._next._prev = session._prev;
- }
- if (session._prev != null) {
- session._prev._next = session._next;
- }
- if (_head == session) {
- // We removed the head element, start new timer.
- _head = session._next;
- _stopTimer();
- _startTimer();
- }
- if (_tail == session) {
- _tail = session._prev;
- }
- session._next = session._prev = null;
- }
-
- void _timerTimeout() {
- _stopTimer(); // Clear timer.
- assert(_head != null);
- var session = _head;
- session.destroy(); // Will remove the session from timeout queue and map.
- if (session._timeoutCallback != null) {
- session._timeoutCallback();
- }
- }
-
- void _startTimer() {
- assert(_timer == null);
- if (_head != null) {
- int seconds = new DateTime.now().difference(_head.lastSeen).inSeconds;
- _timer = new Timer(new Duration(seconds: _sessionTimeout - seconds),
- _timerTimeout);
- }
- }
-
- void _stopTimer() {
- if (_timer != null) {
- _timer.cancel();
- _timer = null;
- }
- }
-}
-
« no previous file with comments | « pkg/dev_compiler/tool/input_sdk/lib/io/http_parser.dart ('k') | pkg/dev_compiler/tool/input_sdk/lib/io/io.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698