Searched refs:writeSched (Results 1 – 1 of 1) sorted by relevance
368 sc.writeSched = s.NewWriteScheduler()370 sc.writeSched = NewRandomWriteScheduler()465 writeSched WriteScheduler member1059 sc.writeSched.Push(wr)1206 if wr, ok := sc.writeSched.Pop(); ok {1475 sc.writeSched.CloseStream(st.id)1770 sc.writeSched.AdjustStream(st.id, f.Priority)1855 sc.writeSched.AdjustStream(f.StreamID, f.PriorityParam)1883 sc.writeSched.OpenStream(st.id, OpenStreamOptions{PusherID: pusherID})