Queue scheduling method and device, and computer storage medium

• US 10,079,772 B2
• Filed: 05/20/2014
• Issued: 09/18/2018
• Est. Priority Date: 12/30/2013
• Status: Active Grant

• Current Assignee: Sanechips Technology Co., Ltd. (ZTE Corporation)
• Original Assignee: Sanechips Technology Co., Ltd. (ZTE Corporation)
• Inventors: Wang, Bin
• Primary Examiner(s): Khirodhar, Maharishi V
• Application Number:
  US15/108,385
• Publication Number:
  US 20160330128A1
• Time in Patent Office: 1,582 Days
• CPC Class Codes: H04L 12/10 Current supply arrangements
• CPC Class Codes: H04L 47/6215 Individual queue per QOS, rate or priority

Abstract

Embodiments of the present disclosure disclose a queue scheduling method and device, and a computer storage medium. The method includes: arranging a scheduling expansion unit; receiving an enqueuing trigger message by the scheduling extension unit after a queue is written in a queue cache, where the enqueuing trigger message has a queue identifier and queue information of the queue; writing the queue identifier in a queue identifier cache and setting a state of the queue identifier to be in the queue identifier cache by the scheduling extension unit; sending an enqueuing report to a scheduling unit by the scheduling extension unit when no authorization arrives; and determining, by the scheduling unit, whether to schedule the queue according to the queue information of the queue.

Claims

1. A queue scheduling method, wherein a scheduling extension unit is arranged, comprising:

receiving an enqueuing trigger message by the scheduling extension unit after a queue is written in a queue cache, wherein the enqueuing trigger message includes a queue identifier;

writing the queue identifier in a queue identifier cache and setting a state of the queue identifier to be in the queue identifier cache by the scheduling extension unit;

acquiring queue information of the queue and sending an enqueuing report to a scheduling unit by the scheduling extension unit when no authorization arrives; and

determining, by the scheduling unit, whether to schedule the queue according to the queue information of the queue;

wherein the queue information comprises a queue depth and a queue authorized value;

determining, by the scheduling unit, whether to schedule the queue according to the queue information of the queue comprises;

the scheduling unit setting a scheduling state of the queue; and

determining, by the scheduling unit, whether the queue is to be scheduled according to the queue information of the queue after the scheduling unit receives the enqueuing report, comprises;

the scheduling unit scheduling the queue and setting a scheduling state of the queue as a scheduling-joined state when a scheduling state of the queue is a scheduling-unjoined state and a queue depth and a queue authorized value of the queue are not zero; and

the scheduling unit discarding the enqueuing report and stopping processing the queue when the scheduling state of the queue is a scheduling-joined state and a queue depth or a queue authorized value of the queue is zero.

2. The method according to claim 1, wherein writing the queue identifier in a queue identifier cache and setting a state of the queue identifier to be in the queue identifier cache by the scheduling extension unit, comprises:

searching the queue identifier cache by the scheduling extension unit according to the queue identifier;

writing the queue identifier in the queue identifier cache and setting a state of the queue identifier to be in the queue identifier cache when the queue identifier is not in the queue identifier cache; and

stopping processing the queue identifier cache and the state of the queue identifier when the queue identifier is in the queue identifier cache.

3. The method according to claim 2, further comprising:

reading the queue out of the queue cache and sending current queue information of the queue to the scheduling unit as a dequeuing report.

4. The method according to claim 3, wherein

determining, by the scheduling unit, whether to schedule the queue according to the queue information of the queue after the scheduling unit receives the dequeuing report, comprises:

the scheduling unit scheduling the queue and keeping a scheduling state of the queue unchanged when a queue depth of the queue is not zero and a queue authorized value of the queue is not zero; and

the scheduling unit discarding the dequeuing report and setting a scheduling state of the queue as a scheduling-unjoined state when a condition that the queue depth of the queue is not zero and the queue authorized value of the queue is not zero is not met.

5. The method according to claim 1, wherein sending an enqueuing report to a scheduling unit by the scheduling extension unit when no authorization arrives, comprises:

reading the queue identifier from the queue identifier cache and setting a state of the queue identifier to be not in the queue identifier cache;

reading the queue information of the queue to form an enqueuing report according to the read queue identifier; and

sending the enqueuing report to the scheduling unit.

6. The method according to claim 5, further comprising:

reading the queue out of the queue cache and sending current queue information of the queue to the scheduling unit as a dequeuing report.

7. The method according to claim 1, further comprising:

reading, by the scheduling extension unit when an authorization arrives, the queue information of the queue according to an authorized queue number when an authorization arrives to form an authorization report; and

sending the authorization report to the scheduling unit.

8. The method according to claim 7, further comprising:

reading the queue out of the queue cache and sending current queue information of the queue to the scheduling unit as a dequeuing report.

9. The method according to claim 7, wherein determining, by the scheduling unit, whether the queue is to be scheduled according to the queue information of the queue after the scheduling unit receives the authorization report, comprises:

the scheduling unit scheduling the queue and setting a scheduling state of the queue as a scheduling-joined state when a scheduling state of the queue is a scheduling-unjoined state, and a queue depth and a queue authorized value of the queue are not zero; and

the scheduling unit discarding the authorization report and stopping processing the queue when the scheduling state of the queue is a scheduling-joined state, and a queue depth or a queue authorized value of the queue is zero.

10. The method according to claim 1, further comprising:

