Chicago Mercantile Exchange Inc.

Kyle Dennis Kavanagh

José Antonio Acuña-Rohter

Pearce Peck-Walden

David Michael Wong

Ari L Studnitzer

Eric Schuldt

Paul J Callaway

Jose Antonio Acuña-Rohter

Elisa Lugo

Joshua Hoffberg

Christopher Walsh

Viren Soni

Sherry Bryant

Jose Antonio Acuna-Rohter

Andrew Pikler

José Antonio Acuna-Rohter

José Antonio Acuna-Rother

A monitoring system monitors processing of incoming messages and logs data related to performance of an application that processes the messages. The monitoring system temporarily associates reusable identifiers with the messages and logs data upon each message traversing different points in the application. Each of the identifiers is sized such that the storage space necessary to store the identifier is less than the storage space necessary to store an identifier sized to uniquely identify all of the plurality of messages, and the identifiers and the logged data are configured to minimize a performance penalty of monitoring the application. The monitoring system parses the data, e.g., during post-processing, to determine, from a plurality of data entries that refers to the same identifier, a subset of the data entries where the same identifier was associated with the same message.

Compressed message tracing and parsing

A data transaction processing system receives electronic data transaction request messages from client computers over a data communication network and augments each message with hardware level data, and generates a monotonically increasing identification number for each electronic data transaction request message based on the hardware level data. The data transaction processing system transmits the identification number to the client computer utilizing transport layer protocols.

Communications protocol based message identification transmission

In a system including a primary process followed by a secondary process, which are performed serially and sequentially, i.e., in a FIFO manner, where the secondary process is downstream of the primary process, the disclosed embodiments relate to selective/conditional secondary processing of electronic data transaction request messages, which speeds up the primary processing of the electronic data transaction request messages, reduces the amount of computing resources wasted on calculating inaccurate information, and reduces the usage of network resources associated with publishing market data feeds and receiving new responsive messages.

Conservation of electronic communications resources and computing resources via selective processing of substantially continuously updated data

A data storage system for use with a multi-threaded processing system receives concurrent requests to store data to a common data store, and efficiently and securely swaps an active data store for a new data store while avoiding conflicts arising from multiple threads attempting to swap a same data store and minimizing reliance on operations that re-attempt actions upon failure of an attempted action, thereby improving performance of the data storage system and also the multi-threaded processing system.

Concurrent write operations for use with multi-threaded file logging

A performance measurement indexing system indexes a data store containing data entries indicative of message processing by an application. The application includes a plurality of checkpoints, and the data store contains data logged upon each message traversing the checkpoints in the application. The performance measurement indexing system determines which data entries relate to messages that satisfy a delay condition, and limits queries run on the data store to those data entries, thereby increasing the speed and efficiency with which queries can be serviced.

Database indexing in performance measurement systems

A monitoring system monitors processing of incoming messages by an application, and logs data related to performance of the application. The application includes a plurality of checkpoints, and the monitoring system logs data upon each message traversing the checkpoints in the application. The monitoring system is configured to dynamically modify checkpoints within the application based on latency detection of portions of the application, resulting in improved granularity/resolution of the data collected from congested portions of the application, and reducing the performance penalty of the monitoring system from portions of the application that are not congested.

Dynamic tracer message logging based on bottleneck detection

A method for generating a prediction of a latency of a transaction processing system includes: sampling a first plurality of messages from a database that stores data indicative of messages previously processed by the transaction processing system including a characteristic and a processing time of each previously processed message; generating latency tables based upon the characteristics and the processing times of the sampled first plurality of messages; determining a characteristic of each of a second plurality of messages being processed by the transaction processing system; selecting, for each of the second plurality of messages, a latency table from the plurality of latency tables based upon the respective determined characteristic; simulating a processing time for each of the second plurality of messages based upon the respective selected latency table; and generating a latency prediction for the transaction processing system based upon the simulated processing times for the second plurality of messages.

Systems and methods for calculating a latency of a transaction processing system

The disclosed embodiments relate to a mechanism for allowing concurrent access, e.g. write operations, to a data structure, e.g. a file, which may have limited capacity, by multiple processes or threads and, in particular, for allowing concurrent, or otherwise substantially simultaneously, appending of data to the file thereby. Each process/thread requests the amount of space it needs to append its data. Upon request, the disclosed mechanism allocates and reserves the requested amount of space and allows the requesting process/thread to commence its append operation. Subsequent to the commencement of the append operation, another thread is then free to request space for its needs and commence its append operation concurrently, or otherwise substantially simultaneously, with the previous append operation, i.e. before the prior append operation is completed.

Thread safe lock-free concurrent write operations for use with multi-threaded in-line logging

In a system including a primary process followed by a secondary process, which are performed serially and sequentially, i.e., in a FIFO manner, where the secondary process is downstream of the primary process, the disclosed embodiments relate to selective/conditional secondary processing of electronic data transaction request messages, which speeds up the primary processing of the electronic data transaction request messages, reduces reduce the amount of computing resources wasted on calculating inaccurate information, and reducing the usage of network resources associated with publishing market data feeds and receiving new responsive messages.

Growing community of inventors

Chicago, IL, United States of America

Kyle Dennis Kavanagh