You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by tr...@apache.org on 2007/10/16 09:44:18 UTC
svn commit: r585066 - in /mina:
branches/1.0/core/src/main/java/org/apache/mina/filter/codec/textline/
branches/1.1/core/src/main/java/org/apache/mina/filter/codec/textline/
trunk/core/src/main/java/org/apache/mina/filter/codec/textline/
Author: trustin
Date: Tue Oct 16 00:44:17 2007
New Revision: 585066
URL: http://svn.apache.org/viewvc?rev=585066&view=rev
Log:
Better exception handling
Modified:
mina/branches/1.0/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java
mina/branches/1.1/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java
Modified: mina/branches/1.0/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java
URL: http://svn.apache.org/viewvc/mina/branches/1.0/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java?rev=585066&r1=585065&r2=585066&view=diff
==============================================================================
--- mina/branches/1.0/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java (original)
+++ mina/branches/1.0/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java Tue Oct 16 00:44:17 2007
@@ -179,8 +179,11 @@
ByteBuffer buf = ctx.getBuffer();
buf.flip();
buf.limit(buf.limit() - matchCount);
- out.write(buf.getString(ctx.getDecoder()));
- buf.clear();
+ try {
+ out.write(buf.getString(ctx.getDecoder()));
+ } finally {
+ buf.clear();
+ }
} else {
int overflowPosition = ctx.getOverflowPosition();
ctx.reset();
@@ -235,8 +238,11 @@
ByteBuffer buf = ctx.getBuffer();
buf.flip();
buf.limit(buf.limit() - matchCount);
- out.write(buf.getString(ctx.getDecoder()));
- buf.clear();
+ try {
+ out.write(buf.getString(ctx.getDecoder()));
+ } finally {
+ buf.clear();
+ }
} else {
int overflowPosition = ctx.getOverflowPosition();
ctx.reset();
Modified: mina/branches/1.1/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java
URL: http://svn.apache.org/viewvc/mina/branches/1.1/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java?rev=585066&r1=585065&r2=585066&view=diff
==============================================================================
--- mina/branches/1.1/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java (original)
+++ mina/branches/1.1/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java Tue Oct 16 00:44:17 2007
@@ -177,8 +177,11 @@
ByteBuffer buf = ctx.getBuffer();
buf.flip();
buf.limit(buf.limit() - matchCount);
- out.write(buf.getString(ctx.getDecoder()));
- buf.clear();
+ try {
+ out.write(buf.getString(ctx.getDecoder()));
+ } finally {
+ buf.clear();
+ }
} else {
int overflowPosition = ctx.getOverflowPosition();
ctx.reset();
@@ -233,8 +236,11 @@
ByteBuffer buf = ctx.getBuffer();
buf.flip();
buf.limit(buf.limit() - matchCount);
- out.write(buf.getString(ctx.getDecoder()));
- buf.clear();
+ try {
+ out.write(buf.getString(ctx.getDecoder()));
+ } finally {
+ buf.clear();
+ }
} else {
int overflowPosition = ctx.getOverflowPosition();
ctx.reset();
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java?rev=585066&r1=585065&r2=585066&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java Tue Oct 16 00:44:17 2007
@@ -177,8 +177,11 @@
IoBuffer buf = ctx.getBuffer();
buf.flip();
buf.limit(buf.limit() - matchCount);
- out.write(buf.getString(ctx.getDecoder()));
- buf.clear();
+ try {
+ out.write(buf.getString(ctx.getDecoder()));
+ } finally {
+ buf.clear();
+ }
} else {
int overflowPosition = ctx.getOverflowPosition();
ctx.reset();
@@ -232,8 +235,11 @@
IoBuffer buf = ctx.getBuffer();
buf.flip();
buf.limit(buf.limit() - matchCount);
- out.write(buf.getString(ctx.getDecoder()));
- buf.clear();
+ try {
+ out.write(buf.getString(ctx.getDecoder()));
+ } finally {
+ buf.clear();
+ }
} else {
int overflowPosition = ctx.getOverflowPosition();
ctx.reset();