mirror of
https://github.com/livekit/livekit.git
synced 2026-07-28 20:49:26 +00:00
Enable data tracks by default. (#4429)
This commit is contained in:
@@ -436,12 +436,13 @@ var DefaultConfig = Config{
|
||||
StreamBufferSize: 1000,
|
||||
ConnectAttempts: 3,
|
||||
},
|
||||
PSRPC: rpc.DefaultPSRPCConfig,
|
||||
Keys: map[string]string{},
|
||||
Metric: metric.DefaultMetricConfig,
|
||||
WebHook: webhook.DefaultWebHookConfig,
|
||||
NodeStats: DefaultNodeStatsConfig,
|
||||
API: DefaultAPIConfig(),
|
||||
PSRPC: rpc.DefaultPSRPCConfig,
|
||||
Keys: map[string]string{},
|
||||
Metric: metric.DefaultMetricConfig,
|
||||
WebHook: webhook.DefaultWebHookConfig,
|
||||
NodeStats: DefaultNodeStatsConfig,
|
||||
API: DefaultAPIConfig(),
|
||||
EnableDataTracks: true,
|
||||
}
|
||||
|
||||
func NewConfig(confString string, strictMode bool, c *cli.Command, baseFlags []cli.Flag) (*Config, error) {
|
||||
|
||||
@@ -63,7 +63,7 @@ func (s *signallerAsync) WriteMessage(msg proto.Message) error {
|
||||
|
||||
if s.params.Participant.IsDisconnected() {
|
||||
s.params.Logger.Debugw(
|
||||
"counld not send message to participant, participant disconnected",
|
||||
"could not send message to participant, participant disconnected",
|
||||
"messageType", getMessageType(msg),
|
||||
)
|
||||
return nil
|
||||
|
||||
@@ -290,10 +290,10 @@ func (s *RTCService) serve(w http.ResponseWriter, r *http.Request, needsJoinRequ
|
||||
}
|
||||
|
||||
var (
|
||||
roomName livekit.RoomName
|
||||
roomID livekit.RoomID
|
||||
participantIdentity livekit.ParticipantIdentity
|
||||
pID livekit.ParticipantID
|
||||
roomName livekit.RoomName = "unresolved"
|
||||
roomID livekit.RoomID = "unresolved"
|
||||
participantIdentity livekit.ParticipantIdentity = "unresolved"
|
||||
pID livekit.ParticipantID = "unresolved"
|
||||
loggerResolved bool
|
||||
|
||||
pi routing.ParticipantInit
|
||||
|
||||
@@ -1420,7 +1420,7 @@ func (d *DownTrack) CloseWithFlush(flush bool, isEnding bool) {
|
||||
return
|
||||
}
|
||||
|
||||
d.params.Logger.Debugw("close downtrack", "flushBlankFrame", flush)
|
||||
d.params.Logger.Debugw("close downtrack", "flushBlankFrame", flush, "isEnding", isEnding)
|
||||
if d.bindState.Load() == bindStateBound {
|
||||
d.forwarder.Mute(true, true)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user