mongo and postgres

conn_pool/CHANGELOG.md

@@ -1,5 +1,9 @@
 # Change log
 
+## 2.1.5
+
++ Minor improvements to `SharedPool` release
+
 ## 2.1.3
 
 + Documentation

conn_pool/example/example.dart

@@ -1,5 +1,3 @@
 import 'package:conn_pool/conn_pool.dart';
 
-main() {
-
-}
+main() {}

conn_pool/lib/src/counted_set.dart

@@ -43,9 +43,8 @@ class CountedSet<T> {
 
     Set<T> set = _set[count];
     if (set == null) throw Exception('$value is not located at $count!');
-    if (!set.remove(value))
-      throw Exception('$value is not located at $count!');
-    if(set.isEmpty) _set.remove(count);
+    if (!set.remove(value)) throw Exception('$value is not located at $count!');
+    if (set.isEmpty) _set.remove(count);
 
     count++;
     set = _set[count] ??= Set<T>();
@@ -59,9 +58,8 @@ class CountedSet<T> {
 
     Set<T> set = _set[count];
     if (set == null) throw Exception('$value is not located at $count!');
-    if (!set.remove(value))
-      throw Exception('$value is not located at $count!');
-    if(set.isEmpty) _set.remove(count);
+    if (!set.remove(value)) throw Exception('$value is not located at $count!');
+    if (set.isEmpty) _set.remove(count);
 
     count--;
     set = _set[count] ??= Set<T>();
@@ -77,15 +75,15 @@ class CountedSet<T> {
 
   int numAt(int count) {
     Set<T> set = _set[count];
-    if(set == null) return 0;
+    if (set == null) return 0;
     return set.length;
   }
 
   List<T> removeAllAt(int count) {
     Set<T> set = _set[count];
-    if(set == null) return [];
+    if (set == null) return [];
 
-    for(T t in set) _values.remove(t);
+    for (T t in set) _values.remove(t);
     _set.remove(count);
 
     return set.toList();

conn_pool/lib/src/pool.dart

@@ -50,9 +50,12 @@ class SharedPool<T> implements Pool<T> {
 
   /// Releases [connection] back to the pool
   void release(Connection<T> connection) {
-    int count = _pool.countOf(connection);
-    if (count == null || count == 0) return;
-    _pool.dec(connection);
+    if (_d <= 0) return;
+    if (!connection.isReleased) {
+      try {
+        _pool.dec(connection);
+      } catch (e) {}
+    }
     if (_pool.length != maxSize) return;
     if (_pool.numAt(0) < _d) return;
     var removes = _pool.removeAllAt(0);

conn_pool/pubspec.yaml

@@ -1,6 +1,6 @@
 name: conn_pool
 description: A starting point for Dart libraries or applications.
-version: 2.1.4
+version: 2.1.5
 homepage: https://github.com/Jaguar-dart/db
 author: Ravi Teja Gudapati <[email protected]>
 

conn_pool/test/conn_pool_test.dart

@@ -3,10 +3,8 @@ import 'package:test/test.dart';
 
 void main() {
   group('A group of tests', () {
-    setUp(() {
-    });
+    setUp(() {});
 
-    test('First Test', () {
-    });
+    test('First Test', () {});
   });
 }