testsuite

Class UnreliableSocketFactory

java.lang.Object

com.mysql.cj.protocol.StandardSocketFactory

testsuite.UnreliableSocketFactory

All Implemented Interfaces:

SocketFactory, SocketMetadata

public class UnreliableSocketFactory
extends StandardSocketFactory

Configure "socketFactory" to use this class in your JDBC URL, and it will operate as normal, unless you map some host aliases to actual IP addresses, and then have the test driver call hangOnConnect/Read/Write() which simulate the given failure condition for the host with the alias argument, and will honor connect or socket timeout properties. You can also cause a host to be immediately-downed by calling downHost() with an alias. ATTENTION! This class is *NOT* thread safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	UnreliableSocketFactory.HangingInputStream
(package private) static class	UnreliableSocketFactory.HangingOutputStream
(package private) class	UnreliableSocketFactory.HangingSocket

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static java.util.List<java.lang.String>	CONNECTION_ATTEMPTS
static long	DEFAULT_TIMEOUT_MILLIS
private java.lang.String	hostname
(package private) static java.util.Set<java.lang.String>	HUNG_CONNECT_HOSTS
(package private) static java.util.Set<java.lang.String>	HUNG_READ_HOSTS
(package private) static java.util.Set<java.lang.String>	HUNG_WRITE_HOSTS
(package private) static java.util.Set<java.lang.String>	IMMEDIATELY_DOWNED_HOSTS
private static java.util.Map<java.lang.String,java.lang.String>	MAPPED_HOSTS
private int	portNumber
private PropertySet	propSet
static java.lang.String	STATUS_CONNECTED
static java.lang.String	STATUS_FAILED
static java.lang.String	STATUS_UNKNOWN

Fields inherited from class com.mysql.cj.protocol.StandardSocketFactory

host, loginTimeoutCheckTimestamp, loginTimeoutCountdown, port, rawSocket, socketTimeoutBackup, sslSocket

Constructor Summary

Constructors

Constructor and Description
UnreliableSocketFactory()

Method Summary

Modifier and Type	Method and Description
<T extends java.io.Closeable> T	connect(java.lang.String host_name, int port_number, PropertySet pset, int loginTimeout) Creates a new socket or channel using the given properties.
static void	dontDownHost(java.lang.String hostname)
static void	dontHangOnConnect(java.lang.String hostname)
static void	dontHangOnRead(java.lang.String hostname)
static void	dontHangOnWrite(java.lang.String hostname)
static void	downHost(java.lang.String hostname)
static void	flushAllStaticData()
static void	flushConnectionAttempts()
static java.lang.String	getHostConnectedStatus(java.lang.String host)
static java.lang.String	getHostFailedStatus(java.lang.String host)
static java.lang.String	getHostFromLastConnection()
static java.lang.String	getHostFromPastConnection(int pos)
static java.util.List<java.lang.String>	getHostsFromAllConnections()
static java.util.List<java.lang.String>	getHostsFromLastConnections(int count)
static java.lang.String	getHostUnknownStatus(java.lang.String host)
private java.net.Socket	getNewSocket()
static void	hangOnConnect(java.lang.String hostname)
static void	hangOnRead(java.lang.String hostname)
static void	hangOnWrite(java.lang.String hostname)
static boolean	isConnected()
static void	mapHost(java.lang.String alias, java.lang.String orig)
(package private) static void	sleepMillisForProperty(PropertySet pset, PropertyKey name)

Methods inherited from class com.mysql.cj.protocol.StandardSocketFactory

afterHandshake, beforeHandshake, configureSocket, createSocket, getRealTimeout, performTlsHandshake, performTlsHandshake, resetLoginTimeCountdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.mysql.cj.protocol.SocketMetadata

isLocallyConnected, isLocallyConnected

Field Detail

STATUS_UNKNOWN

public static final java.lang.String STATUS_UNKNOWN

See Also:

Constant Field Values

STATUS_CONNECTED

public static final java.lang.String STATUS_CONNECTED

See Also:

Constant Field Values

STATUS_FAILED

