8000 Fix transfer.go · postgrespro/postgres_cluster@b95135b · GitHub
[go: up one dir, main page]
Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit b95135b

Browse files
knizhnikknizhnik
committed
Fix transfer.go
1 parent 1510bd2 commit b95135b

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

‎contrib/pg_xtm/tests/transfers.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,8 @@ func prepare_db() {
6767
exec(conn2, "drop table if exists t")
6868
exec(conn2, "create table t(u int primary key, v int)")
6969

70-
xid = execQuery(conn1, "select dtm_begin_transaction(2))
71-
exec(conn2, "select dtm_join_transaction(xid))
70+
xid = execQuery(conn1, "select dtm_begin_transaction(2)")
71+
exec(conn2, "select dtm_join_transaction(xid)")
7272

7373
// strt transaction
7474
exec(conn1, "begin transaction isolation level " + ISOLATION_LEVEL)
@@ -108,8 +108,8 @@ func transfer(id int, wg *sync.WaitGroup) {
108108
account1 := rand.Intn(N_ACCOUNTS)
109109
account2 := rand.Intn(N_ACCOUNTS)
110110

111-
xid = execQuery(conn1, "select dtm_begin_transaction(2))
112-
exec(conn2, "select dtm_join_transaction(xid))
111+
xid = execQuery(conn1, "select dtm_begin_transaction(2)")
112+
exec(conn2, "select dtm_join_transaction(xid)")
113113

114114
// start transaction
115115
exec(conn1, "begin transaction isolation level " + ISOLATION_LEVEL)
@@ -144,8 +144,8 @@ func inspect(wg *sync.WaitGroup) {
144144
for running {
145145

146146

147-
xid = execQuery(conn1, "select dtm_begin_transaction(2))
148-
exec(conn2, "select dtm_join_transaction(xid))
147+
xid = execQuery(conn1, "select dtm_begin_transaction(2)")
148+
exec(conn2, "select dtm_join_transaction(xid)")
149149

150150
exec(conn1, "begin transaction isolation level " + ISOLATION_LEVEL)
151151
exec(conn2, "begin transaction isolation level " + ISOLATION_LEVEL)

0 commit comments

Comments
 (0)
0