messages.h

一个Windows下的Linux专用虚拟机

/*
 * This source code is a part of coLinux source package.
 *
 * Dan Aloni <[e-mail]>, 2003 (c)
 *
 * The code is licensed under the GPL. See the COPYING file at
 * the root directory.
 */

#ifndef __CO_KERNEL_MESSAGES_H__
#define __CO_KERNEL_MESSAGES_H__

#include "list.h"
#include "queue.h"
#include "common.h"

typedef co_rc_t (*co_switch_rule_func_t)(void *data, co_message_t *message);

typedef enum {
	CO_SWITCH_RULE_TYPE_CALLBACK,
	CO_SWITCH_RULE_TYPE_REROUTE,
} co_switch_rule_type;

typedef struct co_switch_rule {
	co_switch_rule_type type;
	co_module_t destination;
	co_list_t node;
	union {
		struct {
			co_switch_rule_func_t func;
			void *data;
		};
		co_module_t reroute_destination;
	};
} co_switch_rule_t;

typedef enum {
	CO_SWITCH_MESSAGE_SET_REROUTE_RULE,
	CO_SWITCH_MESSAGE_FREE_RULE,
} co_switch_message_type;

typedef struct co_switch_message {
	co_switch_message_type type;
	co_module_t destination;
	co_module_t reroute_destination;
} co_switch_message_t;

typedef struct co_message_queue_item {
	co_message_t *message;
} co_message_queue_item_t;

typedef struct co_message_switch {
	co_module_t switch_id;
	co_list_t list;
} co_message_switch_t;

typedef char co_module_name_t[0x20];

extern void co_message_switch_init(co_message_switch_t *ms, co_module_t switch_id);
extern co_rc_t co_message_switch_set_rule(co_message_switch_t *ms, co_module_t destination,
					  co_switch_rule_func_t func, void *data);
extern co_rc_t co_message_switch_set_rule_reroute(co_message_switch_t *ms, co_module_t destination, co_module_t new_destination);
extern co_rc_t co_message_switch_set_rule_queue(co_message_switch_t *ms, co_module_t destination, co_queue_t *queue);
extern co_rc_t co_message_switch_free_rule(co_message_switch_t *ms, co_module_t destination);
extern bool_t co_message_switch_rule_exists(co_message_switch_t *ms, co_module_t destination);
extern co_rc_t co_message_switch_message(co_message_switch_t *ms, co_message_t *message);
extern co_rc_t co_message_switch_dup_message(co_message_switch_t *ms, co_message_t *message);
extern void co_message_switch_free(co_message_switch_t *ms);
extern co_rc_t co_message_dup(co_message_t *message, co_message_t **dup_message_out);
extern co_rc_t co_message_dup_to_queue(co_message_t *message, co_queue_t *queue);
extern co_rc_t co_message_write_queue(co_queue_t *queue, char *buffer, unsigned long size,
				      unsigned long *sent_count, unsigned long *sent_size);

extern char *co_module_repr(co_module_t module, co_module_name_t *str);

#endif