public static final java.lang.String STATUS_FAILED

See Also:

Constant Field Values

DEFAULT_TIMEOUT_MILLIS

public static final long DEFAULT_TIMEOUT_MILLIS

See Also:

Constant Field Values

MAPPED_HOSTS

private static final java.util.Map<java.lang.String,java.lang.String> MAPPED_HOSTS

HUNG_READ_HOSTS

static final java.util.Set<java.lang.String> HUNG_READ_HOSTS

HUNG_WRITE_HOSTS

static final java.util.Set<java.lang.String> HUNG_WRITE_HOSTS

HUNG_CONNECT_HOSTS

static final java.util.Set<java.lang.String> HUNG_CONNECT_HOSTS

IMMEDIATELY_DOWNED_HOSTS

static final java.util.Set<java.lang.String> IMMEDIATELY_DOWNED_HOSTS

CONNECTION_ATTEMPTS

static final java.util.List<java.lang.String> CONNECTION_ATTEMPTS

hostname

private java.lang.String hostname

portNumber

private int portNumber

propSet

private PropertySet propSet

Constructor Detail

UnreliableSocketFactory

public UnreliableSocketFactory()

Method Detail

getHostConnectedStatus

public static java.lang.String getHostConnectedStatus(java.lang.String host)

getHostFailedStatus

public static java.lang.String getHostFailedStatus(java.lang.String host)

getHostUnknownStatus

public static java.lang.String getHostUnknownStatus(java.lang.String host)

flushAllStaticData

public static void flushAllStaticData()

flushConnectionAttempts

public static void flushConnectionAttempts()

mapHost

public static void mapHost(java.lang.String alias,
                           java.lang.String orig)

hangOnRead

public static void hangOnRead(java.lang.String hostname)

dontHangOnRead

public static void dontHangOnRead(java.lang.String hostname)

hangOnWrite

public static void hangOnWrite(java.lang.String hostname)

dontHangOnWrite

public static void dontHangOnWrite(java.lang.String hostname)

hangOnConnect

public static void hangOnConnect(java.lang.String hostname)

dontHangOnConnect

public static void dontHangOnConnect(java.lang.String hostname)

downHost

public static void downHost(java.lang.String hostname)

dontDownHost

public static void dontDownHost(java.lang.String hostname)

getHostFromLastConnection

public static java.lang.String getHostFromLastConnection()

getHostFromPastConnection

public static java.lang.String getHostFromPastConnection(int pos)

getHostsFromAllConnections

public static java.util.List<java.lang.String> getHostsFromAllConnections()

getHostsFromLastConnections

public static java.util.List<java.lang.String> getHostsFromLastConnections(int count)

isConnected

public static boolean isConnected()

connect

public <T extends java.io.Closeable> T connect(java.lang.String host_name,
                                               int port_number,
                                               PropertySet pset,
                                               int loginTimeout)
                                        throws java.io.IOException

Description copied from interface: SocketFactory

Creates a new socket or channel using the given properties. Properties are parsed by the driver from the URL. All properties other than sensitive ones (user and password) are passed to this method. The driver will instantiate the socket factory with the class name given in the property "socketFactory", where the standard is com.mysql.cj.protocol.StandardSocketFactory Implementing classes are responsible for handling synchronization of this method (if needed).

Specified by:

connect in interface SocketFactory

Overrides:

connect in class StandardSocketFactory

Type Parameters:

T - result type

Parameters:

host_name - the hostname passed in the URL. It will be a single hostname, as the driver parses multi-hosts (for failover) and calls this method for each host connection attempt.

port_number - the port number to connect to (if required).

pset - properties passed to the driver via the URL and/or properties instance.

loginTimeout - login timeout in milliseconds

Returns:

a socket connected to the given host

Throws:

java.io.IOException - if an I/O error occurs

getNewSocket

private java.net.Socket getNewSocket()
                              throws java.net.SocketException,
                                     java.io.IOException

Throws:

java.net.SocketException

java.io.IOException

sleepMillisForProperty

static void sleepMillisForProperty(PropertySet pset,
                                   PropertyKey name)