Java 类org.apache.thrift7.transport.TTransport 实例源码

项目：jstorm-0.9.6.3- 文件：SaslTransportPlugin.java

@Override
public boolean process(final TProtocol inProt, final TProtocol outProt)
        throws TException {
    // populating request context
    ReqContext req_context = ReqContext.context();

    TTransport trans = inProt.getTransport();
    // Sasl transport
    TSaslServerTransport saslTrans = (TSaslServerTransport) trans;

    // remote address
    TSocket tsocket = (TSocket) saslTrans.getUnderlyingTransport();
    Socket socket = tsocket.getSocket();
    req_context.setRemoteAddress(socket.getInetAddress());

    // remote subject
    SaslServer saslServer = saslTrans.getSaslServer();
    String authId = saslServer.getAuthorizationID();
    Subject remoteUser = new Subject();
    remoteUser.getPrincipals().add(new User(authId));
    req_context.setSubject(remoteUser);

    // invoke service handler
    return wrapped.process(inProt, outProt);
}

项目：jstorm-0.9.6.3- 文件：SimpleTransportPlugin.java

@Override
public boolean process(final TProtocol inProt, final TProtocol outProt)
        throws TException {
    // populating request context
    ReqContext req_context = ReqContext.context();

    TTransport trans = inProt.getTransport();
    if (trans instanceof TMemoryInputTransport) {
        try {
            req_context.setRemoteAddress(InetAddress.getLocalHost());
        } catch (UnknownHostException e) {
            throw new RuntimeException(e);
        }
    } else if (trans instanceof TSocket) {
        TSocket tsocket = (TSocket) trans;
        // remote address
        Socket socket = tsocket.getSocket();
        req_context.setRemoteAddress(socket.getInetAddress());
    }

    // anonymous user
    req_context.setSubject(null);

    // invoke service handler
    return wrapped.process(inProt, outProt);
}

项目：jstorm-0.9.6.3- 文件：SimpleTransportPlugin.java

public boolean process(final TProtocol inProt, final TProtocol outProt) throws TException {
    //populating request context 
    ReqContext req_context = ReqContext.context();

    TTransport trans = inProt.getTransport();
    if (trans instanceof TMemoryInputTransport) {
        try {
            req_context.setRemoteAddress(InetAddress.getLocalHost());
        } catch (UnknownHostException e) {
            throw new RuntimeException(e);
        }                                
    } else if (trans instanceof TSocket) {
        TSocket tsocket = (TSocket)trans;
        //remote address
        Socket socket = tsocket.getSocket();
        req_context.setRemoteAddress(socket.getInetAddress());                
    } 

    //anonymous user
    req_context.setSubject(null);

    //invoke service handler
    return wrapped.process(inProt, outProt);
}

项目：learn_jstorm 文件：SaslTransportPlugin.java

public boolean process(final TProtocol inProt, final TProtocol outProt)
        throws TException {
    // populating request context
    ReqContext req_context = ReqContext.context();

    TTransport trans = inProt.getTransport();
    // Sasl transport
    TSaslServerTransport saslTrans = (TSaslServerTransport) trans;

    // remote address
    TSocket tsocket = (TSocket) saslTrans.getUnderlyingTransport();
    Socket socket = tsocket.getSocket();
    req_context.setRemoteAddress(socket.getInetAddress());

    // remote subject
    SaslServer saslServer = saslTrans.getSaslServer();
    String authId = saslServer.getAuthorizationID();
    Subject remoteUser = new Subject();
    remoteUser.getPrincipals().add(new User(authId));
    req_context.setSubject(remoteUser);

    // invoke service handler
    return wrapped.process(inProt, outProt);
}

项目：learn_jstorm 文件：SimpleTransportPlugin.java

public boolean process(final TProtocol inProt, final TProtocol outProt)
        throws TException {
    // populating request context
    ReqContext req_context = ReqContext.context();

    TTransport trans = inProt.getTransport();
    if (trans instanceof TMemoryInputTransport) {
        try {
            req_context.setRemoteAddress(InetAddress.getLocalHost());
        } catch (UnknownHostException e) {
            throw new RuntimeException(e);
        }
    } else if (trans instanceof TSocket) {
        TSocket tsocket = (TSocket) trans;
        // remote address
        Socket socket = tsocket.getSocket();
        req_context.setRemoteAddress(socket.getInetAddress());
    }

    // anonymous user
    req_context.setSubject(null);

    // invoke service handler
    return wrapped.process(inProt, outProt);
}

项目：learn_jstorm 文件：SimpleTransportPlugin.java

