US 12,511,216 B2Granted

Distributed virtual data tank for cross service quota management

AssigneeMicrosoft Technology Licensing, LLC

InventorsJinghua Chen, Anatoly Victor Koretsky, Srivalli Chavali, Naresh Sundaram, Pradeep Kamalakumar, Steven James Rayson

Life of this patent

Estimating the term…

patentgrep

Loading patent…

Abstract

Disclosed are embodiments that communicate label information for documents between two enterprise computer systems. The two computer systems operate asynchronous from each other, and have limited available resources for use in buffering information passing between them. To that end, traditional API architectures that utilize method calls and return parameters do not operate well in this environment, as a first computer systems resources can become exhausted if a second computer system is able to generate data faster than the first computer system can consume it. The problem is exacerbated if an error is experienced when processing the consumed data, especially if there are no resources available to store the data until the error can be cleared. To solve this problem, the disclosed embodiments provide an ability for a consumer to request that data previously delivered to it be delivered again by the producer, in some embodiments, after a specified time delay.

Claims19

Dependent claims

A system, comprising:

hardware processing circuitry;
one or more memories storing instructions that when executed configure the hardware processing circuitry to perform operations comprising:
responsive to a read request, providing a plurality of documents to a labeling system;
receiving from the labeling system, a first message;
decoding, from the first message,
a first watermark indicating a first data item in a delivery queue that is to be retrieved next and
an indication that a label that indicates a sensitivity level for at least one of the plurality of documents is available;
determining a label storage space available in one or more second memories;
determining, based on the determined label storage space available, a data limit on an amount of response data;
transmitting a data request that includes the determined limit and the first watermark to the labeling system;
attempting to decode, from a second message from the labeling system
first labels including the first data item and
a second watermark indicating a second data item in the delivery queue after the first labels;
providing a retry request for the first labels;
adjusting the delivery queue to indicate the first labels are pending for delivery based on a time in the retry request;
and
after receiving the first labels, associating each label in the first labels with its respective document in the data store.

14 more elements

A system, comprising:

hardware processing circuitry;
one or more hardware memories storing instructions that when executed configure the hardware processing circuitry to perform operations comprising:
determining a label of a document associated with a read request, the label indicating a sensitivity level of the document;
storing the label in metadata of the document;
storing, in a delivery queue, indications of the label;
detecting a transition of a state of the delivery queue from empty to not empty;
notifying, in response to the detecting, a document processing system that the label is available, the notifying further indicating a first watermark of the delivery queue, the first watermark indicating a first data item in the delivery queue that is to be retrieved next;
attempting to decode, from a request for data, a limit on an amount of response data to be provided and the first watermark;
responsive to a retry request for the first labels, adjusting the delivery queue to indicate the first labels are pending for delivery based on a time in the retry request;
retrieving, from the delivery queue, and based on the first watermark decoded from the request for data, a number of labels consistent with the limit on response data;
determining, based on the number of labels, a second watermark of the delivery queue, the second watermark indicating a second data item in the delivery queue after the number of labels;
generating a first data response message to indicate the number of labels, a retrieved label, and the second watermark;
and
transmitting the first data response message to the document processing system.

11 more elements

A non-transitory computer readable storage medium comprising instructions that when executed configure hardware processing circuitry to perform operations comprising:

determining a label of a document associated with a read request, the label indicating a sensitivity level of the document;
storing the label in metadata of the document;
storing, in a delivery queue, indications of the label;
detecting a transition of a state of the delivery queue from empty to not empty;
notifying, in response to the detecting, a document processing system that the label is available, the notifying further indicating a first watermark of the delivery queue, the first watermark indicating a first data item in the delivery queue that is to be retrieved next;
attempting to decode, from a request for data, a limit on an amount of response data that is to be provided and the first watermark;
responsive to a retry request for the first labels, adjusting the delivery queue to indicate the first labels are pending for delivery based on a time in the retry request;
retrieving, from the delivery queue, and based on the first watermark decoded from the request for data, a number of labels consistent with the limit on response data;
determining, based on the number of labels, a second watermark of the delivery queue, the second watermark indicating a second data item in the delivery queue after the number of labels;
generating a first data response message to indicate the number of labels, a retrieved label, and the second watermark;
and
transmitting the first data response message to the document processing system.

9 more elements

Dependencies are inferred from the claim text.

Facts

Application: 18/358,715Filed 25 Jul 2023 · continuation
Priority: IN 20214100662317 Feb 2021
Published: US 2023/0409459 A121 Dec 2023
Granted: 30 Dec 2025
Term ends: Not estimatedThe source records don’t support an estimate.

Classification9 codes

G06F 11/3096
Monitoring arrangements determined by the means or processing involved in sensing the monitored data, e.g. interfaces, connectors, sensors,…:…
G06Q 10/10
Administration; Management: office automation; Time management
G06F 16/9017
Indexing; Data structures therefor; Storage structures: using directory or table look-up
G06F 16/9038
Querying: presentation of query results

Family

Application17/329,662Parent of this continuation · filed 25 May 2021
US 2023/0409459 A1Pre-grant publication · published 21 Dec 2023
US 11,755,445 B2Parent of this continuation
US 2022/0261328 A1Published application
US 12,511,216 B2This patent

From the US filing history. Foreign family members aren’t listed.