merged
This commit is contained in:
commit
6f23625d4e
@ -27,6 +27,7 @@ then
|
|||||||
fi
|
fi
|
||||||
|
|
||||||
CHANGESET=`bk -R prs -r+ -h -d':P:::I:' ChangeSet`
|
CHANGESET=`bk -R prs -r+ -h -d':P:::I:' ChangeSet`
|
||||||
|
CSETKEY=`bk -R prs -r+ -h -d':KEY:' ChangeSet`
|
||||||
BUG=`bk -R prs -r+ -h -d':C:' ChangeSet | sed -ne 's/^.*[Bb][Uu][Gg] *# *\([0-9][0-9]*\).*$/\1/p'`
|
BUG=`bk -R prs -r+ -h -d':C:' ChangeSet | sed -ne 's/^.*[Bb][Uu][Gg] *# *\([0-9][0-9]*\).*$/\1/p'`
|
||||||
WL=`bk -R prs -r+ -h -d':C:' ChangeSet | sed -ne 's/^.*[Ww][Ll] *# *\([0-9][0-9]*\).*$/ WL#\1/p'`
|
WL=`bk -R prs -r+ -h -d':C:' ChangeSet | sed -ne 's/^.*[Ww][Ll] *# *\([0-9][0-9]*\).*$/ WL#\1/p'`
|
||||||
|
|
||||||
@ -52,6 +53,7 @@ List-ID: <bk.mysql-$VERSION>
|
|||||||
From: $FROM
|
From: $FROM
|
||||||
To: $TO
|
To: $TO
|
||||||
Subject: bk commit - $VERSION tree ($CHANGESET)${BS}${WL}
|
Subject: bk commit - $VERSION tree ($CHANGESET)${BS}${WL}
|
||||||
|
X-CSetKey: <$CSETKEY>
|
||||||
$BH
|
$BH
|
||||||
EOF
|
EOF
|
||||||
bk changes -v -r+
|
bk changes -v -r+
|
||||||
@ -68,6 +70,7 @@ List-ID: <bk.mysql-$VERSION>
|
|||||||
From: $FROM
|
From: $FROM
|
||||||
To: $INTERNALS
|
To: $INTERNALS
|
||||||
Subject: bk commit into $VERSION tree ($CHANGESET)$BS
|
Subject: bk commit into $VERSION tree ($CHANGESET)$BS
|
||||||
|
X-CSetKey: <$CSETKEY>
|
||||||
$BH
|
$BH
|
||||||
Below is the list of changes that have just been committed into a local
|
Below is the list of changes that have just been committed into a local
|
||||||
$VERSION repository of $USER. When $USER does a push these changes will
|
$VERSION repository of $USER. When $USER does a push these changes will
|
||||||
|
@ -505,10 +505,16 @@ void ha_close_connection(THD* thd)
|
|||||||
"beginning of transaction" and "beginning of statement").
|
"beginning of transaction" and "beginning of statement").
|
||||||
Only storage engines registered for the transaction/statement
|
Only storage engines registered for the transaction/statement
|
||||||
will know when to commit/rollback it.
|
will know when to commit/rollback it.
|
||||||
|
|
||||||
|
NOTE
|
||||||
|
trans_register_ha is idempotent - storage engine may register many
|
||||||
|
times per transaction.
|
||||||
|
|
||||||
*/
|
*/
|
||||||
void trans_register_ha(THD *thd, bool all, handlerton *ht_arg)
|
void trans_register_ha(THD *thd, bool all, handlerton *ht_arg)
|
||||||
{
|
{
|
||||||
THD_TRANS *trans;
|
THD_TRANS *trans;
|
||||||
|
handlerton **ht;
|
||||||
DBUG_ENTER("trans_register_ha");
|
DBUG_ENTER("trans_register_ha");
|
||||||
DBUG_PRINT("enter",("%s", all ? "all" : "stmt"));
|
DBUG_PRINT("enter",("%s", all ? "all" : "stmt"));
|
||||||
|
|
||||||
@ -520,15 +526,12 @@ void trans_register_ha(THD *thd, bool all, handlerton *ht_arg)
|
|||||||
else
|
else
|
||||||
trans= &thd->transaction.stmt;
|
trans= &thd->transaction.stmt;
|
||||||
|
|
||||||
handlerton **ht=trans->ht;
|
for (ht=trans->ht; *ht; ht++)
|
||||||
while (*ht)
|
|
||||||
{
|
|
||||||
if (*ht == ht_arg)
|
if (*ht == ht_arg)
|
||||||
DBUG_VOID_RETURN; /* already registered, return */
|
DBUG_VOID_RETURN; /* already registered, return */
|
||||||
ht++;
|
|
||||||
}
|
|
||||||
|
|
||||||
trans->ht[trans->nht++]=ht_arg;
|
trans->ht[trans->nht++]=ht_arg;
|
||||||
|
DBUG_ASSERT(*ht == ht_arg);
|
||||||
trans->no_2pc|=(ht_arg->prepare==0);
|
trans->no_2pc|=(ht_arg->prepare==0);
|
||||||
if (thd->transaction.xid.is_null())
|
if (thd->transaction.xid.is_null())
|
||||||
thd->transaction.xid.set(thd->query_id);
|
thd->transaction.xid.set(thd->query_id);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user