Functions — github.com/MyCATApache/Mycat-NIO

hub / github.com/MyCATApache/Mycat-NIO / functions

Functions708 in github.com/MyCATApache/Mycat-NIO

⨍ Functions 708◇ Types & classes 84

↓ 1 callersMethodsessionVarCheck

SELECT @@session.auto_increment_increment @param stmt @param offset @return

src/main/java/io/mycat/net2/mysql/parser/ServerParseSelect.java:94

↓ 1 callersMethodsetAuthenticated

(boolean authenticated)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:221

↓ 1 callersMethodsetConnector

(NIOConnector connector)

src/main/java/io/mycat/net2/NetSystem.java:58

↓ 1 callersMethodsetCurPacketLength

设置package @param packegeNum @param startIndex

src/main/java/io/mycat/net2/ByteBufferArray.java:139

↓ 1 callersMethodsetCurPacketType

(int packageType)

src/main/java/io/mycat/net2/ByteBufferArray.java:143

↓ 1 callersMethodsetDataSourceProps

()

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDBPool.java:69

↓ 1 callersMethodsetDatasource

(PhysicalDatasource datasource)

src/main/java/io/mycat/net2/BackendConnection.java:26

↓ 1 callersMethodsetDbPool

(PhysicalDBPool dbPool)

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:66

↓ 1 callersMethodsetDirection

(Connection.Direction in)

src/main/java/io/mycat/net2/Connection.java:547

↓ 1 callersMethodsetHandshake

(HandshakePacket handshake)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:213

↓ 1 callersMethodsetIdleTimeout

(long idleTimeout)

src/main/java/io/mycat/net2/mysql/config/DBHostConfig.java:69

↓ 1 callersMethodsetMaxCon

(int maxCon)

src/main/java/io/mycat/net2/mysql/config/DBHostConfig.java:77

↓ 1 callersMethodsetMaxPacketSize

(int maxPacketSize)

src/main/java/io/mycat/net2/Connection.java:567

↓ 1 callersMethodsetNetConfig

(SystemConfig netConfig)

src/main/java/io/mycat/net2/NetSystem.java:76

↓ 1 callersMethodsetNextStatus

(byte packetType)

src/main/java/io/mycat/net2/mysql/connection/MySQLConnectionStatus.java:22

↓ 1 callersMethodsetPacketHeaderSize

(int packetHeaderSize)

src/main/java/io/mycat/net2/Connection.java:572

↓ 1 callersMethodsetPassword

(String password)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:177

↓ 1 callersMethodsetPool

(PhysicalDatasource pool)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:201

↓ 1 callersMethodsetPort

(int port)

src/main/java/io/mycat/net2/Connection.java:105

↓ 1 callersMethodsetPort

(int port)

src/main/java/io/mycat/net2/mysql/config/DBHostConfig.java:109

↓ 1 callersMethodsetResponseHandler

(ResponseHandler commandHandler)

src/main/java/io/mycat/net2/BackendConnection.java:22

↓ 1 callersMethodsetSchema

(String newSchema)

src/main/java/io/mycat/net2/BackendConnection.java:10

↓ 1 callersMethodsetSchema

(String schema)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:185

↓ 1 callersMethodsetUser

(String user)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:169

↓ 1 callersMethodshowCheck

(String stmt, int offset)

src/main/java/io/mycat/net2/mysql/parser/ServerParse.java:632

↓ 1 callersMethodskipIdentifierEscape

