Microsoft Technology Licensing, LLC

Fujitsu Corporation

Patrick James Helland

Mohsen M Al-Ghosein

Rodney Thomas Limprecht

Thomas M Wicki

Wilfred G Russell

Wolf-Dietrich Weber

Takeshi Shimizu

Gagan Chopra

Luis Felipe Cabrera

Christopher G Kaler

Jan Stephen Gray

Steven E Lucco

David E Langworthy

David Richard Reed

Richard Dievendorff

Winfried W Wilcke

John Peter Shewchuk

Mohsen M Agsen

Greg Hope

Niklas Gustafsson

Amit Mital

Bimal Kumar Mehta

Jingren Zhou

Richard L Schober, Jr

Michael T Massa

Donald James McCrady

Anthony Dean Andrews

John Lawrence Hamby

Rod N Gamache

Jonathan A Forbes

Scott A Konersmann

Jeffrey D Larson

William D Devlin

Albert Mu

Raghu Sastry

Yasushi Umezawa

Matthew C McCline

Gerald L Hinson

Yaron Burd

Arunchallam S Sivakumar

Wing Leong Poon

Gregory Lucius Meredith

John P Shewchulk

Embodiments of the present invention relate to systems, methods, and computer-storage media for affinitizing datasets based on efficient query processing. In one embodiment, a plurality of datasets within a data stream is received. The data stream is partitioned based on efficient query processing. Once the data stream is partitioned, an affinity identifier is assigned to datasets based on the partitioning of the dataset. Further, when datasets are broken into extents, the affinity identifier of the parent dataset is retained in the resulting extent. The affinity identifier of each extent is then referenced to preferentially store extents having common affinity identifiers within close proximity of one other across a data center.

Affinitizing datasets based on efficient query processing

The present invention relates to systems and methods that facilitate serial access to related messages stored within a queue. The systems and methods comprise a conversation manager that generates conversation groups and associated conversation group identifiers for related messages, wherein related messages are associated with one or more dialog conversations between services. The conversation manager utilizes a respective conversation group identifier to lock a conversation group and provide exclusive serial access to the related messages therein and any related incoming messages to a reader such that only one reader at a time can access and process the related messages; other readers can still concurrently dequeue and process messages associated with other conversation groups. The present invention employs order queuing techniques that ensure messages are stored in-order, which facilitates in-order serial processing of messages in a conversation group.

Systems and methods that facilitate in-order serial processing of related messages

Systems and methods that integrate data type conversion(s) into a programming language, and describe external formats within a syntax thereof. A mapping component defines a declarative mapping from an external data format to one or more of its internal data types (e.g., expressing external data types in terms of source languages.) Moreover, a rule establishing component can define value-based rules, such as invariants to the external data format, wherein the schema declaration further defines data fields that make up the schema. Accordingly, by expressing rules in form of predicate logic (instead of imperative program logic) the subject innovation increase a likelihood that compilers can reason about the data.

Data schemata in programming language contracts

A method for executing a schedule in a workflow application is provided. The method includes selectively storing a schedule state to a storage medium based on a latency attribute associated with the schedule. Also provided is a method of executing a workflow application comprising long running transactions. This method includes selectively storing a schedule state to a storage medium based on a latency attribute associated with the schedule, and selectively compensating certain actions within the schedule according to a compensation parameter associated with an action, based on failure or abortion of another action within the schedule. In addition, there is provided a method of executing a schedule comprising selectively compensating certain actions or transactions within the schedule according to a compensation parameter associated with an action or transaction, based on failure or abortion of another action or transaction within the schedule.

Long running transaction integration with selective dehydration and selective compensation

Reliable end-to-end messaging in which tracking and acknowledgement information are contained in the electronic message that is visible to layers above the transport layer, thereby being independent of what transport protocols, and whether different transport protocols, are used to communicate between the two end points. Furthermore, acknowledgment messages may identify multiple ranges of sequence numbers corresponding to received electronic messages, thereby permitting further flexibility and completeness in acknowledging received messages.

End-to-end reliable messaging with complete acknowledgement

Queued component interface passing provides a way for a queued component to convey results of processing a client program's method invocations made asynchronously via a queue. A queued component recorder for a 'processing' queued component operates to marshal-by-value a method invocation parameter that is reference to another queued component recorder for another 'results' queued component into a data stream of recorded method invocations, which is then submitted as a message to a queue associated with the processing queued component. On receipt of the message from the queue, a queued component player for the processing queued component unmarshals the reference to the other queued component recorder and passes this reference to the processing queued component. The processing queued component uses the passed reference to invoke methods of the results queued component through its message queue, which conveys the processing queued component's results.

Queued component interface passing for results outflow from queued method invocations

A run-time executive of an object management system for managing execution of software components in an object execution environment uses a component context object to store intrinsic context properties related to an associated component. The run-time executive maintains an implicit association of the component context object with the application component. For example, the context properties can include a client id, an activity id, and a transaction reference. The component context object also provides an interface accessible to the associated component, with member functions for use in transaction processing, in creating additional other application components inheriting component's context properties, and in access control based on abstract user classes (roles).

Software component execution management using context objects for tracking externally-defined intrinsic properties of executing software components within an execution environment

A system and method for employing a key exchange key to facilitate secure communication is provided. The key exchange key can be employed, for example, to encrypt and/or decrypt dialog session key(s) that are used to encrypt and/or decrypt message(s) that form a dialog between an initiator system and target system. In one example, a key exchange key is unique to a service pair, while a dialog session key is unique to a particular dialog between the service pair. The system can facilitate end-to-end encryption of message data in a dialog&#x2014;the message data is encrypted at one dialog endpoint and not decrypted until it reaches the other dialog endpoint. The system can be employed to facilitate secure dialog with minimal performance overhead when compared with conventional system(s). Optionally, the system can facilitate load balancing (e.g., among deployed instances of a service). In this example, secured dialogs to a service can be location transparent so that a dialog targeted to a service can be able to talk to any instance of the same service transparently without any additional security setup. The system employs both public key/private key asymmetric encryption technique(s) and symmetric encryption technique(s) to authenticate and secure information exchanged between an initiator system and a target system.

Session key exchange key

A component-based framework includes system services and component integration interfaces that provide a run-time environment for component-based server application in which server application components have control over the duration of their state independent of client action. The framework provides functions that a server application component calls to indicate its work for a client is complete, and its state is to be destroyed. On the component's return from the client's method call, the framework destroys the component's state thus releasing any server computer resources held by the component. This allows the server application components to be programmed so as to minimize the duration that their state remains in memory consuming server computer resources, and which enhances scalability of the server application.

Recycling components after self-deactivation

Component self-deactivation while client holds a returned reference

Server application components with control over state duration

Growing community of inventors

Bellevue, WA, United States of America

Patrick James Helland