Modifying application behaviour

• US 10,713,099 B2
• Filed: 04/10/2014
• Issued: 07/14/2020
• Est. Priority Date: 08/22/2011
• Status: Active Grant

• Current Assignee: Xilinx, Inc. (Advanced Micro Devices, Inc.)
• Original Assignee: Xilinx, Inc. (Advanced Micro Devices, Inc.)
• Inventors: Pope, Steven L., Riddoch, David J., Mansley, Kieran
• Primary Examiner(s): Wathen, Brian W
• Assistant Examiner(s): Hoang, Phuong N
• Application Number:
  US14/250,290
• Publication Number:
  US 20140304719A1
• Time in Patent Office: 2,287 Days
• Field of Search: None
• CPC Class Codes: G06F 2209/542 Intercept
• CPC Class Codes: G06F 9/541 via adapters, e.g. between incompatible applications
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

A data processing system comprising: an operating system providing an application programming interface; an application supported by the operating system and operable to make calls to the application programming interface; an intercept library configured to intercept calls of a predetermined set of call types made by the application to the application programming interface; and a configuration data structure defining at least one action to be performed for each of a plurality of sequences of one or more calls having predefined characteristics, the one or more calls being of the predetermined set of call types; wherein the intercept library is configured to, on intercepting a sequence of one or more calls defined in the configuration data structure, perform the corresponding action(s) defined by the configuration data structure.

Claims

1. A data processing system comprising:

a computing device having a processor and memory, the computing device configured with;

an operating system providing a socket library;

an application supported by the operating system and configured to receive messages at a socket established by means of the socket library;

a user level network protocol stack operable to perform receive processing of messages held at a receive queue corresponding to the said socket; and

a callback function operable to determine on behalf of the application whether to discard a message held at the receive queue;

wherein the application is operable to make a plurality of different calls of a first type to the socket library that cause state of the receive queue of the said socket to be revealed and the callback function is registered with the user level network protocol stack such that, in response to calls of the first type, the user level network protocol stack invokes the callback function in respect of each message held at the receive queue so as to cause the callback function to indicate to the user level network protocol stack whether each respective message at the receive queue is to be discarded,

wherein the user level network protocol stack is configured to provide packets that are not indicated to be discarded to a buffer of the application for delivery to the application.

2. A data processing system as claimed in claim 1, wherein the socket library is configured to offer a set of functions in accordance with a standard Berkeley sockets API.

3. A data processing system as claimed in claim 2, wherein the first type of calls includes:

recv( ), recvfrom( ), recvmsg( ), select( ), pselect( ), poll( ), ppoll( ), epoll_wait( ), epoll_pwait( ), read( ), readv( ), pread( ), getsockopt( ), and ioctl( ).

4. A data processing system as claimed in claim 1, wherein the user level network protocol stack is configured to, in response to an indication from the callback function that a message is to be discarded, cause that message to be discarded.

5. A data processing system as claimed in claim 1, wherein the state of the receive queue includes one or more of:

whether the receive queue is empty, number of messages held in the receive queue, and the messages themselves.

6. A data processing system as claimed in claim 1, wherein the callback function is configured to return a value indicating whether the message in respect of which the callback function was invoked is to be discarded.

7. A data processing system as claimed in claim 1, wherein the user level network protocol stack is configured not to invoke the callback function if the receive queue is empty.

8. A data processing system as claimed in claim 1, wherein the user level network protocol stack is configured to, in response to an indication that a message is to be discarded, set a flag for that message in the receive queue indicating that the message is to be discarded.

9. A data processing system as claimed in claim 1, wherein the call of the first type is a recv( )call and the user level network protocol stack is configured to provide to the socket only those messages that are indicated not to be discarded.

10. A data processing system as claimed in claim 1, wherein the application is configured to register the callback function for a socket in response to making a call to create that socket.

11. A data processing system as claimed in claim 10, wherein the callback function is provided by the application.

12. A data processing system as claimed in claim 1, further comprising:

an intercept library configured to intercept calls made by the application to an application programming interface; and

a configuration data structure arranged to cause the intercept library to register the callback function in response to intercepting a sequence of one or more calls having predefined characteristics defined in the configuration data structure.

13. A data processing system as claimed in claim 12, wherein the sequence of one or more calls is a single call to create a new socket, and the callback function is registered in respect of the new socket as created.

14. A data processing system as claimed in claim 13, wherein the configuration data structure includes object code and the callback function is provided by the object code.

15. A data processing system as claimed in claim 1, wherein the callback function is provided by an intercept library.

16. A data processing system as claimed in claim 1, wherein the callback function is further configured to, on performing filtering of a message in the receive queue, modify that message so as to bring the message into accordance with a predetermined network protocol.

17. A data processing system as claimed in claim 1, wherein the callback function is further configured to receive an indication of the number of filtered messages in the receive queue and, if the number of filtered messages exceeds a predetermined threshold, cause the rate of delivery of messages into the receive queue to be reduced and/or an error state to be indicated to the application.

18. A data processing system as claimed in claim 1, wherein the socket library is arranged to support one or more of:

inter-process communications at the operating system;

inter-process communications at processes supported at different operating systems of the data processing system; and

communications between remote processes at different data processing systems connected by means of a network.

19. A method of filtering messages at a receive queue of a data processing system, the receive queue being configured to receive messages for a socket of an application and the socket being established by means of a socket library, the data processing system further comprising a user level network protocol stack operable to perform receive processing of messages held at the receive queue, the method comprising:

registering a callback function such that, in response to calls from the application to the socket library that cause state of the receive queue of the socket to be revealed, the user level network protocol stack invokes the callback function in respect of each message held at the receive queue, the callback function being arranged to indicate to the user level network protocol stack whether each respective message at the receive queue is to be discarded; and

discarding those messages indicated the user level network protocol stack as being for discarding,

wherein the user level network protocol stack is configured to provide packets that are not indicated to be discarded to a buffer of the application for delivery to the application.