<code>`abc`d</code> @param offset index of first <code>`</code> @return index of 'd'. return stmt.length() is possible. -1 if string

src/main/java/io/mycat/net2/mysql/parser/ServerParseSelect.java:206

↓ 1 callersMethodskipString

<code>'abc'd</code> @param offset index of first <code>'</code> @return index of 'd'. return stmt.length() is possible. -1 if string

src/main/java/io/mycat/net2/mysql/parser/ServerParseSelect.java:268

↓ 1 callersMethodskipString2

<code>"abc"d</code> @param offset index of first <code>"</code> @return index of 'd'. return stmt.length() is possible. -1 if string

src/main/java/io/mycat/net2/mysql/parser/ServerParseSelect.java:225

↓ 1 callersMethodstartCheck

(String stmt, int offset)

src/main/java/io/mycat/net2/mysql/parser/ServerParse.java:646

↓ 1 callersMethodstartup

()

src/main/java/io/mycat/net2/NIOReactor.java:31

↓ 1 callersMethodsuccess

(MySQLFrontendConnection con, AuthPacket auth)

src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontConnectionHandler.java:253

↓ 1 callersMethodtCheck

(String stmt, int offset)

src/main/java/io/mycat/net2/mysql/parser/ServerParse.java:259

↓ 1 callersMethodtakeCon

(BackendConnection conn, final Object attachment, String schema)

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:175

↓ 1 callersMethodtakeIdleCon

(boolean autoCommit)

src/main/java/io/mycat/net2/mysql/connection/back/ConQueue.java:13

↓ 1 callersMethodtryTakeCon

(final String schema, boolean autoCommit)

src/main/java/io/mycat/net2/mysql/connection/back/ConMap.java:26

↓ 1 callersMethoduCheck

(String stmt, int offset)

src/main/java/io/mycat/net2/mysql/parser/ServerParse.java:662

↓ 1 callersMethodupdate

()

src/main/java/io/mycat/net2/TimeUtil.java:13

↓ 1 callersMethoduserCheck

SELECT USER()

src/main/java/io/mycat/net2/mysql/parser/ServerParseSelect.java:473

↓ 1 callersMethodvalidateHeader

(int offset, int position)

src/main/java/io/mycat/net2/mysql/packet/util/CommonPacketUtil.java:23

↓ 1 callersMethodversionCheck

(String stmt, int offset)

src/main/java/io/mycat/net2/mysql/parser/ServerParseSelect.java:111

↓ 1 callersMethodversionCommentCheck

SELECT @@VERSION_COMMENT

src/main/java/io/mycat/net2/mysql/parser/ServerParseSelect.java:512

↓ 1 callersMethodversionParenthesisCheck

(String stmt, int offset)

src/main/java/io/mycat/net2/mysql/parser/ServerParseSelect.java:141

↓ 1 callersMethodwrite

(OutputStream out)

src/main/java/io/mycat/net2/mysql/packet/AuthPacket.java:88

↓ 1 callersMethodwrite

(ByteBufferArray bufferArray)

src/main/java/io/mycat/net2/mysql/packet/FieldPacket.java:95

↓ 1 callersMethodwrite

(OutputStream out)

src/main/java/io/mycat/net2/mysql/packet/Reply323Packet.java:42

↓ 1 callersMethodwrite

(Connection c)

src/main/java/io/mycat/net2/mysql/packet/ErrorPacket.java:119

↓ 1 callersMethodwrite

(MySQLConnection c)

src/main/java/io/mycat/net2/mysql/packet/HandshakePacket.java:97

↓ 1 callersMethodwrite

(ByteBufferArray bufferArray)

src/main/java/io/mycat/net2/mysql/packet/ResultSetHeaderPacket.java:69

↓ 1 callersMethodwrite0

()

src/main/java/io/mycat/net2/Connection.java:353

↓ 1 callersMethodwriteBody

(ByteBuffer buffer)

src/main/java/io/mycat/net2/mysql/packet/FieldPacket.java:143

↓ 1 callersMethodwriteErrMessage

(int errno, String info)

src/main/java/io/mycat/net2/mysql/connection/MySQLConnection.java:39

↓ 1 callersMethodwriteInt

(OutputStream out, int i)

src/main/java/io/mycat/net2/mysql/packet/util/StreamUtil.java:145

↓ 1 callersMethodwriteInt

(ByteBuffer buffer, int i)

src/main/java/io/mycat/net2/mysql/packet/util/BufferUtil.java:44

↓ 1 callersMethodwriteWithLength

(OutputStream out, byte[] src)

src/main/java/io/mycat/net2/mysql/packet/util/StreamUtil.java:222

MethodByteBufferArray

(ReactorBufferPool bufferPool)

src/main/java/io/mycat/net2/ByteBufferArray.java:34

MethodCharsetCollation

(String charsetName, int collationIndex, String collationName, boolean isDefaultCollation)

src/main/java/io/mycat/net2/mysql/packet/util/CharsetUtil.java:111

MethodConnection

(SocketChannel channel)

src/main/java/io/mycat/net2/Connection.java:64

MethodConnectionException

(int code, String msg)

src/main/java/io/mycat/net2/ConnectionException.java:11

MethodConnectionMeta

(String schema, String charset, int txIsolation, boolean autocommit)

src/main/java/io/mycat/net2/mysql/connection/back/ConnectionMeta.java:40

MethodDBHostConfig

()

src/main/java/io/mycat/net2/mysql/config/DBHostConfig.java:42

MethodMySQLBackendConnection

(SocketChannel channel, boolean readNode)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnection.java:53

MethodMySQLConnection

(SocketChannel channel)

src/main/java/io/mycat/net2/mysql/connection/MySQLConnection.java:17

MethodMySQLConnectionStatus

()

src/main/java/io/mycat/net2/mysql/connection/MySQLConnectionStatus.java:6

MethodMySQLDataSource

(DBHostConfig config, boolean isReadNode)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLDataSource.java:38

MethodMySQLFrontendConnection

(SocketChannel channel)

src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontendConnection.java:31

MethodMySQLMessage

(ByteBufferArray bufferArray, int packetIndex)

src/main/java/io/mycat/net2/mysql/packet/MySQLMessage.java:47

MethodNIOAcceptor

(String name, String bindIp, int port, ConnectionFactory factory, NIOReactorPool reactorPool)

src/main/java/io/mycat/net2/NIOAcceptor.java:28

MethodNIOConnector

(String name, NIOReactorPool reactorPool)

src/main/java/io/mycat/net2/NIOConnector.java:29

MethodNIOHandlerWrap

(NIOHandler handler)

src/main/java/io/mycat/net2/ConnectionFactory.java:52

MethodNIOReactor

(String name, SharedBufferPool shearedBufferPool)

src/main/java/io/mycat/net2/NIOReactor.java:25

MethodNIOReactorPool

(String name, int poolSize, SharedBufferPool shearedBufferPool)

src/main/java/io/mycat/net2/NIOReactorPool.java:9

MethodNameableExecutor

(String name, int size, BlockingQueue<Runnable> queue, ThreadFactory factory)

src/main/java/io/mycat/net2/NameableExecutor.java:14

MethodNameableThreadFactory

(String name, boolean isDaemon)

src/main/java/io/mycat/net2/NameableThreadFactory.java:12

MethodNamebleScheduledExecutor

(String name, int corePoolSize, ThreadFactory threadFactory)

src/main/java/io/mycat/net2/NamebleScheduledExecutor.java:10

MethodNetSystem

(SharedBufferPool bufferPool, NameableExecutor executor, NamebleScheduledExecutor timer)

src/main/java/io/mycat/net2/NetSystem.java:41

MethodPhysicalDBNode

(String hostName, String database, PhysicalDBPool dbPool)

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDBNode.java:38

MethodPhysicalDBPool

(String name, PhysicalDatasource[] writeSources, Map<Integer, PhysicalDatasource[]> readSources)

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDBPool.java:52

MethodPhysicalDatasource

(DBHostConfig config, // DataHostConfig hostConfig, boolean isReadNode)

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:46

MethodRWThread

()

src/main/java/io/mycat/net2/NIOReactor.java:54

MethodReactorBufferPool

(SharedBufferPool shearedBufferPool, Thread reactorThread, int maxFreeCount)

src/main/java/io/mycat/net2/ReactorBufferPool.java:26

MethodRowDataPacket

(int fieldCount)

src/main/java/io/mycat/net2/mysql/packet/RowDataPacket.java:63

MethodSharedBufferPool

(long bufferSize, int chunkSize)

src/main/java/io/mycat/net2/SharedBufferPool.java:25

MethodSystemConfig

()

src/main/java/io/mycat/net2/SystemConfig.java:52

MethodSystemConfig

()

src/main/java/io/mycat/net2/mysql/config/SystemConfig.java:132

MethodWriteQueue

(int maxQueueMemory)

src/main/java/io/mycat/net2/WriteQueue.java:25

MethodaddFieldCount

(int add)

src/main/java/io/mycat/net2/mysql/packet/RowDataPacket.java:73

MethodaddNetInBytes

(long bytes)

src/main/java/io/mycat/net2/NetSystem.java:92

MethodcalcPacketSize

()

src/main/java/io/mycat/net2/mysql/packet/EmptyPacket.java:32

MethodcalcPacketSize

计算数据包大小，不包含包头长度。

src/main/java/io/mycat/net2/mysql/packet/MySQLPacket.java:190

MethodcheckConnections

定时执行该方法，回收部分资源。

src/main/java/io/mycat/net2/NetSystem.java:120

MethodclearCons

(String reason)

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:171

MethodcompactReadBuffer

(ByteBuffer buffer, int offset)

src/main/java/io/mycat/net2/Connection.java:181

MethodconnectionAcquired

(BackendConnection conn)

src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontConnectionHandler.java:176

MethodconnectionAcquired

已获得有效连接的响应处理

src/main/java/io/mycat/net2/mysql/handler/ResponseHandler.java:48

MethodconnectionClose

(BackendConnection conn, String reason)

src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontConnectionHandler.java:170

MethodconnectionClose

on connetion close event

src/main/java/io/mycat/net2/mysql/handler/ResponseHandler.java:63

MethodconnectionClosed

(BackendConnection conn)

src/main/java/io/mycat/net2/mysql/connection/back/PhysicalDatasource.java:248

MethodconnectionError

(Throwable e, BackendConnection conn)

src/main/java/io/mycat/net2/mysql/connection/front/MySQLFrontConnectionHandler.java:164

MethodconnectionError

(Throwable e)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnectionHandler.java:142

MethodconnectionError

无法获取连接 @param e @param conn

src/main/java/io/mycat/net2/mysql/handler/ResponseHandler.java:43

← previous next →301–400 of 708, ranked by callers