X-Git-Url: http://www.project-moonshot.org/gitweb/?a=blobdiff_plain;f=include%2Ftrp_internal.h;h=8401bfa70cab2c0f921d3dab0456da2157dc916f;hb=81a61f8c6064bf52ff2a40a3d28e6ee5b2e478d4;hp=3fa4034831e4ca6280ca09c1e7680b9e34bbe577;hpb=e2b95e95ffdc2e72afa22509cf3473e61090d03f;p=trust_router.git diff --git a/include/trp_internal.h b/include/trp_internal.h index 3fa4034..8401bfa 100644 --- a/include/trp_internal.h +++ b/include/trp_internal.h @@ -142,7 +142,6 @@ struct trpc_instance { unsigned int port; TRP_CONNECTION *conn; TR_MQ *mq; /* msgs from master to trpc */ - int shutting_down; /* 0 unless the TRPC is in the shutdown process */ }; /* TRP Server Instance Data */ @@ -209,7 +208,7 @@ TRP_CONNECTION_STATUS trpc_get_status(TRPC_INSTANCE *trpc); TR_MQ *trpc_get_mq(TRPC_INSTANCE *trpc); void trpc_set_mq(TRPC_INSTANCE *trpc, TR_MQ *mq); void trpc_mq_add(TRPC_INSTANCE *trpc, TR_MQ_MSG *msg); -TR_MQ_MSG *trpc_mq_pop(TRPC_INSTANCE *trpc); +TR_MQ_MSG *trpc_mq_pop(TRPC_INSTANCE *trpc, struct timespec *ts_abort); void trpc_mq_clear(TRPC_INSTANCE *trpc); void trpc_master_mq_add(TRPC_INSTANCE *trpc, TR_MQ_MSG *msg); TR_MQ_MSG *trpc_master_mq_pop(TRPC_INSTANCE *trpc);