Page MenuHomePhabricator
Files F7159135

setuptest5.py
No OneTemporary
Actions

setuptest5.py
View Options

#!/usr/bin/python2
# 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', 30000, '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:59 AM (14 h, 1 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3408622
Default Alt Text
setuptest5.py (2 KB)

Event Timeline