thread_message.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 THREAD_MESSAGE_H_
#define THREAD_MESSAGE_H_
#include "runtime_communication.h"
#include "inter_runtime_messages.h"
#include "rt_controller_messages.h"

enum thread_msg_type {
    UNKNOWN_THREAD_MSG = 0,

    // For the output monitor thread
    CONNECT_TO_RUNTIME = 13, 
    SEND_TO_PEER = 1000, 
    SEND_TO_CTRL = 1001, 
    // For worker threads
    CREATE_MSU = 2001, 
    DELETE_MSU = 2002, 
    MSU_ROUTE  = 3001, 
};

struct thread_msg {
    enum thread_msg_type type;
    int ack_id; 
    ssize_t data_size;
    void *data;
};

struct send_to_peer_msg {
    unsigned int runtime_id; 
    struct inter_runtime_msg_hdr hdr;
    void *data;
};

struct send_to_ctrl_msg {
    struct rt_controller_msg_hdr hdr;
    void *data;
};

struct thread_msg *init_send_thread_msg(unsigned int runtime_id,
                                        unsigned int target_id,
                                        size_t data_len,
                                        void *data);

void destroy_thread_msg(struct thread_msg *msg);

struct thread_msg *construct_thread_msg(enum thread_msg_type type,
                                        ssize_t data_size, void *data);

int enqueue_thread_msg(struct thread_msg *msg, struct msg_queue *queue);

struct thread_msg *dequeue_thread_msg(struct msg_queue *queue);

#endif