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; |
- } |
- } |
-} |
- |