message_state.h

Go to the documentation of this file.

#ifndef MESSAGE_STATE_H
#define MESSAGE_STATE_H

#include "node.h"
typedef struct message_t message_t; // forward declaration
typedef struct message_state_t {
    int progress_every;

    size_t parsed_length;

    void (*cb_progress)(message_t *message, size_t total, size_t current);

    void (*cb_start)(message_t *message);

    void (*cb_end)(message_t *message, size_t max, size_t current, int exit_code);

    void (*cb_segment)(message_t *message, size_t num, char name[3]);
} message_state_t;

#ifdef __cplusplus
extern "C" {
#endif

message_state_t *message_state_new();

void message_state_free(message_state_t *ms);

/*
static size_t hl7_decode_cb_max, 
              hl7_decode_cb_current, 
              hl7_decode_cb_every = 0;

static void (*hl7_decode_cb_callback)(size_t max, size_t current);
static void hl7_decode_cb_reset() {
    hl7_decode_cb_max = 0;
    hl7_decode_cb_current = 0;
    hl7_decode_cb_every = 0;
}

static void hl7_decode_cb(size_t max, size_t current) {
    // global vars to track progress, be careful, this is not thread safe
    hl7_decode_cb_callback(hl7_decode_cb_max, hl7_decode_cb_current);
}

void hl7_decode_cb_register(void (*callback)(size_t max, size_t current), size_t max, size_t every) {
    hl7_decode_cb_reset();
    hl7_decode_cb_every    = every;
    hl7_decode_cb_max      = max;
    hl7_decode_cb_callback = callback;
}
*/

#ifdef __cplusplus
}
#endif

#endif // MESSAGE_STATE_H