8000 Removing volatiles · mst-appear/postgresql-async@9fd4385 · GitHub
[go: up one dir, main page]
Skip to content

Commit 9fd4385

Browse files
mauriciomauricio
committed
Removing volatiles
1 parent 9df4129 commit 9fd4385

File tree

1 file changed

+13
-13
lines changed

1 file changed

+13
-13
lines changed

‎mysql-async/src/main/scala/com/github/mauricio/async/db/mysql/codec/MySQLFrameDecoder.scala

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -45,19 +45,19 @@ class MySQLFrameDecoder(charset: Charset, connectionId : String) extends ByteToM
4545
private final val rowDecoder = new ResultSetRowDecoder(charset)
4646
private final val preparedStatementPrepareDecoder = new PreparedStatementPrepareResponseDecoder()
4747

48-
@volatile private[codec] var processingColumns = false
49-
@volatile private[codec] var processingParams = false
50-
@volatile private[codec] var isInQuery = false
51-
@volatile private[codec] var isPreparedStatementPrepare = false
52-
@volatile private[codec] var isPreparedStatementExecute = false
53-
@volatile private[codec] var isPreparedStatementExecuteRows = false
54-
55-
@volatile private[codec] var totalParams = 0L
56-
@volatile private[codec] var processedParams = 0L
57-
@volatile private[codec] var totalColumns = 0L
58-
@volatile private[codec] var processedColumns = 0L
59-
60-
@volatile private var hasReadColumnsCount = false
48+
private[codec] var processingColumns = false
49+
private[codec] var processingParams = false
50+
private[codec] var isInQuery = false
51+
private[codec] var isPreparedStatementPrepare = false
52+
private[codec] var isPreparedStatementExecute = false
53+
private[codec] var isPreparedStatementExecuteRows = false
54+
55+
private[codec] var totalParams = 0L
56+
private[codec] var processedParams = 0L
57+
private[codec] var totalColumns = 0L
58+
private[codec] var processedColumns = 0L
59+
60+
private var hasReadColumnsCount = false
6161

6262
def decode(ctx: ChannelHandlerContext, buffer: ByteBuf, out: java.util.List[Object]): Unit = {
6363
if (buffer.readableBytes() > 4) {

0 commit comments

Comments
 (0)
0