- CSTRemoteReader *cstRemoteReader;
- ObjectEntryOID *objectEntryOID;
- CSChangeForReader *csChangeForReader1;
- char queue=1;
-
- cstRemoteReader=csChangeForReader->cstRemoteReader;
- objectEntryOID=cstRemoteReader->sobject;
-
- //multicast can do an application with multicast interface
- if (!objectEntryOID->multicastPort)
- return;
-
- ul_list_for_each(CSChangeParticipant,
- csChangeForReader->csChange,
- csChangeForReader1) {
- ObjectEntryOID *objectEntryOID1;
- CSTRemoteReader *cstRemoteReader1;
-
- cstRemoteReader1=csChangeForReader1->cstRemoteReader;
- objectEntryOID1=cstRemoteReader1->sobject;
-
- /* are RRs from same GROUP */
- if (objectEntryOID!=objectEntryOID1)
- continue;
-
- /* is the csChange in state TOSEND ? If yes, marks like proc. */
- CSTWriterCSChangeForReaderNewState(csChangeForReader1);
-
- /* if there are no messages, detach sending timer */
- if (!(cstRemoteReader->commStateSend==NOTHNIGTOSEND) &&
- !(cstRemoteReader->commStateHB==MAYSENDHB))
- continue;
-
- if ((cstRemoteReader->cstWriter->guid.oid & 0x07)==OID_PUBLICATION)
- queue=2;
- eventDetach(cstRemoteReader->cstWriter->domain,
- cstRemoteReader->sobject->objectEntryAID,
- &cstRemoteReader->delayResponceTimer,
- queue);
- }
+ CSTRemoteReader *cstRemoteReader;
+ ObjectEntryOID *objectEntryOID;
+ CSChangeForReader *csChangeForReader1;
+ char queue = 1;
+
+ cstRemoteReader = csChangeForReader->cstRemoteReader;
+ objectEntryOID = cstRemoteReader->sobject;
+
+ //multicast can do an application with multicast interface
+ if (!objectEntryOID->multicastPort)
+ return;
+
+ ul_list_for_each(CSChangeParticipant,
+ csChangeForReader->csChange,
+ csChangeForReader1) {
+ ObjectEntryOID *objectEntryOID1;
+ CSTRemoteReader *cstRemoteReader1;
+
+ cstRemoteReader1 = csChangeForReader1->cstRemoteReader;
+ objectEntryOID1 = cstRemoteReader1->sobject;
+
+ /* are RRs from same GROUP */
+ if (objectEntryOID != objectEntryOID1)
+ continue;
+
+ /* is the csChange in state TOSEND ? If yes, marks like proc. */
+ CSTWriterCSChangeForReaderNewState(csChangeForReader1);
+
+ /* if there are no messages, detach sending timer */
+ if (!(cstRemoteReader->commStateSend == NOTHNIGTOSEND) &&
+ !(cstRemoteReader->commStateHB == MAYSENDHB))
+ continue;
+
+ if ((cstRemoteReader->cstWriter->guid.oid & 0x07) == OID_PUBLICATION)
+ queue = 2;
+ eventDetach(cstRemoteReader->cstWriter->domain,
+ cstRemoteReader->sobject->objectEntryAID,
+ &cstRemoteReader->delayResponceTimer,
+ queue);
+ }