Path Lines of Code core/src/main/java/org/apache/seata/core/auth/AuthSigner.java 7 core/src/main/java/org/apache/seata/core/auth/DefaultAuthSigner.java 17 core/src/main/java/org/apache/seata/core/auth/RamSignAdapter.java 73 core/src/main/java/org/apache/seata/core/compressor/Compressor.java 5 core/src/main/java/org/apache/seata/core/compressor/CompressorFactory.java 28 core/src/main/java/org/apache/seata/core/compressor/CompressorType.java 34 core/src/main/java/org/apache/seata/core/constants/ClientTableColumnsName.java 11 core/src/main/java/org/apache/seata/core/constants/ConfigurationKeys.java 4 core/src/main/java/org/apache/seata/core/constants/DBType.java 47 core/src/main/java/org/apache/seata/core/constants/DubboConstants.java 13 core/src/main/java/org/apache/seata/core/constants/RedisKeyConstants.java 30 core/src/main/java/org/apache/seata/core/constants/RpcMessageConstants.java 6 core/src/main/java/org/apache/seata/core/constants/ServerTableColumnsName.java 39 core/src/main/java/org/apache/seata/core/context/ContextCore.java 12 core/src/main/java/org/apache/seata/core/context/ContextCoreLoader.java 13 core/src/main/java/org/apache/seata/core/context/FastThreadLocalContextCore.java 30 core/src/main/java/org/apache/seata/core/context/GlobalLockConfigHolder.java 16 core/src/main/java/org/apache/seata/core/context/RootContext.java 137 core/src/main/java/org/apache/seata/core/context/ThreadLocalContextCore.java 24 core/src/main/java/org/apache/seata/core/event/Event.java 3 core/src/main/java/org/apache/seata/core/event/EventBus.java 9 core/src/main/java/org/apache/seata/core/event/ExceptionEvent.java 10 core/src/main/java/org/apache/seata/core/event/GlobalTransactionEvent.java 65 core/src/main/java/org/apache/seata/core/event/GuavaEventBus.java 55 core/src/main/java/org/apache/seata/core/event/RateLimitEvent.java 55 core/src/main/java/org/apache/seata/core/exception/AbstractExceptionHandler.java 60 core/src/main/java/org/apache/seata/core/exception/BranchTransactionException.java 24 core/src/main/java/org/apache/seata/core/exception/DecodeException.java 6 core/src/main/java/org/apache/seata/core/exception/GlobalTransactionException.java 24 core/src/main/java/org/apache/seata/core/exception/RmTransactionException.java 24 core/src/main/java/org/apache/seata/core/exception/TmTransactionException.java 24 core/src/main/java/org/apache/seata/core/exception/TransactionException.java 31 core/src/main/java/org/apache/seata/core/exception/TransactionExceptionCode.java 39 core/src/main/java/org/apache/seata/core/lock/AbstractLocker.java 52 core/src/main/java/org/apache/seata/core/lock/LocalDBLocker.java 24 core/src/main/java/org/apache/seata/core/lock/Locker.java 13 core/src/main/java/org/apache/seata/core/lock/RowLock.java 65 core/src/main/java/org/apache/seata/core/logger/StackTraceLogger.java 56 core/src/main/java/org/apache/seata/core/model/BranchStatus.java 38 core/src/main/java/org/apache/seata/core/model/BranchType.java 27 core/src/main/java/org/apache/seata/core/model/GlobalLockConfig.java 25 core/src/main/java/org/apache/seata/core/model/GlobalStatus.java 64 core/src/main/java/org/apache/seata/core/model/LockStatus.java 25 core/src/main/java/org/apache/seata/core/model/Resource.java 6 core/src/main/java/org/apache/seata/core/model/ResourceManager.java 9 core/src/main/java/org/apache/seata/core/model/ResourceManagerInbound.java 6 core/src/main/java/org/apache/seata/core/model/ResourceManagerOutbound.java 9 core/src/main/java/org/apache/seata/core/model/Result.java 41 core/src/main/java/org/apache/seata/core/model/TransactionManager.java 10 core/src/main/java/org/apache/seata/core/protocol/AbstractIdentifyRequest.java 50 core/src/main/java/org/apache/seata/core/protocol/AbstractIdentifyResponse.java 36 core/src/main/java/org/apache/seata/core/protocol/AbstractMessage.java 32 core/src/main/java/org/apache/seata/core/protocol/AbstractResultMessage.java 17 core/src/main/java/org/apache/seata/core/protocol/BatchResultMessage.java 23 core/src/main/java/org/apache/seata/core/protocol/HeartbeatMessage.java 25 core/src/main/java/org/apache/seata/core/protocol/IncompatibleVersionException.java 6 core/src/main/java/org/apache/seata/core/protocol/MergeMessage.java 4 core/src/main/java/org/apache/seata/core/protocol/MergeResultMessage.java 23 core/src/main/java/org/apache/seata/core/protocol/MergedWarpMessage.java 20 core/src/main/java/org/apache/seata/core/protocol/MessageFuture.java 50 core/src/main/java/org/apache/seata/core/protocol/MessageType.java 34 core/src/main/java/org/apache/seata/core/protocol/MessageTypeAware.java 4 core/src/main/java/org/apache/seata/core/protocol/Protocol.java 9 core/src/main/java/org/apache/seata/core/protocol/ProtocolConstants.java 22 core/src/main/java/org/apache/seata/core/protocol/RegisterRMRequest.java 32 core/src/main/java/org/apache/seata/core/protocol/RegisterRMResponse.java 15 core/src/main/java/org/apache/seata/core/protocol/RegisterTMRequest.java 44 core/src/main/java/org/apache/seata/core/protocol/RegisterTMResponse.java 15 core/src/main/java/org/apache/seata/core/protocol/ResultCode.java 16 core/src/main/java/org/apache/seata/core/protocol/RpcMessage.java 69 core/src/main/java/org/apache/seata/core/protocol/Version.java 91 core/src/main/java/org/apache/seata/core/protocol/VersionNotSupportMessage.java 7 core/src/main/java/org/apache/seata/core/protocol/detector/Http2Detector.java 45 core/src/main/java/org/apache/seata/core/protocol/detector/ProtocolDetector.java 7 core/src/main/java/org/apache/seata/core/protocol/detector/SeataDetector.java 28 core/src/main/java/org/apache/seata/core/protocol/transaction/AbstractBranchEndRequest.java 51 core/src/main/java/org/apache/seata/core/protocol/transaction/AbstractBranchEndResponse.java 37 core/src/main/java/org/apache/seata/core/protocol/transaction/AbstractGlobalEndRequest.java 26 core/src/main/java/org/apache/seata/core/protocol/transaction/AbstractGlobalEndResponse.java 21 core/src/main/java/org/apache/seata/core/protocol/transaction/AbstractTransactionRequest.java 6 core/src/main/java/org/apache/seata/core/protocol/transaction/AbstractTransactionRequestToRM.java 7 core/src/main/java/org/apache/seata/core/protocol/transaction/AbstractTransactionRequestToTC.java 7 core/src/main/java/org/apache/seata/core/protocol/transaction/AbstractTransactionResponse.java 12 core/src/main/java/org/apache/seata/core/protocol/transaction/BranchCommitRequest.java 13 core/src/main/java/org/apache/seata/core/protocol/transaction/BranchCommitResponse.java 8 core/src/main/java/org/apache/seata/core/protocol/transaction/BranchRegisterRequest.java 61 core/src/main/java/org/apache/seata/core/protocol/transaction/BranchRegisterResponse.java 25 core/src/main/java/org/apache/seata/core/protocol/transaction/BranchReportRequest.java 69 core/src/main/java/org/apache/seata/core/protocol/transaction/BranchReportResponse.java 16 core/src/main/java/org/apache/seata/core/protocol/transaction/BranchRollbackRequest.java 13 core/src/main/java/org/apache/seata/core/protocol/transaction/BranchRollbackResponse.java 8 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalBeginRequest.java 35 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalBeginResponse.java 32 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalCommitRequest.java 13 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalCommitResponse.java 8 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalLockQueryRequest.java 13 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalLockQueryResponse.java 24 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalReportRequest.java 30 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalReportResponse.java 8 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalRollbackRequest.java 13 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalRollbackResponse.java 8 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalStatusRequest.java 13 core/src/main/java/org/apache/seata/core/protocol/transaction/GlobalStatusResponse.java 8 core/src/main/java/org/apache/seata/core/protocol/transaction/RMInboundHandler.java 6 core/src/main/java/org/apache/seata/core/protocol/transaction/TCInboundHandler.java 12 core/src/main/java/org/apache/seata/core/protocol/transaction/UndoLogDeleteRequest.java 48 core/src/main/java/org/apache/seata/core/rpc/ClientMessageListener.java 6 core/src/main/java/org/apache/seata/core/rpc/ClientMessageSender.java 10 core/src/main/java/org/apache/seata/core/rpc/ClientType.java 17 core/src/main/java/org/apache/seata/core/rpc/DefaultServerMessageListenerImpl.java 184 core/src/main/java/org/apache/seata/core/rpc/Disposable.java 4 core/src/main/java/org/apache/seata/core/rpc/MsgVersionHelper.java 28 core/src/main/java/org/apache/seata/core/rpc/RegisterCheckAuthHandler.java 7 core/src/main/java/org/apache/seata/core/rpc/RemotingBootstrap.java 5 core/src/main/java/org/apache/seata/core/rpc/RemotingClient.java 19 core/src/main/java/org/apache/seata/core/rpc/RemotingServer.java 15 core/src/main/java/org/apache/seata/core/rpc/RemotingService.java 6 core/src/main/java/org/apache/seata/core/rpc/RpcContext.java 151 core/src/main/java/org/apache/seata/core/rpc/ServerMessageListener.java 10 core/src/main/java/org/apache/seata/core/rpc/ServerMessageSender.java 15 core/src/main/java/org/apache/seata/core/rpc/ShutdownHook.java 68 core/src/main/java/org/apache/seata/core/rpc/TransactionMessageHandler.java 7 core/src/main/java/org/apache/seata/core/rpc/TransportProtocolType.java 18 core/src/main/java/org/apache/seata/core/rpc/TransportServerType.java 17 core/src/main/java/org/apache/seata/core/rpc/hook/RpcHook.java 6 core/src/main/java/org/apache/seata/core/rpc/hook/StatusRpcHook.java 13 core/src/main/java/org/apache/seata/core/rpc/netty/AbstractNettyRemoting.java 269 core/src/main/java/org/apache/seata/core/rpc/netty/AbstractNettyRemotingClient.java 398 core/src/main/java/org/apache/seata/core/rpc/netty/AbstractNettyRemotingServer.java 214 core/src/main/java/org/apache/seata/core/rpc/netty/ChannelAuthHealthChecker.java 15 core/src/main/java/org/apache/seata/core/rpc/netty/ChannelEventListener.java 9 core/src/main/java/org/apache/seata/core/rpc/netty/ChannelManager.java 347 core/src/main/java/org/apache/seata/core/rpc/netty/ChannelUtil.java 37 core/src/main/java/org/apache/seata/core/rpc/netty/MultiProtocolDecoder.java 118 core/src/main/java/org/apache/seata/core/rpc/netty/NettyBaseConfig.java 130 core/src/main/java/org/apache/seata/core/rpc/netty/NettyClientBootstrap.java 193 core/src/main/java/org/apache/seata/core/rpc/netty/NettyClientChannelManager.java 251 core/src/main/java/org/apache/seata/core/rpc/netty/NettyClientConfig.java 183 core/src/main/java/org/apache/seata/core/rpc/netty/NettyPoolKey.java 78 core/src/main/java/org/apache/seata/core/rpc/netty/NettyPoolableFactory.java 106 core/src/main/java/org/apache/seata/core/rpc/netty/NettyRemotingServer.java 82 core/src/main/java/org/apache/seata/core/rpc/netty/NettyServerBootstrap.java 152 core/src/main/java/org/apache/seata/core/rpc/netty/NettyServerConfig.java 147 core/src/main/java/org/apache/seata/core/rpc/netty/ProtocolDecoder.java 6 core/src/main/java/org/apache/seata/core/rpc/netty/ProtocolDetectHandler.java 38 core/src/main/java/org/apache/seata/core/rpc/netty/ProtocolEncoder.java 6 core/src/main/java/org/apache/seata/core/rpc/netty/ProtocolRpcMessage.java 6 core/src/main/java/org/apache/seata/core/rpc/netty/RegisterMsgListener.java 8 core/src/main/java/org/apache/seata/core/rpc/netty/RmNettyRemotingClient.java 245 core/src/main/java/org/apache/seata/core/rpc/netty/RpcEventLoopGroup.java 7 core/src/main/java/org/apache/seata/core/rpc/netty/TmNettyRemotingClient.java 206 core/src/main/java/org/apache/seata/core/rpc/netty/grpc/GrpcDecoder.java 87 core/src/main/java/org/apache/seata/core/rpc/netty/grpc/GrpcEncoder.java 71 core/src/main/java/org/apache/seata/core/rpc/netty/grpc/GrpcHeaderEnum.java 12 core/src/main/java/org/apache/seata/core/rpc/netty/v0/MessageCodecV0.java 8 core/src/main/java/org/apache/seata/core/rpc/netty/v0/ProtocolConstantsV0.java 9 core/src/main/java/org/apache/seata/core/rpc/netty/v0/ProtocolDecoderV0.java 89 core/src/main/java/org/apache/seata/core/rpc/netty/v0/ProtocolEncoderV0.java 68 core/src/main/java/org/apache/seata/core/rpc/netty/v0/ProtocolRpcMessageV0.java 103 core/src/main/java/org/apache/seata/core/rpc/netty/v1/HeadMapSerializer.java 65 core/src/main/java/org/apache/seata/core/rpc/netty/v1/ProtocolDecoderV1.java 95 core/src/main/java/org/apache/seata/core/rpc/netty/v1/ProtocolEncoderV1.java 72 core/src/main/java/org/apache/seata/core/rpc/netty/v1/ProtocolRpcMessageV1.java 80 core/src/main/java/org/apache/seata/core/rpc/processor/Pair.java 15 core/src/main/java/org/apache/seata/core/rpc/processor/RemotingProcessor.java 6 core/src/main/java/org/apache/seata/core/rpc/processor/client/ClientHeartbeatProcessor.java 18 core/src/main/java/org/apache/seata/core/rpc/processor/client/ClientOnResponseProcessor.java 92 core/src/main/java/org/apache/seata/core/rpc/processor/client/RmBranchCommitProcessor.java 41 core/src/main/java/org/apache/seata/core/rpc/processor/client/RmBranchRollbackProcessor.java 41 core/src/main/java/org/apache/seata/core/rpc/processor/client/RmUndoLogProcessor.java 30 core/src/main/java/org/apache/seata/core/rpc/processor/server/BatchLogHandler.java 58 core/src/main/java/org/apache/seata/core/rpc/processor/server/RegRmProcessor.java 61 core/src/main/java/org/apache/seata/core/rpc/processor/server/RegTmProcessor.java 64 core/src/main/java/org/apache/seata/core/rpc/processor/server/ServerHeartbeatProcessor.java 26 core/src/main/java/org/apache/seata/core/rpc/processor/server/ServerOnRequestProcessor.java 335 core/src/main/java/org/apache/seata/core/rpc/processor/server/ServerOnResponseProcessor.java 58 core/src/main/java/org/apache/seata/core/serializer/Serializer.java 5 core/src/main/java/org/apache/seata/core/serializer/SerializerSecurityRegistry.java 185 core/src/main/java/org/apache/seata/core/serializer/SerializerServiceLoader.java 86 core/src/main/java/org/apache/seata/core/serializer/SerializerType.java 40 core/src/main/java/org/apache/seata/core/store/BranchTransactionDO.java 97 core/src/main/java/org/apache/seata/core/store/DefaultDistributedLocker.java 11 core/src/main/java/org/apache/seata/core/store/DistributedLockDO.java 31 core/src/main/java/org/apache/seata/core/store/DistributedLocker.java 5 core/src/main/java/org/apache/seata/core/store/GlobalTransactionDO.java 103 core/src/main/java/org/apache/seata/core/store/LockDO.java 67 core/src/main/java/org/apache/seata/core/store/LockStore.java 14 core/src/main/java/org/apache/seata/core/store/LogStore.java 17 core/src/main/java/org/apache/seata/core/store/MappingDO.java 31 core/src/main/java/org/apache/seata/core/store/db/AbstractDataSourceProvider.java 185 core/src/main/java/org/apache/seata/core/store/db/DataSourceProvider.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/distributed/lock/BaseDistributedLockSql.java 28 core/src/main/java/org/apache/seata/core/store/db/sql/distributed/lock/BaseDistributedLockSqlServer.java 12 core/src/main/java/org/apache/seata/core/store/db/sql/distributed/lock/DistributedLockSql.java 6 core/src/main/java/org/apache/seata/core/store/db/sql/distributed/lock/DistributedLockSqlFactory.java 23 core/src/main/java/org/apache/seata/core/store/db/sql/lock/AbstractLockStoreSql.java 125 core/src/main/java/org/apache/seata/core/store/db/sql/lock/DmLockStoreSql.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/lock/H2LockStoreSql.java 11 core/src/main/java/org/apache/seata/core/store/db/sql/lock/KingbaseLockStoreSql.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/lock/LockStoreSql.java 12 core/src/main/java/org/apache/seata/core/store/db/sql/lock/LockStoreSqlFactory.java 12 core/src/main/java/org/apache/seata/core/store/db/sql/lock/MariadbLockStoreSql.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/lock/MysqlLockStoreSql.java 11 core/src/main/java/org/apache/seata/core/store/db/sql/lock/OceanbaseLockStoreSql.java 11 core/src/main/java/org/apache/seata/core/store/db/sql/lock/OracleLockStoreSql.java 11 core/src/main/java/org/apache/seata/core/store/db/sql/lock/OscarLockStoreSql.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/lock/PolarDBXLockStoreSql.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/lock/PostgresqlLockStoreSql.java 11 core/src/main/java/org/apache/seata/core/store/db/sql/lock/SqlServerLockStoreSql.java 17 core/src/main/java/org/apache/seata/core/store/db/sql/log/AbstractLogStoreSqls.java 112 core/src/main/java/org/apache/seata/core/store/db/sql/log/DmLogStoreSqls.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/log/H2LogStoreSqls.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/log/KingbaseLogStoreSqls.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/log/LogStoreSqls.java 22 core/src/main/java/org/apache/seata/core/store/db/sql/log/LogStoreSqlsFactory.java 12 core/src/main/java/org/apache/seata/core/store/db/sql/log/MariadbLogStoreSqls.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/log/MysqlLogStoreSqls.java 72 core/src/main/java/org/apache/seata/core/store/db/sql/log/OceanbaseLogStoreSqls.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/log/OracleLogStoreSqls.java 76 core/src/main/java/org/apache/seata/core/store/db/sql/log/OscarLogStoreSqls.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/log/PolarDBXLogStoreSqls.java 5 core/src/main/java/org/apache/seata/core/store/db/sql/log/PostgresqlLogStoreSqls.java 72 core/src/main/java/org/apache/seata/core/store/db/sql/log/SqlServerLogStoreSqls.java 76 core/src/main/logback.xml 6 core/src/main/resources/protobuf/org/apache/seata/protocol/transcation/grpcMessage.proto 30