channelBuffer = ChannelBuffers.wrappedBuffer(bytes) | channelBuffer = Unpooled.wrappedBuffer(bytes) | ChannelBuffers.wrappedBuffer(bytes) | Unpooled.wrappedBuffer(bytes) | graylog2-server | 5249012d1d82a15cf1533b5042eead6f87636370 | org.graylog.plugins.netflow.codecs.NetflowV9CodecAggregatorTest | | _1 | channelBuffer |
---|
_2 | channelBuffer |
---|
| | | | AssignedTo | True |
buffer = ChannelBuffers.wrappedBuffer(outputStream.toByteArray()) | buffer = Unpooled.wrappedBuffer(outputStream.toByteArray()) | ChannelBuffers.wrappedBuffer(outputStream.toByteArray()) | Unpooled.wrappedBuffer(outputStream.toByteArray()) | graylog2-server | 20b05ffe6fb1a4e8f7b79f687b28fbe9fd34801f | org.graylog.plugins.beats.BeatsFrameDecoder | | | v0 | outputStream.toByteArray() |
---|
| | v0 | outputStream.toByteArray() |
---|
| AssignedTo | True |
buffer = ChannelBuffers.wrappedBuffer(ByteStreams.toByteArray(in)) | buffer = Unpooled.wrappedBuffer(ByteStreams.toByteArray(in)) | ChannelBuffers.wrappedBuffer(ByteStreams.toByteArray(in)) | Unpooled.wrappedBuffer(ByteStreams.toByteArray(in)) | graylog2-server | 20b05ffe6fb1a4e8f7b79f687b28fbe9fd34801f | org.graylog.plugins.beats.BeatsFrameDecoder | | | v0 | ByteStreams.toByteArray(in) |
---|
| | v0 | ByteStreams.toByteArray(in) |
---|
| AssignedTo | True |
buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | buf = Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | hadoop | f41a368c146ab5ebea770017621256d3ff526046 | org.apache.hadoop.hdfs.nfs.nfs3.RpcProgramNfs3 | | | v0 | out.asReadOnlyWrap().buffer() |
---|
| | v0 | out.asReadOnlyWrap().buffer() |
---|
| AssignedTo | True |
buf = ChannelBuffers.wrappedBuffer(reply.asReadOnlyWrap().buffer()) | buf = Unpooled.wrappedBuffer(reply.asReadOnlyWrap().buffer()) | ChannelBuffers.wrappedBuffer(reply.asReadOnlyWrap().buffer()) | Unpooled.wrappedBuffer(reply.asReadOnlyWrap().buffer()) | hadoop | f41a368c146ab5ebea770017621256d3ff526046 | org.apache.hadoop.hdfs.nfs.nfs3.RpcProgramNfs3 | | | v0 | reply.asReadOnlyWrap().buffer() |
---|
| | v0 | reply.asReadOnlyWrap().buffer() |
---|
| AssignedTo | True |
buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | buf = Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | hadoop | f41a368c146ab5ebea770017621256d3ff526046 | org.apache.hadoop.hdfs.nfs.mount.RpcProgramMountd | | | v0 | out.asReadOnlyWrap().buffer() |
---|
| | v0 | out.asReadOnlyWrap().buffer() |
---|
| AssignedTo | True |
b = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | b = Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | hadoop | f41a368c146ab5ebea770017621256d3ff526046 | org.apache.hadoop.oncrpc.TestFrameDecoder.TestRpcProgram | | | v0 | out.asReadOnlyWrap().buffer() |
---|
| | v0 | out.asReadOnlyWrap().buffer() |
---|
| AssignedTo | True |
buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | buf = Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | hadoop | f41a368c146ab5ebea770017621256d3ff526046 | org.apache.hadoop.portmap.RpcProgramPortmap | | | v0 | out.asReadOnlyWrap().buffer() |
---|
| | v0 | out.asReadOnlyWrap().buffer() |
---|
| AssignedTo | True |
header = ChannelBuffers.wrappedBuffer(fragmentHeader) | header = Unpooled.wrappedBuffer(fragmentHeader) | ChannelBuffers.wrappedBuffer(fragmentHeader) | Unpooled.wrappedBuffer(fragmentHeader) | hadoop | f41a368c146ab5ebea770017621256d3ff526046 | org.apache.hadoop.oncrpc.RpcUtil.RpcTcpResponseStage | | | | | | AssignedTo | True |
buf = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | buf = Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | hadoop | f41a368c146ab5ebea770017621256d3ff526046 | org.apache.hadoop.oncrpc.RpcProgram | | | v0 | out.asReadOnlyWrap().buffer() |
---|
| | v0 | out.asReadOnlyWrap().buffer() |
---|
| AssignedTo | True |
b = ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | b = Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | ChannelBuffers.wrappedBuffer(out.asReadOnlyWrap().buffer()) | Unpooled.wrappedBuffer(out.asReadOnlyWrap().buffer()) | hadoop | f41a368c146ab5ebea770017621256d3ff526046 | org.apache.hadoop.oncrpc.RpcProgram | | | v0 | out.asReadOnlyWrap().buffer() |
---|
| | v0 | out.asReadOnlyWrap().buffer() |
---|
| AssignedTo | True |
return ChannelBuffers.wrappedBuffer(allChunks); | return Unpooled.wrappedBuffer(allChunks); | ChannelBuffers.wrappedBuffer(allChunks) | Unpooled.wrappedBuffer(allChunks) | graylog2-server | 6762727721a8a40679cd98992a3d4c756815d4ed | org.graylog2.inputs.codecs.GelfChunkAggregator | | _1 | checkForCompletion |
---|
_2 | checkForCompletion |
---|
| | | | Returns | True |
buffer = ChannelBuffers.wrappedBuffer(value) | buffer = Unpooled.wrappedBuffer(value) | ChannelBuffers.wrappedBuffer(value) | Unpooled.wrappedBuffer(value) | crate | ece360395b432f7f7b7bc1cfbe3e7a23c0802d95 | io.crate.protocols.postgres.types.BasePGTypeTest | | | | | | AssignedTo | True |