@@ -243,44 +243,44 @@ private Opcode toOpcode( byte opcode ) throws InvalidFrameException {
243243 public List <Framedata > translateFrame ( ByteBuffer buffer ) throws LimitExedeedException , InvalidDataException {
244244 List <Framedata > frames = new LinkedList <Framedata >();
245245 Framedata cur ;
246-
247- if (incompleteframe != null && incompleteframe .capacity () > 0 ) {
248- // Check if we have remaining buffer from last run and prepend it to current buffer.
249- ByteBuffer new_buffer = ByteBuffer .allocate ( incompleteframe .capacity () + buffer .remaining () );
250- new_buffer .put (incompleteframe );
251- new_buffer .put (buffer );
252- buffer = new_buffer ;
253-
254- // Clear frame after using it.
255- incompleteframe = null ;
256- }
257-
258- // Start to read at beginning.
259- buffer .rewind ();
260-
261- // Loop through buffer and process frame by frame.
262- while ( buffer .hasRemaining () ) {
263- // Mark the beginn of a frame.
264- buffer .mark ();
265- try {
266- cur = translateSingleFrame ( buffer );
267- frames .add ( cur );
268- } catch ( IncompleteException e ) {
269- // On last incomplete frame, break loop.
270-
271- // Go back to beginn of frame.
272- buffer .reset ();
273-
274- int remaining = buffer .remaining ();
275- if (remaining > 0 ) {
276- // If buffer is still not empty, put it rest to global cache.
277- incompleteframe = ByteBuffer .allocate ( remaining );
278- incompleteframe .put (buffer );
279- incompleteframe .rewind ();
280- }
281- break ;
282- }
283- }
246+
247+ if (incompleteframe != null && incompleteframe .capacity () > 0 ) {
248+ // Check if we have remaining buffer from last run and prepend it to current buffer.
249+ ByteBuffer new_buffer = ByteBuffer .allocate ( incompleteframe .capacity () + buffer .remaining () );
250+ new_buffer .put (incompleteframe );
251+ new_buffer .put (buffer );
252+ buffer = new_buffer ;
253+
254+ // Clear frame after using it.
255+ incompleteframe = null ;
256+ }
257+
258+ // Start to read at beginning.
259+ buffer .rewind ();
260+
261+ // Loop through buffer and process frame by frame.
262+ while ( buffer .hasRemaining () ) {
263+ // Mark the beginn of a frame.
264+ buffer .mark ();
265+ try {
266+ cur = translateSingleFrame ( buffer );
267+ frames .add ( cur );
268+ } catch ( IncompleteException e ) {
269+ // On last incomplete frame, break loop.
270+
271+ // Go back to beginn of frame.
272+ buffer .reset ();
273+
274+ int remaining = buffer .remaining ();
275+ if (remaining > 0 ) {
276+ // If buffer is still not empty, put it rest to global cache.
277+ incompleteframe = ByteBuffer .allocate ( remaining );
278+ incompleteframe .put (buffer );
279+ incompleteframe .rewind ();
280+ }
281+ break ;
282+ }
283+ }
284284
285285 return frames ;
286286 }
0 commit comments