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

↓ 112 callersMethodlength

()

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

↓ 51 callersMethodread

(int i)

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

↓ 23 callersMethodaddNewBuffer

申请一个ByteBuffer，并且放入队列，并且返回此ByteBuffer @return

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

↓ 23 callersMethodsetStatus

(int status)

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

↓ 23 callersMethodwrite

(OutputStream out, byte b)

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

↓ 17 callersMethodarraycopy

(byte[] dest)

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

↓ 17 callersMethodgetInstance

()

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

↓ 17 callersMethodsize

()

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

↓ 16 callersMethodgetLength

(long length)

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

↓ 16 callersMethodwriteUB2

(ByteBuffer buffer, int i)

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

↓ 15 callersMethodcheckWriteBuffer

(int capacity)

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

↓ 15 callersMethodwriteUB3

(ByteBuffer buffer, int i)

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

↓ 14 callersMethodallocate

申请一个ByteBuffer 内存，用完需要在合适的时间释放， @see recycle @return

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

↓ 14 callersMethodposition

()

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

↓ 12 callersMethodgetMyBufferPool

()

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

↓ 11 callersMethodreadUB2

()

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

↓ 10 callersMethodadd

只能同时一个线程写 @param array

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

↓ 10 callersMethodreadBytesWithLength

()

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

↓ 10 callersMethodwriteWithLength

(ByteBuffer buffer, byte[] src)

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

↓ 9 callersMethodadd

(byte[] value)

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

↓ 9 callersMethodhasRemaining

()

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

↓ 9 callersMethodreadUB3

()

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

↓ 9 callersMethodwrite

(MySQLConnection c)

src/main/java/io/mycat/net2/mysql/packet/OkPacket.java:109

↓ 8 callersMethodclear

()

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

↓ 8 callersMethodgetCurPacageIndex

()

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

↓ 8 callersMethodreadLength

()

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

↓ 8 callersMethodwriteLength

(ByteBuffer buffer, long l)

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

↓ 7 callersMethodclose

(String reason)

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

↓ 7 callersMethodmove

(String stmt, int offset, int length)

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

↓ 7 callersMethodread

(InputStream in, byte[] b, int offset, int length)

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

↓ 7 callersMethodsetNextConnectedStatus

(byte packetType)

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

↓ 6 callersMethodcurrentTimeMillis

()

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

↓ 6 callersMethodgetLastByteBuffer

得到队列中最后一个ByteBuffer，也即当前可以写入的位置，如果队列为空，则返回NULL @return

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

↓ 6 callersMethodgetSchema

()

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

↓ 6 callersMethodgetSchemaConQueue

(String schema)

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

↓ 6 callersMethodwriteWithNull

(ByteBuffer buffer, byte[] src)

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

↓ 5 callersMethodallocate

分配一个ByteBufferArray,ByteBufferArray使用完成后需要回收 @return ByteBufferArray

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

↓ 5 callersMethodclose

关闭连接

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

↓ 5 callersMethodcomment

注解保留，注释 @param stmt @param offset @return

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

↓ 5 callersMethodcompare

(String s, int offset, char[] keyword)

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

↓ 5 callersMethodgetId

()

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

↓ 5 callersMethodgetName

()

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

↓ 5 callersMethodreadPacket

(int packetIndex, int offset)

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

↓ 5 callersMethodreadUB4

()

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

↓ 4 callersMethodgetBufferPool

()

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

↓ 4 callersMethodgetConnectedStatus

()

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

↓ 4 callersMethodgetPool

()

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

↓ 4 callersMethodgetState

()

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

↓ 4 callersMethodisEOF

(char c)

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

↓ 4 callersMethodmove

(int i)

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

↓ 4 callersMethodnext

()

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

↓ 4 callersMethodsetState

(State newState)

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

↓ 4 callersMethodskipAs

