24 _input_pres_read(nmsg_input_t input, nmsg_message_t *msg) {
31 while (fgets(line,
sizeof(line), input->pres->fp) != NULL) {
49 input->msgmod->plugin->msgtype.id,
void nmsg_timespec_get(struct timespec *ts)
Get the current time.
nmsg_res nmsg_msgmod_pres_to_payload_finalize(nmsg_msgmod_t mod, void *clos, uint8_t **pbuf, size_t *sz)
After a call to nmsg_msgmod_pres_to_payload() returns nmsg_res_pbuf_ready, this function will return ...
nmsg_res nmsg_msgmod_pres_to_payload(nmsg_msgmod_t mod, void *clos, const char *pres)
Convert a presentation format line to an NMSG payload.
a pbuf is ready to be written
nmsg_message_t nmsg_message_from_raw_payload(unsigned vid, unsigned msgtype, uint8_t *data, size_t sz, const struct timespec *ts)
Initialize a new message object from an opaque payload blob.