Modifying application behaviour

• US 8,763,018 B2
• Filed: 10/27/2011
• Issued: 06/24/2014
• Est. Priority Date: 08/22/2011
• Status: Active Grant

• Current Assignee: Xilinx, Inc. (Advanced Micro Devices, Inc.)
• Original Assignee: SolarFlare Communications Incorporated (Advanced Micro Devices, Inc.)
• Inventors: Pope, Steven L., Riddoch, David J., Mansley, Kieran
• Primary Examiner(s): Sough, H S
• Assistant Examiner(s): HOANG, PHUONG N
• Application Number:
  US13/283,423
• Publication Number:
  US 20130055287A1
• Time in Patent Office: 971 Days
• Field of Search: None
• US Class Current: 719/328
• 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 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 in the configuration data structure,

and wherein the action(s) to be performed for a sequence of one or more calls having predefined characteristics include one or more of;

forwarding the last call in the sequence of one or more calls to the application programming interface with unmodified or modified parameters;

suppressing the last call in the sequence of one or more calls such that it is not delivered to the application programming interface;

making one or more additional calls to the application programming interface or another application programming interface;

writing entries to a log;

pinning a thread executed in consequence of the sequence of one or more calls to a particular processor core of the data processing system; and

enabling spinning for a thread arranged to execute at the data processing system.

2. A data processing system as claimed in claim 1, wherein the predefined characteristics of a sequence of one or more calls include the type of call(s) and the parameters of the call(s).

3. A data processing system as claimed in claim 1, wherein the configuration data structure includes a plurality of specifications each defining a sequence of one or more calls having predefined characteristics and the corresponding action(s) to be performed by the intercept library on a sequence of one or more calls having those predefined characteristics being identified by the intercept library.

4. A data processing system as claimed in claim 1, wherein the configuration data structure is a code module that includes code of a particular programming language and the intercept library includes an interpreter configured to interpret that programming language.

5. A data processing system as claimed in claim 4, wherein the code module includes a handler function for each of at least some of the predetermined set of call types such that, on a sequence of one or more calls being intercepted by the intercept library, the intercept library is configured to call the respective handler function and perform the corresponding action(s) defined in that handler function.

6. A data processing system as claimed in claim 5, wherein at least some of the handler functions invoke routines of the intercept library in order to effect the corresponding action(s).

7. A data processing system as claimed in claim 1, wherein the action(s) are performed in the context of the last call in the sequence.

8. A data processing system as claimed in claim 1, wherein the configuration data structure includes object code arranged to provide a plurality of functions and at least some of the action(s) defined in the configuration data structure use the functions defined in the object code.

9. A data processing system as claimed in claim 8, wherein at least some of the actions defined in the configuration data structure are arranged to cause the intercept library to directly invoke functions of the object code.

10. A data processing system as claimed in claim 8, wherein the code module includes a handler function for each of at least some of the predetermined set of call types such that, on a sequence of one or more calls being intercepted by the intercept library, the intercept library is configured to call the respective handler function and perform the corresponding action(s) defined in that handler function, at least some of the handler functions of the code module being arranged to invoke a function of the object code.

11. A data processing system as claimed in claim 1, wherein the application programming interface is a socket library.

12. A data processing system as claimed in claim 1, wherein the predefined characteristics include characteristics of one or more of the following types:

socket identifier;

network protocol type;

destination address;

port number; and

source address.

13. A data processing system as claimed in claim 1, wherein the action(s) to be performed for a sequence of one or more calls having predefined characteristics include one or more of:

applying configuration options to a user level network stack; and

applying tuning options to a socket in respect of which at least some of the sequence of one or more intercepted calls were made.

14. A data processing system as claimed in claim 1, wherein the configuration data structure is further configured to identify the predetermined set of call types and, if the set of call types that the intercept library is configured to intercept does not match the predetermined set of calls types, a script is configured to, prior to initialising the intercept library, cause the intercept library to be recompiled so as to arrange that the set of call types that the intercept library is configured to intercept matches the predetermined set of call types identified in the configuration data structure.

15. A data processing system as claimed in claim 1, wherein the configuration data structure is supplied by a user.

16. A data processing system as claimed in claim 1, wherein the intercept library is a shared object or dynamic linked library.

17. A method of modifying how calls to an application programming interface operate, comprising:

intercepting calls of a predetermined set of call types from an application to the application programming interface;

