Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 41476d04a2 | |||
| a5780449fc |
@@ -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:
|
||||||
|
|||||||
@@ -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)
|
||||||
|
|||||||
@@ -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 {
|
||||||
|
|||||||
Reference in New Issue
Block a user