|
|
@ -368,13 +368,13 @@ func (session *Session) handleRequest(req *Request) {
|
|
|
|
session.connWLock.Unlock()
|
|
|
|
session.connWLock.Unlock()
|
|
|
|
session.OutBytes += len(outBytes)
|
|
|
|
session.OutBytes += len(outBytes)
|
|
|
|
switch req.Method {
|
|
|
|
switch req.Method {
|
|
|
|
// case "PLAY", "RECORD":
|
|
|
|
case "PLAY", "RECORD":
|
|
|
|
// switch session.Type {
|
|
|
|
switch session.Type {
|
|
|
|
// case SESSEION_TYPE_PLAYER:
|
|
|
|
case SESSEION_TYPE_PLAYER:
|
|
|
|
// session.Pusher.AddPlayer(session.Player)
|
|
|
|
session.Pusher.AddPlayer(session.Player)
|
|
|
|
// case SESSION_TYPE_PUSHER:
|
|
|
|
// case SESSION_TYPE_PUSHER:
|
|
|
|
// session.Server.AddPusher(session.Pusher)
|
|
|
|
// session.Server.AddPusher(session.Pusher)
|
|
|
|
// }
|
|
|
|
}
|
|
|
|
case "TEARDOWN":
|
|
|
|
case "TEARDOWN":
|
|
|
|
{
|
|
|
|
{
|
|
|
|
session.Stop()
|
|
|
|
session.Stop()
|
|
|
|