resource-directory: allow drop event when buffer of subscription is e…

…xhausted
plgd-dev · Oct 8, 2021 · d2e8c3b · d2e8c3b
1 parent 0f6a280
commit d2e8c3b
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/resource-directory/service/subscriptions.go b/resource-directory/service/subscriptions.go
@@ -682,7 +682,7 @@ func (s *subscriptions) SubscribeForEvents(resourceProjection *Projection, srv p
 		}
 	}()
 
-	sendChan := make(chan pb.Event, 16)
+	sendChan := make(chan pb.Event, 1024)
 	go func() {
 		defer wg.Done()
 		for {
@@ -705,9 +705,11 @@ func (s *subscriptions) SubscribeForEvents(resourceProjection *Projection, srv p
 		case sendChan <- e:
 			return nil
 		case <-ctx.Done():
-			return fmt.Errorf("cannot send event: stream context returns error: %v", ctx.Err())
+			return fmt.Errorf("cannot send event (%+v) for subscription(%v): stream context returns error: %v", e.GetType(), e.GetSubscriptionId(), ctx.Err())
 		case <-senderCtx.Done():
-			return fmt.Errorf("cannot send event: sender context returns error: %v", ctx.Err())
+			return fmt.Errorf("cannot send event (%+v) for subscription(%v): sender context returns error: %v", e.GetType(), e.GetSubscriptionId(), ctx.Err())
+		default:
+			return fmt.Errorf("cannot send event (%+v) for subscription(%v): buffer it exhausted", e.GetType(), e.GetSubscriptionId())
 		}
 	}