fix: Fix scheduling issues that can cause unexpected timeouts on new …

…connections

lc-lib/publisher/endpoint/sink_process.go

@@ -47,6 +47,7 @@ func (s *Sink) ProcessEvent(event transports.Event) (endpoint *Endpoint, err err
 		err = fmt.Errorf("unexpected %T message received", event)
 	}
 
+	s.Scheduler.Reschedule()
 	return
 }
 

lc-lib/publisher/publisher.go

@@ -206,7 +206,9 @@ func (p *Publisher) runOnce() bool {
 		} else if p.resendList.Len() != 0 {
 			log.Debug("Holding %d new events until the resend queue is flushed", len(spool))
 		} else if p.endpointSink.CanQueue() {
-			if _, ok := p.sendEvents(spool); ok {
+			_, ok := p.sendEvents(spool)
+			p.endpointSink.Scheduler.Reschedule()
+			if ok {
 				break
 			}
 

lc-lib/receiver/pool.go

@@ -187,6 +187,7 @@ ReceiverLoop:
 				// Schedule partial ack if this is first set of events
 				if len(connectionStatus.progress) == 0 {
 					r.scheduler.Set(connection, 5*time.Second)
+					r.scheduler.Reschedule()
 				}
 				connectionStatus.progress = append(connectionStatus.progress, &poolEventProgress{event: eventImpl, sequence: 0})
 				r.connectionLock.Unlock()