lcc/clcc/remote/config_map/config_map.c

#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <signal.h>
#include "clcc.h"

#define TASK_COMM_LEN 16
struct data_t {
    unsigned int c_pid;
    unsigned int p_pid;
    char c_comm[TASK_COMM_LEN];
    char p_comm[TASK_COMM_LEN];
};

void event_cb(void *ctx, int cpu, void *data, unsigned int size){
    struct data_t *e = (struct data_t *)data;
    printf("poll message: c_pid:%d, p_pid:%d\n", e->c_pid, e->p_pid);
    printf("c_comm:%s, p_comm:%s\n", e->c_comm, e->p_comm);
}

void user_config(struct clcc_struct *pclcc) {
    unsigned int key = 0;
    unsigned int val = 1;

    pclcc->map_update_elem(pclcc->get_maps_id("user_config"), &key, &val);
}

void event_run(struct clcc_struct* pclcc) {
    int event_id;

    event_id = pclcc->get_maps_id("e_out");
    if (event_id < 0) {
        printf("get %s map id failed.\n", "e_out");
        return;
    }

    pclcc->set_event_cb(event_id, event_cb, NULL);
    pclcc->event_loop(event_id, 10);
}

static void stop(int signo){
    printf("signal.\n");
}

int main(int argc,char *argv[]) {
    struct clcc_struct* pclcc = clcc_init("./"SO_NAME);

    if (pclcc == NULL) {
        printf("open so file failed.\n");
        exit(-1);
    }

    signal(SIGINT, stop);
    pclcc->init(-1, 1);
    printf("The program starts executing and will exit after 10 seconds.\n");
    printf("user config map\n");
    user_config(pclcc);
    event_run(pclcc);

    pclcc->exit();
    clcc_deinit(pclcc);
    return 0;
}