Processing incoming transactions based on resource utilization status of backend systems in an appliance cluster

• US 9,882,967 B2
• Filed: 09/24/2014
• Issued: 01/30/2018
• Est. Priority Date: 09/30/2013
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Chang, Chun-Fei, Liu, Jeffrey C H, Tseng, Joey H Y, Shih, Hao-Ting
• Primary Examiner(s): Nguyen, Dustin
• Assistant Examiner(s): Guzman, Javier O
• Application Number:
  US14/494,705
• Publication Number:
  US 20150095500A1
• Time in Patent Office: 1,224 Days
• CPC Class Codes: G06F 11/00 Error detection; Error correction; Monitoring error detection, correction or monitoring in information storage based on relative movement between record carrier and transducer G11B20/18; monitoring, i.e. supervising the progress of recording or reproducing G11B27/36; in static stores G11C29/00
• CPC Class Codes: G06F 11/3433 for load management allocation of a server based on load conditions G06F9/505; load rebalancing G06F9/5083; redistributing the load in a network by a load balancer H04L67/1029
• CPC Class Codes: G06F 2201/81 Threshold
• CPC Class Codes: G06F 2201/87 Monitoring of transactions
• CPC Class Codes: G06F 2201/88 Monitoring involving counting
• CPC Class Codes: G06F 9/00 Arrangements for program control, e.g. control units program control for peripheral devices G06F13/10
• CPC Class Codes: G06F 9/466 Transaction processing
• CPC Class Codes: G06F 9/50 Allocation of resources, e.g. of the central processing unit [CPU]
• CPC Class Codes: G06F 9/505 considering the load
• CPC Class Codes: H04L 12/4641 Virtual LANs, VLANs, e.g. virtual private networks [VPN] LAN interconnection over a bridge based backbone H04L12/462; encapsulation techniques H04L12/4633; routing of packets H04L45/00; packet switches H04L49/00; virtual private networks for security H04L63/0272
• CPC Class Codes: H04L 63/0209 Architectural arrangements, e.g. perimeter networks or demilitarized zones
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46

Abstract

A processor-implemented method and/or computer program product negotiates the processing of incoming transactions based on resource utilization status of backend systems in an appliance cluster. An incoming transaction, which is a specialized function for an appliance, is received by a processor. The processor determines whether the incoming transaction can be processed by the appliance cluster based on a current threshold level and a current transaction count, and then identifies a target appliance from the appliance cluster as a negotiation device in response to determining that the incoming transaction cannot be processed.

Claims

1. A method of negotiating processing of incoming transactions in an appliance cluster, the method comprising:

receiving, by a receiving appliance in an appliance cluster, an incoming transaction from a client device via a network, wherein the incoming transaction is a specialized function for an appliance in the appliance cluster, and wherein all appliances in the appliance cluster share a same backend system that is in network communication with the appliance cluster;

determining, by one or more processors, whether the incoming transaction can be processed by the receiving appliance based on a current threshold level and a current transaction count of the receiving appliance, wherein the current threshold level is a sum of a first quantity of transactions that can be handled by a first appliance in the appliance cluster plus a second quantity of transactions that can be handled by a second appliance in the appliance cluster on behalf of the first appliance;

identifying, by one or more processors, a target appliance from the appliance cluster as a negotiation device in response to determining that the incoming transaction cannot be processed by the receiving appliance, wherein the negotiation device negotiates with another appliance in the appliance cluster to receive the incoming transaction; and

sending, from the negotiation device to a lending appliance in the appliance cluster, the incoming transaction, wherein the lending appliance is an original member of the appliance cluster, wherein the lending appliance has a highest amount of available capacity to handle transferred transactions from other appliances in the appliance cluster, wherein the highest amount of available capacity is based on the lending appliance having a greater current threshold level than any other appliance in the appliance cluster, and wherein the lending appliance has never been chosen before to receive a transferred incoming transaction from another appliance in the appliance cluster.

2. The method of claim 1, wherein the current threshold level is adjusted according to a resource utilization status of the backend system.

3. The method of claim 1, further comprising:

adjusting, by one or more processors, the current threshold level to create an adjusted current threshold level, wherein the adjusted current threshold level is a sum of the current threshold level plus a percentage of the current threshold level as set by an average resource utilization rate of the backend system by the receiving appliance.

4. The method of claim 1, wherein said determining requires determining whether a sum of a unit of the incoming transaction and the current transaction count is less than the current threshold level.

5. The method of claim 1, further comprising:

checking, by one or more processors, a transaction distribution table (TDT) and selecting a spared transaction threshold unit which has the largest positive value but has never been chosen before, thereby identifying the target appliance, wherein the transaction distribution table comprises an incoming transaction unit, an outgoing transaction unit and the spared transaction threshold unit, wherein the spared transaction threshold unit is calculated by subtracting the current transaction count from the current threshold level.

6. The method of claim 5, further comprising:

checking, by one or more processors, the target appliance for capability of receiving the incoming transaction, wherein the target appliance calculates an adjusted value of the current threshold level at a point in time of negotiation and a sum of a current transaction count of the target appliance and a unit of the incoming transaction.

7. The method of claim 6, further comprising:

