Home
last modified time | relevance | path

Searched refs:connection (Results 1 – 25 of 36) sorted by relevance

12

/thrift-3.4.0/lib/cpp/src/thrift/qt/
DTQTcpServer.cpp54 explicit ConnectionContext(shared_ptr<QTcpSocket> connection, in ConnectionContext()
58 : connection_(connection), transport_(transport), iprot_(iprot), oprot_(oprot) {} in ConnectionContext()
77 shared_ptr<QTcpSocket> connection(server_->nextPendingConnection()); in processIncoming() local
84 transport = shared_ptr<TTransport>(new TQIODeviceTransport(connection)); in processIncoming()
92 ctxMap_[connection.get()] in processIncoming()
93 = std::make_shared<ConnectionContext>(connection, transport, iprot, oprot); in processIncoming()
95 connect(connection.get(), SIGNAL(readyRead()), SLOT(beginDecode())); in processIncoming()
97 connect(connection.get(), SIGNAL(disconnected()), SLOT(socketClosed())); in processIncoming()
102 auto* connection(qobject_cast<QTcpSocket*>(sender())); in beginDecode() local
103 Q_ASSERT(connection); in beginDecode()
[all …]
DTQTcpServer.h60 void deleteConnectionContext(QTcpSocket* connection);
67 void scheduleDeleteConnectionContext(QTcpSocket* connection);
/thrift-3.4.0/lib/javame/src/org/apache/thrift/transport/
DTHttpClient.java45 private HttpConnection connection = null; field in THttpClient
87 if (connection != null) { in close()
89 connection.close(); in close()
92 connection = null; in close()
126 connection = (HttpConnection)Connector.open(url_); in flush()
129 connection.setRequestMethod("POST"); in flush()
130 connection.setRequestProperty("Content-Type", "application/x-thrift"); in flush()
131 connection.setRequestProperty("Accept", "application/x-thrift"); in flush()
132 connection.setRequestProperty("User-Agent", "JavaME/THttpClient"); in flush()
134 connection.setRequestProperty("Connection", "Keep-Alive"); in flush()
[all …]
/thrift-3.4.0/lib/nodejs/test/
Dclient.js102 let connection; variable
114 connection = thrift.createUDSConnection(domainSocket, options);
116 connection = ssl
122 connection = thrift.createHttpUDSConnection(domainSocket, options);
124 connection = thrift.createHttpConnection(host, port, options);
127 connection = thrift.createWSConnection(host, port, options);
128 connection.open();
131 connection.on("error", function(err) {
136 client = thrift.createClient(ThriftTest, connection);
140 client = mp.createClient("ThriftTest", ThriftTest, connection);
[all …]
/thrift-3.4.0/lib/nodejs/lib/thrift/
Dmultiplexed_protocol.js24 function Wrapper(serviceName, protocol, connection) { argument
34 connection.seqId2Service[seqid] = serviceName;
51 Multiplexer.prototype.createClient = function(serviceName, ServiceClient, connection) { argument
56 connection.write(buf,seqid);
58 var transport = new connection.transport(undefined, writeCb);
59 var protocolWrapper = new Wrapper(serviceName, connection.protocol, connection);
67 if (typeof connection.client !== 'object') {
68 connection.client = {};
70 connection.client[serviceName] = client;
Dconnection.js40 this.connection = stream;
69 this.connection.addListener(this.ssl ? "secureConnect" : "connect", function() {
83 this.connection.addListener("error", function(err) {
87 if (self.connection.listeners('error').length === 1 ||
94 this.connection.addListener("close", function() {
98 this.connection.addListener("timeout", function() {
102 this.connection.addListener("data", self.transport.receiver(function(transport_with_data) {
164 this.connection.end();
168 this.connection.destroy();
196 this.connection.write(data);
[all …]
Dcreate_client.js28 function createClient(ServiceClient, connection) { argument
47 connection.write(buf, seqid);
49 var transport = new connection.transport(undefined, writeCb);
50 var client = new ServiceClient(transport, connection.protocol);
52 connection.client = client;
Dindex.js26 var connection = require('./connection'); variable
27 exports.Connection = connection.Connection;
28 exports.createClient = connection.createClient;
29 exports.createConnection = connection.createConnection;
30 exports.createUDSConnection = connection.createUDSConnection;
31 exports.createSSLConnection = connection.createSSLConnection;
32 exports.createStdIOClient = connection.createStdIOClient;
33 exports.createStdIOConnection = connection.createStdIOConnection;
/thrift-3.4.0/lib/py/src/server/
DTNonblockingServer.py308 for i, connection in list(self.clients.items()):
309 if connection.is_readable():
310 readable.append(connection.fileno())
311 if connection.remaining or connection.received:
312 remaining.append(connection.fileno())
313 if connection.is_writeable():
314 writable.append(connection.fileno())
315 if connection.is_closed():
329 for i, connection in list(self.clients.items()):
330 if connection.is_readable():
[all …]
/thrift-3.4.0/lib/nodejs/examples/
Dclient.js24 var connection = thrift.createConnection('localhost', 9090), variable
25 client = thrift.createClient(UserStorage, connection);
31 connection.on('error', function(err) {
45 connection.end();
DhttpClient.js12 var connection = thrift.createHttpConnection("localhost", 9090, options); variable
13 var client = thrift.createHttpClient(helloSvc, connection);
15 connection.on("error", function(err) {
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/
DTHttpClient.java353 HttpURLConnection connection = (HttpURLConnection) url_.openConnection(); in flush() local
357 connection.setConnectTimeout(connectTimeout_); in flush()
360 connection.setReadTimeout(readTimeout_); in flush()
364 connection.setRequestMethod("POST"); in flush()
365 connection.setRequestProperty("Content-Type", "application/x-thrift"); in flush()
366 connection.setRequestProperty("Accept", "application/x-thrift"); in flush()
367 connection.setRequestProperty("User-Agent", "Java/THttpClient"); in flush()
370 connection.setRequestProperty(header.getKey(), header.getValue()); in flush()
373 connection.setDoOutput(true); in flush()
374 connection.connect(); in flush()
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/
DTSaslNonblockingServer.java161 TNonblockingTransport connection = serverTransport.accept(); in acceptNewConnection() local
162 if (connection == null) { in acceptNewConnection()
165 if (!networkThreadPool.acceptNewConnection(connection)) { in acceptNewConnection()
166 LOGGER.error("Network thread does not accept: " + connection); in acceptNewConnection()
167 connection.close(); in acceptNewConnection()
273 TNonblockingTransport connection = incomingConnections.poll(); in handleIncomingConnections() local
274 if (connection == null) { in handleIncomingConnections()
277 if (!connection.isOpen()) { in handleIncomingConnections()
282 SelectionKey selectionKey = connection.registerSelector(ioSelector, SelectionKey.OP_READ); in handleIncomingConnections()
287 connection, in handleIncomingConnections()
[all …]
/thrift-3.4.0/tutorial/nodejs/
DNodeClient.js28 var connection = thrift.createConnection("localhost", 9090, { variable
33 connection.on('error', function(err) {
38 var client = thrift.createClient(Calculator, connection);
75 connection.end();
DNodeClientPromise.js28 var connection = thrift.createConnection("localhost", 9090, { variable
33 connection.on('error', function(err) {
38 var client = thrift.createClient(Calculator, connection);
79 connection.end();
/thrift-3.4.0/lib/nodejs/
DREADME.md46 var connection = thrift.createConnection("localhost", 9160),
47 client = thrift.createClient(Cassandra, connection);
49 connection.on('error', function(err) {
59 connection.end();
95 let connection = thrift.createXHRConnection(host, port, opts);
96 let thriftClient = thrift.createXHRClient(MyServiceClient, connection);
98 connection.on('error', (err) => {
125 const connection = thrift.createWSConnection(host, port, opts);
126 connection.open();
127 const thriftClient = thrift.createWSClient(MyServiceClient, connection);
[all …]
/thrift-3.4.0/lib/nodejs/test/episodic-code-generation-test/
Dclient.js43 const connection = thrift.createConnection(host, port, options); constant
62 connection.on("error", function(err) {
66 const client = thrift.createClient(Service, connection);
73 connection.destroy();
/thrift-3.4.0/lib/nodets/test/
Dclient.ts47 var connection = thrift.createConnection("localhost", port, options); variable
49 connection.on("error", function(err: string) {
53 var client = thrift.createClient(ThriftTest.Client, connection);
/thrift-3.4.0/lib/cpp/src/thrift/server/
DTNonblockingServer.cpp322 TConnection* connection) in Task() argument
326 connection_(connection), in Task()
894 TConnection* connection = connectionStack_.top(); in ~TNonblockingServer() local
896 delete connection; in ~TNonblockingServer()
941 void TNonblockingServer::returnConnection(TConnection* connection) { in returnConnection() argument
946 connection), in returnConnection()
950 delete connection; in returnConnection()
953 connection->checkIdleBufferMemLimit(idleReadBufferLimit_, idleWriteBufferLimit_); in returnConnection()
954 connectionStack_.push(connection); in returnConnection()
1071 TConnection* connection = static_cast<TConnection::Task*>(task.get())->getTConnection(); in drainPendingTask() local
[all …]
/thrift-3.4.0/lib/d/src/thrift/server/
Dnonblocking.d517 void disposeConnection(Connection connection) { in disposeConnection() argument
522 connection.checkIdleBufferLimit(idleReadBufferLimit, in disposeConnection()
524 connectionStack_ ~= connection; in disposeConnection()
530 GC.removeRoot(cast(void*)connection); in disposeConnection()
755 Connection connection; in completed() local
759 cast(ubyte[])((&connection)[0 .. 1])); in completed()
771 if (!connection) { in completed()
779 connection.transition(); in completed()
1346 void processRequest(Connection connection) { in processRequest() argument
1349 with (connection) { in processRequest()
[all …]
/thrift-3.4.0/doc/specs/
DSequenceNumbers.md5 connection. This is typically done by asynchronous clients.
11 given transport connection. There is no requirement for unique numbers
/thrift-3.4.0/lib/haxe/src/org/apache/thrift/
DTConfiguration.hx32 // TODO(JensG): add connection and i/o timeouts
/thrift-3.4.0/lib/go/
DREADME.md108 the client closes the connection (this is a best effort check, not a guarantee
110 closes the connection, but when it's canceled you can always assume the client
111 closed the connection). When implementing Go Thrift server, you can take
/thrift-3.4.0/lib/d/src/thrift/transport/
Dwebsocket.d123 auto connection = stripLeft(cast(const(char)[])split[2]); in TServerWebSocketTransport() local
124 connection_ = canFind(connection.toLower, "upgrade"); in TServerWebSocketTransport()
/thrift-3.4.0/tutorial/ocaml/
DCalcClient.ml30 type connection = { type

12