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

项目: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-    文件:UIUtils.java   
public static List nimbusClientandConn(String host, Integer port)
        throws TTransportException {
    TSocket ts = new TSocket(host, port);
    TFramedTransport tt = new TFramedTransport(ts);
    TBinaryProtocol prot = new TBinaryProtocol(tt);
    Client nc = new Client(prot);
    ts.open();
    List l = new ArrayList();
    l.add(nc);
    l.add(tt);
    return l;
}
项目:jstorm-0.9.6.3-    文件:DRPCClient.java   
private void connect() throws TException {
    TSocket socket = new TSocket(host, port);
    if (timeout != null) {
        socket.setTimeout(timeout);
    }
    conn = new TFramedTransport(socket);
    client = new DistributedRPC.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:learn_jstorm    文件:UIUtils.java   
public static List nimbusClientandConn(String host, Integer port)
        throws TTransportException {
    TSocket ts = new TSocket(host, port);
    TFramedTransport tt = new TFramedTransport(ts);
    TBinaryProtocol prot = new TBinaryProtocol(tt);
    Client nc = new Client(prot);
    ts.open();
    List l = new ArrayList();
    l.add(nc);
    l.add(tt);
    return l;
}
项目:learn_jstorm    文件:DRPCClient.java   
private void connect() throws TException {
    TSocket socket = new TSocket(host, port);
    if (timeout != null) {
        socket.setTimeout(timeout);
    }
    conn = new TFramedTransport(socket);
    client = new DistributedRPC.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:Infrastructure    文件:ThriftConnection.java   
/**
 * Creates a connection with explicit nimbus host. Ignored if a local cluster is set 
 * for testing.
 * 
 * @param nimbusHost the nimbus host name
 * @param port the nimbus port number
 * @see #setLocalCluster(ILocalCluster)
 */
public ThriftConnection(String nimbusHost, int port) {
    if (null == localCluster) {
        socket = new TSocket(nimbusHost, port);
        LOGGER.info("Thrift connection info " + nimbusHost + " " + port);
        transport = new TFramedTransport(socket);
        protocol = new TBinaryProtocol(transport);
        client = new Client(protocol);
    }
}
项目:Tstream    文件:DRPCClient.java   
private void connect() throws TException {
    TSocket socket = new TSocket(host, port);
    if (timeout != null) {
        socket.setTimeout(timeout);
    }
    conn = new TFramedTransport(socket);
    client = new DistributedRPC.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:Tstream    文件:UIUtils.java   
public static List nimbusClientandConn(String host, Integer port)
        throws TTransportException {
    TSocket ts = new TSocket(host, port);
    TFramedTransport tt = new TFramedTransport(ts);
    TBinaryProtocol prot = new TBinaryProtocol(tt);
    Client nc = new Client(prot);
    ts.open();
    List l = new ArrayList();
    l.add(nc);
    l.add(tt);
    return l;
}
项目:openimaj    文件:KestrelThriftClient.java   
public KestrelThriftClient(String hostname, int port)
        throws TException
{

    _transport = new TFramedTransport(new TSocket(hostname, port));
    final TProtocol proto = new TBinaryProtocol(_transport);
    _client = new Kestrel.Client(proto);
    _transport.open();
}
项目:jstorm-0.9.6.3-    文件:DRPCInvocationsClient.java   
private void connect() throws TException {
    conn = new TFramedTransport(new TSocket(host, port));
    client = new DistributedRPCInvocations.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:learn_jstorm    文件:DRPCInvocationsClient.java   
private void connect() throws TException {
    conn = new TFramedTransport(new TSocket(host, port));
    client = new DistributedRPCInvocations.Client(new TBinaryProtocol(conn));
    conn.open();
}
项目:Tstream    文件:DRPCInvocationsClient.java   
private void connect() throws TException {
    conn = new TFramedTransport(new TSocket(host, port));
    client = new DistributedRPCInvocations.Client(new TBinaryProtocol(conn));
    conn.open();
}