| /* |
| * Copyright (C) 2008 Martin Willi |
| * HSR Hochschule fuer Technik Rapperswil |
| * |
| * 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 2 of the License, or (at your |
| * option) any later version. See <http://www.fsf.org/copyleft/gpl.txt>. |
| * |
| * 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. |
| */ |
| |
| /** |
| * @defgroup ha_dispatcher ha_dispatcher |
| * @{ @ingroup ha |
| */ |
| |
| #ifndef HA_DISPATCHER_H_ |
| #define HA_DISPATCHER_H_ |
| |
| #include "ha_socket.h" |
| #include "ha_segments.h" |
| #include "ha_cache.h" |
| #include "ha_kernel.h" |
| #include "ha_attribute.h" |
| |
| typedef struct ha_dispatcher_t ha_dispatcher_t; |
| |
| /** |
| * The dispatcher pulls messages in a thread an processes them. |
| */ |
| struct ha_dispatcher_t { |
| |
| /** |
| * Destroy a ha_dispatcher_t. |
| */ |
| void (*destroy)(ha_dispatcher_t *this); |
| }; |
| |
| /** |
| * Create a ha_dispatcher instance pulling from socket. |
| * |
| * @param socket socket to pull messages from |
| * @param segments segments to control based on received messages |
| * @param cache message cache to use for resynchronization |
| * @param kernel kernel helper |
| * @param attr HA enabled pool |
| * @return dispatcher object |
| */ |
| ha_dispatcher_t *ha_dispatcher_create(ha_socket_t *socket, |
| ha_segments_t *segments, ha_cache_t *cache, |
| ha_kernel_t *kernel, ha_attribute_t *attr); |
| |
| #endif /** HA_DISPATCHER_ @}*/ |
