void *arg) {
struct bufferevent *bufev = arg;
/*
- * If we are below the watermak then reschedule reading if it's
+ * If we are below the watermark then reschedule reading if it's
* still enabled.
*/
if (bufev->wm_read.high == 0 || now < bufev->wm_read.high) {
void evtag_init(void);
-void evtag_marshal(struct evbuffer *evbuf, uint8_t tag, const void *data,
- uint16_t len);
+void evtag_marshal(struct evbuffer *evbuf, u_int8_t tag, const void *data,
+ u_int16_t len);
-void encode_int(struct evbuffer *evbuf, uint32_t number);
+void encode_int(struct evbuffer *evbuf, u_int32_t number);
-void evtag_marshal_int(struct evbuffer *evbuf, uint8_t tag, uint32_t integer);
+void evtag_marshal_int(struct evbuffer *evbuf, u_int8_t tag,
+ u_int32_t integer);
-void evtag_marshal_string(struct evbuffer *buf, uint8_t tag,
+void evtag_marshal_string(struct evbuffer *buf, u_int8_t tag,
const char *string);
-void evtag_marshal_timeval(struct evbuffer *evbuf, uint8_t tag,
+void evtag_marshal_timeval(struct evbuffer *evbuf, u_int8_t tag,
struct timeval *tv);
void evtag_test(void);
-int evtag_unmarshal(struct evbuffer *src, uint8_t *ptag, struct evbuffer *dst);
-int evtag_peek(struct evbuffer *evbuf, uint8_t *ptag);
-int evtag_peek_length(struct evbuffer *evbuf, uint32_t *plength);
-int evtag_payload_length(struct evbuffer *evbuf, uint32_t *plength);
+int evtag_unmarshal(struct evbuffer *src, u_int8_t *ptag,
+ struct evbuffer *dst);
+int evtag_peek(struct evbuffer *evbuf, u_int8_t *ptag);
+int evtag_peek_length(struct evbuffer *evbuf, u_int32_t *plength);
+int evtag_payload_length(struct evbuffer *evbuf, u_int32_t *plength);
int evtag_consume(struct evbuffer *evbuf);
-int evtag_unmarshal_int(struct evbuffer *evbuf, uint8_t need_tag,
- uint32_t *pinteger);
+int evtag_unmarshal_int(struct evbuffer *evbuf, u_int8_t need_tag,
+ u_int32_t *pinteger);
-int evtag_unmarshal_fixed(struct evbuffer *src, uint8_t need_tag, void *data,
+int evtag_unmarshal_fixed(struct evbuffer *src, u_int8_t need_tag, void *data,
size_t len);
-int evtag_unmarshal_string(struct evbuffer *evbuf, uint8_t need_tag,
+int evtag_unmarshal_string(struct evbuffer *evbuf, u_int8_t need_tag,
char **pstring);
-int evtag_unmarshal_timeval(struct evbuffer *evbuf, uint8_t need_tag,
+int evtag_unmarshal_timeval(struct evbuffer *evbuf, u_int8_t need_tag,
struct timeval *ptv);
#ifdef __cplusplus
self.PrintIdented(file, ' ', dcl)
print >>file, ''
for entry in self._entries:
- print >>file, ' uint8_t %s_set;' % entry.Name()
+ print >>file, ' u_int8_t %s_set;' % entry.Name()
print >>file, '};\n'
print >>file, (
self._name, self._name) +
'int %s_complete(struct %s *);' % (self._name, self._name)
)
- print >>file, ('void evtag_marshal_%s(struct evbuffer *, uint8_t, '
+ print >>file, ('void evtag_marshal_%s(struct evbuffer *, u_int8_t, '
'const struct %s *);') % ( self._name, self._name)
- print >>file, ('int evtag_unmarshal_%s(struct evbuffer *, uint8_t, '
+ print >>file, ('int evtag_unmarshal_%s(struct evbuffer *, u_int8_t, '
'struct %s *);') % ( self._name, self._name)
# Write a setting function of every variable
' struct evbuffer *evbuf)\n' % (
self._name, self._name) +
'{\n'
- ' uint8_t tag;\n'
+ ' u_int8_t tag;\n'
' while (EVBUFFER_LENGTH(evbuf) > 0) {\n'
' if (evtag_peek(evbuf, &tag) == -1)\n'
' return (-1);\n'
# Complete message unmarshaling
print >>file, (
'int\n'
- 'evtag_unmarshal_%s(struct evbuffer *evbuf, uint8_t need_tag, '
+ 'evtag_unmarshal_%s(struct evbuffer *evbuf, u_int8_t need_tag, '
' struct %s *msg)'
) % (self._name, self._name)
print >>file, (
'{\n'
- ' uint8_t tag;\n'
+ ' u_int8_t tag;\n'
' int res = -1;\n'
'\n'
' struct evbuffer *tmp = evbuffer_new();\n'
# Complete message marshaling
print >>file, (
'void\n'
- 'evtag_marshal_%s(struct evbuffer *evbuf, uint8_t tag, '
+ 'evtag_marshal_%s(struct evbuffer *evbuf, u_int8_t tag, '
'const struct %s *msg)\n' % (self._name, self._name) +
'{\n'
' struct evbuffer *_buf = evbuffer_new();\n'
Entry.__init__(self, type, name, tag)
self._length = length
- self._ctype = 'uint8_t'
+ self._ctype = 'u_int8_t'
def GetDeclaration(self, funcname):
code = [ 'int %s(struct %s *, %s **);' % (
return code
def Declaration(self):
- dcl = ['uint8_t %s_data[%s];' % (self._name, self._length)]
+ dcl = ['u_int8_t %s_data[%s];' % (self._name, self._length)]
return dcl
# Init base class
Entry.__init__(self, type, name, tag)
- self._ctype = 'uint32_t'
+ self._ctype = 'u_int32_t'
def CodeUnmarshal(self, buf, tag_name, var_name):
code = ['if (evtag_unmarshal_int(%s, %s, &%s->%s_data) == -1) {' % (
return code
def Declaration(self):
- dcl = ['uint32_t %s_data;' % self._name]
+ dcl = ['u_int32_t %s_data;' % self._name]
return dcl
# Init base class
Entry.__init__(self, type, name, tag)
- self._ctype = 'uint8_t *'
+ self._ctype = 'u_int8_t *'
def GetDeclaration(self, funcname):
- code = [ 'int %s(struct %s *, %s *, uint32_t *);' % (
+ code = [ 'int %s(struct %s *, %s *, u_int32_t *);' % (
funcname, self._struct.Name(), self._ctype ) ]
return code
def AssignDeclaration(self, funcname):
- code = [ 'int %s(struct %s *, const %s, uint32_t);' % (
+ code = [ 'int %s(struct %s *, const %s, u_int32_t);' % (
funcname, self._struct.Name(), self._ctype ) ]
return code
name = self._name
code = [ 'int',
'%s_%s_assign(struct %s *msg, '
- 'const %s value, uint32_t len)' % (
+ 'const %s value, u_int32_t len)' % (
self._struct.Name(), name,
self._struct.Name(), self._ctype),
'{',
def CodeGet(self):
name = self._name
code = [ 'int',
- '%s_%s_get(struct %s *msg, %s *value, uint32_t *plen)' % (
+ '%s_%s_get(struct %s *msg, %s *value, u_int32_t *plen)' % (
self._struct.Name(), name,
self._struct.Name(), self._ctype),
'{',
return code
def Declaration(self):
- dcl = ['uint8_t *%s_data;' % self._name,
- 'uint32_t %s_length;' % self._name]
+ dcl = ['u_int8_t *%s_data;' % self._name,
+ 'u_int32_t %s_length;' % self._name]
return dcl
#include "event.h"
-int decode_int(uint32_t *pnumber, struct evbuffer *evbuf);
+int decode_int(u_int32_t *pnumber, struct evbuffer *evbuf);
static struct evbuffer *_buf;
*/
void
-encode_int(struct evbuffer *evbuf, uint32_t number)
+encode_int(struct evbuffer *evbuf, u_int32_t number)
{
int off = 1, nibbles = 0;
- uint8_t data[5];
+ u_int8_t data[5];
memset(data, 0, sizeof(data));
while (number) {
*/
void
-evtag_marshal(struct evbuffer *evbuf, uint8_t tag,
- const void *data, uint16_t len)
+evtag_marshal(struct evbuffer *evbuf, u_int8_t tag,
+ const void *data, u_int16_t len)
{
evbuffer_add(evbuf, &tag, sizeof(tag));
encode_int(evbuf, len);
/* Marshaling for integers */
void
-evtag_marshal_int(struct evbuffer *evbuf, uint8_t tag, uint32_t integer)
+evtag_marshal_int(struct evbuffer *evbuf, u_int8_t tag, u_int32_t integer)
{
evbuffer_drain(_buf, EVBUFFER_LENGTH(_buf));
encode_int(_buf, integer);
}
void
-evtag_marshal_string(struct evbuffer *buf, uint8_t tag, const char *string)
+evtag_marshal_string(struct evbuffer *buf, u_int8_t tag, const char *string)
{
evtag_marshal(buf, tag, string, strlen(string));
}
void
-evtag_marshal_timeval(struct evbuffer *evbuf, uint8_t tag, struct timeval *tv)
+evtag_marshal_timeval(struct evbuffer *evbuf, u_int8_t tag, struct timeval *tv)
{
evbuffer_drain(_buf, EVBUFFER_LENGTH(_buf));
}
static int __inline
-decode_int_internal(uint32_t *pnumber, struct evbuffer *evbuf, int dodrain)
+decode_int_internal(u_int32_t *pnumber, struct evbuffer *evbuf, int dodrain)
{
- uint32_t number = 0;
- uint8_t *data = EVBUFFER_DATA(evbuf);
+ u_int32_t number = 0;
+ u_int8_t *data = EVBUFFER_DATA(evbuf);
int len = EVBUFFER_LENGTH(evbuf);
int nibbles = 0, off;
}
int
-decode_int(uint32_t *pnumber, struct evbuffer *evbuf)
+decode_int(u_int32_t *pnumber, struct evbuffer *evbuf)
{
return (decode_int_internal(pnumber, evbuf, 1) == -1 ? -1 : 0);
}
int
-evtag_peek(struct evbuffer *evbuf, uint8_t *ptag)
+evtag_peek(struct evbuffer *evbuf, u_int8_t *ptag)
{
if (EVBUFFER_LENGTH(evbuf) < 2)
return (-1);
}
int
-evtag_peek_length(struct evbuffer *evbuf, uint32_t *plength)
+evtag_peek_length(struct evbuffer *evbuf, u_int32_t *plength)
{
struct evbuffer tmp;
int res;
}
int
-evtag_payload_length(struct evbuffer *evbuf, uint32_t *plength)
+evtag_payload_length(struct evbuffer *evbuf, u_int32_t *plength)
{
struct evbuffer tmp;
int res;
int
evtag_consume(struct evbuffer *evbuf)
{
- uint32_t len;
+ u_int32_t len;
evbuffer_drain(evbuf, 1);
if (decode_int(&len, evbuf) == -1)
return (-1);
/* Reads the data type from an event buffer */
int
-evtag_unmarshal(struct evbuffer *src, uint8_t *ptag, struct evbuffer *dst)
+evtag_unmarshal(struct evbuffer *src, u_int8_t *ptag, struct evbuffer *dst)
{
- uint8_t tag;
- uint16_t len;
- uint32_t integer;
+ u_int8_t tag;
+ u_int16_t len;
+ u_int32_t integer;
if (evbuffer_remove(src, &tag, sizeof(tag)) != sizeof(tag))
return (-1);
/* Marshaling for integers */
int
-evtag_unmarshal_int(struct evbuffer *evbuf, uint8_t need_tag, uint32_t *pinteger)
+evtag_unmarshal_int(struct evbuffer *evbuf, u_int8_t need_tag,
+ u_int32_t *pinteger)
{
- uint8_t tag;
- uint16_t len;
- uint32_t integer;
+ u_int8_t tag;
+ u_int16_t len;
+ u_int32_t integer;
if (evbuffer_remove(evbuf, &tag, sizeof(tag)) != sizeof(tag) ||
tag != need_tag)
/* Unmarshal a fixed length tag */
int
-evtag_unmarshal_fixed(struct evbuffer *src, uint8_t need_tag, void *data,
+evtag_unmarshal_fixed(struct evbuffer *src, u_int8_t need_tag, void *data,
size_t len)
{
- uint8_t tag;
+ u_int8_t tag;
/* Initialize this event buffer so that we can read into it */
evbuffer_drain(_buf, EVBUFFER_LENGTH(_buf));
}
int
-evtag_unmarshal_string(struct evbuffer *evbuf, uint8_t need_tag, char **pstring)
+evtag_unmarshal_string(struct evbuffer *evbuf, u_int8_t need_tag,
+ char **pstring)
{
- uint8_t tag;
+ u_int8_t tag;
evbuffer_drain(_buf, EVBUFFER_LENGTH(_buf));
}
int
-evtag_unmarshal_timeval(struct evbuffer *evbuf, uint8_t need_tag,
+evtag_unmarshal_timeval(struct evbuffer *evbuf, u_int8_t need_tag,
struct timeval *ptv)
{
- uint8_t tag;
- uint32_t integer;
+ u_int8_t tag;
+ u_int32_t integer;
evbuffer_drain(_buf, EVBUFFER_LENGTH(_buf));
if (evtag_unmarshal(evbuf, &tag, _buf) == -1 || tag != need_tag)
cleanup_test();
}
-int decode_int(uint32_t *pnumber, struct evbuffer *evbuf);
+int decode_int(u_int32_t *pnumber, struct evbuffer *evbuf);
#define TEST_MAX_INT 6
evtag_int_test(void)
{
struct evbuffer *tmp = evbuffer_new();
- uint32_t integers[TEST_MAX_INT] = {
+ u_int32_t integers[TEST_MAX_INT] = {
0xaf0, 0x1000, 0x1, 0xdeadbeef, 0x00, 0xbef000
};
- uint32_t integer;
+ u_int32_t integer;
int i;
for (i = 0; i < TEST_MAX_INT; i++) {