Return to recvbuff.h CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / ntp / include

Annotation of embedaddon/ntp/include/recvbuff.h, revision 1.1

1.1     ! misho       1: #ifndef RECVBUFF_H
        !             2: #define RECVBUFF_H
        !             3: 
        !             4: #ifdef HAVE_CONFIG_H
        !             5: # include <config.h>
        !             6: #endif
        !             7: 
        !             8: #include "ntp.h"
        !             9: #include "ntp_fp.h"
        !            10: #include "ntp_lists.h"
        !            11: 
        !            12: #include <isc/result.h>
        !            13: 
        !            14: /*
        !            15:  * recvbuf memory management
        !            16:  */
        !            17: #define RECV_INIT      10      /* 10 buffers initially */
        !            18: #define RECV_LOWAT     3       /* when we're down to three buffers get more */
        !            19: #define RECV_INC       5       /* get 5 more at a time */
        !            20: #define RECV_TOOMANY   40      /* this is way too many buffers */
        !            21: 
        !            22: #if defined HAVE_IO_COMPLETION_PORT
        !            23: # include "ntp_iocompletionport.h"
        !            24: #include "ntp_timer.h"
        !            25: 
        !            26: # define RECV_BLOCK_IO()       EnterCriticalSection(&RecvCritSection)
        !            27: # define RECV_UNBLOCK_IO()     LeaveCriticalSection(&RecvCritSection)
        !            28: 
        !            29: /*  Return the event which is set when items are added to the full list
        !            30:  */
        !            31: extern HANDLE  get_recv_buff_event (void);
        !            32: #else
        !            33: # define RECV_BLOCK_IO()       
        !            34: # define RECV_UNBLOCK_IO()     
        !            35: #endif
        !            36: 
        !            37: 
        !            38: /*
        !            39:  * Format of a recvbuf.  These are used by the asynchronous receive
        !            40:  * routine to store incoming packets and related information.
        !            41:  */
        !            42: 
        !            43: /*
        !            44:  *  the maximum length NTP packet contains the NTP header, one Autokey
        !            45:  *  request, one Autokey response and the MAC. Assuming certificates don't
        !            46:  *  get too big, the maximum packet length is set arbitrarily at 1000.
        !            47:  */   
        !            48: #define        RX_BUFF_SIZE    1000            /* hail Mary */
        !            49: 
        !            50: 
        !            51: typedef struct recvbuf recvbuf_t;
        !            52: 
        !            53: struct recvbuf {
        !            54:        ISC_LINK(recvbuf_t)     link;   /* next in list */
        !            55:        union {
        !            56:                sockaddr_u X_recv_srcadr;
        !            57:                caddr_t X_recv_srcclock;
        !            58:                struct peer *X_recv_peer;
        !            59:        } X_from_where;
        !            60: #define recv_srcadr    X_from_where.X_recv_srcadr
        !            61: #define        recv_srcclock   X_from_where.X_recv_srcclock
        !            62: #define recv_peer      X_from_where.X_recv_peer
        !            63: #ifndef HAVE_IO_COMPLETION_PORT
        !            64:        sockaddr_u srcadr;              /* where packet came from */
        !            65: #else
        !            66:        int recv_srcadr_len;            /* filled in on completion */
        !            67: #endif
        !            68:        endpt * dstadr;                 /* address pkt arrived on */
        !            69:        SOCKET  fd;                     /* fd on which it was received */
        !            70:        int msg_flags;                  /* Flags received about the packet */
        !            71:        l_fp recv_time;                 /* time of arrival */
        !            72:        void (*receiver) (struct recvbuf *); /* routine to receive buffer */
        !            73:        int recv_length;                /* number of octets received */
        !            74:        union {
        !            75:                struct pkt X_recv_pkt;
        !            76:                u_char X_recv_buffer[RX_BUFF_SIZE];
        !            77:        } recv_space;
        !            78: #define        recv_pkt        recv_space.X_recv_pkt
        !            79: #define        recv_buffer     recv_space.X_recv_buffer
        !            80:        int used;                       /* reference count */
        !            81: };
        !            82: 
        !            83: extern void    init_recvbuff   (int);
        !            84: 
        !            85: /* freerecvbuf - make a single recvbuf available for reuse
        !            86:  */
        !            87: extern void    freerecvbuf (struct recvbuf *);
        !            88: 
        !            89: /*  Get a free buffer (typically used so an async
        !            90:  *  read can directly place data into the buffer
        !            91:  *
        !            92:  *  The buffer is removed from the free list. Make sure
        !            93:  *  you put it back with freerecvbuf() or 
        !            94:  */
        !            95: extern struct recvbuf *get_free_recv_buffer (void); /* signal safe - no malloc */
        !            96: extern struct recvbuf *get_free_recv_buffer_alloc (void); /* signal unsafe - may malloc */
        !            97: 
        !            98: /*   Add a buffer to the full list
        !            99:  */
        !           100: extern void    add_full_recv_buffer     (struct recvbuf *);
        !           101: 
        !           102: /*extern       void    process_recv_buffers     (void); */
        !           103: 
        !           104: /* number of recvbufs on freelist */
        !           105: extern u_long free_recvbuffs (void);           
        !           106: extern u_long full_recvbuffs (void);           
        !           107: extern u_long total_recvbuffs (void);
        !           108: extern u_long lowater_additions (void);
        !           109:                
        !           110: /*  Returns the next buffer in the full list.
        !           111:  *
        !           112:  */
        !           113: extern struct recvbuf *get_full_recv_buffer (void);
        !           114: 
        !           115: /*
        !           116:  * Checks to see if there are buffers to process
        !           117:  */
        !           118: extern isc_boolean_t has_full_recv_buffer (void);
        !           119: 
        !           120: #endif /* RECVBUFF_H */