local_msu.h

Go to the documentation of this file.

/*
START OF LICENSE STUB
    DeDOS: Declarative Dispersion-Oriented Software
    Copyright (C) 2017 University of Pennsylvania, Georgetown University

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
END OF LICENSE STUB
*/
#ifndef LOCAL_MSU_H_
#define LOCAL_MSU_H_
#include "msu_type.h"
#include "message_queue.h"
#include "worker_thread.h"

// Forward declaration due to circular dependency
struct msu_msg_hdr;
struct msu_msg_key;

struct local_msu {

    struct msu_type *type;

    struct route_set routes;

    unsigned int id;

    unsigned int scheduling_weight;

    struct msg_queue queue;

    struct msu_state *item_state;

    void *msu_state;

    struct worker_thread *thread;
};

struct local_msu *init_msu(unsigned int id, struct msu_type *type,
                           struct worker_thread *thread, struct msu_init_data *data);

int try_destroy_msu(struct local_msu *msu);

void destroy_msu(struct local_msu *msu);

int msu_dequeue(struct local_msu *msu);

struct local_msu *get_local_msu(unsigned int id);

int msu_error(struct local_msu *msu, struct msu_msg_hdr *hdr, int broadcast);
#endif