Back to results
US 10,248,465 B2Granted
Convergent mediation system with dynamic resource allocation
AssigneeComptel Oy
InventorsMika Tanttu, Jussi Lassila
Life of this patent
Estimating the term…
Abstract
An object is to create a convergent mediation system (10) and method that meet the technical requirements of low latency time and high throughput, without compromising the interoperability and ease of administration of the system. According an aspect of the invention, these objects are achieved by providing a convergent mediation system (10) that comprises a common platform (18) providing processing power for both online processing (12) and off-line processing (14) of data. The convergent mediation system (10) is also provided with a system controller (110) that is adapted to dynamically allocate the processing power of the common platform (18) for the online processing (12) and off-line processing (14) of data.
Claims35
A convergent mediation system for mediating data records, the convergent mediation system comprising:
- a common platform comprising hardware defining a processing power for online processing and off-line processing of data corresponding to usage of at least one of a communication network or a data communications platform, the common platform comprising:
- a plurality of independent processing nodes forming processing streams, each of the processing streams comprising at least two independent processing nodes in sequence, the independent processing nodes structured to continue operating if another independent node in the processing stream fails;
- and
- a buffer between an upstream and a downstream independent processing node from the at least two independent processing nodes in sequence, wherein the system is adapted to transport a portion of the data from the downstream to the upstream processing node through the buffer and to remove the portion of the data from the buffer only after successfully processing the portion of the data in the upstream independent processing node after receipt thereof from the buffer,
- wherein at least the first independent node in the processing stream is an interface node adapted to receive the data from the at least one of the communications network or the service delivery platform and send a response thereto, wherein each of the independent processing nodes of the plurality of independent processing nodes comprises a node application and a node base, wherein the node application contains logical rules according to which the processing node processes the data and the node base provides basic functionalities for the processing node;
- and
- a system controller adapted to dynamically allocate the processing power of the common platform for the online processing and off-line processing of the data, wherein the system controller allocates more of the processing power for the online processing of the data when a current processing power allocated to the online processing of the data exceeds a current online processing load caused by the online processing of the data by a value less than a minimum reserve threshold, the minimum reserve threshold defining a reserve of the processing power to maintain a low online processing latency during peak load times, the low online processing latency representing an online processing speed that is small enough to prevent a fraud window.
4 more elements
A convergent mediation method, comprising
- providing a processing platform and a system controller, the processing platform comprising hardware defining a processing power and comprising a plurality of independent processing nodes, each of the independent processing nodes of the plurality of independent processing nodes comprising a node application and a node base, wherein the node application contains logical rules according to which the processing node processes data corresponding to usage of at least one of a communication network or a data communications platform and the node base provides basic functionalities for the processing node,
- forming processing streams comprising at least two independent processing nodes in sequence and a buffer coupled between an upstream and a downstream independent processing node from the at least two independent processing nodes in sequence, the independent nodes of a processing stream structured to continue operating if another independent node in the processing stream fails, wherein at least the first independent node in the processing stream is an interface node adapted to receive the data from the at least one of the communications network or the service delivery platform and send a response thereto,
- obtaining the data from the least one of the communications network or the service delivery platform,
- online processing a first portion of the data by means of the processing platform, wherein online processing comprises transporting a portion of the data from the downstream to the upstream processing node through the buffer and removing the portion of the data from the buffer only after successfully processing the portion of the data in the upstream independent processing node after receipt thereof from the buffer,
- off-line processing a second portion of the data by means of the same processing-platform, and
- the system controller allocating dynamically the processing power of the processing platform for the online processing of the data and for the off-line processing of the data and allocating more of the processing power for the online processing of the data when a current processing power allocated to the online processing of the data exceeds a current online processing load caused by the online processing of the data by a value less than a minimum reserve threshold, the minimum reserve threshold defining a reserve of the processing power to maintain a low online processing latency during peak load times, the low online processing latency representing an online processing speed that is small enough to prevent a fraud window.
3 more elements
A non-transitory computer program product, comprising program code means adapted to direct a computer system to perform a method, the computer system comprising a processing platform comprising hardware defining a processing power and a system controller, the processing platform comprising a plurality of independent processing nodes, each of the independent processing nodes of the plurality of independent processing nodes comprising a node application and a node base, wherein the node application contains logical rules according to which the processing node processes data corresponding to usage of at least one of a communication network or a data communications platform and the node base provides basic functionalities for the processing node, the method comprising:
- forming processing streams comprising at least two independent processing nodes in sequence and a buffer coupled between an upstream and a downstream independent processing node from the at least two independent processing nodes in sequence, the independent nodes of a processing stream structured to continue operating if another independent node in the processing stream fails, wherein at least the first independent node in the processing stream is an interface node adapted to receive the data from the at least one of the communications network or the service delivery platform and send a response thereto,
- obtaining the data from the at least one of the communications network or the service delivery platform,
- online processing a first portion of the data by means of the processing platform, wherein online processing comprises transporting a portion of the data from the downstream to the upstream processing node through the buffer and removing the portion of the data from the buffer only after successfully processing the portion of the data in the upstream independent processing node after receipt thereof from the buffer,
- off-line processing a second portion of the data by means of the same processing platform, and
- allocating dynamically the processing power of the processing platform for the online processing of the data and for the off-line processing of the data, and
- allocating more of the processing power for the online processing of the data when a current processing power allocated to the online processing of the data exceeds a current online processing load caused by the online processing of the data by a value less than a minimum reserve threshold, the minimum reserve threshold defining a reserve of the processing power to maintain a low online processing latency during peak load times, the low online processing latency representing an online processing speed that is small enough to prevent a fraud window.
3 more elements
A convergent mediation system for mediating data records, the convergent mediation system comprising:
- a common platform for online processing and off-line processing of data corresponding to usage of at least one of a communication network or a data communications platform, the common platform comprising hardware defining a processing power and comprising a plurality of independent processing nodes forming processing streams, each of the processing streams comprising at least two independent processing nodes in sequence, the independent processing nodes structured to continue operating if another independent node in the processing stream fails, wherein at least the first independent node in the processing stream is an interface node adapted to receive the data from the at least one of the communications network or the service delivery platform and send a response thereto,
- wherein each of the independent processing nodes of the plurality of independent processing nodes comprises a node application and a node base, wherein the node application contains logical rules according to which the processing node processes the data and the node base provides basic functionalities for the processing node;
- and
- a system controller adapted to dynamically allocate the processing power of the common platform for the online processing and off-line processing of the data and to allocate more of the processing power for the online processing of the data when a current processing power allocated to the online processing of the data exceeds a current online processing load caused by the online processing of the data by a value less than a minimum reserve threshold, the minimum reserve threshold defining a reserve of the processing power to maintain a low online processing latency during peak load times, the low online processing latency representing an online processing speed that is small enough to prevent a fraud window,
- wherein the system has a maximum reserve threshold and the system controller is adapted to use the maximum reserve threshold as a parameter in the dynamical allocation such that the system controller allocates less of the processing power for the online processing of the data when the current processing power allocated to the online processing of the data exceeds the current processing load caused by the online processing of the data by a value greater than the maximum reserve threshold to increase the processing power for the off-line processing while maintaining the low online processing latency during off-peak load times, thereby utilizing some of the processing power both for the online processing during peak load times and for the off-line processing during off-peak times.
2 more elements
A convergent mediation method, comprising
- providing a processing platform and a system controller, the processing platform comprising hardware defining a processing power and comprising a plurality of independent processing nodes, each of the independent processing nodes of the plurality of independent processing nodes comprising a node application and a node base, wherein the node application contains logical rules according to which the processing node processes data corresponding to usage of at least one of a communication network or a data communications platform and the node base provides basic functionalities for the processing node,
- forming processing streams comprising at least two independent processing nodes in sequence, the independent nodes of a processing stream structured to continue operating if another independent node in the processing stream fails, wherein at least the first independent node in the processing stream is an interface node adapted to receive the data from the at least one of the communications network or the service delivery platform and send a response thereto,
- obtaining the data from the least one of the communications network or the service delivery platform,
- online processing a first portion of the data by means of the processing platform,
- off-line processing a second portion of the data by means of the same processing-platform, and
- the system controller allocating dynamically the processing power of the processing platform for the online processing of the data and for the off-line processing of the data and allocating more of the processing power for the online processing of the data when a current processing power allocated to the online processing of the data exceeds a current online processing load caused by the online processing of the data by a value less than a minimum reserve threshold, the minimum reserve threshold defining a reserve of the processing power to maintain a low online processing latency during peak load times, the low online processing latency representing an online processing speed that is small enough to prevent a fraud window,
- wherein the system has a maximum reserve threshold and the system controller is adapted to use the maximum reserve threshold as a parameter in the dynamical allocation such that the system controller allocates less processing power for the online processing of the data when the current processing power allocated to the online processing of the data exceeds the current processing load caused by the online processing of the data by a value greater than the maximum reserve threshold to increase the processing power for the off-line processing while maintaining the low online processing latency during off-peak load times, thereby utilizing some of the processing power both for the online processing during peak load times and for the off-line processing during off-peak times.
4 more elements
Dependencies are inferred from the claim text.