Skip to content

Commit 7d8c48c

Browse files
authored
Merge pull request #25 from wizeline/feature/fix-too-many-files-open
fix issue open too many files
2 parents a7a834a + c01818b commit 7d8c48c

File tree

1 file changed

+4
-16
lines changed

1 file changed

+4
-16
lines changed

local/get_data_all_repos/main.go

+4-16
Original file line numberDiff line numberDiff line change
@@ -26,42 +26,30 @@ func main() {
2626
count := 0
2727
conn := db.SQLDBConn()
2828
defer conn.Close()
29-
c := make(chan bool)
3029
for repoRows.Next() {
3130
err := repoRows.Scan(&id, &name, &url, &accessToken)
3231
token := utils.GetAccessToken(accessToken)
3332
if err != nil {
3433
log.Println(err)
3534
} else {
3635
count++
37-
go getDataOneRepo(c, id, url, name, token, conn)
36+
getDataOneRepo(id, url, name, token, conn)
3837
}
3938
}
4039

41-
successCount, failCount := 0, 0
42-
for i := 0; i < count; i++ {
43-
if <-c {
44-
successCount++
45-
} else {
46-
failCount++
47-
}
48-
}
49-
log.Printf("Done. %d repo updated successfully. %d repo failed", successCount, failCount)
40+
log.Printf("Done. %d repo updated successfully", count)
5041

5142
}
5243

53-
func getDataOneRepo(c chan bool, id int, url, name, token string, conn *sql.DB) {
54-
flag := false
44+
func getDataOneRepo(id int, url, name, token string, conn *sql.DB) {
5545
defer func() {
5646
r := recover()
5747
if r != nil {
5848
log.Println("Recover: ", r)
5949
}
60-
c <- flag
6150
return
6251
}()
63-
gogit.UpdateDataForRepo(id, url, name, token, "", gogit.GetLastNDayDateRange(360), conn)
52+
gogit.UpdateDataForRepo(id, url, name, token, "", gogit.GetFullGitDateRange(), conn)
6453
github.CollectPRsOfRepo(github.NewGithubPullRequestService(token), id, url, conn)
6554
db.NewCommonOps().UpdateRepoLastUpdated(id)
66-
flag = true
6755
}

0 commit comments

Comments
 (0)