Session execution decision

• US 9,857,974 B2
• Filed: 08/04/2014
• Issued: 01/02/2018
• Est. Priority Date: 10/03/2013
• Status: Active Grant

• Current Assignee: Pure Storage, Inc.
• Original Assignee: International Business Machines Corporation
• Inventors: Baptist, Andrew, Kaczmarek, Joseph Martin, Vedpathak, Yogesh Ramesh
• Primary Examiner(s): HOANG, HIEU T
• Application Number:
  US14/450,804
• Publication Number:
  US 20150100697A1
• Time in Patent Office: 1,247 Days
• Field of Search: 709228, 709229
• CPC Class Codes: G06F 11/1076 Parity data used in redundant arrays of independent storages, e.g. in RAID systems
• CPC Class Codes: G06F 12/1458 by checking the subject access rights
• CPC Class Codes: G06F 16/10 File systems; File servers
• CPC Class Codes: G06F 16/182 Distributed file systems
• CPC Class Codes: G06F 21/31 User authentication
• CPC Class Codes: G06F 21/6272 by registering files or documents with a third party
• CPC Class Codes: G06F 2211/1028 Distributed, i.e. distributed RAID systems with parity
• CPC Class Codes: G06F 2212/1052 Security improvement
• CPC Class Codes: G06F 2212/154 Networked environment
• CPC Class Codes: G06F 2221/2149 Restricted operating environment
• CPC Class Codes: G06F 3/0604 Improving or facilitating administration, e.g. storage management
• CPC Class Codes: G06F 3/061 Improving I/O performance
• CPC Class Codes: G06F 3/0611 in relation to response time
• CPC Class Codes: G06F 3/0619 in relation to data integrity, e.g. data losses, bit errors
• CPC Class Codes: G06F 3/0622 in relation to access
• CPC Class Codes: G06F 3/0635 by changing the path, e.g. traffic rerouting, path reconfiguration
• CPC Class Codes: G06F 3/0637 Permissions
• CPC Class Codes: G06F 3/064 Management of blocks
• CPC Class Codes: G06F 3/0647 Migration mechanisms
• CPC Class Codes: G06F 3/0655 Vertical data movement, i.e. input-output transfer; data movement between one or more hosts and one or more storage devices
• CPC Class Codes: G06F 3/0665 : at area level, e.g. provisioning of virtual or logical volumes
• CPC Class Codes: G06F 3/067 : Distributed or networked storage systems, e.g. storage area networks [SAN], network attached storage [NAS]
• CPC Class Codes: G06F 3/0682 : Tape device
• CPC Class Codes: G06F 3/0689 : Disk arrays, e.g. RAID, JBOD
• CPC Class Codes: G06F 9/4881 : Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues
• CPC Class Codes: H04L 67/1001 : for accessing one among a plurality of replicated servers
• CPC Class Codes: H04L 67/1095 : Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
• CPC Class Codes: H04L 67/1097 : for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
• CPC Class Codes: H04L 67/145 : avoiding end of session, e.g. keep-alive, heartbeats, resumption message or wake-up for inactive or interrupted session

Abstract

A method includes a dispersed storage (DS) processing module receiving a request. The method continues by identifying a session associated with the request. The method continues by queueing one or more tasks associated with the request. The method continues by determining whether the session is still active. When the session is not active, the method continues by cancelling the one or more tasks associated with the session prior to execution. When the session is still active, the method continues by executing the first task of the one or more tasks when a task resource is available.

Claims

1. A method for execution by one or more processing modules of one or more computing devices of a dispersed storage network (DSN), the method comprises:

receiving a request, wherein the request comprises a read slice request for data;

identifying a session associated with the request;

queueing a task associated with the request and the session;

prior to being ready to execute the task, determining whether a decode threshold is met message is received, wherein the decode threshold is met message indicates that sufficient slices have been received to decode the data;

when the decode threshold is met message has been received, cancelling the task;

when the decode threshold is met message has not been received and when ready to execute the task, determining whether the session is still active based on a timeout or a detection of disconnection with a requesting entity or an end of session message has been received;

when the session is not active, cancelling the task; and

when the session is still active, executing the task when task resources are available.

2. The method of claim 1 further comprises determining whether the task resources are available to execute the task.

3. The method of claim 2 further comprises executing the task utilizing the available task resources.

4. The method of claim 1, wherein the task resources comprise one or more of:

computer processing;

computer storage; and

communications.

5. The method of claim 1, wherein the identifying a session includes one or more of:

receiving a session identifier;

initiating a query;

receiving a response;

assigning a new session number; and

obtaining a session from another storage unit.

6. The method of claim 1, wherein the queuing includes looking up the task and storing the task in a queue.

7. The method of claim 1, wherein the canceling includes removing the task from the queue.

8. The method of claim 1, wherein the determining whether the session is still active includes one or more of:

receiving a resource indicator;

receiving an indication that a threat is available;

receiving an indication that an aggregated partial result threshold has been met;

initiating a query;

receiving a response;

performing a look up; and

de-prioritizing another task associated with the resources.

9. A computing device of a dispersed storage network (DSN) configured to:

receive a request, wherein the request comprises a read slice request for data;

identify a session associated with the request;

queue a task associated with the request and the session;

prior to being ready to execute the task, determine whether a decode threshold is met message has been received, wherein the decode threshold is met message indicates that sufficient slices have been received to decode the data;

when the decode threshold is met message has been received, cancelling the task;

when the decode threshold is met message has not been received and when ready to execute the task, determine whether the session is still active based on a timeout or a detection of disconnection with a requesting entity or an end of session message has been received;

when the session is not active, cancel the task; and

when the session is still active, execute the task when a task resource is available.

10. The computing device of claim 9 further comprises determining whether resources are available to execute the task.

11. The computing device of claim 9, wherein the resources comprise one or more of:

computer processing;

computer storage; and

communications.

12. The computing device of claim 9, wherein the identifying a session includes one or more of:

receiving a session identifier;

initiating a query;

receiving a response;

assigning a new session number; and

obtaining a session from another storage unit.

13. The computing device of claim 9, wherein the canceling includes removing the task from the queue.

14. The computing device of claim 9, wherein the determining whether the session is still active includes one or more of:

receiving a resource indicator;

receiving an indication that a threat is available;

receiving an indication that an aggregated partial result threshold has been met;

initiating a query;

receiving a response;

performing a look up; and

de-prioritizing another task associated with the resources.