Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add debug to multistream #1366

Draft
wants to merge 1 commit into
base: main
Choose a base branch
from
Draft

Add debug to multistream #1366

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions mapic/mistapiconnector_app.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -623,6 +623,7 @@ func (mc *mac) invalidateAllSessions(playbackID string) {
// Note that we use Mist AUTO_PUSH (which in turn makes sure that the PUSH is always available).
// Note also that we only create AUTO_PUSH for active streams which are ingest (not playback).
func (mc *mac) reconcileMultistream(mistState clients.MistState) {
glog.Warningf("### Reconciling Multistreams, mistState=%v", mistState)
type key struct {
stream string
target string
Expand Down Expand Up @@ -652,6 +653,8 @@ func (mc *mac) reconcileMultistream(mistState clients.MistState) {
mistMap[toKey(e.Stream, e.Target)] = true
}
}
glog.Warningf("### mistMap=%v", mistMap)
glog.Warningf("### filteredMistPushAutoList=%v", filteredMistPushAutoList)

// Get the existing PUSH from Mist
var filteredMistPushList []*clients.MistPush
Expand All @@ -661,6 +664,7 @@ func (mc *mac) reconcileMultistream(mistState clients.MistState) {
filteredMistPushList = append(filteredMistPushList, e)
}
}
glog.Warningf("### mistMap=%v", mistMap)

// Get the expected multistreams from cached streamInfo
type pushInfo struct {
Expand All @@ -681,6 +685,7 @@ func (mc *mac) reconcileMultistream(mistState clients.MistState) {
}
}
mc.mu.Unlock()
glog.Warningf("### cachedMap=%v", cachedMap)

// Remove AUTO_PUSH that exists in Mist, but is not in streamInfo cache
for _, e := range filteredMistPushAutoList {
Expand Down Expand Up @@ -710,6 +715,8 @@ func (mc *mac) reconcileMultistream(mistState clients.MistState) {

// Add AUTO_PUSH that exists streamInfo cache, but not in Mist
for k, v := range cachedMap {
glog.Warningf("### k=%v v=%v", k, v)
glog.Warningf("### v.enabled=%v mistMap[toKey(k.stream, k.target)]=%v", v.enabled, mistMap[toKey(k.stream, k.target)])
if v.enabled && !mistMap[toKey(k.stream, k.target)] {
glog.Infof("adding AUTO_PUSH for stream=%s target=%s", k.stream, k.target)
if err := mc.mist.PushAutoAdd(k.stream, k.target); err != nil {
Expand Down
Loading