matching in the intercepted calls one of a plurality of sequences of one or more calls having predefined characteristics, with one of a plurality of sequences of one or more calls defined by a configuration data structure; and

in response to matching a sequence of one or more calls, performing a set of at least one corresponding actions defined in the configuration data structure,

wherein the action(s) to be performed for a sequence of one or more calls having predefined characteristics include one or more of;

forwarding the last call in the sequence of one or more calls to the application programming interface with unmodified or modified parameters;

suppressing the last call in the sequence of one or more calls such that it is not delivered to the application programming interface;

making one or more additional calls to the application programming interface or another application programming interface;

writing entries to a log;

pinning a thread executed in consequence of the sequence of one or more calls to a particular processor core of the data processing system; and

enabling spinning for a thread arranged to execute at the data processing system.

18. 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,

and wherein the receive queue comprises an unfiltered queue and a filtered queue, the unfiltered queue initially receiving all messages for the socket, and the user level network protocol stack is configured to move from the unfiltered queue into the filtered queue only those messages that are not indicated to be discarded.

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

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

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

21. A data processing system as claimed in claim 18, 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.

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

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

23. A data processing system as claimed in claim 18, 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.

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

25. A data processing system as claimed in claim 18, wherein the user level network protocol stack is configured to not invoke the callback function if there are messages in the filtered queue.

26. A data processing system as claimed in claim 18, 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.

27. A data processing system as claimed in claim 18, 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.

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

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

30. A data processing system as claimed in claim 18, further comprising:

an intercept library configured to intercept calls made by the application to the 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.

31. A data processing system as claimed in claim 30, 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 newly created socket.

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

33. A data processing system as claimed in claim 18, wherein the callback function is provided by the intercept library.

34. A data processing system as claimed in claim 18, wherein the callback function is further operable to, on performing filtering of a message in the receive queue, return data by means of the callback function indicating one or more sub-messages within that message that are to be delivered to the socket, the remaining parts of the message to be discarded.

35. A data processing system as claimed in claim 34, wherein the one or more sub-messages are indicated by means of byte ranges of the message in the receive queue.

36. A data processing system as claimed in claim 18, 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.

37. A data processing system as claimed in claim 18, 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.

38. A data processing system as claimed in claim 18, 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.

39. 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 receive queue comprises an unfiltered queue and a filtered queue, the unfiltered queue initially receiving all messages for the socket, and the user level network protocol stack is configured to move from the unfiltered queue into the filtered queue only those messages that are not indicated to be discarded.

40. A data processing system comprising:

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

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 in the configuration data structure,

and wherein the configuration data structure is further configured to identify the predetermined set of call types and, if the set of call types that the intercept library is configured to intercept does not match the predetermined set of calls types, a script is configured to, prior to initialising the intercept library, cause the intercept library to be recompiled so as to arrange that the set of call types that the intercept library is configured to intercept matches the predetermined set of call types identified in the configuration data structure.

41. A method of modifying the operation of calls to an application programming interface comprising:

intercepting calls of a predetermined set of call types from an application to the application programming interface;

matching in the intercepted calls one of a plurality of sequences of one or more calls having predefined characteristics, with one of a plurality of sequences of one or more calls defined by a configuration data structure; and

in response to matching a sequence of one or more calls, performing a set of at least one corresponding actions defined in the configuration data structure,

and wherein the configuration data structure is configured to identify the predetermined set of call types and, if the set of call types that the intercept library is configured to intercept does not match the predetermined set of calls types, a script is configured to, prior to initialising the intercept library, cause the intercept library to be recompiled so as to arrange that the set of call types that the intercept library is configured to intercept matches the predetermined set of call types identified in the configuration data structure.

42. 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,

and wherein the callback function is further operable to, on performing filtering of a message in the receive queue, return data by means of the callback function indicating one or more sub-messages within that message that are to be delivered to the socket, the remaining parts of the message to be discarded.

43. A data processing system as claimed in claim 42, wherein the one or more sub-messages are indicated by means of byte ranges of the message in the receive queue.

44. 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 callback function is further operable to, on performing filtering of a message in the receive queue, return data by means of the callback function indicating one or more sub-messages within that message that are to be delivered to the socket, the remaining parts of the message to be discarded.

45. A method as claimed in claim 44, wherein the one or more sub-messages are indicated by means of byte ranges of the message in the receive queue.