re-directing, by one or more processors, the incoming transaction to the target appliance and updating a transaction distribution table (TDT) in response to the adjusted value of the current threshold level of the target appliance being larger than the sum of the current transaction count of the target appliance and the unit of the incoming transaction.

8. The method of claim 1, wherein the current threshold level is a threshold in a Service Level Monitoring (SLM) policy.

18. The method of claim 1, further comprising:

adjusting, by one or more processors, a current threshold level of the appliance cluster according to a resource utilization status of backend systems that are utilized by the appliance cluster.

19. The method of claim 1, wherein each appliance in the appliance cluster has a unique and dynamic current threshold level.

20. The method of claim 1, further comprising:

receiving, by the negotiation device and from the lending appliance, responses to the incoming transaction from a backend system that is utilized by the appliance cluster.

9. An appliance, comprising:

a bus;

a memory connected to the bus, wherein the memory stores therein an instruction; and

a processing unit connected to the bus, wherein the processing unit executes instructions to;

receive an incoming transaction, wherein the incoming transaction is a specialized function for an appliance in an appliance cluster, and wherein all appliances in the appliance cluster share a same backend system that is in network communication with the appliance cluster;

determine whether the incoming transaction can be processed by a receiving appliance in the appliance cluster based on a current threshold level and a current transaction count of the receiving appliance in the appliance cluster, wherein the current threshold level is a sum of a first quantity of transactions that can be handled by a first appliance in the appliance cluster plus a second quantity of transactions that can be handled by a second appliance in the appliance cluster on behalf of the first appliance;

identify a target appliance from the appliance cluster as a negotiation device in response to determining that the incoming transaction cannot be processed, wherein the negotiation device negotiates with another appliance in the appliance cluster to receive the incoming transaction; and

send the incoming transaction from the negotiation device to a lending appliance in the appliance cluster, wherein the lending appliance is an original member of the appliance cluster, wherein the lending appliance has a highest amount of available capacity to handle transferred transactions from other appliances in the appliance cluster, wherein the highest amount of available capacity is based on the lending appliance having a greater current threshold level than any other appliance in the appliance cluster, and wherein the lending appliance has never been chosen before to receive a transferred incoming transaction from another appliance in the appliance cluster.

10. The appliance of claim 9, wherein the current threshold level is adjusted according to resource utilization status of backend systems.

11. The appliance of claim 10, wherein the current threshold level depends on a difference between a current resource utilization rate and a predetermined average resource utilization rate.

12. The appliance of claim 9, wherein the determination requires determining whether a sum of a unit of the incoming transaction and the current transaction count is less than the current threshold level.

13. The appliance of claim 9, wherein the processing unit further executes instructions to:

check a transaction distribution table (TDT) and select a spared transaction threshold unit which has the largest positive value but has never been chosen before, thereby identifying the target appliance,

wherein the transaction distribution table comprises an incoming transaction unit, an outgoing transaction unit and the spared transaction threshold unit,

wherein the spared transaction threshold unit is calculated by subtracting the current transaction count from the current threshold level.

14. The appliance of claim 13, wherein the processing unit further executes instructions to:

check the target appliance for capability of receiving the incoming transaction, wherein the target appliance calculates an adjusted value of the current threshold level at a point in time of negotiation and a sum of a current transaction count of the target appliance and a unit of the incoming transaction.

15. The appliance of claim 14, wherein the processing unit further executes instructions to:

re-direct the incoming transaction to the target appliance and update a transaction distribution table (TDT) in response to the adjusted value of the current threshold level of the target appliance being larger than the sum of the current transaction count of the target appliance and the unit of the incoming transaction.

16. The appliance of claim 9, wherein the current threshold level is a threshold in a Service Level Monitoring (SLM) policy.

17. A computer program product to negotiate the processing of incoming transactions based on resource utilization status of backend systems in an appliance cluster, the computer program product comprising a computer readable storage medium having program code embodied therewith, wherein the computer readable storage medium is not a transitory signal per se, and wherein the program code is readable and executable by a processor to perform a method comprising:

receiving, by a receiving appliance in an appliance cluster, an incoming transaction from a client device, wherein the incoming transaction is a specialized function for an appliance in the appliance cluster, and wherein all appliances in the appliance cluster share a same backend system that is in network communication with the appliance cluster;

determining whether the incoming transaction can be processed by a receiving appliance in the appliance cluster based on a current threshold level and a current transaction count of the receiving appliance, wherein the current threshold level is a sum of a first quantity of transactions that can be handled by a first appliance in the appliance cluster plus a second quantity of transactions that can be handled by a second appliance in the appliance cluster on behalf of the first appliance;

identifying a target appliance from the applicant cluster as a negotiation device in response to determining that the incoming transaction cannot be processed, wherein the negotiation device negotiates with another appliance in the appliance cluster to receive the incoming transaction; and

sending the incoming transaction from the negotiation device to a lending appliance in the appliance cluster, wherein the lending appliance is an original member of the appliance cluster, wherein the lending appliance has a highest amount of available capacity to handle transferred transactions from other appliances in the appliance cluster, wherein the highest amount of available capacity is based on the lending appliance having a greater current threshold level than any other appliance in the appliance cluster, and wherein the lending appliance has never been chosen before to receive a transferred incoming transaction from another appliance in the appliance cluster.