import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.TimeoutException;
-import org.apache.commons.lang.ObjectUtils;
import org.apache.thrift.TException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
-import org.apache.thrift.async.TAsyncClientManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
*/
private ServerSocket serverSocket_ = null;
- /**
- * Port to listen on
- */
- private int port_ = 0;
-
/**
* Timeout for client sockets from accept
*/
private int clientTimeout_ = 0;
- /**
- * Creates a server socket from underlying socket object
- */
- // public TNonblockingServerSocket(ServerSocket serverSocket) {
- // this(serverSocket, 0);
- // }
-
- /**
- * Creates a server socket from underlying socket object
- */
- // public TNonblockingServerSocket(ServerSocket serverSocket, int clientTimeout) {
- // serverSocket_ = serverSocket;
- // clientTimeout_ = clientTimeout;
- // }
-
/**
* Creates just a port listening server socket
*/
*/
public TNonblockingServerSocket(int port, int clientTimeout) throws TTransportException {
this(new InetSocketAddress(port), clientTimeout);
- port_ = port;
- }
+ }
public TNonblockingServerSocket(InetSocketAddress bindAddr) throws TTransportException {
this(bindAddr, 0);
package org.apache.thrift.transport;
import java.io.IOException;
-import java.nio.channels.Selector;
-import java.nio.channels.SelectionKey;
+import java.net.SocketAddress;
import java.nio.ByteBuffer;
-
-import org.apache.thrift.async.TAsyncMethodCall;
+import java.nio.channels.SelectionKey;
+import java.nio.channels.Selector;
public abstract class TNonblockingTransport extends TTransport {
import javax.security.sasl.SaslClient;
import javax.security.sasl.SaslException;
-import org.apache.thrift.EncodingUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
package org.apache.thrift.transport;
import java.io.UnsupportedEncodingException;
-import java.util.Arrays;
-import java.util.Map;
import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Set;
+import java.util.Map;
import javax.security.sasl.Sasl;
import javax.security.sasl.SaslClient;
*/
private ServerSocket serverSocket_ = null;
- /**
- * Port to listen on
- */
- private int port_ = 0;
-
/**
* Timeout for client sockets from accept
*/
*/
public TServerSocket(int port, int clientTimeout) throws TTransportException {
this(new InetSocketAddress(port), clientTimeout);
- port_ = port;
}
public TServerSocket(InetSocketAddress bindAddr) throws TTransportException {
package org.apache.thrift;
import java.nio.ByteBuffer;
-import java.util.*;
-import thrift.test.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+
+import thrift.test.Bonk;
+import thrift.test.CompactProtoTestStruct;
+import thrift.test.HolyMoley;
+import thrift.test.Nesting;
+import thrift.test.OneOfEach;
public class Fixtures {
public static final OneOfEach oneOfEach;
package org.apache.thrift.async;
+import junit.framework.TestCase;
+
import org.apache.thrift.TException;
-import junit.framework.TestCase;
import thrift.test.Srv;
import thrift.test.Srv.AsyncClient;
package org.apache.thrift.protocol;
-import org.apache.thrift.protocol.TCompactProtocol;
-import org.apache.thrift.protocol.TProtocolFactory;
public class TestTCompactProtocol extends ProtocolTestBase {
@Override
*/
package org.apache.thrift.transport;
-import org.apache.thrift.transport.TTransport;
-import org.apache.thrift.transport.TTransportException;
public class ReadCountingTransport extends TTransport {
public int readCount = 0;
import javax.security.sasl.Sasl;
import javax.security.sasl.SaslClient;
import javax.security.sasl.SaslClientFactory;
+import javax.security.sasl.SaslException;
import javax.security.sasl.SaslServer;
import javax.security.sasl.SaslServerFactory;
-import javax.security.sasl.SaslException;
+
+import junit.framework.TestCase;
import org.apache.thrift.TProcessor;
import org.apache.thrift.protocol.TProtocolFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import junit.framework.TestCase;
-
public class TestTSaslTransports extends TestCase {
private static final Logger LOGGER = LoggerFactory.getLogger(TestTSaslTransports.class);
*/
package org.apache.thrift.transport;
-import org.apache.thrift.transport.TTransport;
-import org.apache.thrift.transport.TTransportException;
public class WriteCountingTransport extends TTransport {
public int writeCount = 0;