tcjlj/nezha
1
0
Fork 0
mirror of https://github.com/nezhahq/nezha.git synced 2025-02-08 20:48:13 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
uubulb 2025-02-02 00:44:49 +08:00
parent af5466651a
commit a9ae4c30aa
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/ddns/ddns.go
View File

@ -54,7 +54,7 @@ func (provider *Provider) UpdateDomain(ctx context.Context, overrideDomains ...s
if err := provider.updateDomain(domain); err != nil { if err := provider.updateDomain(domain); err != nil {
log.Printf("NEZHA>> Failed to update DNS record of domain %s: %v", domain, err) log.Printf("NEZHA>> Failed to update DNS record of domain %s: %v", domain, err)
} else { } else {
log.Printf("NEZHA>> Update DNS record of domain %s succeed", domain) log.Printf("NEZHA>> Update DNS record of domain %s succeeded", domain)
break break
} }
} }

4
service/rpc/nezha.go
View File

@ -44,9 +44,9 @@ func (s *NezhaHandler) RequestTask(stream pb.NezhaService_RequestTaskServer) err
return err return err
} }
singleton.ServerLock.RLock() singleton.ServerLock.Lock()
singleton.ServerList[clientID].TaskStream = stream singleton.ServerList[clientID].TaskStream = stream
singleton.ServerLock.RUnlock() singleton.ServerLock.Unlock()
var result *pb.TaskResult var result *pb.TaskResult
for { for {

2
service/singleton/notification.go
View File

@ -270,7 +270,7 @@ func SendNotification(notificationGroupID uint64, desc string, muteLabel *string
if err := ns.Send(desc); err != nil { if err := ns.Send(desc); err != nil {
log.Printf("NEZHA>> Sending notification to %s failed: %v", n.Name, err) log.Printf("NEZHA>> Sending notification to %s failed: %v", n.Name, err)
} else { } else {
log.Printf("NEZHA>> Sending notification to %s succeed", n.Name) log.Printf("NEZHA>> Sending notification to %s succeeded", n.Name)
} }
} }
} }