Skip to content

Package: TGrizzlyServerTransport

TGrizzlyServerTransport

nameinstructionbranchcomplexitylinemethod
TGrizzlyServerTransport(Buffer, BufferOutputStream)
M: 9 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 4 C: 0
0%
M: 1 C: 0
0%
close()
M: 1 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 1 C: 0
0%
M: 1 C: 0
0%
flush()
M: 1 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 1 C: 0
0%
M: 1 C: 0
0%
getInputBuffer()
M: 3 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 1 C: 0
0%
M: 1 C: 0
0%
getOutputStream()
M: 3 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 1 C: 0
0%
M: 1 C: 0
0%
isOpen()
M: 2 C: 0
0%
M: 0 C: 0
100%
M: 1 C: 0
0%
M: 1 C: 0
0%
M: 1 C: 0
0%

Coverage

1: /*
2: * Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.
3: *
4: * This program and the accompanying materials are made available under the
5: * terms of the Eclipse Public License v. 2.0, which is available at
6: * http://www.eclipse.org/legal/epl-2.0.
7: *
8: * This Source Code may also be made available under the following Secondary
9: * Licenses when the conditions for such availability set forth in the
10: * Eclipse Public License v. 2.0 are satisfied: GNU General Public License,
11: * version 2 with the GNU Classpath Exception, which is available at
12: * https://www.gnu.org/software/classpath/license.html.
13: *
14: * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
15: */
16:
17: package org.glassfish.grizzly.thrift;
18:
19: import org.apache.thrift.transport.TTransportException;
20: import org.glassfish.grizzly.Buffer;
21: import org.glassfish.grizzly.utils.BufferOutputStream;
22:
23: /**
24: * TGrizzlyServerTransport is the server-side TTransport.
25: * <p>
26: * Input and output buffers are already allocated by Grizzly or
27: * ThriftServerFilter.
28: *
29: * @author Bongjae Chang
30: */
31: public class TGrizzlyServerTransport extends AbstractTGrizzlyTransport {
32:
33: private final Buffer input;
34: private final BufferOutputStream outputStream;
35:
36: public TGrizzlyServerTransport(final Buffer input, final BufferOutputStream outputStream) {
37: this.input = input;
38: this.outputStream = outputStream;
39: }
40:
41: @Override
42: public boolean isOpen() {
43: return true;
44: }
45:
46: @Override
47: public void close() {
48: }
49:
50: @Override
51: public void flush() throws TTransportException {
52: }
53:
54: @Override
55: protected Buffer getInputBuffer() throws TTransportException {
56: return input;
57: }
58:
59: @Override
60: protected BufferOutputStream getOutputStream() {
61: return outputStream;
62: }
63: }