guid.aid = AID_UNKNOWN;
guid.oid = OID_APP;
if (!objectEntryFind(d, &guid)) {
- CSTRemoteReader *cstRemoteReader;
appParams = (AppParams *)MALLOC(sizeof(AppParams));
AppParamsInit(appParams);
appParams->hostId = guid.hid;
objectEntryOID->multicastPort = 0;
}
appParams->userdataUnicastPort = 0; //Manager support only metatraffic
- cstRemoteReader = CSTWriterAddRemoteReader(d,
- &d->writerApplicationSelf,
- objectEntryOID,
- OID_READ_MGR,
- objectEntryOID);
+ CSTWriterAddRemoteReader(d,
+ &d->writerApplicationSelf,
+ objectEntryOID,
+ OID_READ_MGR,
+ objectEntryOID);
debug(29, 2) ("ORTEDomainCreate: add fellow manager (%s)\n",
IPAddressToString(ipAddress, sIPAddress));
}
ul_htim_time_t *pact_time)
{
HTimFncUserNode *timer;
- int retValue;
while ((timer = htimerUnicastSendMetatraffic_cut_expired(objectEntryAID, pact_time))) {
if (timer->lock)
pthread_rwlock_wrlock(timer->lock);
debug(2, 10) ("htimerUnicastMetatraffic: %s\n",
timer->name);
- retValue = timer->func(d, timer->arg1);
+ timer->func(d, timer->arg1);
while (d->taskSend.mb.needSend) {
ORTESendData(d, objectEntryAID, ORTE_TRUE);
timer->func(d, timer->arg1);
ul_htim_time_t *pact_time)
{
HTimFncUserNode *timer;
- int retValue;
while ((timer = htimerUnicastSendUserData_cut_expired(objectEntryAID, pact_time))) {
if (timer->lock)
pthread_rwlock_wrlock(timer->lock);
- retValue = timer->func(d, timer->arg1);
+ timer->func(d, timer->arg1);
while (d->taskSend.mb.needSend) {
ORTESendData(d, objectEntryAID, ORTE_FALSE);
timer->func(d, timer->arg1);