303 lines
9.4 KiB
C
303 lines
9.4 KiB
C
|
/* omapip_p.h
|
||
|
|
|
||
|
|
Private master include file for the OMAPI library. */
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Copyright (c) 1996-2001 Internet Software Consortium.
|
||
|
|
* All rights reserved.
|
||
|
|
*
|
||
|
|
* Redistribution and use in source and binary forms, with or without
|
||
|
|
* modification, are permitted provided that the following conditions
|
||
|
|
* are met:
|
||
|
|
*
|
||
|
|
* 1. Redistributions of source code must retain the above copyright
|
||
|
|
* notice, this list of conditions and the following disclaimer.
|
||
|
|
* 2. Redistributions in binary form must reproduce the above copyright
|
||
|
|
* notice, this list of conditions and the following disclaimer in the
|
||
|
|
* documentation and/or other materials provided with the distribution.
|
||
|
|
* 3. Neither the name of The Internet Software Consortium nor the names
|
||
|
|
* of its contributors may be used to endorse or promote products derived
|
||
|
|
* from this software without specific prior written permission.
|
||
|
|
*
|
||
|
|
* THIS SOFTWARE IS PROVIDED BY THE INTERNET SOFTWARE CONSORTIUM AND
|
||
|
|
* CONTRIBUTORS ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,
|
||
|
|
* INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
|
||
|
|
* MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
||
|
|
* DISCLAIMED. IN NO EVENT SHALL THE INTERNET SOFTWARE CONSORTIUM OR
|
||
|
|
* CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||
|
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||
|
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
|
||
|
|
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
||
|
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
||
|
|
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
|
||
|
|
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
||
|
|
* SUCH DAMAGE.
|
||
|
|
*
|
||
|
|
* This software has been written for the Internet Software Consortium
|
||
|
|
* by Ted Lemon in cooperation with Vixie Enterprises and Nominum, Inc.
|
||
|
|
* To learn more about the Internet Software Consortium, see
|
||
|
|
* ``http://www.isc.org/''. To learn more about Vixie Enterprises,
|
||
|
|
* see ``http://www.vix.com''. To learn more about Nominum, Inc., see
|
||
|
|
* ``http://www.nominum.com''.
|
||
|
|
*/
|
||
|
|
|
||
|
|
#ifndef __OMAPIP_OMAPIP_P_H__
|
||
|
|
#define __OMAPIP_OMAPIP_P_H__
|
||
|
|
|
||
|
|
#ifndef __CYGWIN32__
|
||
|
|
#include <sys/types.h>
|
||
|
|
#include <netinet/in.h>
|
||
|
|
#include <sys/socket.h>
|
||
|
|
#include <sys/un.h>
|
||
|
|
#include <arpa/inet.h>
|
||
|
|
|
||
|
|
#include <netdb.h>
|
||
|
|
#else
|
||
|
|
#define fd_set cygwin_fd_set
|
||
|
|
#include <sys/types.h>
|
||
|
|
#endif
|
||
|
|
#include <fcntl.h>
|
||
|
|
#include <stdio.h>
|
||
|
|
#include <unistd.h>
|
||
|
|
#include <string.h>
|
||
|
|
#include <memory.h>
|
||
|
|
#include <stdlib.h>
|
||
|
|
#include <sys/stat.h>
|
||
|
|
#include <ctype.h>
|
||
|
|
#include <time.h>
|
||
|
|
|
||
|
|
#include "cdefs.h"
|
||
|
|
#include "osdep.h"
|
||
|
|
|
||
|
|
#include <isc-dhcp/dst.h>
|
||
|
|
#include <isc-dhcp/result.h>
|
||
|
|
|
||
|
|
#include <omapip/convert.h>
|
||
|
|
#include <omapip/hash.h>
|
||
|
|
#include <omapip/omapip.h>
|
||
|
|
#include <omapip/trace.h>
|
||
|
|
|
||
|
|
/* OMAPI protocol header, version 1.00 */
|
||
|
|
typedef struct {
|
||
|
|
u_int32_t authlen; /* Length of authenticator. */
|
||
|
|
u_int32_t authid; /* Authenticator object ID. */
|
||
|
|
u_int32_t op; /* Opcode. */
|
||
|
|
omapi_handle_t handle; /* Handle of object being operated on,
|
||
|
|
or zero. */
|
||
|
|
u_int32_t id; /* Transaction ID. */
|
||
|
|
u_int32_t rid; /* ID of transaction to which this is a response. */
|
||
|
|
} omapi_protocol_header_t;
|
||
|
|
|
||
|
|
#define OMAPI_PROTOCOL_VERSION 100
|
||
|
|
|
||
|
|
#define OMAPI_OP_OPEN 1
|
||
|
|
#define OMAPI_OP_REFRESH 2
|
||
|
|
#define OMAPI_OP_UPDATE 3
|
||
|
|
#define OMAPI_OP_NOTIFY 4
|
||
|
|
#define OMAPI_OP_STATUS 5
|
||
|
|
#define OMAPI_OP_DELETE 6
|
||
|
|
|
||
|
|
typedef enum {
|
||
|
|
omapi_connection_unconnected,
|
||
|
|
omapi_connection_connecting,
|
||
|
|
omapi_connection_connected,
|
||
|
|
omapi_connection_disconnecting,
|
||
|
|
omapi_connection_closed
|
||
|
|
} omapi_connection_state_t;
|
||
|
|
|
||
|
|
typedef enum {
|
||
|
|
omapi_protocol_intro_wait,
|
||
|
|
omapi_protocol_header_wait,
|
||
|
|
omapi_protocol_signature_wait,
|
||
|
|
omapi_protocol_name_wait,
|
||
|
|
omapi_protocol_name_length_wait,
|
||
|
|
omapi_protocol_value_wait,
|
||
|
|
omapi_protocol_value_length_wait
|
||
|
|
} omapi_protocol_state_t;
|
||
|
|
|
||
|
|
typedef struct __omapi_message_object {
|
||
|
|
OMAPI_OBJECT_PREAMBLE;
|
||
|
|
struct __omapi_message_object *next, *prev;
|
||
|
|
omapi_object_t *object;
|
||
|
|
omapi_object_t *notify_object;
|
||
|
|
struct __omapi_protocol_object *protocol_object;
|
||
|
|
u_int32_t authlen;
|
||
|
|
omapi_typed_data_t *authenticator;
|
||
|
|
u_int32_t authid;
|
||
|
|
omapi_object_t *id_object;
|
||
|
|
u_int32_t op;
|
||
|
|
u_int32_t h;
|
||
|
|
u_int32_t id;
|
||
|
|
u_int32_t rid;
|
||
|
|
} omapi_message_object_t;
|
||
|
|
|
||
|
|
typedef struct __omapi_remote_auth {
|
||
|
|
struct __omapi_remote_auth *next;
|
||
|
|
omapi_handle_t remote_handle;
|
||
|
|
omapi_object_t *a;
|
||
|
|
} omapi_remote_auth_t;
|
||
|
|
|
||
|
|
typedef struct __omapi_protocol_object {
|
||
|
|
OMAPI_OBJECT_PREAMBLE;
|
||
|
|
u_int32_t header_size;
|
||
|
|
u_int32_t protocol_version;
|
||
|
|
u_int32_t next_xid;
|
||
|
|
|
||
|
|
omapi_protocol_state_t state; /* Input state. */
|
||
|
|
int reading_message_values; /* True if reading message-specific
|
||
|
|
values. */
|
||
|
|
omapi_message_object_t *message; /* Incoming message. */
|
||
|
|
omapi_data_string_t *name; /* Incoming name. */
|
||
|
|
omapi_typed_data_t *value; /* Incoming value. */
|
||
|
|
isc_result_t verify_result;
|
||
|
|
omapi_remote_auth_t *default_auth; /* Default authinfo to use. */
|
||
|
|
omapi_remote_auth_t *remote_auth_list; /* Authenticators active on
|
||
|
|
this connection. */
|
||
|
|
|
||
|
|
isc_boolean_t insecure; /* Set to allow unauthenticated
|
||
|
|
messages. */
|
||
|
|
|
||
|
|
isc_result_t (*verify_auth) (omapi_object_t *, omapi_auth_key_t *);
|
||
|
|
} omapi_protocol_object_t;
|
||
|
|
|
||
|
|
typedef struct {
|
||
|
|
OMAPI_OBJECT_PREAMBLE;
|
||
|
|
|
||
|
|
isc_boolean_t insecure; /* Set to allow unauthenticated
|
||
|
|
messages. */
|
||
|
|
|
||
|
|
isc_result_t (*verify_auth) (omapi_object_t *, omapi_auth_key_t *);
|
||
|
|
} omapi_protocol_listener_object_t;
|
||
|
|
|
||
|
|
#include <omapip/buffer.h>
|
||
|
|
|
||
|
|
typedef struct __omapi_listener_object {
|
||
|
|
OMAPI_OBJECT_PREAMBLE;
|
||
|
|
int socket; /* Connection socket. */
|
||
|
|
int index;
|
||
|
|
struct sockaddr_in address;
|
||
|
|
isc_result_t (*verify_addr) (omapi_object_t *, omapi_addr_t *);
|
||
|
|
} omapi_listener_object_t;
|
||
|
|
|
||
|
|
typedef struct __omapi_connection_object {
|
||
|
|
OMAPI_OBJECT_PREAMBLE;
|
||
|
|
int socket; /* Connection socket. */
|
||
|
|
int32_t index;
|
||
|
|
omapi_connection_state_t state;
|
||
|
|
struct sockaddr_in remote_addr;
|
||
|
|
struct sockaddr_in local_addr;
|
||
|
|
omapi_addr_list_t *connect_list; /* List of addresses to which
|
||
|
|
to connect. */
|
||
|
|
int cptr; /* Current element we are connecting to. */
|
||
|
|
u_int32_t bytes_needed; /* Bytes of input needed before wakeup. */
|
||
|
|
u_int32_t in_bytes; /* Bytes of input already buffered. */
|
||
|
|
omapi_buffer_t *inbufs;
|
||
|
|
u_int32_t out_bytes; /* Bytes of output in buffers. */
|
||
|
|
omapi_buffer_t *outbufs;
|
||
|
|
omapi_listener_object_t *listener; /* Listener that accepted this
|
||
|
|
connection, if any. */
|
||
|
|
DST_KEY *in_key; /* Authenticator signing incoming
|
||
|
|
data. */
|
||
|
|
void *in_context; /* Input hash context. */
|
||
|
|
DST_KEY *out_key; /* Authenticator signing outgoing
|
||
|
|
data. */
|
||
|
|
void *out_context; /* Output hash context. */
|
||
|
|
} omapi_connection_object_t;
|
||
|
|
|
||
|
|
typedef struct __omapi_io_object {
|
||
|
|
OMAPI_OBJECT_PREAMBLE;
|
||
|
|
struct __omapi_io_object *next;
|
||
|
|
int (*readfd) (omapi_object_t *);
|
||
|
|
int (*writefd) (omapi_object_t *);
|
||
|
|
isc_result_t (*reader) (omapi_object_t *);
|
||
|
|
isc_result_t (*writer) (omapi_object_t *);
|
||
|
|
isc_result_t (*reaper) (omapi_object_t *);
|
||
|
|
} omapi_io_object_t;
|
||
|
|
|
||
|
|
typedef struct __omapi_generic_object {
|
||
|
|
OMAPI_OBJECT_PREAMBLE;
|
||
|
|
omapi_value_t **values;
|
||
|
|
u_int8_t *changed;
|
||
|
|
int nvalues, va_max;
|
||
|
|
} omapi_generic_object_t;
|
||
|
|
|
||
|
|
typedef struct __omapi_waiter_object {
|
||
|
|
OMAPI_OBJECT_PREAMBLE;
|
||
|
|
int ready;
|
||
|
|
isc_result_t waitstatus;
|
||
|
|
struct __omapi_waiter_object *next;
|
||
|
|
} omapi_waiter_object_t;
|
||
|
|
|
||
|
|
#define OMAPI_HANDLE_TABLE_SIZE 120
|
||
|
|
|
||
|
|
typedef struct __omapi_handle_table {
|
||
|
|
omapi_handle_t first, limit;
|
||
|
|
omapi_handle_t next;
|
||
|
|
int leafp;
|
||
|
|
union {
|
||
|
|
omapi_object_t *object;
|
||
|
|
struct __omapi_handle_table *table;
|
||
|
|
} children [OMAPI_HANDLE_TABLE_SIZE];
|
||
|
|
} omapi_handle_table_t;
|
||
|
|
|
||
|
|
#include <omapip/alloc.h>
|
||
|
|
|
||
|
|
OMAPI_OBJECT_ALLOC_DECL (omapi_protocol, omapi_protocol_object_t,
|
||
|
|
omapi_type_protocol)
|
||
|
|
OMAPI_OBJECT_ALLOC_DECL (omapi_protocol_listener,
|
||
|
|
omapi_protocol_listener_object_t,
|
||
|
|
omapi_type_protocol_listener)
|
||
|
|
OMAPI_OBJECT_ALLOC_DECL (omapi_connection,
|
||
|
|
omapi_connection_object_t, omapi_type_connection)
|
||
|
|
OMAPI_OBJECT_ALLOC_DECL (omapi_listener,
|
||
|
|
omapi_listener_object_t, omapi_type_listener)
|
||
|
|
OMAPI_OBJECT_ALLOC_DECL (omapi_io,
|
||
|
|
omapi_io_object_t, omapi_type_io_object)
|
||
|
|
OMAPI_OBJECT_ALLOC_DECL (omapi_waiter,
|
||
|
|
omapi_waiter_object_t, omapi_type_waiter)
|
||
|
|
OMAPI_OBJECT_ALLOC_DECL (omapi_generic,
|
||
|
|
omapi_generic_object_t, omapi_type_generic)
|
||
|
|
OMAPI_OBJECT_ALLOC_DECL (omapi_message,
|
||
|
|
omapi_message_object_t, omapi_type_message)
|
||
|
|
|
||
|
|
isc_result_t omapi_connection_sign_data (int mode,
|
||
|
|
DST_KEY *key,
|
||
|
|
void **context,
|
||
|
|
const unsigned char *data,
|
||
|
|
const unsigned len,
|
||
|
|
omapi_typed_data_t **result);
|
||
|
|
isc_result_t omapi_listener_connect (omapi_connection_object_t **obj,
|
||
|
|
omapi_listener_object_t *listener,
|
||
|
|
int socket,
|
||
|
|
struct sockaddr_in *remote_addr);
|
||
|
|
void omapi_listener_trace_setup (void);
|
||
|
|
void omapi_connection_trace_setup (void);
|
||
|
|
void omapi_buffer_trace_setup (void);
|
||
|
|
void omapi_connection_register (omapi_connection_object_t *,
|
||
|
|
const char *, int);
|
||
|
|
void trace_mr_init (void);
|
||
|
|
|
||
|
|
OMAPI_ARRAY_TYPE_DECL(omapi_listener, omapi_listener_object_t);
|
||
|
|
OMAPI_ARRAY_TYPE_DECL(omapi_connection, omapi_connection_object_t);
|
||
|
|
|
||
|
|
extern int log_priority;
|
||
|
|
extern int log_perror;
|
||
|
|
extern void (*log_cleanup) (void);
|
||
|
|
|
||
|
|
void log_fatal (const char *, ...)
|
||
|
|
__attribute__((__format__(__printf__,1,2)));
|
||
|
|
int log_error (const char *, ...)
|
||
|
|
__attribute__((__format__(__printf__,1,2)));
|
||
|
|
int log_info (const char *, ...)
|
||
|
|
__attribute__((__format__(__printf__,1,2)));
|
||
|
|
int log_debug (const char *, ...)
|
||
|
|
__attribute__((__format__(__printf__,1,2)));
|
||
|
|
void do_percentm (char *obuf, const char *ibuf);
|
||
|
|
|
||
|
|
isc_result_t uerr2isc (int);
|
||
|
|
isc_result_t ns_rcode_to_isc (int);
|
||
|
|
|
||
|
|
extern omapi_message_object_t *omapi_registered_messages;
|
||
|
|
|
||
|
|
#endif /* __OMAPIP_OMAPIP_P_H__ */
|