Movatterモバイル変換

[0]ホーム
URL:

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

 Sign up
Appearance settings

Commit970a1b1

Browse files
committed
deploy stuff
1 parent14b54c2 commit970a1b1

File tree

10 files changed

+90
-69
lines changed

10 files changed

+90
-69
lines changed

‎contrib/pg_dtm/tests/deploy_layouts/cluster.yml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
---
2-
-hosts:master-workers
2+
-hosts:dtm
33
roles:
44
-role:postgrespro
55
deploy_dtm:true
@@ -10,5 +10,5 @@
1010
pg_port:15432
1111
deploy_postgres:true
1212
pg_dtm_enable:true
13-
pg_dtm_host:"{{groups['master-workers'][0]}}"
13+
pg_dtm_host:"{{groups['dtm'][0]}}"
1414

‎contrib/pg_dtm/tests/deploy_layouts/cluster_nodtm.yml‎

Lines changed: 0 additions & 13 deletions
This file was deleted.
Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
---
2+
-hosts:master-workers
3+
roles:
4+
-role:postgrespro
5+
deploy_dtm:true
6+
7+
-hosts:master-workers:workers
8+
roles:
9+
-role:postgrespro
10+
pg_port:15432
11+
deploy_postgres:true
12+
deploy_pg_shard:true
13+
pg_dtm_enable:true
14+
pg_dtm_host:"{{ groups['master-workers'][0] }}"
15+

‎contrib/pg_dtm/tests/deploy_layouts/cluster_pg_shard_nodtm.yml‎

Lines changed: 0 additions & 40 deletions
This file was deleted.
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
[master-workers]
2+
localhost

‎contrib/pg_dtm/tests/farms/mephi‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,15 @@
1-
[client]
1+
[clients]
22
br.theor.mephi.ru
3+
blade3 ansible_ssh_host=85.143.113.31 ansible_ssh_port=4203
34

45
[workers]
5-
blade3 ansible_ssh_host=85.143.113.31 ansible_ssh_port=4203
66
blade4 ansible_ssh_host=85.143.113.31 ansible_ssh_port=4204
77
blade5 ansible_ssh_host=85.143.113.31 ansible_ssh_port=4205
88
blade6 ansible_ssh_host=85.143.113.31 ansible_ssh_port=4206
99
blade7 ansible_ssh_host=85.143.113.31 ansible_ssh_port=4207
1010
blade8 ansible_ssh_host=85.143.113.31 ansible_ssh_port=4208
1111

12-
[master-workers]
12+
[dtm]
1313
blade8 ansible_ssh_host=85.143.113.31 ansible_ssh_port=4208
1414

1515

‎contrib/pg_dtm/tests/farms/sai‎

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,12 @@
1+
[clients]
2+
158.250.29.4 ansible_ssh_user=s.kelvich
3+
158.250.29.5 ansible_ssh_user=s.kelvich
4+
15
[workers]
2-
astro4 ansible_ssh_host=158.250.29.4 ansible_ssh_user=s.kelvich
3-
astro5 ansible_ssh_host=158.250.29.5 ansible_ssh_user=s.kelvich
4-
astro6 ansible_ssh_host=158.250.29.6 ansible_ssh_user=s.kelvich
5-
astro8 ansible_ssh_host=158.250.29.8 ansible_ssh_user=s.kelvich
6-
astro9 ansible_ssh_host=158.250.29.9 ansible_ssh_user=s.kelvich
6+
158.250.29.6 ansible_ssh_user=s.kelvich
7+
158.250.29.8 ansible_ssh_user=s.kelvich
8+
158.250.29.9 ansible_ssh_user=s.kelvich
9+
158.250.29.10 ansible_ssh_user=s.kelvich
710

8-
[master-workers]
9-
astro10 ansible_ssh_host=158.250.29.10 ansible_ssh_user=s.kelvich
11+
[dtm]
12+
158.250.29.10 ansible_ssh_user=s.kelvich

‎contrib/pg_dtm/tests/transfers-remote.sh‎

Lines changed: 21 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,15 @@
11
#!/bin/sh
22

3+
FARM="sai"
4+
WORKERS=3
5+
TRANS_SRV="s.kelvich@158.250.29.10"
6+
7+
38
if [!-f ./transfers.linux ];then
4-
GOOS=linux GOARCH=amd64 go build -o ./transfers ./transfers.go
9+
GOOS=linux GOARCH=amd64 go build -o ./transfers.linux ./transfers.go
510
fi
611

