-
Notifications
You must be signed in to change notification settings - Fork 20
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Updated RootContext #27
base: master
Are you sure you want to change the base?
Changes from 1 commit
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -68,11 +68,15 @@ public static function bind(string $xid): void | |
{ | ||
if (! $xid) { | ||
static::log('debug', 'xid is blank, switch to unbind operation!'); | ||
self::unbind(); | ||
} | ||
static::log('debug', 'Bind xid: ' . $xid); | ||
static::set(static::KEY_XID, $xid); | ||
} | ||
|
||
/** | ||
* Unbind xid. | ||
*/ | ||
public static function unbind(): ?string | ||
{ | ||
$xid = static::getXID(); | ||
|
@@ -94,21 +98,34 @@ public static function unbindGlobalLockFlag(): void | |
static::set(static::KEY_GLOBAL_LOCK_FLAG, null); | ||
} | ||
|
||
/** | ||
* In global transaction boolean. | ||
*/ | ||
public static function inGlobalTransaction(): bool | ||
{ | ||
return static::getXID() !== null; | ||
} | ||
|
||
/** | ||
* In tcc branch boolean. | ||
*/ | ||
public static function inTccBranch(): bool | ||
{ | ||
return static::getBranchType() === BranchType::TCC; | ||
} | ||
|
||
|
||
/** | ||
* In saga branch boolean. | ||
*/ | ||
public static function inSagaBranch(): bool | ||
{ | ||
return static::getBranchType() === BranchType::SAGA; | ||
} | ||
|
||
/** | ||
* get the branch type | ||
*/ | ||
public static function getBranchType(): ?int | ||
{ | ||
$branchType = null; | ||
|
@@ -118,12 +135,22 @@ public static function getBranchType(): ?int | |
return $branchType; | ||
} | ||
|
||
/** | ||
* bind branch type | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. 注释为句子,首字母应该大写 |
||
*/ | ||
public static function bindBranchType(int $branchType) | ||
{ | ||
if (empty($branchType)) { | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. int 类型约束了这里不会有 null 的吧? There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. 这里其实只是为了防止 0 传进来,所以我加了 |
||
throw new IllegalArgumentException('branchType must be not null'); | ||
} | ||
|
||
static::log('debug', 'Bind branch type %d', $branchType); | ||
static::set(static::KEY_BRANCH_TYPE, $branchType); | ||
} | ||
|
||
/** | ||
* unbind branch type | ||
*/ | ||
public static function unbindBranchType(): null|int | ||
{ | ||
$prevBranchType = static::get(static::KEY_BRANCH_TYPE, null); | ||
|
@@ -132,6 +159,9 @@ public static function unbindBranchType(): null|int | |
return $prevBranchType; | ||
} | ||
|
||
/** | ||
* requires global lock check | ||
*/ | ||
public static function requireGlobalLock(): bool | ||
{ | ||
return static::get(static::KEY_GLOBAL_LOCK_FLAG) !== null; | ||
|
@@ -147,6 +177,14 @@ public static function assertNotInGlobalTransaction(): void | |
} | ||
} | ||
|
||
/** | ||
* entry map | ||
*/ | ||
public static function entries(): array | ||
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. 这个是 array 还是 ContainerInterface ? |
||
{ | ||
return Context::getContainer(); | ||
} | ||
|
||
private static function log($level = 'debug', ...$content) | ||
{ | ||
if (! static::$logger instanceof LoggerInterface && ApplicationContext::hasContainer()) { | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这里 unbind 之后后面的逻辑还需要走吗?