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 callersMethodgetCurHandlingPacageIndex

()

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

↓ 1 callersMethodgetDirection

()

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

↓ 1 callersMethodgetExecuteCount

()

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

↓ 1 callersMethodgetField

(String name, String orgName, int type)

src/main/java/io/mycat/net2/mysql/packet/util/PacketUtil.java:57

↓ 1 callersMethodgetFrontSocketNoDelay

()

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

↓ 1 callersMethodgetFrontsocketsorcvbuf

()

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

↓ 1 callersMethodgetFrontsocketsosndbuf

()

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

↓ 1 callersMethodgetHandler

()

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

↓ 1 callersMethodgetHeader

(int fieldCount)

src/main/java/io/mycat/net2/mysql/packet/util/PacketUtil.java:39

↓ 1 callersMethodgetHostName

()

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

↓ 1 callersMethodgetIdleTimeout

()

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

↓ 1 callersMethodgetIndex

()

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

↓ 1 callersMethodgetIp

()

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

↓ 1 callersMethodgetMaxCon

()

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

↓ 1 callersMethodgetMaxPacketSize

()

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

↓ 1 callersMethodgetMinCon

()

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

↓ 1 callersMethodgetNIOHandler

NIOHandler是无状态的，多个连接共享一个，因此建议作为 Factory的私有变量 @return NIOHandler

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

↓ 1 callersMethodgetPacketHeaderSize

()

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

↓ 1 callersMethodgetPacketInfo

取得数据包信息

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

↓ 1 callersMethodgetPacketLength

获取报文长度 @param buffer 报文buffer @param offset buffer解析位置偏移量 @param position buffer已读位置偏移量 @return 报文长度(Header长度+内容长度)

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

↓ 1 callersMethodgetPacketType

获取报文类型(0-255) @param buffer 报文buffer @param offset buffer解析位置偏移量 @param position buffer已读位置偏移量 @return 报文类型标识

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

↓ 1 callersMethodgetPassword

()

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

↓ 1 callersMethodgetPassword

()

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

↓ 1 callersMethodgetPort

()

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

↓ 1 callersMethodgetPort

()

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

↓ 1 callersMethodgetPort

()

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

↓ 1 callersMethodgetReactorThread

()

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

↓ 1 callersMethodgetServerCapabilities

()

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

↓ 1 callersMethodgetSharedBufferPool

()

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

↓ 1 callersMethodgetSource

()

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

↓ 1 callersMethodgetTotalBytesLength

返回当前所有bytebuffer里的字节数长度总和 @return

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

↓ 1 callersMethodgetUser

()

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

↓ 1 callersMethodgetWriteQueue

()

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

↓ 1 callersMethodhandle

(String stmt, MySQLFrontendConnection c, int offs)

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

↓ 1 callersMethodhandleBusiness

(byte field, MySQLConnection con)

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

↓ 1 callersMethodhandleData

(final MySQLBackendConnection source, final ByteBufferArray bufferArray, final int packetIndex)

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

↓ 1 callersMethodhandleLogin

(MySQLBackendConnection source, ByteBufferArray bufferArray, int packetIndex)

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

↓ 1 callersMethodhandleLogin

(byte field, MySQLConnection con)

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

↓ 1 callersMethodhandleResponse

收到数据包的响应处理

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

↓ 1 callersMethodhelpCheck

(String stmt, int offset)

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

↓ 1 callersMethodidentityCheck

select @@identity<br/> select @@identiTy aS iD

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

↓ 1 callersMethodidleCheck

()

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

↓ 1 callersMethodincExecuteCount

()

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

↓ 1 callersMethodincreatePacketIndex

()

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

↓ 1 callersMethodinit

(int index)

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

↓ 1 callersMethodinitClientFlags

()

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

↓ 1 callersMethodinitSource

(int index, PhysicalDatasource ds)

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

↓ 1 callersMethodinitialValue

()

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

↓ 1 callersMethodinsertCheck

(String stmt, int offset)

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

↓ 1 callersMethodisClosed

()

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

↓ 1 callersMethodisIdleTimeout

()

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

↓ 1 callersMethodisReadNode

()

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

↓ 1 callersMethodkillCheck

(String stmt, int offset)

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

↓ 1 callersMethodkillQueryCheck

(String stmt, int offset)

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

↓ 1 callersMethodlastInsertCheck

SELECT LAST_INSERT_ID()

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

↓ 1 callersMethodloadDataCheck

(String stmt, int offset)

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

