projects
/
trust_router.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge pull request #100 from painless-security/milestone/monitoring
[trust_router.git]
/
trp
/
trpc.c
diff --git
a/trp/trpc.c
b/trp/trpc.c
index
b6a2cea
..
04a8ca2
100644
(file)
--- a/
trp/trpc.c
+++ b/
trp/trpc.c
@@
-153,7
+153,7
@@
unsigned int trpc_get_port(TRPC_INSTANCE *trpc)
return trpc->port;
}
return trpc->port;
}
-void trpc_set_port(TRPC_INSTANCE *trpc,
unsigned
int port)
+void trpc_set_port(TRPC_INSTANCE *trpc, int port)
{
trpc->port=port;
}
{
trpc->port=port;
}
@@
-189,9
+189,9
@@
void trpc_mq_add(TRPC_INSTANCE *trpc, TR_MQ_MSG *msg)
tr_mq_add(trpc->mq, msg);
}
tr_mq_add(trpc->mq, msg);
}
-TR_MQ_MSG *trpc_mq_pop(TRPC_INSTANCE *trpc)
+TR_MQ_MSG *trpc_mq_pop(TRPC_INSTANCE *trpc
, struct timespec *ts_abort
)
{
{
- return tr_mq_pop(trpc->mq,
0
);
+ return tr_mq_pop(trpc->mq,
ts_abort
);
}
void trpc_mq_clear(TRPC_INSTANCE *trpc)
}
void trpc_mq_clear(TRPC_INSTANCE *trpc)
@@
-216,7
+216,7
@@
TRP_RC trpc_send_msg (TRPC_INSTANCE *trpc,
*trp_connection_get_gssctx(trpc_get_conn(trpc)),
msg_content,
strlen(msg_content))) {
*trp_connection_get_gssctx(trpc_get_conn(trpc)),
msg_content,
strlen(msg_content))) {
- tr_err( "trpc_send_msg: Error sending message over connection.
\n
");
+ tr_err( "trpc_send_msg: Error sending message over connection.");
rc=TRP_ERROR;
}
return rc;
rc=TRP_ERROR;
}
return rc;