Merge pull request #181 from lightyang/master

mauricio · mauricio · commit 5be0eb17165a · 2016-05-20T17:36:53.000-04:00
Fixed ByteBuf leaks
diff --git a/postgresql-async/src/main/scala/com/github/mauricio/async/db/postgresql/PostgreSQLConnection.scala b/postgresql-async/src/main/scala/com/github/mauricio/async/db/postgresql/PostgreSQLConnection.scala
@@ -191,11 +191,16 @@ class PostgreSQLConnection
     var x = 0
 
     while ( x < m.values.size ) {
-      items(x) = if ( m.values(x) == null ) {
+      val buf = m.values(x)
+      items(x) = if ( buf == null ) {
         null
       } else {
-        val columnType = this.currentQuery.get.columnTypes(x)
-        this.decoderRegistry.decode(columnType, m.values(x), configuration.charset)
+        try {
+          val columnType = this.currentQuery.get.columnTypes(x)
+          this.decoderRegistry.decode(columnType, buf, configuration.charset)
+        } finally {
+          buf.release()
+        }
       }
       x += 1
     }
