testsuite

Class InjectedSocketFactory

java.lang.Object

com.mysql.cj.protocol.StandardSocketFactory

testsuite.InjectedSocketFactory

All Implemented Interfaces:

SocketFactory, SocketMetadata

public class InjectedSocketFactory
extends StandardSocketFactory

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	InjectedSocketFactory.InjectedInputStream
(package private) class	InjectedSocketFactory.SocketWrapper

Field Summary

Fields

Modifier and Type	Field and Description
private HostInfo	hi
(package private) static java.util.Set<java.lang.String>	IMMEDIATELY_DOWNED_HOSTS_PORT
static byte[]	injectedBuffer
protected static int	injectedBufferPos
private PropertySet	propSet

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

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

Constructor Summary

Constructors

Constructor and Description
InjectedSocketFactory()

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	downHost(java.lang.String hostPortPair)
static void	flushAllStaticData()

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

IMMEDIATELY_DOWNED_HOSTS_PORT

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

hi

private HostInfo hi

propSet

private PropertySet propSet

injectedBuffer

public static byte[] injectedBuffer

injectedBufferPos

protected static int injectedBufferPos

Constructor Detail

InjectedSocketFactory

public InjectedSocketFactory()

Method Detail

flushAllStaticData

public static void flushAllStaticData()

downHost

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

dontDownHost

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

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