Adds server awareness. (#14271)
Co-authored-by: mattermod <mattermod@users.noreply.github.com>
Этот коммит содержится в:
коммит произвёл
GitHub
родитель
744ec281d2
Коммит
3f6c9ab40c
@@ -222,9 +222,9 @@ func linkGroupSyncable(c *Context, w http.ResponseWriter, r *http.Request) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// Not awaiting completion because the group sync job executes the same procedure—but for all syncables—and
|
c.App.Srv().Go(func() {
|
||||||
// persists the execution status to the jobs table.
|
c.App.SyncRolesAndMembership(syncableID, syncableType)
|
||||||
go c.App.SyncRolesAndMembership(syncableID, syncableType)
|
})
|
||||||
|
|
||||||
w.WriteHeader(http.StatusCreated)
|
w.WriteHeader(http.StatusCreated)
|
||||||
|
|
||||||
@@ -383,9 +383,9 @@ func patchGroupSyncable(c *Context, w http.ResponseWriter, r *http.Request) {
|
|||||||
auditRec.AddMeta("new_syncable_id", groupSyncable.SyncableId)
|
auditRec.AddMeta("new_syncable_id", groupSyncable.SyncableId)
|
||||||
auditRec.AddMeta("new_syncable_type", groupSyncable.Type)
|
auditRec.AddMeta("new_syncable_type", groupSyncable.Type)
|
||||||
|
|
||||||
// Not awaiting completion because the group sync job executes the same procedure—but for all syncables—and
|
c.App.Srv().Go(func() {
|
||||||
// persists the execution status to the jobs table.
|
c.App.SyncRolesAndMembership(syncableID, syncableType)
|
||||||
go c.App.SyncRolesAndMembership(syncableID, syncableType)
|
})
|
||||||
|
|
||||||
b, marshalErr := json.Marshal(groupSyncable)
|
b, marshalErr := json.Marshal(groupSyncable)
|
||||||
if marshalErr != nil {
|
if marshalErr != nil {
|
||||||
@@ -437,9 +437,9 @@ func unlinkGroupSyncable(c *Context, w http.ResponseWriter, r *http.Request) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// Not awaiting completion because the group sync job executes the same procedure—but for all syncables—and
|
c.App.Srv().Go(func() {
|
||||||
// persists the execution status to the jobs table.
|
c.App.SyncRolesAndMembership(syncableID, syncableType)
|
||||||
go c.App.SyncRolesAndMembership(syncableID, syncableType)
|
})
|
||||||
|
|
||||||
auditRec.Success()
|
auditRec.Success()
|
||||||
|
|
||||||
|
|||||||
Ссылка в новой задаче
Block a user