lwes_listener.h

Go to the documentation of this file.

/*======================================================================*
 * Copyright (C) 2008 Light Weight Event System                         *
 * All rights reserved.                                                 *
 *                                                                      *
 * 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.                                  *
 *                                                                      *
 * 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, write to the Free Software          *
 * Foundation, Inc., 51 Franklin Street, Fifth Floor,                   *
 * Boston, MA 02110-1301 USA.                                           *
 *======================================================================*/
#ifndef __LWES_LISTENER_H
#define __LWES_LISTENER_H

#include "lwes_types.h"
#include "lwes_net_functions.h"
#include "lwes_event.h"

#ifdef __cplusplus
extern "C" {
#endif 

struct lwes_listener
{
  struct lwes_net_connection connection;
  struct lwes_event_deserialize_tmp *dtmp;
  LWES_BYTE_P buffer;
};

struct lwes_listener *
lwes_listener_create
  (LWES_SHORT_STRING address,
   LWES_SHORT_STRING iface,
   LWES_U_INT_32 port);

int
lwes_listener_add_header_fields
  (struct lwes_listener *listener,
   LWES_BYTE_P bytes,
   size_t max,
   size_t *len);

int
lwes_listener_event_has_name
  (LWES_BYTE_P bytes,
   size_t len,
   LWES_CONST_SHORT_STRING name);

int
lwes_listener_recv_process_event
  (struct lwes_listener *listener,
   struct lwes_event *event,
   int len);

int
lwes_listener_recv
  (struct lwes_listener *listener,
   struct lwes_event *event);

int
lwes_listener_recv_by
  (struct lwes_listener *listener,
   struct lwes_event *event,
   unsigned int timeout_ms);

int
lwes_listener_recv_bytes
  (struct lwes_listener *listener,
   LWES_BYTE_P bytes,
   size_t max);

int
lwes_listener_recv_bytes_by
  (struct lwes_listener *listener,
   LWES_BYTE_P bytes,
   size_t max,
   unsigned int timeout_ms);

int
lwes_listener_destroy
  (struct lwes_listener *listener);

#ifdef __cplusplus
}
#endif 

#endif /* __LWES_LISTENER_H */

---