Fixed ByteBuf leaks

Mansheng Yang · Mansheng Yang · commit 8fb137a6fec7 · 2016-05-12T15:35:40.000+08:00
PostgreSQLConnection.onDataRow should release the raw ByteBufs after
decoding the data
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
     }