↓ 1 callersMethodloop

(int i)

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

↓ 1 callersMethodmake

(SocketChannel channel)

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

↓ 1 callersMethodmake

(MySQLDataSource pool, String schema)

src/main/java/io/mycat/net2/mysql/connection/back/MySQLBackendConnectionFactory.java:12

↓ 1 callersMethodmakeConnection

创建一个具体的连接 @param channel @return Connection @throws IOException

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

↓ 1 callersMethodnextCharIsSep

检查下一个字符是否为分隔符，并把偏移量加1

src/main/java/io/mycat/net2/mysql/util/ParseUtil.java:243

↓ 1 callersMethodparse

(String stmt)

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

↓ 1 callersMethodparse

(String stmt, int offset)

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

↓ 1 callersMethodparseIdentifierEscape

<code>AS `abc`</code> @param offset stmt.charAt(offset) == first <code>`</code>

src/main/java/io/mycat/net2/mysql/util/ParseUtil.java:144

↓ 1 callersMethodparseProtocolPakage

(ByteBufferArray readBufferArray, ByteBuffer readBuffer, int readBufferOffset)

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

↓ 1 callersMethodparseString

<code>'abc'</code> @param offset stmt.charAt(offset) == first <code>'</code>

src/main/java/io/mycat/net2/mysql/util/ParseUtil.java:52

↓ 1 callersMethodparseString2

<code>"abc"</code> @param offset stmt.charAt(offset) == first <code>"</code>

src/main/java/io/mycat/net2/mysql/util/ParseUtil.java:98

↓ 1 callersMethodpasswd

(String pass, HandshakePacket hs)

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

↓ 1 callersMethodpostConnect

添加一个需要异步连接的Connection到队列中，等待连接 @param Connection

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

↓ 1 callersMethodrCheck

(String stmt, int offset)

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

↓ 1 callersMethodrandomByte

(byte[] b)

src/main/java/io/mycat/net2/mysql/util/RandomUtil.java:56

↓ 1 callersMethodread

(ByteBufferArray bufferArray, int packetIndex)

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

↓ 1 callersMethodread

(ByteBufferArray bufferArray, int packetIndex)

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

↓ 1 callersMethodread

(ByteBufferArray bufferArray, int packetIndex)

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

↓ 1 callersMethodreadBody

(MySQLMessage mm)

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

↓ 1 callersMethodreadInt

()

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

↓ 1 callersMethodreadInt

(InputStream in)

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

↓ 1 callersMethodreadLength

(InputStream in)

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

↓ 1 callersMethodreadString

()

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

↓ 1 callersMethodreadStringWithLength

()

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

↓ 1 callersMethodreadUB2

(InputStream in)

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

↓ 1 callersMethodreadUB3

(InputStream in)

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

↓ 1 callersMethodregister

(Selector selector)

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

↓ 1 callersMethodrelease

()

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

↓ 1 callersMethodreleaseChannel

(BackendConnection c)

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

↓ 1 callersMethodremoveCon

(BackendConnection con)

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

↓ 1 callersMethodremoveConnection

(Connection con)

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

↓ 1 callersMethodreplaceCheck

(String stmt, int offset)

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

↓ 1 callersMethodresponse

(MySQLFrontendConnection c)

src/main/java/io/mycat/net2/mysql/response/SelectVersionComment.java:58

↓ 1 callersMethodresponse

(MySQLFrontendConnection c)

src/main/java/io/mycat/net2/mysql/response/FakeResultSet.java:11

↓ 1 callersMethodreturnCon

(BackendConnection c)

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

↓ 1 callersMethodrollabckCheck

(String stmt, int offset)

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

↓ 1 callersMethodsCheck

(String stmt, int offset)

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

↓ 1 callersMethodsavepointCheck

(String stmt, int offset)

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

↓ 1 callersMethodscramble323

(String pass, String seed)

src/main/java/io/mycat/net2/mysql/packet/util/SecurityUtil.java:50

↓ 1 callersMethodscramble411

(byte[] pass, byte[] seed)

src/main/java/io/mycat/net2/mysql/packet/util/SecurityUtil.java:36

↓ 1 callersMethodseCheck

(String stmt, int offset)

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

↓ 1 callersMethodselect2Check

(String stmt, int offset)

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

↓ 1 callersMethodselectCheck

(String stmt, int offset)

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

↓ 1 callersMethodsendAuthPackge

()

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

← previous next →201–300 of 708, ranked by callers