public boolean process(final TProtocol inProt, final TProtocol outProt) throws TException {
    //populating request context 
    ReqContext req_context = ReqContext.context();

    TTransport trans = inProt.getTransport();
    if (trans instanceof TMemoryInputTransport) {
        try {
            req_context.setRemoteAddress(InetAddress.getLocalHost());
        } catch (UnknownHostException e) {
            throw new RuntimeException(e);
        }                                
    } else if (trans instanceof TSocket) {
        TSocket tsocket = (TSocket)trans;
        //remote address
        Socket socket = tsocket.getSocket();
        req_context.setRemoteAddress(socket.getInetAddress());                
    } 

    //anonymous user
    req_context.setSubject(null);

    //invoke service handler
    return wrapped.process(inProt, outProt);
}

项目：jstrom 文件：SimpleTransportPlugin.java

public boolean process(final TProtocol inProt, final TProtocol outProt) throws TException {
    //populating request context 
    ReqContext req_context = ReqContext.context();

    TTransport trans = inProt.getTransport();
    if (trans instanceof TMemoryInputTransport) {
        try {
            req_context.setRemoteAddress(InetAddress.getLocalHost());
        } catch (UnknownHostException e) {
            throw new RuntimeException(e);
        }                                
    } else if (trans instanceof TSocket) {
        TSocket tsocket = (TSocket)trans;
        //remote address
        Socket socket = tsocket.getSocket();
        req_context.setRemoteAddress(socket.getInetAddress());                
    } 

    //anonymous user
    req_context.setSubject(null);

    //invoke service handler
    return wrapped.process(inProt, outProt);
}

项目：Tstream 文件：SaslTransportPlugin.java

public boolean process(final TProtocol inProt, final TProtocol outProt)
        throws TException {
    // populating request context
    ReqContext req_context = ReqContext.context();

    TTransport trans = inProt.getTransport();
    // Sasl transport
    TSaslServerTransport saslTrans = (TSaslServerTransport) trans;

    // remote address
    TSocket tsocket = (TSocket) saslTrans.getUnderlyingTransport();
    Socket socket = tsocket.getSocket();
    req_context.setRemoteAddress(socket.getInetAddress());

    // remote subject
    SaslServer saslServer = saslTrans.getSaslServer();
    String authId = saslServer.getAuthorizationID();
    Subject remoteUser = new Subject();
    remoteUser.getPrincipals().add(new User(authId));
    req_context.setSubject(remoteUser);

    // invoke service handler
    return wrapped.process(inProt, outProt);
}

项目：Tstream 文件：SimpleTransportPlugin.java

public boolean process(final TProtocol inProt, final TProtocol outProt)
        throws TException {
    // populating request context
    ReqContext req_context = ReqContext.context();

    TTransport trans = inProt.getTransport();
    if (trans instanceof TMemoryInputTransport) {
        try {
            req_context.setRemoteAddress(InetAddress.getLocalHost());
        } catch (UnknownHostException e) {
            throw new RuntimeException(e);
        }
    } else if (trans instanceof TSocket) {
        TSocket tsocket = (TSocket) trans;
        // remote address
        Socket socket = tsocket.getSocket();
        req_context.setRemoteAddress(socket.getInetAddress());
    }

    // anonymous user
    req_context.setSubject(null);

    // invoke service handler
    return wrapped.process(inProt, outProt);
}

项目：jstorm-0.9.6.3- 文件：DigestSaslTransportPlugin.java

@Override
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException, IOException {
    ClientCallbackHandler client_callback_handler = new ClientCallbackHandler(
            login_conf);
    TSaslClientTransport wrapper_transport = new TSaslClientTransport(
            DIGEST, null, AuthUtils.SERVICE, serverHost, null,
            client_callback_handler, transport);

    wrapper_transport.open();
    LOG.debug("SASL DIGEST-MD5 client transport has been established");

    return wrapper_transport;
}

项目：jstorm-0.9.6.3- 文件：SimpleTransportPlugin.java

/**
 * Connect to the specified server via framed transport
 * 
 * @param transport
 *            The underlying Thrift transport.
 */
