Skip to content

Commit

Permalink
MB-31938 Use collectionAware flag in projector
Browse files Browse the repository at this point in the history
Projector should use collectionAware flag from MTR request rather than
feedVersion to make sure things work fine in mixed mode.

Change-Id: Ib4290fa5c9f9b3a36d6131a42f5bc6055b4aedb0
  • Loading branch information
deepkaran authored and Deepkaran Salooja committed May 14, 2020
1 parent 13474f9 commit 30d0de2
Showing 1 changed file with 1 addition and 4 deletions.
5 changes: 1 addition & 4 deletions secondary/projector/feed.go
Original file line number Diff line number Diff line change
Expand Up @@ -853,17 +853,14 @@ func (feed *Feed) start(
req *protobuf.MutationTopicRequest, opaque uint16) (err error) {

feed.endpointType = req.GetEndpointType()
feed.version = req.GetVersion()
opaque2 := req.GetOpaque2()

keyspaceIdMap, err := req.GetKeyspaceIdMap()
if err != nil {
return err
}

if feed.version >= protobuf.FeedVersion_cheshireCat {
feed.collectionsAware = true
}
feed.collectionsAware = req.GetCollectionAware()

// update engines and endpoints
if _, err = feed.processSubscribers(opaque, req, keyspaceIdMap); err != nil { // :SideEffect:
Expand Down

0 comments on commit 30d0de2

Please sign in to comment.