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

↓ 2 callersMethodgetChunkSize

()

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

↓ 2 callersMethodgetConnection

(String schema, boolean autoCommit, // RouteResultsetNode // rrs, // ResponseHandler h

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

↓ 2 callersMethodgetCurByteBuffersCount

()

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

↓ 2 callersMethodgetIndex

因为每一个 charset 对应多个 collationIndex, 所以这里返回的是默认的那个 collationIndex；如果想获得确定的值 index，而非默认的index, 那么需要使用 getIndexByCollationName 或者 getIndexByCharsetNameA

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

↓ 2 callersMethodgetManCommitCons

()

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

↓ 2 callersMethodgetNewCreated

()

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

↓ 2 callersMethodgetNextReactor

()

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

↓ 2 callersMethodgetResponseHandler

()

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

↓ 2 callersMethodgetSources

()

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

↓ 2 callersMethodhandle

收到数据需要处理 @param con 当前连接 @param data 收到的数据包

src/main/java/io/mycat/net2/NIOHandler.java:45

↓ 2 callersMethodhash

(String src)

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

↓ 2 callersMethodindexAfterIdentity

@param offset <code>stmt.charAt(offset) == first '`' OR 'i' OR 'I' OR '\'' OR '"'</code> @return index after identity or `identity` or "ide

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

↓ 2 callersMethodindexAfterLastInsertIdFunc

@param offset <code>stmt.charAt(offset) == first 'L' OR 'l'</code> @return index after LAST_INSERT_ID(), might equals to length. -1 if not

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

↓ 2 callersMethodisBorrowed

()

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

↓ 2 callersMethodisClosedOrQuit

()

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

↓ 2 callersMethodisInitSuccess

()

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

↓ 2 callersMethodnextStringIsExpectedWithIgnoreSepChar

检查下一个字符串是否为期望的字符串，并把偏移量移到从offset开始计算，expectValue之后的位置 @param stmt 被解析的sql @param offset 被解析的sql的当前位置 @param nextExpectedString 在stmt中准备查找的字符串 @param

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

↓ 2 callersMethodonClosed

连接关闭通知 @param con @throws IOException

src/main/java/io/mycat/net2/NIOHandler.java:35

↓ 2 callersMethodonConnectFailed

连接失败 @param con 失败的连接 @param e 连接异常

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

↓ 2 callersMethodonConnected

连接建立成功的通知事件 @param con 当前连接

src/main/java/io/mycat/net2/NIOHandler.java:18

↓ 2 callersMethodparsePackets

解析出Packet边界,Packet为MSQL格式的报文，其他报文可以类比， @param readBuffer 当前（最后一个bytebuffer） @param readBufferOffset 上次解析的位置偏移量 @return 下次解析的位置偏移量

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

↓ 2 callersMethodpostRegister

(Connection c)

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

↓ 2 callersMethodprocessHandShakePacket

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

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

↓ 2 callersMethodpull

仅仅供Reactor线程调用，用于写数据到Socket @return ByteBufferArray，如果为空，表示当前没有数据，需要下次调用查看

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

↓ 2 callersMethodrandomBytes

(int size)

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

↓ 2 callersMethodread

把字节数组转变成FieldPacket

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

↓ 2 callersMethodread

(ByteBufferArray bufferArray, int packetIndex)

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

↓ 2 callersMethodreadBytes

()

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

↓ 2 callersMethodreadLong

()

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

↓ 2 callersMethodreadLong

(InputStream in)

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

↓ 2 callersMethodreadStringWithNull

()

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

↓ 2 callersMethodrecycle

(ByteBuffer buffer)

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

↓ 2 callersMethodsendPacket

(ByteBuffer newBuffer, ByteBufferArray bufferArray, int packetIndex)

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

↓ 2 callersMethodsetBorrowed

(boolean b)

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

↓ 2 callersMethodsetConnectedStatus

(int connectedStatus)

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

↓ 2 callersMethodsetCurHandlingPacageIndex

(int curHandlingPacageIndex)

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

↓ 2 callersMethodsetHandler

(NIOHandler<? extends Connection> handler)

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

↓ 2 callersMethodsetHost

(String host)

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

↓ 2 callersMethodsetId

(long id)

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

↓ 2 callersMethodsetSocketParams

(Connection con, boolean isFrontChannel)

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

↓ 2 callersMethodskipAlias

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

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

↓ 2 callersMethodtryPull

()

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

↓ 2 callersMethodwrite

(ByteBufferArray bufferArray)

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

↓ 2 callersMethodwrite

(ByteBufferArray bufferArray)

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

↓ 2 callersMethodwriteUB2

(OutputStream out, int i)

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

↓ 2 callersMethodwriteUB4

(OutputStream out, long l)

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

↓ 1 callersMethodaCheck

(String stmt, int offset)

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

↓ 1 callersMethodaccept

接受新连接

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

↓ 1 callersMethodaddConnection

添加一个连接到系统中被监控 @param c

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

↓ 1 callersMethodaddNetOutBytes

(long bytes)

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

↓ 1 callersMethodallocateByteBuffer

()

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

↓ 1 callersMethodauth323

(MySQLBackendConnection source, byte packetId)

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

↓ 1 callersMethodbeginCheck

(String stmt, int offset)

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

↓ 1 callersMethodcalcPacketSize

()

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

↓ 1 callersMethodcalcPacketSize

()

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

↓ 1 callersMethodcalcPacketSize

()

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

↓ 1 callersMethodcalcTotalPacketSize

计算所有packages的字节总数 @return

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

↓ 1 callersMethodcallCheck

(String stmt, int offset)

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

↓ 1 callersMethodcheckRequest

(String schema)

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

↓ 1 callersMethodcheckValidBuffer

(ByteBuffer buffer)

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

↓ 1 callersMethodclearConnections

(String reason, PhysicalDatasource dataSouce)

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

↓ 1 callersMethodcloseChannel

(SocketChannel channel)

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

↓ 1 callersMethodcloseSocket

()

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

↓ 1 callersMethodcommitCheck

(String stmt, int offset)

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

↓ 1 callersMethodcommitOrCallCheckOrCreate

(String stmt, int offset)

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

↓ 1 callersMethodconnect

(Selector selector)

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

↓ 1 callersMethodcopyToNewBuffer

将当前解析bytebuffer被截断的部分复制到新的buffer里，新buffer作为bufferArray的队列最新位置 @param readBuffer 当前（最后一个bytebuffer） @param offset 上次解析的位置偏移量

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

↓ 1 callersMethodcreate

(String name, int size)

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

↓ 1 callersMethodcreateCheck

(String stmt, int offset)

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

↓ 1 callersMethodcreateDirectBuffer

(int size)

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

↓ 1 callersMethodcreateNewConnection

(final Object attachment, final String schema)

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

↓ 1 callersMethodcreatePackage

根据MySQL报文格式构造内容长度为len的报文（总长度应为len+4） @param len 内容长度 @return 报文字节数组

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

↓ 1 callersMethodcreateRandomMysgqlPackages

随机构造报文进行测试，报文长度按照报文协议特点，在0xFF-0xFFFF-0xFFFFFF上均匀分布 @return @throws IOException

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

↓ 1 callersMethodcreateSheduledExecute

( String name, int size)

src/main/java/io/mycat/net2/ExecutorUtil.java:18

↓ 1 callersMethodcurrentUserCheck

SELECT USER()

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

↓ 1 callersMethoddCheck

(String stmt, int offset)

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

↓ 1 callersMethoddatabaseCheck

SELECT DATABASE()

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

↓ 1 callersMethoddeleteOrdCheck

(String stmt, int offset)

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

↓ 1 callersMethoddescribeCheck

(String stmt, int offset)

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

↓ 1 callersMethoddisableWrite

()

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

↓ 1 callersMethoddoConnecting

(MySQLBackendConnection con, ByteBufferArray bufferArray, int packetIndex)

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

↓ 1 callersMethoddoHandleBusinessMsg

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

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

↓ 1 callersMethoddoLogin

(MySQLFrontendConnection con, ByteBufferArray bufferArray, int packetIndex)

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

↓ 1 callersMethoddoQuery

(MySQLFrontendConnection con, ByteBufferArray bufferArray, final int packetIndex)

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

↓ 1 callersMethoddoWriteQueue

()

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

↓ 1 callersMethoddropCheck

(String stmt, int offset)

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

↓ 1 callersMethodexplainCheck

(String stmt, int offset)

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

↓ 1 callersMethodfailure

(MySQLFrontendConnection source, int errno, String info)

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

↓ 1 callersMethodfinishConnect

(SelectionKey key, Object att)

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

↓ 1 callersMethodfinishResponse

收到行数据包结束的响应处理

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

↓ 1 callersMethodgenAllDataSources

()

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

↓ 1 callersMethodgetActiveCount

()

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

↓ 1 callersMethodgetActiveCountForDs

(PhysicalDatasource dataSouce)

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

↓ 1 callersMethodgetActivedIndex

()

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

↓ 1 callersMethodgetAllConQueue

()

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

↓ 1 callersMethodgetBackSocketNoDelay

()

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

↓ 1 callersMethodgetBacksocketsorcvbuf

()

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

↓ 1 callersMethodgetBacksocketsosndbuf

()

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

↓ 1 callersMethodgetCharset

(int index)

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

↓ 1 callersMethodgetConnector

()

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

← previous next →101–200 of 708, ranked by callers