3 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
xuu
4784c1c380 fix: error
All checks were successful
Go Bump / bump (push) Successful in 34s
Go Test / test (push) Successful in 46s
Deploy / deploy (push) Successful in 1m44s
2023-10-01 17:06:24 -06:00
4 changed files with 14 additions and 12 deletions

View File

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

View File

@@ -1,6 +1,8 @@
name: Deploy name: Deploy
on: on:
push:
branches: [ "main" ]
release: release:
types: [ published ] types: [ published ]

View File

@@ -304,7 +304,7 @@ func (s *service) getResults(w http.ResponseWriter, r *http.Request) {
sort.Sort(sort.Reverse(requests)) sort.Sort(sort.Reverse(requests))
args := requestArgs(r) 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 { s.state.Use(ctx, func(ctx context.Context, state *state) error {
args.CountPeers = len(state.peers) 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) subRes, e := s.es.EventStream().Subscribe(ctx, queueResults, 0)
errs = multierr.Append(errs, e) errs = multierr.Append(errs, e)
if errs != nil {
return errs
}
defer func() { defer func() {
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second) ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
defer cancel() 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 { for {
var events event.Events var events event.Events
select { select {