Mercurial > stress-tester
changeset 1114:776dcb7c749e
PgSql bugfixes
| author | Devel 2 |
|---|---|
| date | Thu, 21 May 2020 12:30:07 +0200 |
| parents | 37d6e04592dc |
| children | fdb8d3772440 |
| files | stress-tester/src/main/java/com/passus/st/client/pgsql/PgSqlFlowHandlerDataDecoder.java stress-tester/src/main/java/com/passus/st/client/pgsql/PgSqlResponsePacketsDecoder.java |
| diffstat | 2 files changed, 10 insertions(+), 0 deletions(-) [+] |
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/client/pgsql/PgSqlFlowHandlerDataDecoder.java Thu May 21 11:53:03 2020 +0200 +++ b/stress-tester/src/main/java/com/passus/st/client/pgsql/PgSqlFlowHandlerDataDecoder.java Thu May 21 12:30:07 2020 +0200 @@ -40,6 +40,11 @@ } @Override + public void clear(FlowContext flowContext) { + decoder.clear(); + } + + @Override public int decode(ByteBuff buffer, FlowContext flowContext) { int res = decoder.decode(buffer); if (decoder.state() == DataDecoder.STATE_FINISHED) {
--- a/stress-tester/src/main/java/com/passus/st/client/pgsql/PgSqlResponsePacketsDecoder.java Thu May 21 11:53:03 2020 +0200 +++ b/stress-tester/src/main/java/com/passus/st/client/pgsql/PgSqlResponsePacketsDecoder.java Thu May 21 12:30:07 2020 +0200 @@ -41,6 +41,11 @@ return bulk; } + @Override + public void clear() { + bulk.packets.clear(); + } + private void doDecode(byte[] data, int offset, int length) { try { decoder.decode(data, offset, length);