Load balancing and overload control techniques are disclosed for use in a SIP-based network or other type of network comprising a plurality of servers. In a load balancing technique, a first server receives feedback information from at least first and second downstream servers associated with respective first and second paths between the first server and a target server, the feedback information comprising congestion measures for the respective downstream servers. The first server dynamically adjusts a message routing process based on the received feedback information to compensate for imbalance among the congestion measures of the downstream servers. In an overload control technique, the first server utilizes feedback information received from at least one downstream server to generate a blocking message for delivery to a user agent.

An improved core network that can monitor micro-level issues, identify specific services of specific nodes that may be causing an outage, and perform targeted node failovers in a manner that does not cause unnecessary disruptions in service is described herein. For example, the improved core network can include a failover and isolation server (FIS) system. The FIS system can obtain service-specific KPIs from the various nodes in the core network. The FIS can then compare the obtained KPI values of the respective service with corresponding threshold values. If any KPI value exceeds a corresponding threshold value, the FIS may preliminarily determine that the service of the node associated with the KPI value is responsible for a service outage. The FIS can initiate a failover operation, which causes the node to re-route any received requests corresponding to the service potentially responsible for the service outage to a redundant node.

An improved core network that can monitor micro-level issues, identify specific services of specific nodes that may be causing an outage, and perform targeted node failovers in a manner that does not cause unnecessary disruptions in service is described herein. For example, the improved core network can include a failover and isolation server (FIS) system. The FIS system can obtain service-specific KPIs from the various nodes in the core network. The FIS can then compare the obtained KPI values of the respective service with corresponding threshold values. If any KPI value exceeds a corresponding threshold value, the FIS may preliminarily determine that the service of the node associated with the KPI value is responsible for a service outage. The FIS can initiate a failover operation, which causes the node to re-route any received requests corresponding to the service potentially responsible for the service outage to a redundant node.

Described herein is a method for processing an invalidation of a downlink data tunnel between networks. The method includes the following steps: (1) a core network user plane anchor receives an error indication of data tunnel sent from an access network device, (2) after deciding that the user plane corresponding to the error indication uses a One Tunnel technology, the core network user plane anchor notifies a relevant core network control plane to request recovering the downlink data tunnel, (3) the core network control plane recovers the downlink data tunnel and notifies the core network user plane anchor to update information of the user plane. In addition, a communication system and a communication device are also provided. The method, system, and device can improve the speed of recovering data transmission after the downlink data tunnel becomes invalid.

A generation identifier is employed with various systems and methods in order to identify situations where a workload has been reassigned to a new node and where a workload is still being processed by an old node during a failure between nodes. A master node may assign a workload to a worker node. The worker node sends a request to access target data. The request may be associated with a generation identifier and workload identifier that identifies the node and workload. At some point, a failure occurs between the master node and worker node. The master node reassigns the workload to another worker node. The new worker node accesses the target data with a different generation identifier, indicating to the storage system that the workload has been reassigned. The old worker node receives an indication from the storage system that the workload has been reassigned and stops processing the workload.

Techniques are disclosed for promulgating service information and topology information in a network in a high availability manner. An example device is configured to create a first service and topology exchange protocol (STEP) document. The first STEP document includes service information and topology information. The example device is configured to send the first STEP document to a first STEP repository for forwarding to at least one subscribing network device. The example device is also configured to send the first STEP document to a second STEP repository for forwarding to the at least one subscribing network device.

Systems, methods, and devices for implementing destination and source group-based routing are disclosed herein. Systems include transmitters configured to transmit media streams that are packetized streams of data. Each of the transmitters is implemented on one of a first plurality of physical nodes included in a first node cluster. The transmitters include encoders configured to generate the plurality of media streams. Systems include receivers configured to receive the media streams. Each of the receivers is implemented on one of a second plurality of physical nodes included in a second node cluster. The receivers include decoders configured to receive and decode the media streams. Systems include a controller configured to generate a first grouping for each node cluster based on node characteristics and cluster parameters, generate a second grouping for each node cluster based on grouping parameters, and route the media streams based on the first grouping and second grouping.

A system and method for a live streaming platform that can redundantly process input streams in parallel ingestion pipelines is disclosed herein. Ingested input streams in the parallel pipelines can be segmented using a segmentation function that creates identical segments in each of the streams in the pipelines. If errors occur, or there are disruptions in one or more of the input streams or pipelines, the live streaming platform can ensure that segments are identifiable and different parts of the pipelines can join a main stream at different points in time without disruption.

A network anomaly data detection method includes the following steps: receiving access request data transmitted by a client; searching historical access request data corresponding to a user session identifier in the access request data; acquiring a header character string of the access request data; performing word segmentation processing on the header character string according to a preset step length so as to obtain a word segmentation set; obtaining a word segmentation weight matrix according to the historical access request data and the word segmentation set; inputting the word segmentation weight matrix into an anomaly data detection model so as to obtain a data anomaly probability; and judging whether anomaly data exists in the header character string according to the data anomaly probability.

A system for alert of energy resource outages includes: a resource monitor, disposed within radio range of resource meters that each transmit corresponding radio signals indicative of corresponding meter identifiers and current readings, configured to: determine whether the corresponding radio signals are fixed frequency or frequency hopping by scanning frequency channels for a time period and counting hits of desired meter identifiers; decode each of the one or more of the corresponding radio signals of the resource meters according to determined protocol to obtain one or more of the corresponding meter identifiers and current readings; and transmit the one or more of the corresponding meter identifiers and current readings; and a server, configured to: receive the one or more of the corresponding meter identifiers and current readings; employ the corresponding meter identifiers and current readings to detect an outage; and transmit an alert that corresponds to the outage.