| /thrift-3.4.0/lib/go/thrift/ |
| D | socket.go | 29 conn *socketConn member
95 func NewTSocketFromConnConf(conn net.Conn, conf *TConfiguration) *TSocket {
97 conn: wrapSocketConn(conn),
98 addr: conn.RemoteAddr(),
104 func NewTSocketFromConnTimeout(conn net.Conn, socketTimeout time.Duration) *TSocket {
105 return NewTSocketFromConnConf(conn, &TConfiguration{
147 p.conn.SetDeadline(t)
149 p.conn.SetReadDeadline(t)
151 p.conn.SetWriteDeadline(t)
157 if p.conn.isValid() {
[all …]
|
| D | ssl_socket.go | 30 conn *socketConn member
103 func NewTSSLSocketFromConnConf(conn net.Conn, conf *TConfiguration) *TSSLSocket {
105 conn: wrapSocketConn(conn),
106 addr: conn.RemoteAddr(),
112 func NewTSSLSocketFromConnTimeout(conn net.Conn, cfg *tls.Config, socketTimeout time.Duration) *TSS…
113 return NewTSSLSocketFromConnConf(conn, &TConfiguration{
152 p.conn.SetDeadline(t)
154 p.conn.SetReadDeadline(t)
156 p.conn.SetWriteDeadline(t)
166 if p.conn, err = createSocketConnFromReturn(tls.DialWithDialer(
[all …]
|
| D | socket_conn.go | 40 func createSocketConnFromReturn(conn net.Conn, err error) (*socketConn, error) {
45 Conn: conn,
50 func wrapSocketConn(conn net.Conn) *socketConn {
53 if sc, ok := conn.(*socketConn); ok {
58 Conn: conn,
|
| D | simple_server_test.go | 183 conn, err := ln.Accept()
188 return NewTSocketFromConnConf(conn, nil), nil
246 conn, err := ln.Accept()
251 return NewTSocketFromConnConf(conn, conf), nil
|
| D | ssl_server_socket.go | 70 conn, err := p.listener.Accept()
74 return NewTSSLSocketFromConnTimeout(conn, p.cfg, p.clientTimeout), nil
|
| D | server_socket.go | 85 conn, err := listener.Accept()
89 return NewTSocketFromConnTimeout(conn, p.clientTimeout), nil
|
| /thrift-3.4.0/tutorial/js/src/ |
| D | Httpd.java | 247 DefaultHttpServerConnection conn = new DefaultHttpServerConnection(); in run() local
249 conn.bind(socket, this.params); in run()
252 Thread t = new WorkerThread(this.httpService, conn); in run()
268 private final HttpServerConnection conn; field in Httpd.WorkerThread
270 public WorkerThread(final HttpService httpservice, final HttpServerConnection conn) { in WorkerThread() argument
273 this.conn = conn; in WorkerThread()
280 while (!Thread.interrupted() && this.conn.isOpen()) { in run()
281 this.httpservice.handleRequest(this.conn, context); in run()
291 this.conn.shutdown(); in run()
|
| /thrift-3.4.0/lib/js/test/src/test/ |
| D | Httpd.java | 271 DefaultHttpServerConnection conn = new DefaultHttpServerConnection(); in run() local
273 conn.bind(socket, this.params); in run()
276 Thread t = new WorkerThread(this.httpService, conn); in run()
292 private final HttpServerConnection conn; field in Httpd.WorkerThread
294 public WorkerThread(final HttpService httpservice, final HttpServerConnection conn) { in WorkerThread() argument
297 this.conn = conn; in WorkerThread()
304 while (!Thread.interrupted() && this.conn.isOpen()) { in run()
305 this.httpservice.handleRequest(this.conn, context); in run()
315 this.conn.shutdown(); in run()
|
| /thrift-3.4.0/tutorial/py.twisted/ |
| D | PythonClient.py | 77 d.addCallback(lambda conn: conn.client)
|
| /thrift-3.4.0/lib/d/src/thrift/server/ |
| D | nonblocking.d | 424 Connection conn = void; in acceptConnections() local
440 conn = new Connection(clientSocket, loop); in acceptConnections()
444 GC.addRoot(cast(void*)conn); in acceptConnections()
446 conn = connectionStack_[$ - 1]; in acceptConnections()
449 conn.init(clientSocket, loop); in acceptConnections()
462 conn.transition(); in acceptConnections()
464 loop.notifyCompleted(conn); in acceptConnections()
685 void disposeConnection(Connection conn) { in disposeConnection() argument
686 server_.disposeConnection(conn); in disposeConnection()
703 void notifyCompleted(Connection conn) { in notifyCompleted() argument
[all …]
|
| /thrift-3.4.0/lib/cpp/src/thrift/server/ |
| D | TNonblockingServer.cpp | 1301 bool TNonblockingIOThread::notify(TNonblockingServer::TConnection* conn) { in createNotificationPipe() argument
1308 long kSize = sizeof(conn); in createNotificationPipe()
1309 const char * pos = (const char *)const_cast_sockopt(&conn); in createNotificationPipe()
|
| D | TNonblockingServer.h | 771 bool notify(TNonblockingServer::TConnection* conn);
|
