From a75a56089f9f79fcc9a675384a9bf8499f0962b2 Mon Sep 17 00:00:00 2001 From: PangXing Date: Mon, 8 Aug 2022 18:53:02 +0800 Subject: [PATCH] my dev --- .github/ISSUE_TEMPLATE/bug_report.md | 2 +- go.mod | 2 +- pkg/base/config_center/base_operate.go | 2 +- .../config_center/config_center_factory.go | 2 +- pkg/base/config_center/etcdv3/factory.go | 10 ++++---- pkg/base/config_center/nacos/factory.go | 8 +++---- pkg/base/extension/config_center.go | 4 ++-- pkg/base/extension/registry.go | 2 +- pkg/base/getty/message_future.go | 2 +- pkg/base/getty/readwriter/readwriter.go | 4 ++-- pkg/base/model/resource.go | 2 +- pkg/base/protocal/codec/codec.go | 4 ++-- pkg/base/protocal/codec/seata_decoder.go | 4 ++-- pkg/base/protocal/codec/seata_encoder.go | 4 ++-- pkg/base/protocal/transaction.go | 2 +- pkg/base/registry/etcdv3/registry.go | 12 +++++----- pkg/base/registry/file/registry.go | 10 ++++---- pkg/base/registry/nacos/registry.go | 10 ++++---- pkg/client/config/client_config.go | 10 ++++---- pkg/client/config/getty_config.go | 2 +- pkg/client/context/root_context.go | 4 ++-- pkg/client/proxy/service.go | 4 ++-- pkg/client/rm/abstract_resource_manager.go | 12 +++++----- pkg/client/rm/resource_manager.go | 4 ++-- pkg/client/rpc_client.go | 10 ++++---- .../rpc_client/client_message_sender.go | 2 +- pkg/client/rpc_client/rpc_remoting_client.go | 12 +++++----- pkg/client/rpc_client/rpc_rm_message.go | 2 +- pkg/client/tcc/proxy.go | 10 ++++---- pkg/client/tcc/tcc_resource.go | 4 ++-- pkg/client/tcc/tcc_resource_manager.go | 14 +++++------ pkg/client/tm/default_transaction_manager.go | 6 ++--- pkg/client/tm/global_transaction.go | 10 ++++---- pkg/client/tm/proxy.go | 6 ++--- pkg/client/tm/transaction_manager.go | 2 +- pkg/tc/config/server_config.go | 10 ++++---- pkg/tc/event/global_transaction_event.go | 2 +- pkg/tc/holder/db_based_session_manager.go | 8 +++---- pkg/tc/holder/db_transaction_store_manager.go | 8 +++---- pkg/tc/holder/default_session_manager.go | 6 ++--- pkg/tc/holder/default_session_manager_test.go | 6 ++--- pkg/tc/holder/file_based_session_manager.go | 8 +++---- .../holder/file_based_session_manager_test.go | 6 ++--- .../holder/file_transaction_store_manager.go | 8 +++---- pkg/tc/holder/log_store_database_dao.go | 4 ++-- pkg/tc/holder/session_holder.go | 10 ++++---- pkg/tc/holder/session_manager.go | 8 +++---- pkg/tc/holder/transaction_store_manager.go | 4 ++-- pkg/tc/holder/transaction_write_store.go | 2 +- pkg/tc/lock/database_lock.go | 6 ++--- pkg/tc/lock/lock_manager.go | 4 ++-- pkg/tc/lock/lock_manager_test.go | 10 ++++---- pkg/tc/lock/lock_store_database_dao.go | 4 ++-- pkg/tc/lock/memory_lock.go | 8 +++---- pkg/tc/lock/row_locker.go | 4 ++-- pkg/tc/metrics/metrics.go | 6 ++--- pkg/tc/model/session_condition.go | 2 +- pkg/tc/server/default_coordinator.go | 24 +++++++++---------- .../default_coordinator_event_listener.go | 6 ++--- ...ult_coordinator_server_message_listener.go | 4 ++-- ...fault_coordinator_server_message_sender.go | 2 +- .../default_coordinator_tc_inbound_handler.go | 8 +++---- pkg/tc/server/default_core.go | 18 +++++++------- pkg/tc/server/getty_session_manager.go | 8 +++---- pkg/tc/server/rpc_context.go | 4 ++-- pkg/tc/server/server.go | 10 ++++---- pkg/tc/server/server_message_listener.go | 2 +- pkg/tc/server/server_message_sender.go | 2 +- pkg/tc/server/tc_inbound_handler.go | 2 +- pkg/tc/server/transaction_coordinator.go | 8 +++---- pkg/tc/session/branch_session.go | 8 +++---- pkg/tc/session/branch_session_test.go | 4 ++-- pkg/tc/session/global_session.go | 12 +++++----- pkg/util/etcdv3/utils.go | 4 ++-- pkg/util/parser/parser.go | 2 +- pkg/util/uuid/id_worker.go | 2 +- 76 files changed, 232 insertions(+), 232 deletions(-) diff --git a/.github/ISSUE_TEMPLATE/bug_report.md b/.github/ISSUE_TEMPLATE/bug_report.md index 658984073..24918e22b 100644 --- a/.github/ISSUE_TEMPLATE/bug_report.md +++ b/.github/ISSUE_TEMPLATE/bug_report.md @@ -4,7 +4,7 @@ about: Create a report to help us improve title: '' --- -- [ ] I have searched the [issues](https://github.com/seata/seata-go/issues) of this repository and believe that this is not a duplicate. +- [ ] I have searched the [issues](https://github.com/PangXing/seata-go/issues) of this repository and believe that this is not a duplicate. **Describe the bug** A clear and concise description of what the bug is. diff --git a/go.mod b/go.mod index 308686895..b45287270 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/seata/seata-go +module github.com/PangXing/seata-go go 1.16 diff --git a/pkg/base/config_center/base_operate.go b/pkg/base/config_center/base_operate.go index 51bb0feea..f0215c048 100644 --- a/pkg/base/config_center/base_operate.go +++ b/pkg/base/config_center/base_operate.go @@ -1,7 +1,7 @@ package config_center import ( - "github.com/seata/seata-go/pkg/base/config" + "github.com/PangXing/seata-go/pkg/base/config" ) // AddListener add config center listener diff --git a/pkg/base/config_center/config_center_factory.go b/pkg/base/config_center/config_center_factory.go index 35cb6a2de..73b6edc70 100644 --- a/pkg/base/config_center/config_center_factory.go +++ b/pkg/base/config_center/config_center_factory.go @@ -1,7 +1,7 @@ package config_center import ( - "github.com/seata/seata-go/pkg/base/config" + "github.com/PangXing/seata-go/pkg/base/config" ) type DynamicConfigurationFactory interface { diff --git a/pkg/base/config_center/etcdv3/factory.go b/pkg/base/config_center/etcdv3/factory.go index f233bb080..ccb11f7a0 100644 --- a/pkg/base/config_center/etcdv3/factory.go +++ b/pkg/base/config_center/etcdv3/factory.go @@ -6,11 +6,11 @@ import ( gxetcd "github.com/dubbogo/gost/database/kv/etcd/v3" - "github.com/seata/seata-go/pkg/base/config" - "github.com/seata/seata-go/pkg/base/config_center" - "github.com/seata/seata-go/pkg/base/constant" - "github.com/seata/seata-go/pkg/base/extension" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/config" + "github.com/PangXing/seata-go/pkg/base/config_center" + "github.com/PangXing/seata-go/pkg/base/constant" + "github.com/PangXing/seata-go/pkg/base/extension" + "github.com/PangXing/seata-go/pkg/util/log" clientv3 "go.etcd.io/etcd/client/v3" ) diff --git a/pkg/base/config_center/nacos/factory.go b/pkg/base/config_center/nacos/factory.go index bd08d3243..c94cb48bf 100644 --- a/pkg/base/config_center/nacos/factory.go +++ b/pkg/base/config_center/nacos/factory.go @@ -8,12 +8,12 @@ import ( "github.com/nacos-group/nacos-sdk-go/clients" "github.com/nacos-group/nacos-sdk-go/clients/config_client" + "github.com/PangXing/seata-go/pkg/base/config" + "github.com/PangXing/seata-go/pkg/base/config_center" + "github.com/PangXing/seata-go/pkg/base/constant" + "github.com/PangXing/seata-go/pkg/base/extension" nacosConstant "github.com/nacos-group/nacos-sdk-go/common/constant" "github.com/nacos-group/nacos-sdk-go/vo" - "github.com/seata/seata-go/pkg/base/config" - "github.com/seata/seata-go/pkg/base/config_center" - "github.com/seata/seata-go/pkg/base/constant" - "github.com/seata/seata-go/pkg/base/extension" ) func init() { diff --git a/pkg/base/extension/config_center.go b/pkg/base/extension/config_center.go index 42c5d48a0..0fc2e26bf 100644 --- a/pkg/base/extension/config_center.go +++ b/pkg/base/extension/config_center.go @@ -3,9 +3,9 @@ package extension import ( "sync" + "github.com/PangXing/seata-go/pkg/base/config" + "github.com/PangXing/seata-go/pkg/base/config_center" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/config" - "github.com/seata/seata-go/pkg/base/config_center" ) var ( diff --git a/pkg/base/extension/registry.go b/pkg/base/extension/registry.go index 6a9215dcb..7c1bd4f40 100644 --- a/pkg/base/extension/registry.go +++ b/pkg/base/extension/registry.go @@ -3,8 +3,8 @@ package extension import ( "sync" + "github.com/PangXing/seata-go/pkg/base/registry" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/registry" ) var ( diff --git a/pkg/base/getty/message_future.go b/pkg/base/getty/message_future.go index f50042c4a..4dc8e54c6 100644 --- a/pkg/base/getty/message_future.go +++ b/pkg/base/getty/message_future.go @@ -1,7 +1,7 @@ package getty import ( - "github.com/seata/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/base/protocal" ) // MessageFuture ... diff --git a/pkg/base/getty/readwriter/readwriter.go b/pkg/base/getty/readwriter/readwriter.go index dff17e14c..f50065106 100644 --- a/pkg/base/getty/readwriter/readwriter.go +++ b/pkg/base/getty/readwriter/readwriter.go @@ -4,10 +4,10 @@ import ( "bytes" "encoding/binary" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/base/protocal/codec" getty "github.com/apache/dubbo-getty" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/base/protocal/codec" "vimagination.zapto.org/byteio" ) diff --git a/pkg/base/model/resource.go b/pkg/base/model/resource.go index 725842456..91cb2f7cd 100644 --- a/pkg/base/model/resource.go +++ b/pkg/base/model/resource.go @@ -1,7 +1,7 @@ package model import ( - "github.com/seata/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/meta" ) type IResource interface { diff --git a/pkg/base/protocal/codec/codec.go b/pkg/base/protocal/codec/codec.go index 39108edff..3a536eb63 100644 --- a/pkg/base/protocal/codec/codec.go +++ b/pkg/base/protocal/codec/codec.go @@ -3,8 +3,8 @@ package codec import ( "bytes" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/util/log" "vimagination.zapto.org/byteio" ) diff --git a/pkg/base/protocal/codec/seata_decoder.go b/pkg/base/protocal/codec/seata_decoder.go index ec9a86c90..dab6a9339 100644 --- a/pkg/base/protocal/codec/seata_decoder.go +++ b/pkg/base/protocal/codec/seata_decoder.go @@ -3,8 +3,8 @@ package codec import ( "bytes" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/protocal" "vimagination.zapto.org/byteio" ) diff --git a/pkg/base/protocal/codec/seata_encoder.go b/pkg/base/protocal/codec/seata_encoder.go index fd3dfad27..33ce7954c 100644 --- a/pkg/base/protocal/codec/seata_encoder.go +++ b/pkg/base/protocal/codec/seata_encoder.go @@ -3,8 +3,8 @@ package codec import ( "bytes" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/util/log" "vimagination.zapto.org/byteio" ) diff --git a/pkg/base/protocal/transaction.go b/pkg/base/protocal/transaction.go index 320f1eaed..7695e66a3 100644 --- a/pkg/base/protocal/transaction.go +++ b/pkg/base/protocal/transaction.go @@ -1,7 +1,7 @@ package protocal import ( - "github.com/seata/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/meta" ) type AbstractTransactionResponse struct { diff --git a/pkg/base/registry/etcdv3/registry.go b/pkg/base/registry/etcdv3/registry.go index 4645822a2..2497a022b 100644 --- a/pkg/base/registry/etcdv3/registry.go +++ b/pkg/base/registry/etcdv3/registry.go @@ -12,14 +12,14 @@ import ( perrors "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/config" - "github.com/seata/seata-go/pkg/base/constant" - "github.com/seata/seata-go/pkg/base/extension" - "github.com/seata/seata-go/pkg/base/registry" + "github.com/PangXing/seata-go/pkg/base/config" + "github.com/PangXing/seata-go/pkg/base/constant" + "github.com/PangXing/seata-go/pkg/base/extension" + "github.com/PangXing/seata-go/pkg/base/registry" clientv3 "go.etcd.io/etcd/client/v3" - utils "github.com/seata/seata-go/pkg/util/etcdv3" - "github.com/seata/seata-go/pkg/util/log" + utils "github.com/PangXing/seata-go/pkg/util/etcdv3" + "github.com/PangXing/seata-go/pkg/util/log" ) func init() { diff --git a/pkg/base/registry/file/registry.go b/pkg/base/registry/file/registry.go index b5aa9128f..13c793abf 100644 --- a/pkg/base/registry/file/registry.go +++ b/pkg/base/registry/file/registry.go @@ -3,11 +3,11 @@ package file import ( "strings" - "github.com/seata/seata-go/pkg/base/constant" - "github.com/seata/seata-go/pkg/base/extension" - "github.com/seata/seata-go/pkg/base/registry" - "github.com/seata/seata-go/pkg/client/config" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/constant" + "github.com/PangXing/seata-go/pkg/base/extension" + "github.com/PangXing/seata-go/pkg/base/registry" + "github.com/PangXing/seata-go/pkg/client/config" + "github.com/PangXing/seata-go/pkg/util/log" ) func init() { diff --git a/pkg/base/registry/nacos/registry.go b/pkg/base/registry/nacos/registry.go index c2e5bd24f..a00f5aaa1 100644 --- a/pkg/base/registry/nacos/registry.go +++ b/pkg/base/registry/nacos/registry.go @@ -9,15 +9,15 @@ import ( "github.com/nacos-group/nacos-sdk-go/clients" "github.com/nacos-group/nacos-sdk-go/clients/naming_client" + "github.com/PangXing/seata-go/pkg/base/config" + "github.com/PangXing/seata-go/pkg/base/constant" + "github.com/PangXing/seata-go/pkg/base/extension" + "github.com/PangXing/seata-go/pkg/base/registry" + "github.com/PangXing/seata-go/pkg/util/log" nacosConstant "github.com/nacos-group/nacos-sdk-go/common/constant" "github.com/nacos-group/nacos-sdk-go/model" "github.com/nacos-group/nacos-sdk-go/vo" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/config" - "github.com/seata/seata-go/pkg/base/constant" - "github.com/seata/seata-go/pkg/base/extension" - "github.com/seata/seata-go/pkg/base/registry" - "github.com/seata/seata-go/pkg/util/log" ) func init() { diff --git a/pkg/client/config/client_config.go b/pkg/client/config/client_config.go index 00e605f63..5aa01da6e 100644 --- a/pkg/client/config/client_config.go +++ b/pkg/client/config/client_config.go @@ -6,13 +6,13 @@ import ( "os" "time" + "github.com/PangXing/seata-go/pkg/base/config" + "github.com/PangXing/seata-go/pkg/base/config_center" + "github.com/PangXing/seata-go/pkg/base/extension" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/parser" "github.com/creasty/defaults" "github.com/imdario/mergo" - "github.com/seata/seata-go/pkg/base/config" - "github.com/seata/seata-go/pkg/base/config_center" - "github.com/seata/seata-go/pkg/base/extension" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/parser" "gopkg.in/yaml.v2" ) diff --git a/pkg/client/config/getty_config.go b/pkg/client/config/getty_config.go index b6f234e9f..bc71ac693 100644 --- a/pkg/client/config/getty_config.go +++ b/pkg/client/config/getty_config.go @@ -3,7 +3,7 @@ package config import ( "time" - config2 "github.com/seata/seata-go/pkg/base/config" + config2 "github.com/PangXing/seata-go/pkg/base/config" ) // GettyConfig diff --git a/pkg/client/context/root_context.go b/pkg/client/context/root_context.go index 11ff746a0..a1a4a6152 100644 --- a/pkg/client/context/root_context.go +++ b/pkg/client/context/root_context.go @@ -5,8 +5,8 @@ import ( "fmt" "strings" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/util/log" ) const ( diff --git a/pkg/client/proxy/service.go b/pkg/client/proxy/service.go index 55b99b8ed..d38b1b25b 100644 --- a/pkg/client/proxy/service.go +++ b/pkg/client/proxy/service.go @@ -7,8 +7,8 @@ import ( "unicode" "unicode/utf8" - context2 "github.com/seata/seata-go/pkg/client/context" - "github.com/seata/seata-go/pkg/util/log" + context2 "github.com/PangXing/seata-go/pkg/client/context" + "github.com/PangXing/seata-go/pkg/util/log" ) var ( diff --git a/pkg/client/rm/abstract_resource_manager.go b/pkg/client/rm/abstract_resource_manager.go index 9265196a9..f5e29ce18 100644 --- a/pkg/client/rm/abstract_resource_manager.go +++ b/pkg/client/rm/abstract_resource_manager.go @@ -3,13 +3,13 @@ package rm import ( "strings" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/model" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/client/config" + "github.com/PangXing/seata-go/pkg/client/context" + "github.com/PangXing/seata-go/pkg/client/rpc_client" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/model" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/client/config" - "github.com/seata/seata-go/pkg/client/context" - "github.com/seata/seata-go/pkg/client/rpc_client" ) var ( diff --git a/pkg/client/rm/resource_manager.go b/pkg/client/rm/resource_manager.go index 4a8d214d6..84363992c 100644 --- a/pkg/client/rm/resource_manager.go +++ b/pkg/client/rm/resource_manager.go @@ -1,8 +1,8 @@ package rm import ( - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/model" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/model" ) type ResourceManagerInbound interface { diff --git a/pkg/client/rpc_client.go b/pkg/client/rpc_client.go index 3b2d98580..92f66242e 100644 --- a/pkg/client/rpc_client.go +++ b/pkg/client/rpc_client.go @@ -6,14 +6,14 @@ import ( getty "github.com/apache/dubbo-getty" + "github.com/PangXing/seata-go/pkg/base/extension" + "github.com/PangXing/seata-go/pkg/base/getty/readwriter" + "github.com/PangXing/seata-go/pkg/client/config" gxsync "github.com/dubbogo/gost/sync" "github.com/nacos-group/nacos-sdk-go/common/logger" - "github.com/seata/seata-go/pkg/base/extension" - "github.com/seata/seata-go/pkg/base/getty/readwriter" - "github.com/seata/seata-go/pkg/client/config" - getty2 "github.com/seata/seata-go/pkg/client/rpc_client" - "github.com/seata/seata-go/pkg/util/log" + getty2 "github.com/PangXing/seata-go/pkg/client/rpc_client" + "github.com/PangXing/seata-go/pkg/util/log" ) type RpcClient struct { diff --git a/pkg/client/rpc_client/client_message_sender.go b/pkg/client/rpc_client/client_message_sender.go index b41875d82..d2fce96ab 100644 --- a/pkg/client/rpc_client/client_message_sender.go +++ b/pkg/client/rpc_client/client_message_sender.go @@ -3,7 +3,7 @@ package rpc_client import ( "time" - "github.com/seata/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/base/protocal" ) type ClientMessageSender interface { diff --git a/pkg/client/rpc_client/rpc_remoting_client.go b/pkg/client/rpc_client/rpc_remoting_client.go index 5b01a2292..90932cacd 100644 --- a/pkg/client/rpc_client/rpc_remoting_client.go +++ b/pkg/client/rpc_client/rpc_remoting_client.go @@ -12,12 +12,12 @@ import ( "github.com/pkg/errors" "go.uber.org/atomic" - getty2 "github.com/seata/seata-go/pkg/base/getty" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/base/protocal/codec" - "github.com/seata/seata-go/pkg/client/config" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/runtime" + getty2 "github.com/PangXing/seata-go/pkg/base/getty" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/base/protocal/codec" + "github.com/PangXing/seata-go/pkg/client/config" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/runtime" ) const ( diff --git a/pkg/client/rpc_client/rpc_rm_message.go b/pkg/client/rpc_client/rpc_rm_message.go index 7e0f97c0e..e1b52d99d 100644 --- a/pkg/client/rpc_client/rpc_rm_message.go +++ b/pkg/client/rpc_client/rpc_rm_message.go @@ -1,7 +1,7 @@ package rpc_client import ( - "github.com/seata/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/base/protocal" ) type RpcRMMessage struct { diff --git a/pkg/client/tcc/proxy.go b/pkg/client/tcc/proxy.go index 4e2961825..6b610599a 100644 --- a/pkg/client/tcc/proxy.go +++ b/pkg/client/tcc/proxy.go @@ -5,13 +5,13 @@ import ( "reflect" "strconv" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/client/context" + "github.com/PangXing/seata-go/pkg/client/proxy" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/time" gxnet "github.com/dubbogo/gost/net" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/client/context" - "github.com/seata/seata-go/pkg/client/proxy" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/time" ) var ( diff --git a/pkg/client/tcc/tcc_resource.go b/pkg/client/tcc/tcc_resource.go index 20f25eb56..381381b27 100644 --- a/pkg/client/tcc/tcc_resource.go +++ b/pkg/client/tcc/tcc_resource.go @@ -1,8 +1,8 @@ package tcc import ( - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/client/proxy" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/client/proxy" ) type TCCResource struct { diff --git a/pkg/client/tcc/tcc_resource_manager.go b/pkg/client/tcc/tcc_resource_manager.go index d3f8f7032..ca22f77cb 100644 --- a/pkg/client/tcc/tcc_resource_manager.go +++ b/pkg/client/tcc/tcc_resource_manager.go @@ -5,14 +5,14 @@ import ( "fmt" "strconv" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/client/context" + "github.com/PangXing/seata-go/pkg/client/proxy" + "github.com/PangXing/seata-go/pkg/client/rm" + "github.com/PangXing/seata-go/pkg/client/rpc_client" + "github.com/PangXing/seata-go/pkg/util/log" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/client/context" - "github.com/seata/seata-go/pkg/client/proxy" - "github.com/seata/seata-go/pkg/client/rm" - "github.com/seata/seata-go/pkg/client/rpc_client" - "github.com/seata/seata-go/pkg/util/log" ) var ( diff --git a/pkg/client/tm/default_transaction_manager.go b/pkg/client/tm/default_transaction_manager.go index 2c10b57d9..736b0e4e8 100644 --- a/pkg/client/tm/default_transaction_manager.go +++ b/pkg/client/tm/default_transaction_manager.go @@ -1,10 +1,10 @@ package tm import ( + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/client/rpc_client" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/client/rpc_client" ) type DefaultTransactionManager struct { diff --git a/pkg/client/tm/global_transaction.go b/pkg/client/tm/global_transaction.go index 12ece3abe..b6fc92cc1 100644 --- a/pkg/client/tm/global_transaction.go +++ b/pkg/client/tm/global_transaction.go @@ -3,13 +3,13 @@ package tm import ( "fmt" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/client/config" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/client/config" - context2 "github.com/seata/seata-go/pkg/client/context" - "github.com/seata/seata-go/pkg/client/rpc_client" - "github.com/seata/seata-go/pkg/util/log" + context2 "github.com/PangXing/seata-go/pkg/client/context" + "github.com/PangXing/seata-go/pkg/client/rpc_client" + "github.com/PangXing/seata-go/pkg/util/log" ) const ( diff --git a/pkg/client/tm/proxy.go b/pkg/client/tm/proxy.go index a31872d99..f37333319 100644 --- a/pkg/client/tm/proxy.go +++ b/pkg/client/tm/proxy.go @@ -6,9 +6,9 @@ import ( "github.com/pkg/errors" - context2 "github.com/seata/seata-go/pkg/client/context" - "github.com/seata/seata-go/pkg/client/proxy" - "github.com/seata/seata-go/pkg/util/log" + context2 "github.com/PangXing/seata-go/pkg/client/context" + "github.com/PangXing/seata-go/pkg/client/proxy" + "github.com/PangXing/seata-go/pkg/util/log" ) type GlobalTransactionServiceProxy interface { diff --git a/pkg/client/tm/transaction_manager.go b/pkg/client/tm/transaction_manager.go index cede4eef4..05a4eaaea 100644 --- a/pkg/client/tm/transaction_manager.go +++ b/pkg/client/tm/transaction_manager.go @@ -1,7 +1,7 @@ package tm import ( - "github.com/seata/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/meta" ) type TransactionManager interface { diff --git a/pkg/tc/config/server_config.go b/pkg/tc/config/server_config.go index 11b973ee5..4d6c5bf92 100644 --- a/pkg/tc/config/server_config.go +++ b/pkg/tc/config/server_config.go @@ -7,16 +7,16 @@ import ( "os" "time" + "github.com/PangXing/seata-go/pkg/base/config" + "github.com/PangXing/seata-go/pkg/base/config_center" + "github.com/PangXing/seata-go/pkg/base/extension" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/parser" getty "github.com/apache/dubbo-getty" "github.com/creasty/defaults" "github.com/go-xorm/xorm" "github.com/imdario/mergo" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/config" - "github.com/seata/seata-go/pkg/base/config_center" - "github.com/seata/seata-go/pkg/base/extension" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/parser" "gopkg.in/yaml.v2" ) diff --git a/pkg/tc/event/global_transaction_event.go b/pkg/tc/event/global_transaction_event.go index 2eacfa263..9b4843d05 100644 --- a/pkg/tc/event/global_transaction_event.go +++ b/pkg/tc/event/global_transaction_event.go @@ -1,7 +1,7 @@ package event import ( - "github.com/seata/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/meta" ) const ( diff --git a/pkg/tc/holder/db_based_session_manager.go b/pkg/tc/holder/db_based_session_manager.go index 8718a5347..4adf4f2d8 100644 --- a/pkg/tc/holder/db_based_session_manager.go +++ b/pkg/tc/holder/db_based_session_manager.go @@ -1,11 +1,11 @@ package holder import ( + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/config" + "github.com/PangXing/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/tc/session" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/config" - "github.com/seata/seata-go/pkg/tc/model" - "github.com/seata/seata-go/pkg/tc/session" ) type DataBaseSessionManager struct { diff --git a/pkg/tc/holder/db_transaction_store_manager.go b/pkg/tc/holder/db_transaction_store_manager.go index f235067bd..195930cd7 100644 --- a/pkg/tc/holder/db_transaction_store_manager.go +++ b/pkg/tc/holder/db_transaction_store_manager.go @@ -1,10 +1,10 @@ package holder import ( - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/model" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/log" ) type DBTransactionStoreManager struct { diff --git a/pkg/tc/holder/default_session_manager.go b/pkg/tc/holder/default_session_manager.go index 92370793b..11c993045 100644 --- a/pkg/tc/holder/default_session_manager.go +++ b/pkg/tc/holder/default_session_manager.go @@ -1,9 +1,9 @@ package holder import ( - "github.com/seata/seata-go/pkg/tc/model" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/time" + "github.com/PangXing/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/time" ) type DefaultSessionManager struct { diff --git a/pkg/tc/holder/default_session_manager_test.go b/pkg/tc/holder/default_session_manager_test.go index b35a64a5a..721e2ae63 100644 --- a/pkg/tc/holder/default_session_manager_test.go +++ b/pkg/tc/holder/default_session_manager_test.go @@ -3,9 +3,9 @@ package holder import ( "testing" - "github.com/seata/seata-go/pkg/base/common" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/base/common" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/session" "github.com/stretchr/testify/assert" ) diff --git a/pkg/tc/holder/file_based_session_manager.go b/pkg/tc/holder/file_based_session_manager.go index 769dd95d1..7ff8f74fa 100644 --- a/pkg/tc/holder/file_based_session_manager.go +++ b/pkg/tc/holder/file_based_session_manager.go @@ -1,10 +1,10 @@ package holder import ( - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/config" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/config" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/log" ) type FileBasedSessionManager struct { diff --git a/pkg/tc/holder/file_based_session_manager_test.go b/pkg/tc/holder/file_based_session_manager_test.go index 655ed442b..e6ecdd259 100644 --- a/pkg/tc/holder/file_based_session_manager_test.go +++ b/pkg/tc/holder/file_based_session_manager_test.go @@ -3,9 +3,9 @@ package holder import ( "testing" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/config" - "github.com/seata/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/config" + "github.com/PangXing/seata-go/pkg/tc/model" "github.com/stretchr/testify/assert" ) diff --git a/pkg/tc/holder/file_transaction_store_manager.go b/pkg/tc/holder/file_transaction_store_manager.go index 1a0700876..38a08bae3 100644 --- a/pkg/tc/holder/file_transaction_store_manager.go +++ b/pkg/tc/holder/file_transaction_store_manager.go @@ -6,10 +6,10 @@ import ( "sync" "sync/atomic" - "github.com/seata/seata-go/pkg/tc/model" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/time" + "github.com/PangXing/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/time" "vimagination.zapto.org/byteio" ) diff --git a/pkg/tc/holder/log_store_database_dao.go b/pkg/tc/holder/log_store_database_dao.go index e2d38d0fa..d0c8825b3 100644 --- a/pkg/tc/holder/log_store_database_dao.go +++ b/pkg/tc/holder/log_store_database_dao.go @@ -3,8 +3,8 @@ package holder import ( "github.com/go-xorm/xorm" - "github.com/seata/seata-go/pkg/tc/model" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/util/log" "xorm.io/builder" ) diff --git a/pkg/tc/holder/session_holder.go b/pkg/tc/holder/session_holder.go index 3dbd679b6..cee73f1a1 100644 --- a/pkg/tc/holder/session_holder.go +++ b/pkg/tc/holder/session_holder.go @@ -1,11 +1,11 @@ package holder import ( - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/config" - "github.com/seata/seata-go/pkg/tc/lock" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/config" + "github.com/PangXing/seata-go/pkg/tc/lock" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/log" ) var ( diff --git a/pkg/tc/holder/session_manager.go b/pkg/tc/holder/session_manager.go index 6631c920f..6763eee6b 100644 --- a/pkg/tc/holder/session_manager.go +++ b/pkg/tc/holder/session_manager.go @@ -3,10 +3,10 @@ package holder import ( "errors" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/model" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/log" ) type SessionManager interface { diff --git a/pkg/tc/holder/transaction_store_manager.go b/pkg/tc/holder/transaction_store_manager.go index 6cf38dc81..8a44fea4e 100644 --- a/pkg/tc/holder/transaction_store_manager.go +++ b/pkg/tc/holder/transaction_store_manager.go @@ -3,8 +3,8 @@ package holder import ( "fmt" - "github.com/seata/seata-go/pkg/tc/model" - "github.com/seata/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/tc/session" ) type LogOperation byte diff --git a/pkg/tc/holder/transaction_write_store.go b/pkg/tc/holder/transaction_write_store.go index 666991a31..e6566162a 100644 --- a/pkg/tc/holder/transaction_write_store.go +++ b/pkg/tc/holder/transaction_write_store.go @@ -1,8 +1,8 @@ package holder import ( + "github.com/PangXing/seata-go/pkg/tc/session" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/tc/session" ) type TransactionWriteStore struct { diff --git a/pkg/tc/lock/database_lock.go b/pkg/tc/lock/database_lock.go index c8128b77d..d599d6a53 100644 --- a/pkg/tc/lock/database_lock.go +++ b/pkg/tc/lock/database_lock.go @@ -3,10 +3,10 @@ package lock import ( "fmt" + "github.com/PangXing/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/log" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/tc/model" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/log" ) type DataBaseLocker struct { diff --git a/pkg/tc/lock/lock_manager.go b/pkg/tc/lock/lock_manager.go index ab8bfd8c3..d244c5902 100644 --- a/pkg/tc/lock/lock_manager.go +++ b/pkg/tc/lock/lock_manager.go @@ -3,8 +3,8 @@ package lock import ( "sync" - "github.com/seata/seata-go/pkg/tc/config" - "github.com/seata/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/tc/config" + "github.com/PangXing/seata-go/pkg/tc/session" ) var lockManager LockManager diff --git a/pkg/tc/lock/lock_manager_test.go b/pkg/tc/lock/lock_manager_test.go index ba2bdd320..b3dc3569e 100644 --- a/pkg/tc/lock/lock_manager_test.go +++ b/pkg/tc/lock/lock_manager_test.go @@ -4,11 +4,11 @@ import ( "sync" "testing" - "github.com/seata/seata-go/pkg/base/common" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/uuid" + "github.com/PangXing/seata-go/pkg/base/common" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/uuid" "github.com/stretchr/testify/assert" ) diff --git a/pkg/tc/lock/lock_store_database_dao.go b/pkg/tc/lock/lock_store_database_dao.go index a76f160e1..f8aeb819e 100644 --- a/pkg/tc/lock/lock_store_database_dao.go +++ b/pkg/tc/lock/lock_store_database_dao.go @@ -3,8 +3,8 @@ package lock import ( "github.com/go-xorm/xorm" - "github.com/seata/seata-go/pkg/tc/model" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/tc/model" + "github.com/PangXing/seata-go/pkg/util/log" "xorm.io/builder" ) diff --git a/pkg/tc/lock/memory_lock.go b/pkg/tc/lock/memory_lock.go index 79f96092d..6cfb50dd2 100644 --- a/pkg/tc/lock/memory_lock.go +++ b/pkg/tc/lock/memory_lock.go @@ -5,11 +5,11 @@ import ( "sync" "sync/atomic" + "github.com/PangXing/seata-go/pkg/base/model" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/hashcode" + "github.com/PangXing/seata-go/pkg/util/log" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/model" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/hashcode" - "github.com/seata/seata-go/pkg/util/log" ) const BucketPerTable = 128 diff --git a/pkg/tc/lock/row_locker.go b/pkg/tc/lock/row_locker.go index 9bf8aecdc..9b6940328 100644 --- a/pkg/tc/lock/row_locker.go +++ b/pkg/tc/lock/row_locker.go @@ -3,8 +3,8 @@ package lock import ( "strings" - "github.com/seata/seata-go/pkg/base/common" - "github.com/seata/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/base/common" + "github.com/PangXing/seata-go/pkg/tc/session" ) const LOCK_SPLIT = "^^^" diff --git a/pkg/tc/metrics/metrics.go b/pkg/tc/metrics/metrics.go index 860d48a01..b9ddfb4ce 100644 --- a/pkg/tc/metrics/metrics.go +++ b/pkg/tc/metrics/metrics.go @@ -3,10 +3,10 @@ package metrics import ( "sort" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/event" + "github.com/PangXing/seata-go/pkg/util/runtime" "github.com/rcrowley/go-metrics" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/event" - "github.com/seata/seata-go/pkg/util/runtime" ) var ( diff --git a/pkg/tc/model/session_condition.go b/pkg/tc/model/session_condition.go index 3b38b7061..66a0aa6cb 100644 --- a/pkg/tc/model/session_condition.go +++ b/pkg/tc/model/session_condition.go @@ -1,7 +1,7 @@ package model import ( - "github.com/seata/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/meta" ) // SessionCondition for query GlobalSession diff --git a/pkg/tc/server/default_coordinator.go b/pkg/tc/server/default_coordinator.go index 8a14b04ba..36517db30 100644 --- a/pkg/tc/server/default_coordinator.go +++ b/pkg/tc/server/default_coordinator.go @@ -10,19 +10,19 @@ import ( "github.com/pkg/errors" "go.uber.org/atomic" - getty2 "github.com/seata/seata-go/pkg/base/getty" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/base/protocal/codec" - "github.com/seata/seata-go/pkg/tc/config" - "github.com/seata/seata-go/pkg/tc/event" - "github.com/seata/seata-go/pkg/tc/holder" - "github.com/seata/seata-go/pkg/tc/lock" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/runtime" + getty2 "github.com/PangXing/seata-go/pkg/base/getty" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/base/protocal/codec" + "github.com/PangXing/seata-go/pkg/tc/config" + "github.com/PangXing/seata-go/pkg/tc/event" + "github.com/PangXing/seata-go/pkg/tc/holder" + "github.com/PangXing/seata-go/pkg/tc/lock" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/runtime" - time2 "github.com/seata/seata-go/pkg/util/time" + time2 "github.com/PangXing/seata-go/pkg/util/time" ) const ( diff --git a/pkg/tc/server/default_coordinator_event_listener.go b/pkg/tc/server/default_coordinator_event_listener.go index be48de85e..8335c28ac 100644 --- a/pkg/tc/server/default_coordinator_event_listener.go +++ b/pkg/tc/server/default_coordinator_event_listener.go @@ -5,9 +5,9 @@ import ( getty "github.com/apache/dubbo-getty" - getty2 "github.com/seata/seata-go/pkg/base/getty" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/util/log" + getty2 "github.com/PangXing/seata-go/pkg/base/getty" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/util/log" ) const ( diff --git a/pkg/tc/server/default_coordinator_server_message_listener.go b/pkg/tc/server/default_coordinator_server_message_listener.go index faadc0a0a..1297dfd6a 100644 --- a/pkg/tc/server/default_coordinator_server_message_listener.go +++ b/pkg/tc/server/default_coordinator_server_message_listener.go @@ -1,9 +1,9 @@ package server import ( + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/util/log" getty "github.com/apache/dubbo-getty" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/util/log" ) func (coordinator *DefaultCoordinator) OnTrxMessage(rpcMessage protocal.RpcMessage, session getty.Session) { diff --git a/pkg/tc/server/default_coordinator_server_message_sender.go b/pkg/tc/server/default_coordinator_server_message_sender.go index c386ca7ce..b546ead95 100644 --- a/pkg/tc/server/default_coordinator_server_message_sender.go +++ b/pkg/tc/server/default_coordinator_server_message_sender.go @@ -3,9 +3,9 @@ package server import ( "time" + "github.com/PangXing/seata-go/pkg/base/protocal" getty "github.com/apache/dubbo-getty" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/protocal" ) func (coordinator *DefaultCoordinator) SendResponse(request protocal.RpcMessage, session getty.Session, msg interface{}) { diff --git a/pkg/tc/server/default_coordinator_tc_inbound_handler.go b/pkg/tc/server/default_coordinator_tc_inbound_handler.go index 27c60c023..8d97bbca8 100644 --- a/pkg/tc/server/default_coordinator_tc_inbound_handler.go +++ b/pkg/tc/server/default_coordinator_tc_inbound_handler.go @@ -4,10 +4,10 @@ import ( "errors" "fmt" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/tc/holder" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/tc/holder" + "github.com/PangXing/seata-go/pkg/util/log" ) func (coordinator *DefaultCoordinator) doGlobalBegin(request protocal.GlobalBeginRequest, ctx RpcContext) protocal.GlobalBeginResponse { diff --git a/pkg/tc/server/default_core.go b/pkg/tc/server/default_core.go index 17fd4953e..4d3f6509e 100644 --- a/pkg/tc/server/default_core.go +++ b/pkg/tc/server/default_core.go @@ -3,15 +3,15 @@ package server import ( "fmt" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/tc/event" - "github.com/seata/seata-go/pkg/tc/holder" - "github.com/seata/seata-go/pkg/tc/lock" - "github.com/seata/seata-go/pkg/tc/session" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/runtime" - "github.com/seata/seata-go/pkg/util/time" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/tc/event" + "github.com/PangXing/seata-go/pkg/tc/holder" + "github.com/PangXing/seata-go/pkg/tc/lock" + "github.com/PangXing/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/runtime" + "github.com/PangXing/seata-go/pkg/util/time" ) /** diff --git a/pkg/tc/server/getty_session_manager.go b/pkg/tc/server/getty_session_manager.go index 4f4a32fd8..093ba89ef 100644 --- a/pkg/tc/server/getty_session_manager.go +++ b/pkg/tc/server/getty_session_manager.go @@ -5,12 +5,12 @@ import ( "strings" "sync" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/model" + "github.com/PangXing/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/util/log" getty "github.com/apache/dubbo-getty" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/model" - "github.com/seata/seata-go/pkg/base/protocal" - "github.com/seata/seata-go/pkg/util/log" ) var ( diff --git a/pkg/tc/server/rpc_context.go b/pkg/tc/server/rpc_context.go index 585cac0b3..f7c3515c0 100644 --- a/pkg/tc/server/rpc_context.go +++ b/pkg/tc/server/rpc_context.go @@ -1,9 +1,9 @@ package server import ( + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/base/model" getty "github.com/apache/dubbo-getty" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/base/model" ) const IpPortSplitChar = ":" diff --git a/pkg/tc/server/server.go b/pkg/tc/server/server.go index 5b9430af4..7d785bc94 100644 --- a/pkg/tc/server/server.go +++ b/pkg/tc/server/server.go @@ -13,12 +13,12 @@ import ( gxnet "github.com/dubbogo/gost/net" + "github.com/PangXing/seata-go/pkg/base/extension" + "github.com/PangXing/seata-go/pkg/base/getty/readwriter" + "github.com/PangXing/seata-go/pkg/base/registry" + "github.com/PangXing/seata-go/pkg/tc/config" + "github.com/PangXing/seata-go/pkg/util/log" gxsync "github.com/dubbogo/gost/sync" - "github.com/seata/seata-go/pkg/base/extension" - "github.com/seata/seata-go/pkg/base/getty/readwriter" - "github.com/seata/seata-go/pkg/base/registry" - "github.com/seata/seata-go/pkg/tc/config" - "github.com/seata/seata-go/pkg/util/log" ) type Server struct { diff --git a/pkg/tc/server/server_message_listener.go b/pkg/tc/server/server_message_listener.go index 7f3855781..480d23a78 100644 --- a/pkg/tc/server/server_message_listener.go +++ b/pkg/tc/server/server_message_listener.go @@ -1,8 +1,8 @@ package server import ( + "github.com/PangXing/seata-go/pkg/base/protocal" getty "github.com/apache/dubbo-getty" - "github.com/seata/seata-go/pkg/base/protocal" ) type ServerMessageListener interface { diff --git a/pkg/tc/server/server_message_sender.go b/pkg/tc/server/server_message_sender.go index 5d77147c5..a5a639ac4 100644 --- a/pkg/tc/server/server_message_sender.go +++ b/pkg/tc/server/server_message_sender.go @@ -3,8 +3,8 @@ package server import ( "time" + "github.com/PangXing/seata-go/pkg/base/protocal" getty "github.com/apache/dubbo-getty" - "github.com/seata/seata-go/pkg/base/protocal" ) type ServerMessageSender interface { diff --git a/pkg/tc/server/tc_inbound_handler.go b/pkg/tc/server/tc_inbound_handler.go index 966c16ec8..ec7dd04e1 100644 --- a/pkg/tc/server/tc_inbound_handler.go +++ b/pkg/tc/server/tc_inbound_handler.go @@ -1,7 +1,7 @@ package server import ( - "github.com/seata/seata-go/pkg/base/protocal" + "github.com/PangXing/seata-go/pkg/base/protocal" ) type TCInboundHandler interface { diff --git a/pkg/tc/server/transaction_coordinator.go b/pkg/tc/server/transaction_coordinator.go index fbb119f7a..ad2962559 100644 --- a/pkg/tc/server/transaction_coordinator.go +++ b/pkg/tc/server/transaction_coordinator.go @@ -1,10 +1,10 @@ package server import ( - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/client/rm" - "github.com/seata/seata-go/pkg/client/tm" - "github.com/seata/seata-go/pkg/tc/session" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/client/rm" + "github.com/PangXing/seata-go/pkg/client/tm" + "github.com/PangXing/seata-go/pkg/tc/session" ) type TransactionCoordinatorInbound interface { diff --git a/pkg/tc/session/branch_session.go b/pkg/tc/session/branch_session.go index fa6a03201..697533c7b 100644 --- a/pkg/tc/session/branch_session.go +++ b/pkg/tc/session/branch_session.go @@ -3,11 +3,11 @@ package session import ( "bytes" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/config" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/uuid" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/config" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/uuid" "vimagination.zapto.org/byteio" ) diff --git a/pkg/tc/session/branch_session_test.go b/pkg/tc/session/branch_session_test.go index eb027d750..a402fe2e2 100644 --- a/pkg/tc/session/branch_session_test.go +++ b/pkg/tc/session/branch_session_test.go @@ -3,8 +3,8 @@ package session import ( "testing" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/util/uuid" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/util/uuid" "github.com/stretchr/testify/assert" ) diff --git a/pkg/tc/session/global_session.go b/pkg/tc/session/global_session.go index 9982cdc89..13b533e2a 100644 --- a/pkg/tc/session/global_session.go +++ b/pkg/tc/session/global_session.go @@ -5,13 +5,13 @@ import ( "sort" "sync" + "github.com/PangXing/seata-go/pkg/base/common" + "github.com/PangXing/seata-go/pkg/base/meta" + "github.com/PangXing/seata-go/pkg/tc/config" + "github.com/PangXing/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/time" + "github.com/PangXing/seata-go/pkg/util/uuid" "github.com/pkg/errors" - "github.com/seata/seata-go/pkg/base/common" - "github.com/seata/seata-go/pkg/base/meta" - "github.com/seata/seata-go/pkg/tc/config" - "github.com/seata/seata-go/pkg/util/log" - "github.com/seata/seata-go/pkg/util/time" - "github.com/seata/seata-go/pkg/util/uuid" "vimagination.zapto.org/byteio" ) diff --git a/pkg/util/etcdv3/utils.go b/pkg/util/etcdv3/utils.go index 44304accd..d536a2863 100644 --- a/pkg/util/etcdv3/utils.go +++ b/pkg/util/etcdv3/utils.go @@ -5,8 +5,8 @@ import ( "fmt" "strconv" - "github.com/seata/seata-go/pkg/base/constant" - "github.com/seata/seata-go/pkg/base/registry" + "github.com/PangXing/seata-go/pkg/base/constant" + "github.com/PangXing/seata-go/pkg/base/registry" ) func IsAddressValid(addr registry.Address) bool { diff --git a/pkg/util/parser/parser.go b/pkg/util/parser/parser.go index fa4b0130a..cc21c4511 100644 --- a/pkg/util/parser/parser.go +++ b/pkg/util/parser/parser.go @@ -7,7 +7,7 @@ import ( "sort" "strings" - "github.com/seata/seata-go/pkg/util/log" + "github.com/PangXing/seata-go/pkg/util/log" "gopkg.in/yaml.v2" ) diff --git a/pkg/util/uuid/id_worker.go b/pkg/util/uuid/id_worker.go index 305ff3193..f23658be4 100644 --- a/pkg/util/uuid/id_worker.go +++ b/pkg/util/uuid/id_worker.go @@ -6,7 +6,7 @@ import ( "net" "sync/atomic" - time2 "github.com/seata/seata-go/pkg/util/time" + time2 "github.com/PangXing/seata-go/pkg/util/time" ) const (