LCM
|
Sending and receiving LCM messages with C
This tutorial will walk you through the main tasks for exchanging messages using the LCM C API. It covers the following topics:
This tutorial uses the example_t
message type defined in the type definition tutorial, and assumes that you have generated the C bindings for the example type by running
After running this command, you should have two files: exlcm_example_t.c
and exlcm_example_t.h
. These two files are the C bindings for the example message type. Notice that the message type package name "exlcm" was prepended to the file name. This is how LCM emulates namespaces in C, and the package name is also prefixed to the generated C struct name.
If you have the time, take a moment to open up those two files and inspect the generated code.
The first task for any application that uses LCM is to initialize the library. Here's an example of that (and how to clean up after itself as well):
The function lcm_create() allocates and initializes an instance of lcm_t, which represents a connection to an LCM network. The single argument can be NULL
as shown above, to initialize LCM with default settings. The defaults initialized are suitable for communicating with other LCM applications on the local computer. The argument can also be a string specifying the underlying communications mechanisms. For communication across computers, or other usages such as reading data from an LCM logfile (e.g., to post-process or analyze previously collected data), see the API reference for lcm_create().
Once you're all done, it's a good idea to call lcm_destroy() to clean up any resources used by LCM.
When you create an LCM data type and generate C code with lcm-gen
, that data type will then be available as a C struct with the same name. For example_t
, the C struct that gets generated looks like this:
Notice here that fixed-length arrays in LCM appear as fixed-length C arrays. Variable length arrays appear as pointers in C. More on that below.
We can instantiate and then publish some sample data as follows:
The full example is available in runnable form as examples/c/send_message.c
in the LCM source distribution.
For the most part, this example should be pretty straightforward. Note that my_data.ranges
refers to a variable length array defined by the example_t
LCM type, and is represented by a pointer in the generated C struct. It is up to the programmer to set this pointer to an array of the proper type, and set my_data.num_ranges
to a value smaller or equal to the number of elements in that array. When the message is encoded, my_data.num_ranges
determines how many elements will actually be read and transmitted from my_data.ranges
. If my_data.num_ranges
is set to 0, the value of my_data.ranges
is ignored.
The call to exlcm_example_t_publish() serializes the data into a byte stream and transmits the packet using LCM to any interested receivers. The string "EXAMPLE"
is the channel name, which is a string transmitted with each packet that identifies the contents to receivers. Receivers subscribe to different channels using this identifier, allowing uninteresting data to be discarded quickly and efficiently.
As discussed above, each LCM message is transmitted with an attached channel name. You can use these channel names to determine which LCM messages your application receives, by subscribing to the channels of interest. It is important for senders and receivers to agree on the channel names which will be used for each message type.
Here is a sample program that sets up LCM and adds a subscription to the "EXAMPLE"
channel. Whenever a message is received on this channel, its contents are printed out. If messages on other channels are being transmitted over the network, this program will not see them because it only has a subscription to the "EXAMPLE"
channel. A particular instance of LCM may have an unlimited number of subscriptions.
The full example is available in runnable form as examples/c/listener.c
in the LCM source distribution.
A key design principal for this subscription code is that it is event driven. The application supplies a callback function to example_t_subscribe() that is called whenever a message is available. This happens inside a single thread without need for concurrency, since the callback is dispatched from within the lcm_handle() function.
It is important to call lcm_handle() whenever work needs to be done by LCM. If no work is needed, the function will block until there is. For applications without another type of main loop, it is suitable to call lcm_handle() in a loop as seen above. However, many applications already use some type of event loop. In these cases, it is best to monitor the LCM file descriptor, which can be obtained with lcm_get_fileno(). Whenever this file descriptor becomes readable, the application should call lcm_handle() which is guaranteed to not block in such a situation. Additional examples for doing this can be found in examples/c
, in the LCM source distribution.