vincent/aptly
1
0
Fork 0
mirror of https://github.com/aptly-dev/aptly.git synced 2026-06-09 06:04:12 +00:00
Code Issues Projects Releases Wiki Activity

Eliminate data races by using API without Progress. #116

Browse Source
This commit is contained in:
Andrey Smirnov
2015-02-16 00:32:45 +03:00
parent f153c7c3ea
commit 76ee53e9f8
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
api/api.go
+1 -1
View File
@@ -26,7 +26,7 @@ func apiVersion(c *gin.Context) {
func showPackages(c *gin.Context, reflist *deb.PackageRefList) { func showPackages(c *gin.Context, reflist *deb.PackageRefList) {
result := []*deb.Package{} result := []*deb.Package{}
list, err := deb.NewPackageListFromRefList(reflist, context.CollectionFactory().PackageCollection(), context.Progress()) list, err := deb.NewPackageListFromRefList(reflist, context.CollectionFactory().PackageCollection(), nil)
if err != nil { if err != nil {
c.Fail(404, err) c.Fail(404, err)
return return
api/publish.go
+3 -3
View File
@@ -153,7 +153,7 @@ func apiPublishRepoOrSnapshot(c *gin.Context) {
return return
} }
err = published.Publish(context.PackagePool(), context, context.CollectionFactory(), signer, context.Progress(), b.ForceOverwrite) err = published.Publish(context.PackagePool(), context, context.CollectionFactory(), signer, nil, b.ForceOverwrite)
if err != nil { if err != nil {
c.Fail(500, fmt.Errorf("unable to publish: %s", err)) c.Fail(500, fmt.Errorf("unable to publish: %s", err))
return return
@@ -218,7 +218,7 @@ func apiPublishUpdateSwitch(c *gin.Context) {
published.UpdateLocalRepo(component) published.UpdateLocalRepo(component)
} }
err = published.Publish(context.PackagePool(), context, context.CollectionFactory(), signer, context.Progress(), b.ForceOverwrite) err = published.Publish(context.PackagePool(), context, context.CollectionFactory(), signer, nil, b.ForceOverwrite)
if err != nil { if err != nil {
c.Fail(500, fmt.Errorf("unable to update: %s", err)) c.Fail(500, fmt.Errorf("unable to update: %s", err))
} }
@@ -229,7 +229,7 @@ func apiPublishUpdateSwitch(c *gin.Context) {
} }
err = collection.CleanupPrefixComponentFiles(published.Prefix, components, err = collection.CleanupPrefixComponentFiles(published.Prefix, components,
context.GetPublishedStorage(storage), context.CollectionFactory(), context.Progress()) context.GetPublishedStorage(storage), context.CollectionFactory(), nil)
if err != nil { if err != nil {
c.Fail(500, fmt.Errorf("unable to update: %s", err)) c.Fail(500, fmt.Errorf("unable to update: %s", err))
} }