Skip to content

Commit

Permalink
Merge pull request #12 from piaodazhu/dev
Browse files Browse the repository at this point in the history
clean code
  • Loading branch information
piaodazhu authored May 9, 2023
2 parents e3f2fbd + 8c6efe4 commit 1eb7f71
Show file tree
Hide file tree
Showing 3 changed files with 189 additions and 233 deletions.
304 changes: 147 additions & 157 deletions coverage.out
Original file line number Diff line number Diff line change
Expand Up @@ -11,161 +11,151 @@ github.com/piaodazhu/gotcc/message.go:83.31,87.2 3 1
github.com/piaodazhu/gotcc/message.go:89.39,92.26 3 1
github.com/piaodazhu/gotcc/message.go:98.2,99.20 2 1
github.com/piaodazhu/gotcc/message.go:92.26,97.3 4 1
github.com/piaodazhu/gotcc/pool.go:15.44,18.2 2 1
github.com/piaodazhu/gotcc/pool.go:24.43,25.15 1 1
github.com/piaodazhu/gotcc/pool.go:25.15,28.3 2 1
github.com/piaodazhu/gotcc/pool.go:28.8,31.3 2 1
github.com/piaodazhu/gotcc/pool.go:34.44,36.2 1 1
github.com/piaodazhu/gotcc/pool.go:38.30,40.2 1 1
github.com/piaodazhu/gotcc/pool.go:42.84,43.40 1 1
github.com/piaodazhu/gotcc/pool.go:46.2,47.13 2 1
github.com/piaodazhu/gotcc/pool.go:50.2,51.14 2 1
github.com/piaodazhu/gotcc/pool.go:55.2,59.34 3 1
github.com/piaodazhu/gotcc/pool.go:112.2,117.28 4 1
github.com/piaodazhu/gotcc/pool.go:128.2,128.14 1 1
github.com/piaodazhu/gotcc/pool.go:43.40,45.3 1 1
github.com/piaodazhu/gotcc/pool.go:47.13,49.3 1 1
github.com/piaodazhu/gotcc/pool.go:51.14,53.3 1 1
github.com/piaodazhu/gotcc/pool.go:59.34,62.25 3 1
github.com/piaodazhu/gotcc/pool.go:101.3,101.17 1 1
github.com/piaodazhu/gotcc/pool.go:104.3,104.10 1 1
github.com/piaodazhu/gotcc/pool.go:62.25,66.30 3 1
github.com/piaodazhu/gotcc/pool.go:77.4,79.18 3 1
github.com/piaodazhu/gotcc/pool.go:97.4,97.45 1 1
github.com/piaodazhu/gotcc/pool.go:66.30,68.12 1 1
github.com/piaodazhu/gotcc/pool.go:69.31,70.12 1 1
github.com/piaodazhu/gotcc/pool.go:71.35,73.38 2 1
github.com/piaodazhu/gotcc/pool.go:79.18,80.30 1 1
github.com/piaodazhu/gotcc/pool.go:89.5,89.11 1 1
github.com/piaodazhu/gotcc/pool.go:83.23,84.60 1 1
github.com/piaodazhu/gotcc/pool.go:85.13,87.20 2 1
github.com/piaodazhu/gotcc/pool.go:90.10,95.5 2 1
github.com/piaodazhu/gotcc/pool.go:97.45,99.5 1 1
github.com/piaodazhu/gotcc/pool.go:101.17,103.4 1 1
github.com/piaodazhu/gotcc/pool.go:105.29,106.19 1 1
github.com/piaodazhu/gotcc/pool.go:107.11,107.11 0 1
github.com/piaodazhu/gotcc/pool.go:117.28,118.10 1 1
github.com/piaodazhu/gotcc/pool.go:119.29,122.18 2 1
github.com/piaodazhu/gotcc/pool.go:123.33,125.39 2 1
github.com/piaodazhu/gotcc/pool.go:128.14,133.3 3 1
github.com/piaodazhu/gotcc/pool.go:133.8,145.3 4 1
github.com/piaodazhu/gotcc/rollback.go:19.55,21.2 1 1
github.com/piaodazhu/gotcc/rollback.go:23.132,30.2 1 1
github.com/piaodazhu/gotcc/rollback.go:32.40,36.2 3 1
github.com/piaodazhu/gotcc/rollback.go:38.29,42.2 3 1
github.com/piaodazhu/gotcc/rollback.go:44.86,46.41 2 1
github.com/piaodazhu/gotcc/rollback.go:59.2,59.19 1 1
github.com/piaodazhu/gotcc/rollback.go:46.41,52.17 5 1
github.com/piaodazhu/gotcc/rollback.go:52.17,54.29 2 1
github.com/piaodazhu/gotcc/rollback.go:54.29,56.5 1 1
github.com/piaodazhu/gotcc/tcc.go:24.38,34.2 2 1
github.com/piaodazhu/gotcc/tcc.go:36.131,40.2 3 1
github.com/piaodazhu/gotcc/tcc.go:42.66,44.2 1 1
github.com/piaodazhu/gotcc/tcc.go:46.63,48.2 1 1
github.com/piaodazhu/gotcc/tcc.go:50.77,51.58 1 1
github.com/piaodazhu/gotcc/tcc.go:56.2,56.58 1 1
github.com/piaodazhu/gotcc/tcc.go:51.58,55.3 3 1
github.com/piaodazhu/gotcc/tcc.go:59.67,60.40 1 1
github.com/piaodazhu/gotcc/tcc.go:63.2,63.49 1 1
github.com/piaodazhu/gotcc/tcc.go:67.2,71.34 4 1
github.com/piaodazhu/gotcc/tcc.go:115.2,120.28 4 1
github.com/piaodazhu/gotcc/tcc.go:131.2,131.14 1 1
github.com/piaodazhu/gotcc/tcc.go:60.40,62.3 1 1
github.com/piaodazhu/gotcc/tcc.go:63.49,65.3 1 1
github.com/piaodazhu/gotcc/tcc.go:71.34,73.13 2 1
github.com/piaodazhu/gotcc/tcc.go:73.13,77.30 3 1
github.com/piaodazhu/gotcc/tcc.go:88.4,90.18 3 1
github.com/piaodazhu/gotcc/tcc.go:108.4,108.45 1 1
github.com/piaodazhu/gotcc/tcc.go:77.30,79.12 1 1
github.com/piaodazhu/gotcc/tcc.go:80.31,81.12 1 1
github.com/piaodazhu/gotcc/tcc.go:82.35,84.38 2 1
github.com/piaodazhu/gotcc/tcc.go:90.18,91.30 1 1
github.com/piaodazhu/gotcc/tcc.go:100.5,100.11 1 1
github.com/piaodazhu/gotcc/tcc.go:92.24,93.54 1 1
github.com/piaodazhu/gotcc/tcc.go:94.23,95.60 1 1
github.com/piaodazhu/gotcc/tcc.go:96.13,98.20 2 1
github.com/piaodazhu/gotcc/tcc.go:101.10,106.5 2 1
github.com/piaodazhu/gotcc/tcc.go:108.45,110.5 1 1
github.com/piaodazhu/gotcc/tcc.go:120.28,121.10 1 1
github.com/piaodazhu/gotcc/tcc.go:122.29,125.18 2 1
github.com/piaodazhu/gotcc/tcc.go:126.33,128.39 2 1
github.com/piaodazhu/gotcc/tcc.go:131.14,136.3 3 1
github.com/piaodazhu/gotcc/tcc.go:136.8,148.3 4 1
github.com/piaodazhu/gotcc/tcc.go:151.32,156.32 5 1
github.com/piaodazhu/gotcc/tcc.go:162.2,162.45 1 1
github.com/piaodazhu/gotcc/tcc.go:156.32,158.33 2 1
github.com/piaodazhu/gotcc/tcc.go:158.33,160.4 1 1
github.com/piaodazhu/gotcc/tcc.go:162.45,164.3 1 1
github.com/piaodazhu/gotcc/tcc.go:167.40,175.30 8 1
github.com/piaodazhu/gotcc/tcc.go:178.2,178.38 1 1
github.com/piaodazhu/gotcc/tcc.go:179.2,179.25 1 1
github.com/piaodazhu/gotcc/tcc.go:195.2,197.47 3 1
github.com/piaodazhu/gotcc/tcc.go:200.2,200.33 1 1
github.com/piaodazhu/gotcc/tcc.go:204.2,206.20 2 1
github.com/piaodazhu/gotcc/tcc.go:175.30,177.3 1 1
github.com/piaodazhu/gotcc/tcc.go:178.38,178.64 1 1
github.com/piaodazhu/gotcc/tcc.go:179.25,185.35 5 1
github.com/piaodazhu/gotcc/tcc.go:188.3,188.42 1 1
github.com/piaodazhu/gotcc/tcc.go:189.3,189.32 1 1
github.com/piaodazhu/gotcc/tcc.go:193.3,193.24 1 1
github.com/piaodazhu/gotcc/tcc.go:185.35,187.4 1 1
github.com/piaodazhu/gotcc/tcc.go:188.42,188.74 1 1
github.com/piaodazhu/gotcc/tcc.go:189.32,192.4 2 1
github.com/piaodazhu/gotcc/tcc.go:197.47,199.3 1 1
github.com/piaodazhu/gotcc/tcc.go:200.33,203.3 2 1
github.com/piaodazhu/gotcc/dependency.go:12.81,14.18 1 1
github.com/piaodazhu/gotcc/dependency.go:14.18,16.4 1 1
github.com/piaodazhu/gotcc/dependency.go:22.17,24.3 1 1
github.com/piaodazhu/gotcc/dependency.go:29.17,31.3 1 1
github.com/piaodazhu/gotcc/dependency.go:35.66,37.18 1 1
github.com/piaodazhu/gotcc/dependency.go:37.18,39.4 1 1
github.com/piaodazhu/gotcc/dependency.go:44.95,46.18 1 1
github.com/piaodazhu/gotcc/dependency.go:46.18,48.4 1 1
github.com/piaodazhu/gotcc/dependency.go:53.94,55.18 1 1
github.com/piaodazhu/gotcc/dependency.go:55.18,57.4 1 1
github.com/piaodazhu/gotcc/dependency.go:62.95,64.18 1 1
github.com/piaodazhu/gotcc/dependency.go:64.18,66.4 1 1
github.com/piaodazhu/gotcc/dependency.go:104.67,113.31 5 1
github.com/piaodazhu/gotcc/dependency.go:140.2,140.34 1 1
github.com/piaodazhu/gotcc/dependency.go:146.2,146.20 1 1
github.com/piaodazhu/gotcc/dependency.go:113.31,114.45 1 1
github.com/piaodazhu/gotcc/dependency.go:120.3,122.54 3 1
github.com/piaodazhu/gotcc/dependency.go:135.3,137.14 3 1
github.com/piaodazhu/gotcc/dependency.go:114.45,118.4 3 1
github.com/piaodazhu/gotcc/dependency.go:122.54,123.27 1 1
github.com/piaodazhu/gotcc/dependency.go:124.15,125.23 1 1
github.com/piaodazhu/gotcc/dependency.go:128.5,128.46 1 1
github.com/piaodazhu/gotcc/dependency.go:129.14,130.17 1 1
github.com/piaodazhu/gotcc/dependency.go:131.15,132.46 1 1
github.com/piaodazhu/gotcc/dependency.go:125.23,127.6 1 1
github.com/piaodazhu/gotcc/dependency.go:140.34,141.19 1 1
github.com/piaodazhu/gotcc/dependency.go:141.19,143.4 1 1
github.com/piaodazhu/gotcc/dependency.go:149.24,150.11 1 1
github.com/piaodazhu/gotcc/dependency.go:153.2,153.10 1 1
github.com/piaodazhu/gotcc/dependency.go:150.11,152.3 1 1
github.com/piaodazhu/gotcc/dependency.go:156.80,164.39 4 1
github.com/piaodazhu/gotcc/dependency.go:175.2,175.43 1 1
github.com/piaodazhu/gotcc/dependency.go:181.2,181.26 1 1
github.com/piaodazhu/gotcc/dependency.go:184.2,184.18 1 1
github.com/piaodazhu/gotcc/dependency.go:164.39,166.31 2 1
github.com/piaodazhu/gotcc/dependency.go:169.3,173.5 1 1
github.com/piaodazhu/gotcc/dependency.go:166.31,168.4 1 1
github.com/piaodazhu/gotcc/dependency.go:175.43,176.45 1 1
github.com/piaodazhu/gotcc/dependency.go:179.3,179.47 1 1
github.com/piaodazhu/gotcc/dependency.go:176.45,178.4 1 1
github.com/piaodazhu/gotcc/dependency.go:181.26,183.3 1 1
github.com/piaodazhu/gotcc/error.go:11.38,13.2 1 1
github.com/piaodazhu/gotcc/error.go:17.39,19.2 1 1
github.com/piaodazhu/gotcc/error.go:25.40,27.2 1 1
github.com/piaodazhu/gotcc/error.go:33.43,35.2 1 1
github.com/piaodazhu/gotcc/error.go:43.36,52.2 8 1
github.com/piaodazhu/gotcc/error.go:56.40,58.2 1 1
github.com/piaodazhu/gotcc/pool.go:17.84,18.40 1 1
github.com/piaodazhu/gotcc/pool.go:21.2,22.13 2 1
github.com/piaodazhu/gotcc/pool.go:25.2,26.14 2 1
github.com/piaodazhu/gotcc/pool.go:30.2,34.34 3 1
github.com/piaodazhu/gotcc/pool.go:51.2,56.28 4 1
github.com/piaodazhu/gotcc/pool.go:67.2,67.14 1 1
github.com/piaodazhu/gotcc/pool.go:18.40,20.3 1 1
github.com/piaodazhu/gotcc/pool.go:22.13,24.3 1 1
github.com/piaodazhu/gotcc/pool.go:26.14,28.3 1 1
github.com/piaodazhu/gotcc/pool.go:34.34,37.25 3 1
github.com/piaodazhu/gotcc/pool.go:40.3,40.17 1 1
github.com/piaodazhu/gotcc/pool.go:43.3,43.10 1 1
github.com/piaodazhu/gotcc/pool.go:37.25,39.4 1 1
github.com/piaodazhu/gotcc/pool.go:40.17,42.4 1 1
github.com/piaodazhu/gotcc/pool.go:44.29,45.19 1 1
github.com/piaodazhu/gotcc/pool.go:46.11,46.11 0 1
github.com/piaodazhu/gotcc/pool.go:56.28,57.10 1 1
github.com/piaodazhu/gotcc/pool.go:58.29,61.18 2 1
github.com/piaodazhu/gotcc/pool.go:62.33,64.39 2 1
github.com/piaodazhu/gotcc/pool.go:67.14,72.3 3 1
github.com/piaodazhu/gotcc/pool.go:72.8,84.3 4 1
github.com/piaodazhu/gotcc/pool.go:90.44,93.2 2 1
github.com/piaodazhu/gotcc/pool.go:101.43,102.15 1 1
github.com/piaodazhu/gotcc/pool.go:102.15,105.3 2 1
github.com/piaodazhu/gotcc/pool.go:105.8,108.3 2 1
github.com/piaodazhu/gotcc/pool.go:111.44,113.2 1 1
github.com/piaodazhu/gotcc/pool.go:115.30,117.2 1 1
github.com/piaodazhu/gotcc/rollback.go:19.132,26.2 1 1
github.com/piaodazhu/gotcc/rollback.go:28.40,32.2 3 1
github.com/piaodazhu/gotcc/rollback.go:34.29,38.2 3 1
github.com/piaodazhu/gotcc/rollback.go:40.86,42.41 2 1
github.com/piaodazhu/gotcc/rollback.go:55.2,55.19 1 1
github.com/piaodazhu/gotcc/rollback.go:42.41,48.17 5 1
github.com/piaodazhu/gotcc/rollback.go:48.17,50.29 2 1
github.com/piaodazhu/gotcc/rollback.go:50.29,52.5 1 1
github.com/piaodazhu/gotcc/rollback.go:59.61,61.2 1 1
github.com/piaodazhu/gotcc/tcc.go:26.38,37.2 2 1
github.com/piaodazhu/gotcc/tcc.go:42.131,46.2 3 1
github.com/piaodazhu/gotcc/tcc.go:49.66,51.2 1 1
github.com/piaodazhu/gotcc/tcc.go:54.63,56.2 1 1
github.com/piaodazhu/gotcc/tcc.go:60.77,61.58 1 1
github.com/piaodazhu/gotcc/tcc.go:66.2,66.58 1 1
github.com/piaodazhu/gotcc/tcc.go:61.58,65.3 3 1
github.com/piaodazhu/gotcc/tcc.go:72.67,73.40 1 1
github.com/piaodazhu/gotcc/tcc.go:76.2,76.49 1 1
github.com/piaodazhu/gotcc/tcc.go:80.2,84.34 4 1
github.com/piaodazhu/gotcc/tcc.go:90.2,95.28 4 1
github.com/piaodazhu/gotcc/tcc.go:106.2,106.14 1 1
github.com/piaodazhu/gotcc/tcc.go:73.40,75.3 1 1
github.com/piaodazhu/gotcc/tcc.go:76.49,78.3 1 1
github.com/piaodazhu/gotcc/tcc.go:84.34,87.3 2 1
github.com/piaodazhu/gotcc/tcc.go:95.28,96.10 1 1
github.com/piaodazhu/gotcc/tcc.go:97.29,100.18 2 1
github.com/piaodazhu/gotcc/tcc.go:101.33,103.39 2 1
github.com/piaodazhu/gotcc/tcc.go:106.14,111.3 3 1
github.com/piaodazhu/gotcc/tcc.go:111.8,123.3 4 1
github.com/piaodazhu/gotcc/tcc.go:126.64,130.28 3 1
github.com/piaodazhu/gotcc/tcc.go:141.2,143.16 3 1
github.com/piaodazhu/gotcc/tcc.go:161.2,161.43 1 1
github.com/piaodazhu/gotcc/tcc.go:130.28,132.10 1 1
github.com/piaodazhu/gotcc/tcc.go:133.29,134.10 1 1
github.com/piaodazhu/gotcc/tcc.go:135.33,137.36 2 1
github.com/piaodazhu/gotcc/tcc.go:143.16,144.28 1 1
github.com/piaodazhu/gotcc/tcc.go:153.3,153.9 1 1
github.com/piaodazhu/gotcc/tcc.go:145.22,146.52 1 1
github.com/piaodazhu/gotcc/tcc.go:147.21,148.58 1 1
github.com/piaodazhu/gotcc/tcc.go:149.11,151.18 2 1
github.com/piaodazhu/gotcc/tcc.go:154.8,159.3 2 1
github.com/piaodazhu/gotcc/tcc.go:161.43,163.3 1 1
github.com/piaodazhu/gotcc/tcc.go:166.32,171.32 5 1
github.com/piaodazhu/gotcc/tcc.go:177.2,177.45 1 1
github.com/piaodazhu/gotcc/tcc.go:171.32,173.33 2 1
github.com/piaodazhu/gotcc/tcc.go:173.33,175.4 1 1
github.com/piaodazhu/gotcc/tcc.go:177.45,179.3 1 1
github.com/piaodazhu/gotcc/tcc.go:183.40,191.30 8 1
github.com/piaodazhu/gotcc/tcc.go:194.2,194.38 1 1
github.com/piaodazhu/gotcc/tcc.go:195.2,195.25 1 1
github.com/piaodazhu/gotcc/tcc.go:211.2,213.47 3 1
github.com/piaodazhu/gotcc/tcc.go:216.2,216.33 1 1
github.com/piaodazhu/gotcc/tcc.go:220.2,222.20 2 1
github.com/piaodazhu/gotcc/tcc.go:191.30,193.3 1 1
github.com/piaodazhu/gotcc/tcc.go:194.38,194.64 1 1
github.com/piaodazhu/gotcc/tcc.go:195.25,201.35 5 1
github.com/piaodazhu/gotcc/tcc.go:204.3,204.42 1 1
github.com/piaodazhu/gotcc/tcc.go:205.3,205.32 1 1
github.com/piaodazhu/gotcc/tcc.go:209.3,209.24 1 1
github.com/piaodazhu/gotcc/tcc.go:201.35,203.4 1 1
github.com/piaodazhu/gotcc/tcc.go:204.42,204.74 1 1
github.com/piaodazhu/gotcc/tcc.go:205.32,208.4 2 1
github.com/piaodazhu/gotcc/tcc.go:213.47,215.3 1 1
github.com/piaodazhu/gotcc/tcc.go:216.33,219.3 2 1
github.com/piaodazhu/gotcc/dependency.go:14.66,16.18 1 1
github.com/piaodazhu/gotcc/dependency.go:16.18,18.4 1 1
github.com/piaodazhu/gotcc/dependency.go:23.95,25.18 1 1
github.com/piaodazhu/gotcc/dependency.go:25.18,27.4 1 1
github.com/piaodazhu/gotcc/dependency.go:32.94,34.18 1 1
github.com/piaodazhu/gotcc/dependency.go:34.18,36.4 1 1
github.com/piaodazhu/gotcc/dependency.go:41.95,43.18 1 1
github.com/piaodazhu/gotcc/dependency.go:43.18,45.4 1 1
github.com/piaodazhu/gotcc/dependency.go:50.81,52.18 1 1
github.com/piaodazhu/gotcc/dependency.go:52.18,54.4 1 1
github.com/piaodazhu/gotcc/dependency.go:59.67,68.31 5 1
github.com/piaodazhu/gotcc/dependency.go:95.2,95.34 1 1
github.com/piaodazhu/gotcc/dependency.go:101.2,101.20 1 1
github.com/piaodazhu/gotcc/dependency.go:68.31,69.45 1 1
github.com/piaodazhu/gotcc/dependency.go:75.3,77.54 3 1
github.com/piaodazhu/gotcc/dependency.go:90.3,92.14 3 1
github.com/piaodazhu/gotcc/dependency.go:69.45,73.4 3 1
github.com/piaodazhu/gotcc/dependency.go:77.54,78.27 1 1
github.com/piaodazhu/gotcc/dependency.go:79.15,80.23 1 1
github.com/piaodazhu/gotcc/dependency.go:83.5,83.46 1 1
github.com/piaodazhu/gotcc/dependency.go:84.14,85.17 1 1
github.com/piaodazhu/gotcc/dependency.go:86.15,87.46 1 1
github.com/piaodazhu/gotcc/dependency.go:80.23,82.6 1 1
github.com/piaodazhu/gotcc/dependency.go:95.34,96.19 1 1
github.com/piaodazhu/gotcc/dependency.go:96.19,98.4 1 1
github.com/piaodazhu/gotcc/dependency.go:104.24,105.11 1 1
github.com/piaodazhu/gotcc/dependency.go:108.2,108.10 1 1
github.com/piaodazhu/gotcc/dependency.go:105.11,107.3 1 1
github.com/piaodazhu/gotcc/dependency.go:111.80,119.39 4 1
github.com/piaodazhu/gotcc/dependency.go:130.2,130.43 1 1
github.com/piaodazhu/gotcc/dependency.go:136.2,136.26 1 1
github.com/piaodazhu/gotcc/dependency.go:139.2,139.18 1 1
github.com/piaodazhu/gotcc/dependency.go:119.39,121.31 2 1
github.com/piaodazhu/gotcc/dependency.go:124.3,128.5 1 1
github.com/piaodazhu/gotcc/dependency.go:121.31,123.4 1 1
github.com/piaodazhu/gotcc/dependency.go:130.43,131.45 1 1
github.com/piaodazhu/gotcc/dependency.go:134.3,134.47 1 1
github.com/piaodazhu/gotcc/dependency.go:131.45,133.4 1 1
github.com/piaodazhu/gotcc/dependency.go:136.26,138.3 1 1
github.com/piaodazhu/gotcc/dependency.go:144.17,146.3 1 1
github.com/piaodazhu/gotcc/dependency.go:152.17,154.3 1 1
github.com/piaodazhu/gotcc/error.go:15.38,17.2 1 1
github.com/piaodazhu/gotcc/error.go:23.39,25.2 1 1
github.com/piaodazhu/gotcc/error.go:32.40,34.2 1 1
github.com/piaodazhu/gotcc/error.go:41.43,43.2 1 1
github.com/piaodazhu/gotcc/error.go:48.40,50.2 1 1
github.com/piaodazhu/gotcc/error.go:61.36,70.2 8 1
github.com/piaodazhu/gotcc/executor.go:23.117,38.2 1 1
github.com/piaodazhu/gotcc/executor.go:40.72,41.46 1 1
github.com/piaodazhu/gotcc/executor.go:46.2,46.46 1 1
github.com/piaodazhu/gotcc/executor.go:41.46,45.3 3 1
github.com/piaodazhu/gotcc/executor.go:49.58,51.2 1 1
github.com/piaodazhu/gotcc/executor.go:53.71,56.2 2 1
github.com/piaodazhu/gotcc/executor.go:58.42,60.2 1 1
github.com/piaodazhu/gotcc/executor.go:62.61,64.2 1 1
github.com/piaodazhu/gotcc/executor.go:66.104,70.2 3 1
github.com/piaodazhu/gotcc/executor.go:42.72,43.46 1 1
github.com/piaodazhu/gotcc/executor.go:48.2,48.46 1 1
github.com/piaodazhu/gotcc/executor.go:43.46,47.3 3 1
github.com/piaodazhu/gotcc/executor.go:52.58,54.2 1 1
github.com/piaodazhu/gotcc/executor.go:57.71,60.2 2 1
github.com/piaodazhu/gotcc/executor.go:62.42,64.2 1 1
github.com/piaodazhu/gotcc/executor.go:66.61,68.2 1 1
github.com/piaodazhu/gotcc/executor.go:71.104,75.2 3 1
github.com/piaodazhu/gotcc/executor.go:78.34,80.2 1 1
38 changes: 1 addition & 37 deletions pool.go
Original file line number Diff line number Diff line change
Expand Up @@ -35,43 +35,7 @@ lauchLoop:
e := m.executors[taskid]
wg.Add(1)
err := pool.Go(func() {
defer wg.Done()
args := map[string]interface{}{"BIND": e.bindArgs, "CANCEL": m.cancelCtx, "NAME": e.name}

for !e.dependencyExpr.f() {
// wait until dep ok
select {
case <-m.cancelCtx.Done():
return
case msg := <-e.messageBuffer:
e.markDependency(msg.senderId, true)
args[msg.senderName] = msg.value
}
}

outMsg := message{senderId: e.id, senderName: e.name}
result, err := e.task(args)
if err != nil {
switch err := err.(type) {
// case ErrSilentFail:
// m.errorMsgs.Append(newErrorMessage(e.Name, err))
case ErrCancelled:
m.cancelled.append(newStateMessage(e.name, err.State))
default:
m.errorMsgs.append(newErrorMessage(e.name, err))
m.cancelFunc()
}
return
} else {
outMsg.value = result

// add to finished stack...
m.undoStack.push(newUndoFunc(e.name, e.undoSkipError, e.undo, args))
}

for _, subscriber := range e.subscribers {
*subscriber <- outMsg
}
m.launch(e, &wg)
})
if err != nil {
return nil, err
Expand Down
Loading

0 comments on commit 1eb7f71

Please sign in to comment.