reading the queue out of the queue cache and sending current queue information of the queue to the scheduling unit as a dequeuing report.

11. The method according to claim 10, wherein

determining, by the scheduling unit, whether to schedule the queue according to the queue information of the queue after the scheduling unit receives the dequeuing report, comprises:

scheduling the queue and keeping a scheduling state of the queue unchanged by the scheduling unit when a queue depth of the queue is not zero and a queue authorized value of the queue is not zero; and

discarding the dequeuing report and setting a scheduling state of the queue as a scheduling-unjoined state by the scheduling unit when a condition that the queue depth of the queue is not zero and the queue authorized value of the queue is not zero is not met.

12. A queue scheduling device, comprising:

a processor and a storage device, wherein the storage device stores processor-executable programs, and the programs comprise a scheduling extension unit and a scheduling unit, wherein

the scheduling extension unit is configured for;

receiving an enqueuing trigger message after a queue is written in a queue cache, wherein the enqueuing trigger message includes a queue identifier and queue information of a queue;

writing the queue identifier in the queue identifier cache and setting a state of the queue identifier to be in the queue identifier cache; and

acquiring queue information of the queue and sending an enqueuing report to the scheduling unit when no authorization arrives;

the scheduling unit is configured for;

determining whether to schedule the queue according to the queue information of the queue;

wherein the queue information comprises a queue depth and a queue authorized value;

the scheduling unit is configured for setting a scheduling state of the queue; and

after receiving the enqueuing report, the scheduling unit is further configured for;

scheduling the queue and setting a scheduling state of the queue as a scheduling-joined state when a scheduling state of the queue is a scheduling-unjoined state and a queue depth and a queue authorized value of the queue are not zero; and

discarding the enqueuing report and stopping processing the queue when a scheduling state of the queue is a scheduling-joined state and a queue depth or a queue authorized value of the queue is zero.

13. The device according to claim 12, wherein the scheduling extension unit is configured for:

searching the queue identifier cache according to the queue identifier;

writing the queue identifier in the queue identifier cache and setting a state of the queue identifier to be in the queue identifier cache when the queue identifier is not in the queue identifier cache; and

stopping processing the queue identifier cache and the state of the queue identifier when the queue identifier is in the queue identifier cache.

14. The device according to claim 12, further comprising an authorization unit configured for sending an authorization to the scheduling unit through the scheduling extension unit;

when no authorization arrives, the scheduling extension unit is configured for;

reading the queue identifier from the queue identifier cache and setting a state of the queue identifier to be not in the queue identifier cache;

reading the queue information of the queue to form an enqueuing report according to the read queue identifier; and

sending the enqueuing report to the scheduling unit.

15. The device according to claim 14, further comprising a dequeuing management unit configured for reading the queue out of the queue cache and sending current queue information of the queue to the scheduling unit as a dequeuing report.

16. The device according to claim 12, wherein when an authorization arrives, the scheduling extension unit is configured for:

reading the queue information of the queue according to an authorized queue number when an authorization arrives to form an authorization report; and

sending the authorization report to the scheduling unit.

17. The device according to claim 16, wherein after receiving the authorization report, the scheduling unit is further configured for:

scheduling the queue and setting a scheduling state of the queue as a scheduling-joined state when a scheduling state of the queue is a scheduling-unj oined state and a queue depth and a queue authorized value of the queue are not zero; and

discarding the authorization report and stopping processing the queue when a scheduling state of the queue is a scheduling-joined state and a queue depth or a queue authorized value of the queue is zero.

18. The device according to claim 12, further comprising a dequeuing management unit configured for reading the queue out of the queue cache and sending current queue information of the queue to the scheduling unit as a dequeuing report.

19. The device according to claim 18,

after receiving the dequeuing report, the scheduling unit is further configured for:

scheduling the queue and keeping a scheduling state of the queue unchanged when a queue depth of the queue is not zero and a queue authorized value of the queue is not zero; and

discarding the dequeuing report and setting a scheduling state of the queue as a scheduling-unjoined state when a condition that the queue depth of the queue is not zero and the queue authorized value of the queue is not zero is not met.

20. A non-transitory computer storage medium, in which a computer executable instruction is stored and is used for executing a queue scheduling method, wherein a scheduling extension unit is arranged, comprising:

receiving an enqueuing trigger message by the scheduling extension unit after a queue is written in a queue cache, wherein the enqueuing trigger message includes a queue identifier;

writing the queue identifier in a queue identifier cache and setting a state of the queue identifier to be in the queue identifier cache by the scheduling extension unit;

acquiring queue information of the queue and sending an enqueuing report to a scheduling unit by the scheduling extension unit when no authorization arrives; and

determining, by the scheduling unit, whether to schedule the queue according to the queue information of the queue;

wherein the queue information comprises a queue depth and a queue authorized value;

determining, by the scheduling unit, whether to schedule the queue according to the queue information of the queue comprises;

the scheduling unit setting a scheduling state of the queue; and

determining, by the scheduling unit, whether the queue is to be scheduled according to the queue information of the queue after the scheduling unit receives the enqueuing report, comprises;

the scheduling unit scheduling the queue and setting a scheduling state of the queue as a scheduling-joined state when a scheduling state of the queue is a scheduling-unjoined state, and a queue depth and a queue authorized value of the queue are not zero; and

the scheduling unit discarding the enqueuing report and stopping processing the queue when the scheduling state of the queue is a scheduling-joined state; and

a queue depth or a queue authorized value of the queue is zero.