<code>SELECT LAST_INSERT_ID() AS id</code> @param offset index of first ' ' after LAST_INSERT_ID(), offset == stmt.length() is

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

↓ 4 callersMethodtoString

()

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

↓ 4 callersMethodwriteUB3

(OutputStream out, int i)

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

↓ 4 callersMethodwriteUB4

(ByteBuffer buffer, long l)

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

↓ 3 callersMethodcalcPacketSize

()

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

↓ 3 callersMethodcalcPacketSize

()

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

↓ 3 callersMethodcreateMultiPackage

根据长度构造报文 @param lenList @return @throws IOException

src/test/java/io/mycat/net2/mysql/TestMySQLPackageSplitter.java:144

↓ 3 callersMethodcurrentCharIsSep

(String stmt, int offset)

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

↓ 3 callersMethodencode

(String src, String charset)

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

↓ 3 callersMethodgetAllConnectios

()

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

↓ 3 callersMethodgetConfig

()

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

↓ 3 callersMethodgetCurPacageLength

()

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

↓ 3 callersMethodgetCurPacageType

()

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

↓ 3 callersMethodgetHandshake

()

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

↓ 3 callersMethodgetINSTNCE

()

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

↓ 3 callersMethodgetLocalCalendar

()

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

↓ 3 callersMethodgetMessage

(int index, String info)

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

↓ 3 callersMethodgetName

()

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

↓ 3 callersMethodgetPacageLength

(int index)

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

↓ 3 callersMethodgetPacageType

(int index)

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

↓ 3 callersMethodgetStatus

()

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

↓ 3 callersMethodgetWritedBlockLst

()

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

↓ 3 callersMethodisAlive

(PhysicalDatasource theSource)

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

↓ 3 callersMethodisIdentifierChar

(char c)

src/main/java/io/mycat/net2/mysql/util/CharTypes.java:67

↓ 3 callersMethodreadBytesWithNull

()

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

↓ 3 callersMethodrecycle

回收此对象，用完需要在合适的地方释放，否則產生內存泄露問題

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

↓ 3 callersMethodregister

(Selector selector, ReactorBufferPool myBufferPool)

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

↓ 3 callersMethodreset

()

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

↓ 3 callersMethodsplitPackage

测试核心逻辑，将模拟好的报文按序写入buffer，并进行解析 @param mysqlPackgsStream @param chunkSize @return @throws IOException

src/test/java/io/mycat/net2/mysql/TestMySQLPackageSplitter.java:42

↓ 3 callersMethodtoString

()

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

↓ 3 callersMethodtoString

()

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

↓ 3 callersMethodwrite

(ByteBufferArray bufferArray)

src/main/java/io/mycat/net2/mysql/packet/EOFPacket.java:66

↓ 3 callersMethodwriteLong

(OutputStream out, long l)

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

↓ 3 callersMethodwriteLong

(ByteBuffer buffer, long l)

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

↓ 3 callersMethodwriteWithNull

(OutputStream out, byte[] src)

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

↓ 2 callersMethodallocate

()

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

↓ 2 callersMethodasynRead

异步读取数据,only nio thread call @throws IOException

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

↓ 2 callersMethodauthenticate

()

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

↓ 2 callersMethodcalcPacketSize

()

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

↓ 2 callersMethodcalcPacketSize

()

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

↓ 2 callersMethodcalcPacketSize

()

src/main/java/io/mycat/net2/mysql/packet/OkPacket.java:125

↓ 2 callersMethodcalcPacketSize

()

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

↓ 2 callersMethodcheckIndex

(int i)

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

↓ 2 callersMethodcleanup

清理资源

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

↓ 2 callersMethodclearSelectionKey

(SelectionKey key)

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

↓ 2 callersMethodenableWrite

(boolean wakeup)

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

↓ 2 callersMethodgetAutoCommitCons

()

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

↓ 2 callersMethodgetChannel

()

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

next →1–100 of 708, ranked by callers