7-
ansible master-workers -i farms/mephi -m copy -a"src=transfers dest=~/transfers mode=a+x"
12+
ansible master-workers -i farms/$FARM -m copy -a"src=transfers.linux dest=~/transfers mode=a+x"
813

914

1015

@@ -18,3 +23,17 @@ ssh -p4207 br.theor.mephi.ru "./transfers -d 'host=blade8 dbname=postgres user=s
1823

1924

2025

26+
ssh s.kelvich@158.250.29.10"./transfers -d 'host=158.250.29.9 port=15432 dbname=postgres' -d 'host=158.250.29.8 port=15432 dbname=postgres' -d 'host=158.250.29.4 port=15432 dbname=postgres' -d 'host=158.250.29.5 port=15432 dbname=postgres' -d 'host=158.250.29.6 port=15432 dbname=postgres' -g -w 64"
27+
28+
29+
ssh s.kelvich@158.250.29.10"./transfers -d 'host=158.250.29.9 user=s.kelvich port=15432 dbname=postgres' -g -w 128"
30+
31+
ssh s.kelvich@158.250.29.10"./transfers -d 'host=158.250.29.9 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.8 user=s.kelvich port=15432 dbname=postgres' -g -w 128"
32+
33+
ssh s.kelvich@158.250.29.10"./transfers -d 'host=158.250.29.9 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.8 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.6 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.5 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.4 user=s.kelvich port=15432 dbname=postgres' -g -w 128"
34+
35+
36+
37+
38+
./transfers -d'host=127.0.0.1 port=5432 dbname=postgres' -d'host=127.0.0.1 port=5433 dbname=postgres' -g -w 128
39+

‎contrib/pg_dtm/tests/transfers.go‎

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,9 @@ var cfg struct {
3232

3333
Verbosebool
3434
UseDtmbool
35+
InitOnlybool
36+
SkipInitbool
37+
3538
Isolationstring// "repeatable read" or "read committed"
3639

3740
Accountsstruct {
@@ -108,6 +111,8 @@ func init() {
108111
flag.BoolVar(&cfg.Writers.AllowLocal,"l",false,"Allow local updates")
109112
flag.BoolVar(&cfg.Writers.PrivateRows,"p",false,"Private rows (avoid waits/aborts caused by concurrent updates of the same rows)")
110113
flag.BoolVar(&cfg.Writers.UseCursors,"c",false,"Use cursors for updates")
114+
flag.BoolVar(&cfg.InitOnly,"f",false,"Only feed databses with data")
115+
flag.BoolVar(&cfg.SkipInit,"s",false,"Skip init phase")
111116
flag.Parse()
112117

113118
iflen(cfg.ConnStrs)==0 {
@@ -141,8 +146,15 @@ func init() {
141146

142147
funcmain() {
143148
start:=time.Now()
144-
prepare(cfg.ConnStrs)
145-
fmt.Printf("database prepared in %0.2f seconds\n",time.Since(start).Seconds())
149+
150+
if (!cfg.SkipInit){
151+
prepare(cfg.ConnStrs)
152+
fmt.Printf("database prepared in %0.2f seconds\n",time.Since(start).Seconds())
153+
}
154+
155+
if (cfg.InitOnly) {
156+
return
157+
}
146158

147159
varwriterWg sync.WaitGroup
148160
varreaderWg sync.WaitGroup

‎contrib/pg_dtm/tests/transfers.yml‎

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
---
2+
3+
-hosts:masters
4+
gather_facts:no
5+
tasks:
6+
-name:copy transfers binary
7+
copy:src=transfers.linux dest=~/transfers mode=a+x
8+
9+
-hosts:158.250.29.4
10+
gather_facts:no
11+
tasks:
12+
-name:setup the databases
13+
shell:"./transfers -d 'host=158.250.29.10 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.9 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.8 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.5 user=s.kelvich port=15432 dbname=postgres' -f -g -w 200 -r 0"
14+
register:transfers_result
15+
-debug:var=transfers_result
16+
17+
-hosts:masters
18+
gather_facts:no
19+
tasks:
20+
-name:run transfers
21+
shell:"./transfers -d 'host=158.250.29.10 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.9 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.8 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.5 user=s.kelvich port=15432 dbname=postgres' -s -g -w 200 -r 0"
22+
register:transfers_result
23+
-debug:var=transfers_result

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp