Debug output for all received messages.
FossilOrigin-Name: 2dd8b2aa490714135f764e512b87763425fe8a872f0816f3d1f4052d9f4557c4
This commit is contained in:
parent
a3064a77e3
commit
25a321ce5f
@ -6,22 +6,26 @@
|
|||||||
|
|
||||||
#include "conn.h"
|
#include "conn.h"
|
||||||
#include "cwrmsg.h"
|
#include "cwrmsg.h"
|
||||||
|
#include "cw_log.h"
|
||||||
|
#include "capwap.h"
|
||||||
|
#include "sock.h"
|
||||||
|
|
||||||
struct args{
|
struct args {
|
||||||
struct conn * conn;
|
struct conn *conn;
|
||||||
struct cwrmsg * cwrmsg;
|
struct cwrmsg *cwrmsg;
|
||||||
};
|
};
|
||||||
|
|
||||||
static int pmessage(void *p, struct cwrmsg * cwrmsg)
|
static int pmessage(void *p, struct cwrmsg *cwrmsg)
|
||||||
{
|
{
|
||||||
struct args * args = (struct args*)p;
|
struct args *args = (struct args *) p;
|
||||||
struct conn * conn = args->conn;
|
struct conn *conn = args->conn;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
memcpy(&conn->cwrmsg,cwrmsg,sizeof(struct cwrmsg));
|
memcpy(&conn->cwrmsg, cwrmsg, sizeof(struct cwrmsg));
|
||||||
memcpy(conn->cwrmsg_buffer,cwrmsg->msgelems,cwrmsg->msgelems_len);
|
memcpy(conn->cwrmsg_buffer, cwrmsg->msgelems,
|
||||||
conn->cwrmsg.msgelems=conn->cwrmsg_buffer;
|
cwrmsg->msgelems_len);
|
||||||
|
conn->cwrmsg.msgelems = conn->cwrmsg_buffer;
|
||||||
args->cwrmsg = &conn->cwrmsg;
|
args->cwrmsg = &conn->cwrmsg;
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
@ -29,18 +33,28 @@ static int pmessage(void *p, struct cwrmsg * cwrmsg)
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
struct cwrmsg * conn_get_message(struct conn * conn)
|
struct cwrmsg *conn_get_message(struct conn *conn)
|
||||||
{
|
{
|
||||||
struct args args;
|
struct args args;
|
||||||
args.cwrmsg=0;
|
args.cwrmsg = 0;
|
||||||
args.conn=conn;
|
args.conn = conn;
|
||||||
uint8_t buf[2024];
|
uint8_t buf[2024];
|
||||||
int len=2024;
|
int len = 2024;
|
||||||
|
|
||||||
int n = conn->read(conn,buf,len);
|
int n = conn->read(conn, buf, len);
|
||||||
if (n>0)
|
if (n > 0)
|
||||||
conn_process_packet(conn,buf,n,pmessage,&args);
|
conn_process_packet(conn, buf, n, pmessage, &args);
|
||||||
|
|
||||||
|
|
||||||
|
if (args.cwrmsg) {
|
||||||
|
|
||||||
|
cw_dbg(DBG_CW_MSG,
|
||||||
|
"Received message from %s, type=%d - %s, seq=%d",
|
||||||
|
sock_addr2str(&conn->addr), args.cwrmsg->type,
|
||||||
|
cw_msgtostr(args.cwrmsg->type),
|
||||||
|
args.cwrmsg->seqnum);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
return args.cwrmsg;
|
return args.cwrmsg;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user