2 Commits

Author SHA1 Message Date
xuu
41476d04a2 fix: null pointer when unable to startu peerfinder
All checks were successful
Go Bump / bump (push) Successful in 30s
Go Test / test (push) Successful in 43s
Deploy / deploy (push) Successful in 1m25s
2023-10-02 11:26:14 -06:00
xuu
a5780449fc fix: error
All checks were successful
Go Bump / bump (push) Successful in 46s
Go Test / test (push) Successful in 1m1s
Deploy / deploy (push) Successful in 2m8s
2023-10-01 17:18:28 -06:00
3 changed files with 12 additions and 12 deletions

View File

@@ -10,12 +10,12 @@
owner: root
group: root
- name: Copy build to remote
ansible.builtin.copy:
src: ev.service
dest: /etc/systemd/system/ev.service
owner: root
group: root
# - name: Copy build to remote
# ansible.builtin.copy:
# src: ev.service
# dest: /etc/systemd/system/ev.service
# owner: root
# group: root
- name: Restart service
systemd:

View File

@@ -304,7 +304,7 @@ func (s *service) getResults(w http.ResponseWriter, r *http.Request) {
sort.Sort(sort.Reverse(requests))
args := requestArgs(r)
args.Requests = requests[:maxResults]
args.Requests = requests[:min(maxResults, len(requests))]
s.state.Use(ctx, func(ctx context.Context, state *state) error {
args.CountPeers = len(state.peers)

View File

@@ -91,17 +91,17 @@ func (s *service) Run(ctx context.Context) (err error) {
subRes, e := s.es.EventStream().Subscribe(ctx, queueResults, 0)
errs = multierr.Append(errs, e)
if errs != nil {
return errs
}
defer func() {
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
defer cancel()
err = multierr.Combine(errs, subReq.Close(ctx), subRes.Close(ctx))
err = multierr.Combine(err, subReq.Close(ctx), subRes.Close(ctx))
}()
if errs != nil {
return errs
}
for {
var events event.Events
select {