Home
last modified time | relevance | path

Searched refs:transport (Results 1 – 25 of 701) sorted by relevance

12345678910>>...29

/thrift-3.4.0/lib/c_glib/src/thrift/c_glib/transport/
Dthrift_zlib_transport.c70 thrift_zlib_transport_read_avail (ThriftTransport *transport) in G_DEFINE_TYPE()
72 ThriftZlibTransport *t = THRIFT_ZLIB_TRANSPORT (transport); in G_DEFINE_TYPE()
78 thrift_zlib_transport_is_open (ThriftTransport *transport) in thrift_zlib_transport_is_open() argument
80 ThriftZlibTransport *t = THRIFT_ZLIB_TRANSPORT (transport); in thrift_zlib_transport_is_open()
81 return (thrift_zlib_transport_read_avail (transport) > 0) || \ in thrift_zlib_transport_is_open()
82 … (t->rstream->avail_in > 0) || THRIFT_TRANSPORT_GET_CLASS (t->transport)->is_open (t->transport); in thrift_zlib_transport_is_open()
87 thrift_zlib_transport_peek (ThriftTransport *transport, GError **error) in thrift_zlib_transport_peek() argument
89 ThriftZlibTransport *t = THRIFT_ZLIB_TRANSPORT (transport); in thrift_zlib_transport_peek()
90 return (thrift_zlib_transport_read_avail (transport) > 0) || \ in thrift_zlib_transport_peek()
91 …(t->rstream->avail_in > 0) || THRIFT_TRANSPORT_GET_CLASS (t->transport)->peek (t->transport, error… in thrift_zlib_transport_peek()
[all …]
Dthrift_transport.c41 thrift_transport_is_open (ThriftTransport *transport) in G_DEFINE_ABSTRACT_TYPE()
43 return THRIFT_TRANSPORT_GET_CLASS (transport)->is_open (transport); in G_DEFINE_ABSTRACT_TYPE()
47 thrift_transport_peek (ThriftTransport *transport, GError **error) in thrift_transport_peek() argument
49 return THRIFT_TRANSPORT_GET_CLASS (transport)->peek (transport, error); in thrift_transport_peek()
53 thrift_transport_open (ThriftTransport *transport, GError **error) in thrift_transport_open() argument
55 return THRIFT_TRANSPORT_GET_CLASS (transport)->open (transport, error); in thrift_transport_open()
59 thrift_transport_close (ThriftTransport *transport, GError **error) in thrift_transport_close() argument
61 return THRIFT_TRANSPORT_GET_CLASS (transport)->close (transport, error); in thrift_transport_close()
65 thrift_transport_read (ThriftTransport *transport, gpointer buf, in thrift_transport_read() argument
68 return THRIFT_TRANSPORT_GET_CLASS (transport)->read (transport, buf, in thrift_transport_read()
[all …]
Dthrift_buffered_transport.c47 thrift_buffered_transport_is_open (ThriftTransport *transport) in G_DEFINE_TYPE()
49 ThriftBufferedTransport *t = THRIFT_BUFFERED_TRANSPORT (transport); in G_DEFINE_TYPE()
50 return THRIFT_TRANSPORT_GET_CLASS (t->transport)->is_open (t->transport); in G_DEFINE_TYPE()
55 thrift_buffered_transport_peek (ThriftTransport *transport, GError **error) in thrift_buffered_transport_peek() argument
57 ThriftBufferedTransport *t = THRIFT_BUFFERED_TRANSPORT (transport); in thrift_buffered_transport_peek()
58 return (t->r_buf->len > 0) || thrift_transport_peek (t->transport, error); in thrift_buffered_transport_peek()
63 thrift_buffered_transport_open (ThriftTransport *transport, GError **error) in thrift_buffered_transport_open() argument
65 ThriftBufferedTransport *t = THRIFT_BUFFERED_TRANSPORT (transport); in thrift_buffered_transport_open()
66 return THRIFT_TRANSPORT_GET_CLASS (t->transport)->open (t->transport, error); in thrift_buffered_transport_open()
71 thrift_buffered_transport_close (ThriftTransport *transport, GError **error) in thrift_buffered_transport_close() argument
[all …]
Dthrift_framed_transport.c50 thrift_framed_transport_is_open (ThriftTransport *transport) in G_DEFINE_TYPE()
52 ThriftFramedTransport *t = THRIFT_FRAMED_TRANSPORT (transport); in G_DEFINE_TYPE()
53 return THRIFT_TRANSPORT_GET_CLASS (t->transport)->is_open (t->transport); in G_DEFINE_TYPE()
58 thrift_framed_transport_peek (ThriftTransport *transport, GError **error) in thrift_framed_transport_peek() argument
60 ThriftFramedTransport *t = THRIFT_FRAMED_TRANSPORT (transport); in thrift_framed_transport_peek()
61 return (t->r_buf->len > 0) || thrift_transport_peek (t->transport, error); in thrift_framed_transport_peek()
66 thrift_framed_transport_open (ThriftTransport *transport, GError **error) in thrift_framed_transport_open() argument
68 ThriftFramedTransport *t = THRIFT_FRAMED_TRANSPORT (transport); in thrift_framed_transport_open()
69 return THRIFT_TRANSPORT_GET_CLASS (t->transport)->open (t->transport, error); in thrift_framed_transport_open()
74 thrift_framed_transport_close (ThriftTransport *transport, GError **error) in thrift_framed_transport_close() argument
[all …]
Dthrift_server_transport.c36 thrift_server_transport_updateKnownMessageSize(ThriftServerTransport *transport, glong size, GError… in G_DEFINE_ABSTRACT_TYPE()
39 ThriftServerTransport *tst = THRIFT_SERVER_TRANSPORT (transport); in G_DEFINE_ABSTRACT_TYPE()
40 ThriftServerTransportClass *tstc = THRIFT_SERVER_TRANSPORT_GET_CLASS (transport); in G_DEFINE_ABSTRACT_TYPE()
42 if(!tstc->resetConsumedMessageSize (transport, size, error)) in G_DEFINE_ABSTRACT_TYPE()
46 if(!tstc->countConsumedMessageBytes (transport, consumed, error)) in G_DEFINE_ABSTRACT_TYPE()
54 thrift_server_transport_checkReadBytesAvailable(ThriftServerTransport *transport, glong numBytes, G… in thrift_server_transport_checkReadBytesAvailable() argument
57 ThriftServerTransport *tst = THRIFT_SERVER_TRANSPORT (transport); in thrift_server_transport_checkReadBytesAvailable()
71 thrift_server_transport_resetConsumedMessageSize(ThriftServerTransport *transport, glong newSize, G… in thrift_server_transport_resetConsumedMessageSize() argument
73 ThriftServerTransport *tst = THRIFT_SERVER_TRANSPORT (transport); in thrift_server_transport_resetConsumedMessageSize()
105 thrift_server_transport_countConsumedMessageBytes(ThriftServerTransport *transport, glong numBytes,… in thrift_server_transport_countConsumedMessageBytes() argument
[all …]
Dthrift_transport.h72 gboolean (*is_open) (ThriftTransport *transport);
73 gboolean (*peek) (ThriftTransport *transport, GError **error);
74 gboolean (*open) (ThriftTransport *transport, GError **error);
75 gboolean (*close) (ThriftTransport *transport, GError **error);
76 gint32 (*read) (ThriftTransport *transport, gpointer buf,
78 gboolean (*read_end) (ThriftTransport *transport, GError **error);
79 gboolean (*write) (ThriftTransport *transport, const gpointer buf,
81 gboolean (*write_end) (ThriftTransport *transport, GError **error);
82 gboolean (*flush) (ThriftTransport *transport, GError **error);
83 gint32 (*read_all) (ThriftTransport *transport, gpointer buf,
[all …]
/thrift-3.4.0/lib/c_glib/test/
Dtestbufferedtransport.c40 ThriftTransport *transport = NULL; in test_create_and_destroy() local
47 g_object_get (G_OBJECT (object), "transport", &transport, in test_create_and_destroy()
57 ThriftTransport *transport = NULL; in test_open_and_close() local
79 transport = g_object_new (THRIFT_TYPE_BUFFERED_TRANSPORT, in test_open_and_close()
83 g_assert (thrift_buffered_transport_open (transport, NULL) == TRUE); in test_open_and_close()
84 g_assert (thrift_buffered_transport_is_open (transport) == TRUE); in test_open_and_close()
85 g_assert (thrift_buffered_transport_close (transport, NULL) == TRUE); in test_open_and_close()
86 g_object_unref (transport); in test_open_and_close()
94 transport = g_object_new (THRIFT_TYPE_BUFFERED_TRANSPORT, in test_open_and_close()
97 g_assert (thrift_buffered_transport_open (transport, &err) == FALSE); in test_open_and_close()
[all …]
Dtestfdtransport.c46 ThriftTransport *transport; in test_open_and_close() local
58 transport = THRIFT_TRANSPORT (g_object_new (THRIFT_TYPE_FD_TRANSPORT, in test_open_and_close()
61 klass = THRIFT_TRANSPORT_GET_CLASS (transport); in test_open_and_close()
64 g_assert (klass->is_open (transport)); in test_open_and_close()
65 g_assert (klass->peek (transport, &error)); in test_open_and_close()
66 g_assert (klass->open (transport, &error)); in test_open_and_close()
67 g_assert (klass->is_open (transport)); in test_open_and_close()
68 g_assert (klass->peek (transport, &error)); in test_open_and_close()
70 g_assert (klass->close (transport, &error)); in test_open_and_close()
71 g_assert (! klass->open (transport, &error)); in test_open_and_close()
[all …]
Dtestthriftfdreadcheck.c40 ThriftTransport *transport; in test_open_and_close() local
55 transport = THRIFT_TRANSPORT (g_object_new (THRIFT_TYPE_FD_TRANSPORT, in test_open_and_close()
58 klass = THRIFT_TRANSPORT_GET_CLASS (transport); in test_open_and_close()
61 g_assert (klass->is_open (transport)); in test_open_and_close()
62 g_assert (klass->peek (transport, &error)); in test_open_and_close()
63 g_assert (klass->open (transport, &error)); in test_open_and_close()
64 g_assert (klass->is_open (transport)); in test_open_and_close()
65 g_assert (klass->peek (transport, &error)); in test_open_and_close()
67 g_assert (klass->close (transport, &error)); in test_open_and_close()
68 g_assert (! klass->open (transport, &error)); in test_open_and_close()
[all …]
Dtestframedtransport.c39 ThriftTransport *transport = NULL; in test_create_and_destroy() local
46 g_object_get (G_OBJECT (object), "transport", &transport, in test_create_and_destroy()
56 ThriftTransport *transport = NULL; in test_open_and_close() local
78 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_open_and_close()
82 g_assert (thrift_framed_transport_open (transport, NULL) == TRUE); in test_open_and_close()
83 g_assert (thrift_framed_transport_is_open (transport) == TRUE); in test_open_and_close()
84 g_assert (thrift_framed_transport_close (transport, NULL) == TRUE); in test_open_and_close()
85 g_object_unref (transport); in test_open_and_close()
93 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_open_and_close()
96 g_assert (thrift_framed_transport_open (transport, &err) == FALSE); in test_open_and_close()
[all …]
Dtestthriftframedreadcheck.c40 ThriftTransport *transport = NULL; in test_open_and_close() local
62 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_open_and_close()
66 g_assert (thrift_framed_transport_open (transport, NULL) == TRUE); in test_open_and_close()
67 g_assert (thrift_framed_transport_is_open (transport) == TRUE); in test_open_and_close()
68 g_assert (thrift_framed_transport_close (transport, NULL) == TRUE); in test_open_and_close()
69 g_object_unref (transport); in test_open_and_close()
77 transport = g_object_new (THRIFT_TYPE_FRAMED_TRANSPORT, in test_open_and_close()
80 g_assert (thrift_framed_transport_open (transport, &err) == FALSE); in test_open_and_close()
81 g_object_unref (transport); in test_open_and_close()
97 ThriftTransport *transport = NULL; in test_read_and_write() local
[all …]
Dtestthriftbufferedreadcheck.c42 ThriftTransport *transport = NULL; in test_open_and_close() local
64 transport = g_object_new (THRIFT_TYPE_BUFFERED_TRANSPORT, in test_open_and_close()
69 g_assert (thrift_buffered_transport_open (transport, NULL) == TRUE); in test_open_and_close()
70 g_assert (thrift_buffered_transport_is_open (transport) == TRUE); in test_open_and_close()
71 g_assert (thrift_buffered_transport_close (transport, NULL) == TRUE); in test_open_and_close()
72 g_object_unref (transport); in test_open_and_close()
80 transport = g_object_new (THRIFT_TYPE_BUFFERED_TRANSPORT, in test_open_and_close()
83 g_assert (thrift_buffered_transport_open (transport, &err) == FALSE); in test_open_and_close()
84 g_object_unref (transport); in test_open_and_close()
99 ThriftTransport *transport = NULL; in test_read_and_write() local
[all …]
Dtestzlibtransport.c44 ThriftTransport *transport = NULL; in test_create_and_destroy() local
54 g_object_get (G_OBJECT (object), "transport", &transport, in test_create_and_destroy()
67 ThriftTransport *transport = NULL; in test_open_and_close() local
89 transport = g_object_new (THRIFT_TYPE_ZLIB_TRANSPORT, in test_open_and_close()
93 g_assert (thrift_zlib_transport_open (transport, NULL) == TRUE); in test_open_and_close()
94 g_assert (thrift_zlib_transport_is_open (transport) == TRUE); in test_open_and_close()
95 g_assert (thrift_zlib_transport_close (transport, NULL) == TRUE); in test_open_and_close()
96 g_object_unref (transport); in test_open_and_close()
104 transport = g_object_new (THRIFT_TYPE_ZLIB_TRANSPORT, in test_open_and_close()
107 g_assert (thrift_zlib_transport_open (transport, &err) == FALSE); in test_open_and_close()
[all …]
Dtesttransportsocket.c94 ThriftTransport *transport = NULL; in test_open_and_close() local
115 transport = THRIFT_TRANSPORT (tsocket); in test_open_and_close()
116 thrift_socket_open (transport, NULL); in test_open_and_close()
117 g_assert (thrift_socket_is_open (transport) == TRUE); in test_open_and_close()
118 thrift_socket_close (transport, NULL); in test_open_and_close()
119 g_assert (thrift_socket_is_open (transport) == FALSE); in test_open_and_close()
123 thrift_socket_close (transport, NULL); in test_open_and_close()
129 transport = THRIFT_TRANSPORT (tsocket); in test_open_and_close()
130 g_assert (thrift_socket_open (transport, &err) == FALSE); in test_open_and_close()
137 transport = THRIFT_TRANSPORT (tsocket); in test_open_and_close()
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/
DTZlibTransport.java19 package org.apache.thrift.transport;
50 public TZlibTransport(TTransport transport) throws TTransportException { in TZlibTransport() argument
51 this(transport, Deflater.BEST_COMPRESSION); in TZlibTransport()
60 public TZlibTransport(TTransport transport, int compressionLevel) throws TTransportException { in TZlibTransport() argument
62 Objects.isNull(transport.getConfiguration()) in TZlibTransport()
64 : transport.getConfiguration()); in TZlibTransport()
65 transport_ = transport; in TZlibTransport()
93 private TTransport transport = null; field in TTransportInputStream
95 public TTransportInputStream(TTransport transport) { in TTransportInputStream() argument
96 this.transport = transport; in TTransportInputStream()
[all …]
/thrift-3.4.0/lib/php/lib/Server/
DTForkingServer.php43 $transport = $this->transport_->accept();
45 if ($transport != null) {
49 $this->handleParent($transport, $pid);
51 $this->handleChild($transport);
66 * @param TTransport $transport
70 private function handleParent(TTransport $transport, $pid) argument
72 $this->children_[$pid] = $transport;
78 * @param TTransport $transport
81 private function handleChild(TTransport $transport) argument
84 $inputTransport = $this->inputTransportFactory_->getTransport($transport);
[all …]
/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/transport/
DTestTIOStreamTransport.java19 package org.apache.thrift.transport;
37 TTransport transport = new TIOStreamTransport(input, output); in testOpenClose_2streams() local
38 runOpenClose(transport); in testOpenClose_2streams()
46 TTransport transport = new TIOStreamTransport(input); in testOpenClose_1input() local
47 runOpenClose(transport); in testOpenClose_1input()
54 TTransport transport = new TIOStreamTransport(output); in testIOpenClose_1output() local
55 runOpenClose(transport); in testIOpenClose_1output()
58 private void runOpenClose(TTransport transport) throws TTransportException { in runOpenClose() argument
59 transport.open(); in runOpenClose()
60 boolean b1 = transport.isOpen(); in runOpenClose()
[all …]
/thrift-3.4.0/lib/swift/Sources/
DTFramedTransport.swift27 public var transport: TTransport variable
34 public init(transport: TTransport, maxSize: Int) {
35 self.transport = transport
39 public convenience init(transport: TTransport) {
40 self.init(transport: transport, maxSize: TFramedTransport.defaultMaxLength)
44 let read = try transport.readAll(size: TFramedTransport.headerSize) in readHeader()
68 let data = try transport.readAll(size: toRead) in read()
80 try transport.write(data: frameSize) in flush()
81 try transport.write(data: buff) in flush()
82 try transport.flush() in flush()
[all …]
/thrift-3.4.0/lib/perl/lib/Thrift/
DFramedTransport.pm40 my $transport = shift;
45 transport => $transport,
58 return $self->{transport}->isOpen();
65 $self->{transport}->open();
72 if (defined $self->{transport}) {
73 $self->{transport}->close();
90 return $self->{transport}->read($len);
117 my $buf = $self->{transport}->readAll(4);
121 $self->{rBuf} = $self->{transport}->readAll($sz);
137 return $self->{transport}->write($buf, $len);
[all …]
DBufferedTransport.pm35 my $transport = shift;
40 transport => $transport,
54 return $self->{transport}->isOpen();
60 $self->{transport}->open();
66 $self->{transport}->close();
74 return $self->{transport}->readAll($len);
84 return $self->{transport}->read($len);
94 $self->{transport}->write($self->{wBuf});
104 $self->{transport}->write($self->{wBuf});
107 $self->{transport}->flush();
/thrift-3.4.0/lib/c_glib/
DMakefile.am48 src/thrift/c_glib/transport/thrift_transport.c \
49 src/thrift/c_glib/transport/thrift_transport_factory.c \
50 src/thrift/c_glib/transport/thrift_buffered_transport_factory.c \
51 src/thrift/c_glib/transport/thrift_framed_transport_factory.c \
52 src/thrift/c_glib/transport/thrift_zlib_transport_factory.c \
53 src/thrift/c_glib/transport/thrift_socket.c \
54 src/thrift/c_glib/transport/thrift_ssl_socket.c \
55 src/thrift/c_glib/transport/thrift_server_transport.c \
56 src/thrift/c_glib/transport/thrift_server_socket.c \
57 src/thrift/c_glib/transport/thrift_buffered_transport.c \
[all …]
/thrift-3.4.0/lib/cpp/
DMakefile.am72 src/thrift/transport/TTransportException.cpp \
73 src/thrift/transport/TFDTransport.cpp \
74 src/thrift/transport/TFileTransport.cpp \
75 src/thrift/transport/TSimpleFileTransport.cpp \
76 src/thrift/transport/THttpTransport.cpp \
77 src/thrift/transport/THttpClient.cpp \
78 src/thrift/transport/THttpServer.cpp \
79 src/thrift/transport/TSocket.cpp \
80 src/thrift/transport/TPipe.cpp \
81 src/thrift/transport/TPipeServer.cpp \
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/sasl/
DFrameReader.java20 package org.apache.thrift.transport.sasl;
23 import org.apache.thrift.transport.TEOFException;
24 import org.apache.thrift.transport.TTransport;
25 import org.apache.thrift.transport.TTransportException;
51 public boolean read(TTransport transport) throws TSaslNegotiationException, TTransportException { in read() argument
53 if (readHeader(transport)) { in read()
62 return readPayload(transport); in read()
72 private boolean readHeader(TTransport transport) in readHeader() argument
74 return header.read(transport); in readHeader()
84 private boolean readPayload(TTransport transport) throws TTransportException { in readPayload() argument
[all …]
/thrift-3.4.0/test/py/
DTestClient.py46 …self.transport = THttpClient.THttpClient(uri, cafile=__cafile, cert_file=__certfile, key_file=__ke…
48 self.transport = THttpClient.THttpClient(uri)
51 from thrift.transport import TSSLSocket
56 self.transport = TTransport.TBufferedTransport(socket)
58 self.transport = TTransport.TFramedTransport(socket)
60 self.transport = TTransport.TBufferedTransport(socket)
64 self.transport = TZlibTransport.TZlibTransport(self.transport, 9)
65 self.transport.open()
66 protocol = self.get_protocol(self.transport)
69 protocol2 = self.get_protocol2(self.transport)
[all …]
/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/transport/sasl/
DTestSaslNegotiationFrameReader.java20 package org.apache.thrift.transport.sasl;
28 import org.apache.thrift.transport.TMemoryInputTransport;
29 import org.apache.thrift.transport.TTransportException;
36 TMemoryInputTransport transport = new TMemoryInputTransport(); in testRead() local
39 negotiationReader.read(transport); in testRead()
46 transport.reset(buffer.array()); in testRead()
47 negotiationReader.read(transport); in testRead()
52 transport.reset(new byte[20]); in testRead()
53 negotiationReader.read(transport); in testRead()
63 TMemoryInputTransport transport = new TMemoryInputTransport(bytes); in testReadInvalidNegotiationStatus() local
[all …]

12345678910>>...29