Class SharedMemorySocket
- java.lang.Object
-
- java.net.Socket
-
- org.mariadb.jdbc.internal.io.socket.SharedMemorySocket
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class SharedMemorySocket extends java.net.Socket
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
SharedMemorySocket.Advapi32
static interface
SharedMemorySocket.Kernel32
(package private) class
SharedMemorySocket.SharedMemoryInputStream
(package private) class
SharedMemorySocket.SharedMemoryOutputStream
-
Field Summary
Fields Modifier and Type Field Description private static int
BUFFERLEN
private int
bytesLeft
private com.sun.jna.platform.win32.WinNT.HANDLE
clientRead
private com.sun.jna.platform.win32.WinNT.HANDLE
clientWrote
private com.sun.jna.platform.win32.WinNT.HANDLE
connectionClosed
private static java.lang.String
EVERYONE_SYNCHRONIZE_SDDL
private java.io.InputStream
is
private java.lang.String
memoryName
private java.io.OutputStream
os
private int
position
private com.sun.jna.platform.win32.WinNT.HANDLE
serverRead
private com.sun.jna.platform.win32.WinNT.HANDLE
serverWrote
private int
timeout
private com.sun.jna.Pointer
view
private static java.util.Map<java.lang.String,java.lang.Object>
WIN32API_OPTIONS
-
Constructor Summary
Constructors Constructor Description SharedMemorySocket(java.lang.String name)
Create ShareMemorySocket.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
connect(java.net.SocketAddress endpoint)
void
connect(java.net.SocketAddress endpoint, int timeout)
private int
getConnectNumber()
java.io.InputStream
getInputStream()
java.io.OutputStream
getOutputStream()
private com.sun.jna.platform.win32.WinNT.HANDLE
lockMutex()
private static com.sun.jna.Pointer
mapMemory(java.lang.String mapName, int mode, int size)
Map memoryprivate static com.sun.jna.platform.win32.WinNT.HANDLE
openEvent(java.lang.String name)
void
setKeepAlive(boolean b)
void
setReceiveBufferSize(int size)
void
setSendBufferSize(int size)
void
setSoLinger(boolean b, int i)
void
setSoTimeout(int t)
void
setTcpNoDelay(boolean b)
void
shutdownInput()
void
shutdownOutput()
-
Methods inherited from class java.net.Socket
bind, getChannel, getInetAddress, getKeepAlive, getLocalAddress, getLocalPort, getLocalSocketAddress, getOOBInline, getOption, getPort, getReceiveBufferSize, getRemoteSocketAddress, getReuseAddress, getSendBufferSize, getSoLinger, getSoTimeout, getTcpNoDelay, getTrafficClass, isBound, isClosed, isConnected, isInputShutdown, isOutputShutdown, sendUrgentData, setOOBInline, setOption, setPerformancePreferences, setReuseAddress, setSocketImplFactory, setTrafficClass, supportedOptions, toString
-
-
-
-
Field Detail
-
EVERYONE_SYNCHRONIZE_SDDL
private static final java.lang.String EVERYONE_SYNCHRONIZE_SDDL
- See Also:
- Constant Field Values
-
WIN32API_OPTIONS
private static final java.util.Map<java.lang.String,java.lang.Object> WIN32API_OPTIONS
-
BUFFERLEN
private static final int BUFFERLEN
- See Also:
- Constant Field Values
-
is
private java.io.InputStream is
-
os
private java.io.OutputStream os
-
memoryName
private java.lang.String memoryName
-
serverRead
private com.sun.jna.platform.win32.WinNT.HANDLE serverRead
-
serverWrote
private com.sun.jna.platform.win32.WinNT.HANDLE serverWrote
-
clientRead
private com.sun.jna.platform.win32.WinNT.HANDLE clientRead
-
clientWrote
private com.sun.jna.platform.win32.WinNT.HANDLE clientWrote
-
connectionClosed
private com.sun.jna.platform.win32.WinNT.HANDLE connectionClosed
-
view
private com.sun.jna.Pointer view
-
bytesLeft
private int bytesLeft
-
position
private int position
-
timeout
private int timeout
-
-
Method Detail
-
openEvent
private static com.sun.jna.platform.win32.WinNT.HANDLE openEvent(java.lang.String name)
-
mapMemory
private static com.sun.jna.Pointer mapMemory(java.lang.String mapName, int mode, int size)
Map memory- Parameters:
mapName
- map namemode
- modesize
- size- Returns:
- Pointer
-
connect
public void connect(java.net.SocketAddress endpoint) throws java.io.IOException
- Overrides:
connect
in classjava.net.Socket
- Throws:
java.io.IOException
-
lockMutex
private com.sun.jna.platform.win32.WinNT.HANDLE lockMutex() throws java.io.IOException
- Throws:
java.io.IOException
-
getConnectNumber
private int getConnectNumber() throws java.io.IOException
- Throws:
java.io.IOException
-
connect
public void connect(java.net.SocketAddress endpoint, int timeout) throws java.io.IOException
- Overrides:
connect
in classjava.net.Socket
- Throws:
java.io.IOException
-
getInputStream
public java.io.InputStream getInputStream()
- Overrides:
getInputStream
in classjava.net.Socket
-
getOutputStream
public java.io.OutputStream getOutputStream()
- Overrides:
getOutputStream
in classjava.net.Socket
-
setTcpNoDelay
public void setTcpNoDelay(boolean b)
- Overrides:
setTcpNoDelay
in classjava.net.Socket
-
setKeepAlive
public void setKeepAlive(boolean b)
- Overrides:
setKeepAlive
in classjava.net.Socket
-
setReceiveBufferSize
public void setReceiveBufferSize(int size)
- Overrides:
setReceiveBufferSize
in classjava.net.Socket
-
setSendBufferSize
public void setSendBufferSize(int size)
- Overrides:
setSendBufferSize
in classjava.net.Socket
-
setSoLinger
public void setSoLinger(boolean b, int i)
- Overrides:
setSoLinger
in classjava.net.Socket
-
setSoTimeout
public void setSoTimeout(int t)
- Overrides:
setSoTimeout
in classjava.net.Socket
-
shutdownInput
public void shutdownInput()
- Overrides:
shutdownInput
in classjava.net.Socket
-
shutdownOutput
public void shutdownOutput()
- Overrides:
shutdownOutput
in classjava.net.Socket
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Overrides:
close
in classjava.net.Socket
-
-