@Override
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException {
    // create a framed transport
    TTransport conn = new TFramedTransport(transport);

    // connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}

项目：jstorm-0.9.6.3- 文件：SimpleTransportPlugin.java

/**
 * Connect to the specified server via framed transport 
 * @param transport The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost) throws TTransportException {
    //create a framed transport
    TTransport conn = new TFramedTransport(transport);

    //connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}

项目：learn_jstorm 文件：DigestSaslTransportPlugin.java

public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException, IOException {
    ClientCallbackHandler client_callback_handler = new ClientCallbackHandler(
            login_conf);
    TSaslClientTransport wrapper_transport = new TSaslClientTransport(
            DIGEST, null, AuthUtils.SERVICE, serverHost, null,
            client_callback_handler, transport);

    wrapper_transport.open();
    LOG.debug("SASL DIGEST-MD5 client transport has been established");

    return wrapper_transport;
}

项目：learn_jstorm 文件：SimpleTransportPlugin.java

/**
 * Connect to the specified server via framed transport
 * 
 * @param transport
 *            The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException {
    // create a framed transport
    TTransport conn = new TFramedTransport(transport);

    // connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}

项目：learn_jstorm 文件：SimpleTransportPlugin.java

/**
 * Connect to the specified server via framed transport 
 * @param transport The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost) throws TTransportException {
    //create a framed transport
    TTransport conn = new TFramedTransport(transport);

    //connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}

项目：jstrom 文件：SimpleTransportPlugin.java

/**
 * Connect to the specified server via framed transport 
 * @param transport The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost) throws TTransportException {
    //create a framed transport
    TTransport conn = new TFramedTransport(transport);

    //connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}

项目：Tstream 文件：DigestSaslTransportPlugin.java

public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException, IOException {
    ClientCallbackHandler client_callback_handler = new ClientCallbackHandler(
            login_conf);
    TSaslClientTransport wrapper_transport = new TSaslClientTransport(
            DIGEST, null, AuthUtils.SERVICE, serverHost, null,
            client_callback_handler, transport);

    wrapper_transport.open();
    LOG.debug("SASL DIGEST-MD5 client transport has been established");

    return wrapper_transport;
}

项目：Tstream 文件：SimpleTransportPlugin.java

/**
 * Connect to the specified server via framed transport
 * 
 * @param transport
 *            The underlying Thrift transport.
 */
public TTransport connect(TTransport transport, String serverHost)
        throws TTransportException {
    // create a framed transport
    TTransport conn = new TFramedTransport(transport);

    // connect
    conn.open();
    LOG.debug("Simple client transport has been established");

    return conn;
}

项目：jstorm-0.9.6.3- 文件：ThriftClient.java

public TTransport transport() {
    return _transport;
}

项目：jstorm-0.9.6.3- 文件：ThriftClient.java

public TTransport transport() {
    return _transport;
}

项目：learn_jstorm 文件：ThriftClient.java

public TTransport transport() {
    return _transport;
}

项目：learn_jstorm 文件：ThriftClient.java

public TTransport transport() {
    return _transport;
}

项目：jstrom 文件：ThriftClient.java

public TTransport transport() {
    return _transport;
}

项目：Tstream 文件：ThriftClient.java

public TTransport transport() {
    return _transport;
}

项目：jstorm-0.9.6.3- 文件：ITransportPlugin.java

/**
 * Connect to the specified server via framed transport
 * 
 * @param transport
 *            The underlying Thrift transport.
 * @param serverHost
 *            server host
 */
public TTransport connect(TTransport transport, String serverHost)
        throws IOException, TTransportException;

项目：jstorm-0.9.6.3- 文件：ITransportPlugin.java

/**
 * Connect to the specified server via framed transport 
 * @param transport The underlying Thrift transport.
 * @param serverHost server host
 */
public TTransport connect(TTransport transport, String serverHost) throws IOException, TTransportException;

项目：learn_jstorm 文件：ITransportPlugin.java

/**
 * Connect to the specified server via framed transport
 * 
 * @param transport
 *            The underlying Thrift transport.
 * @param serverHost
 *            server host
 */
public TTransport connect(TTransport transport, String serverHost)
        throws IOException, TTransportException;

项目：learn_jstorm 文件：ITransportPlugin.java

/**
 * Connect to the specified server via framed transport 
 * @param transport The underlying Thrift transport.
 * @param serverHost server host
 */
public TTransport connect(TTransport transport, String serverHost) throws IOException, TTransportException;

项目：jstrom 文件：ITransportPlugin.java

/**
 * Connect to the specified server via framed transport 
 * @param transport The underlying Thrift transport.
 * @param serverHost server host
 */
public TTransport connect(TTransport transport, String serverHost) throws IOException, TTransportException;

项目：Tstream 文件：ITransportPlugin.java

/**
 * Connect to the specified server via framed transport
 * 
 * @param transport
 *            The underlying Thrift transport.
 * @param serverHost
 *            server host
 */
public TTransport connect(TTransport transport, String serverHost)
        throws IOException, TTransportException;