grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove unused ByteBufDeframer. 

It was previously replaced by the new deframer.
-------------
Created by MOE: http://code.google.com/p/moe-java
MOE_MIGRATED_REVID=73750795
This commit is contained in:
ejona 2014-08-20 14:30:22 -07:00 committed by Eric Anderson
parent 3184bb8fec
commit 603959e640
1 changed files with 0 additions and 75 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

75
core/src/main/java/com/google/net/stubby/newtransport/netty/ByteBufDeframer.java
View File

@ -1,75 +0,0 @@
package com.google.net.stubby.newtransport.netty;
import com.google.net.stubby.newtransport.Deframer;
import com.google.net.stubby.newtransport.GrpcMessageListener;
import com.google.net.stubby.newtransport.TransportFrameUtil;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufAllocator;
import io.netty.buffer.ByteBufInputStream;
import io.netty.buffer.CompositeByteBuf;
import io.netty.buffer.UnpooledByteBufAllocator;
import java.io.DataInputStream;
import java.io.IOException;
import java.nio.ByteOrder;
/**
* Parse a sequence of {@link ByteBuf} instances that represent the frames of a GRPC call
*/
public class ByteBufDeframer extends Deframer<ByteBuf> {
private final CompositeByteBuf buffer;
public ByteBufDeframer(GrpcMessageListener target) {
this(UnpooledByteBufAllocator.DEFAULT, target);
}
public ByteBufDeframer(ByteBufAllocator alloc, GrpcMessageListener target) {
super(target);
buffer = alloc.compositeBuffer();
}
public void dispose() {
// Remove the components from the composite buffer. This should set the reference
// count on all buffers to zero.
buffer.removeComponents(0, buffer.numComponents());
// Release the composite buffer
buffer.release();
}
@Override
protected DataInputStream prefix(ByteBuf frame) throws IOException {
buffer.addComponent(frame);
buffer.writerIndex(buffer.writerIndex() + frame.writerIndex() - frame.readerIndex());
return new DataInputStream(new ByteBufInputStream(buffer));
}
@Override
protected int consolidate() {
buffer.consolidate();
return buffer.readableBytes();
}
@Override
protected ByteBuf decompress(ByteBuf frame) throws IOException {
if (frame.readableBytes() == 0) {
frame.retain();
return frame;
}
frame = frame.order(ByteOrder.BIG_ENDIAN);
int compressionType = frame.readUnsignedByte();
int frameLength = frame.readUnsignedMedium();
if (frameLength != frame.readableBytes()) {
throw new IllegalArgumentException("GRPC and buffer lengths misaligned. Frame length="
+ frameLength + ", readableBytes=" + frame.readableBytes());
}
if (TransportFrameUtil.isNotCompressed(compressionType)) {
// Need to retain the frame as we may be holding it over channel events
frame.retain();
return frame;
}
throw new IOException("Unknown compression type " + compressionType);
}
}