Again, the goal is to make the code more readable.
publisherCreate(void *arg)
{
ORTEPublication *p;
- NtpTime persistence, delay;
+ NtpTime persistence = NTPTIME_INITIALIZER(3);
+ NtpTime delay = NTPTIME_INITIALIZER(1);
ORTETypeRegisterAdd(d, "HelloMsg", NULL, NULL, NULL, sizeof(instance2Send));
- NTPTIME_BUILD(persistence, 3);
- NTPTIME_BUILD(delay, 1);
p = ORTEPublicationCreate(
d,
"Example HelloMsg",
subscriberCreate(void *arg)
{
ORTESubscription *s;
- NtpTime deadline, minimumSeparation;
+ NtpTime deadline = NTPTIME_INITIALIZER(10);
+ NtpTime minimumSeparation = NTPTIME_INITIALIZER(0);
ORTETypeRegisterAdd(d, "HelloMsg", NULL, NULL, NULL, sizeof(instance2Recv));
- NTPTIME_BUILD(deadline, 10);
- NTPTIME_BUILD(minimumSeparation, 0);
s = ORTESubscriptionCreate(
d,
IMMEDIATE,
subscriberCreate(void *arg)
{
ORTESubscription *s;
- NtpTime deadline, minimumSeparation;
+ NtpTime deadline = NTPTIME_INITIALIZER(10), minimumSeparation = NTPTIME_INITIALIZER(0);
ORTETypeRegisterAdd(d, "HelloMsg", NULL, NULL, maxDataSize, sizeof(instance2Recv));
- NTPTIME_BUILD(deadline, 10);
- NTPTIME_BUILD(minimumSeparation, 0);
s = ORTESubscriptionCreate(
d,
IMMEDIATE,
int opt, domain = ORTE_DEFAULT_DOMAIN;
int32_t strength = 1;
int32_t instanceSend = 0, instanceRecv = 0;
- NtpTime persistence, deadline, minimumSeparation, delay;
+ NtpTime persistence, deadline, minimumSeparation = NTPTIME_INITIALIZER(0);
+ NtpTime delay = NTPTIME_INITIALIZER(1);
Boolean havePublisher = ORTE_FALSE;
Boolean haveSubscriber = ORTE_FALSE;
IPAddress smIPAddress = IPADDRESS_INVALID;
ORTEInit();
ORTEDomainPropDefaultGet(&dp);
- NTPTIME_BUILD(minimumSeparation, 0);
- NTPTIME_BUILD(delay, 1); //1s
#if defined HAVE_GETOPT_LONG || defined HAVE_GETOPT_LONG_ORTE
while ((opt = getopt_long(argc, argv, "m:S:d:v:R:E:P:l:I:i:t:D:Vhpsq", &long_opts[0], NULL)) != EOF) {
main(int argc, char *args[])
{
ORTEPublication *p;
- NtpTime persistence, repeating;
+ NtpTime persistence = NTPTIME_INITIALIZER(3), repeating = NTPTIME_INITIALIZER(1);
ORTEInit();
d = ORTEDomainAppCreate(ORTE_DEFAULT_DOMAIN, NULL, NULL, ORTE_FALSE);
ORTETypeRegisterAdd(d, "HelloMsg", NULL, NULL, NULL, sizeof(instance2Send));
- NTPTIME_BUILD(persistence, 3);
- NTPTIME_BUILD(repeating, 1);
p = ORTEPublicationCreate(
d,
"Reliable HelloMsg",
main(int argc, char *args[])
{
ORTESubscription *s;
- NtpTime deadline, minimumSeparation;
+ NtpTime deadline = NTPTIME_INITIALIZER(3), minimumSeparation = NTPTIME_INITIALIZER(0);
ORTEInit();
//ORTEVerbositySetOptions("ALL,10");
d = ORTEDomainAppCreate(ORTE_DEFAULT_DOMAIN, NULL, NULL, ORTE_FALSE);
ORTETypeRegisterAdd(d, "HelloMsg", NULL, NULL, NULL, sizeof(instance2Recv));
- NTPTIME_BUILD(deadline, 3);
- NTPTIME_BUILD(minimumSeparation, 0);
s = ORTESubscriptionCreate(
d,
IMMEDIATE,
main(int argc, char *args[])
{
ORTESubscription *s;
- NtpTime deadline, minimumSeparation;
+ NtpTime deadline = NTPTIME_INITIALIZER(3), minimumSeparation = NTPTIME_INITIALIZER(0);
ORTEInit();
//ORTEVerbositySetOptions("ALL,10");
d = ORTEDomainAppCreate(ORTE_DEFAULT_DOMAIN, NULL, NULL, ORTE_FALSE);
ORTETypeRegisterAdd(d, "HelloMsg", NULL, NULL, NULL, sizeof(instance2Recv));
- NTPTIME_BUILD(deadline, 3);
- NTPTIME_BUILD(minimumSeparation, 0);
s = ORTESubscriptionCreate(
d,
IMMEDIATE,
subscriberCreate(void *arg)
{
ORTESubscription *s;
- NtpTime deadline, minimumSeparation;
+ NtpTime deadline = NTPTIME_INITIALIZER(10), minimumSeparation = NTPTIME_INITIALIZER(0);
ORTETypeRegisterAdd(d, "IDA_OCTETSTRING", NULL, NULL, maxDataSize, sizeof(instance2Recv));
- NTPTIME_BUILD(deadline, 10);
- NTPTIME_BUILD(minimumSeparation, 0);
s = ORTESubscriptionCreate(
d,
IMMEDIATE,