X-Git-Url: http://www.project-moonshot.org/gitweb/?p=trust_router.git;a=blobdiff_plain;f=trp%2Ftrpc.c;fp=trp%2Ftrpc.c;h=04a8ca2c64b1b18e4d6a92162d05c3a782576f9e;hp=b6a2ceae87a981a18ed22add7104d5f1fa06b83a;hb=6f65c9cce86719147d0b4dcc9823b25443c2d185;hpb=eaa1a8ceed54fbfadc2638cf383aaa12ab446a57 diff --git a/trp/trpc.c b/trp/trpc.c index b6a2cea..04a8ca2 100644 --- a/trp/trpc.c +++ b/trp/trpc.c @@ -153,7 +153,7 @@ unsigned int trpc_get_port(TRPC_INSTANCE *trpc) 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; } @@ -189,9 +189,9 @@ void trpc_mq_add(TRPC_INSTANCE *trpc, TR_MQ_MSG *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) @@ -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))) { - 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;