Distributed session-based data
View Patent ↗Session-based data, such as call detail accounting information, is tracked and distributed to a plurality of servers in a distributed telephony environment. One type of session is a telephone call between participants. Session-based data includes information about a session provided by the switches along the media path. Session-based data further includes information related to the session obtained from the application layer (e.g., user input metadata). A network proxy maintains a participant list to which the session data is distributed. The network proxy sends updates to the participants and determines the network status to implement fault tolerance of data distribution.
1. A method for distributing call data, the method comprising:
receiving, at a server, from a participant, a registration request including a call identifier;
receiving, at the server, from at least one of a switch and an application, call data associated with the call identifier;
determining whether the call data had been previously received and determining whether a timestamp assigned to the call data matches a timestamp assigned to call data that had been previously received, wherein the timestamp assigned to the call data is calculated by adding a time difference between a timestamp of an origin of the call data and a timestamp of a CDS instance on the server to a timestamp of the origin of the call data; and
responsive to a determination that the call data had not been previously received, sending the call data to the participant.
2. The method of claim 1 further comprising:
receiving, at the server, an end of session message; and
writing the call data to a database responsive to the end of session message.
3. The method of claim 1 further comprising:
receiving, at the participant, the call data; and
storing the call data in a local data store.
4. The method of claim 3 wherein storing the call data in the local data store comprises:
determining whether the call data had been previously received; and
responsive to a determination that the call data had not been previously received, storing the call data in the local data store.
5. The method of claim 4 wherein determining whether the call data had been previously received comprises:
determining whether a timestamp assigned to the call data matches a timestamp assigned to call data that had been previously received.
6. The method of claim 5 wherein the timestamp assigned to the call data is calculated by adding a time difference between a timestamp of an origin of the call data and a timestamp of a CDS instance on the participant to a timestamp of a CDS instance on the participant.
7. The method of claim 3 further comprising:
receiving, at the participant, supplemental call data from a local participant; and
sending the supplemental call data to the server.
8. The method of claim 7 wherein sending the supplemental call data to the server comprises:
determining whether the supplemental call data had been previously received; and
responsive to a determination that the supplemental call data had not been previously received, sending the supplemental call data to the server.
9. The method of claim 8 wherein determining whether the supplemental call data had been previously received comprises:
determining whether a timestamp assigned to the supplemental call data matches a timestamp assigned to supplemental call data that had been previously received.
10. The method of claim 9 wherein the timestamp assigned to the supplemental call data is calculated by adding a time difference between a timestamp of an origin of the supplemental call data and a timestamp of a CDS instance on the participant to a timestamp of a CDS instance on the participant.
11. The method of claim 1 wherein the call identifier comprises a callID.
12. The method of claim 1 wherein the server includes an owning TMS process.
13. The method of claim 1 wherein the participant includes a participant TMS process.
14. The method of claim 1 wherein the call represents a telephone call between participants.
15. The method of claim 1 wherein the server and the participant are associated with different sites.
16. The method of claim 1 wherein the participant comprises one element of a group containing a switch and a server.
17. An apparatus for distributing call data, the apparatus comprising:
an interface module configured to receive, at a server, from a participant, a registration request including a call identifier;
an update module configured to receive, at the server, from at least one of a switch and an application, call data associated with the call identifier, and to send the call data to the participant; and
a timestamp module configured to calculate a time difference between a timestamp of a CDS instance on the server and a timestamp of a CDS instance on the participant.
18. The apparatus of claim 17 wherein the update module is further configured to receive, from the participant, the-call data.
19. The apparatus of claim 18 further comprising:
a storage module configured to store the call data in a local data store.
20. The apparatus of claim 19 wherein the interface module is further configured to receive an end of session message; and the storage module is configured to write the call data to a database responsive to the end of session message.
21. The apparatus of claim 18 wherein the update module is further configured to receive, at the participant, supplemental session data from a local participant; and to send the supplemental session data to the server.
22. The apparatus of claim 17 wherein the call identifier comprises a callID.
23. The apparatus of claim 17 wherein the server includes an owning TMS process.
24. The apparatus of claim 17 wherein the participant includes a participant TMS process.
25. The apparatus of claim 17 wherein the call represents a telephone call between participants.
26. The apparatus of claim 17 wherein the server and the participant are associated with different sites.
27. The apparatus of claim 17 wherein the participant comprises one element of a group containing a switch and a server.