Page MenuHomePhabricator
Files F7159103

setuptest5.py
No OneTemporary
Actions

setuptest5.py
View Options

#!/usr/bin/env python
# Copyright (C) 2008 AG Projects
#
"""
This test simulates call setup where no SDP is sent in the INVITE:
- the callee sends a 200 OK
- the caller sends a ACK with SDP
- Both parties will start sending media
- Media will flow for 5 seconds
- The callee will send a BYE
"""
from common import *
def callee_update(protocol, session, caller_media, callee_media):
print "doing update for callee"
defer = session.do_update(protocol, "callee", "reply", False)
defer.addCallback(caller_update, protocol, session, caller_media, callee_media)
return defer
def caller_update(caller_addr, protocol, session, caller_media, callee_media):
print "doing update for caller"
defer = session.do_update(protocol, "caller", "request", True)
defer.addCallback(do_media, caller_addr, protocol, session, caller_media, callee_media)
return defer
def do_media((callee_ip, callee_ports), (caller_ip, caller_ports), protocol, session, caller_media, callee_media):
print "starting media for both parties"
session.caller.start_media(caller_ip, caller_ports)
session.callee.start_media(callee_ip, callee_ports)
defer = DeferredList([caller_media, callee_media])
defer.addCallback(wait, protocol, session)
return defer
def wait(result, protocol, session):
print "got media, waiting 5 seconds"
defer = Deferred()
defer.addCallback(kthxbye, protocol, session)
reactor.callLater(5, defer.callback, None)
return defer
def kthxbye(result, protocol, session):
print "sending remove"
return session.do_remove(protocol, "callee")
def disconnect(result, connector):
print "disconnecting"
connector.disconnect()
reactor.callLater(1, reactor.stop)
def catch_all_err(failure):
print failure
if __name__ == "__main__":
caller = Endpoint("Alice <alice@example.com>", "Caller UA", True)
caller_media = caller.set_media([("audio", 40000, "sendrecv")])
callee = Endpoint("Bob <bob@example.com>", "Callee UA", False)
callee_media = callee.set_media([("audio", 50000, "sendrecv")])
session = Session(caller, callee)
connector, defer = connect_to_dispatcher()
defer.addCallback(callee_update, session, caller_media, callee_media)
defer.addCallback(disconnect, connector)
defer.addErrback(catch_all_err)
reactor.run()

File Metadata

Mime Type
text/x-python
Expires
Sat, Nov 23, 2:28 AM (13 h, 16 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3408593
Default Alt Text
setuptest5.py (2 KB)

Event Timeline