Lines Matching refs:ren
72 ReadyEventNode *ren = readyEventNodeList[eventIndex]; in ForceCompletion() local
73 ren->eventStatus=ID_READY_EVENT_FORCE_ALL_SET; in ForceCompletion()
108 ReadyEventNode *ren = readyEventNodeList[eventIndex]; in IsEventCompletionProcessing() local
109 if (ren->eventStatus==ID_READY_EVENT_FORCE_ALL_SET) in IsEventCompletionProcessing()
111 for (unsigned i=0; i < ren->systemList.Size(); i++) in IsEventCompletionProcessing()
113 if (ren->systemList[i].lastReceivedStatus==ID_READY_EVENT_ALL_SET) in IsEventCompletionProcessing()
252 ReadyEventNode *ren = readyEventNodeList[readyIndex]; in GetReadyStatus() local
253 unsigned systemIndex = ren->systemList.GetIndexFromKey(address, &objectExists); in GetReadyStatus()
256 if (ren->systemList[systemIndex].lastReceivedStatus==ID_READY_EVENT_SET) in GetReadyStatus()
258 if (ren->systemList[systemIndex].lastReceivedStatus==ID_READY_EVENT_UNSET) in GetReadyStatus()
260 if (ren->systemList[systemIndex].lastReceivedStatus==ID_READY_EVENT_ALL_SET) in GetReadyStatus()
298 ReadyEventNode *ren = readyEventNodeList[eventIndex]; in AddToWaitListInternal() local
300 unsigned systemIndex = ren->systemList.GetIndexFromKey(address, &objectExists); in AddToWaitListInternal()
307 ren->systemList.InsertAtIndex(rs,systemIndex, __FILE__,__LINE__); in AddToWaitListInternal()
309 SendReadyStateQuery(ren->eventId, address); in AddToWaitListInternal()
324 ReadyEventNode *ren = readyEventNodeList[readyIndex]; in OnReadyEventForceAllSet() local
325 if (ren->eventStatus!=ID_READY_EVENT_FORCE_ALL_SET) in OnReadyEventForceAllSet()
327 ren->eventStatus=ID_READY_EVENT_FORCE_ALL_SET; in OnReadyEventForceAllSet()
328 PushCompletionPacket(ren->eventId); in OnReadyEventForceAllSet()
342 ReadyEventNode *ren = readyEventNodeList[readyIndex]; in OnReadyEventPacketUpdate() local
344 unsigned systemIndex = ren->systemList.GetIndexFromKey(packet->systemAddress, &systemExists); in OnReadyEventPacketUpdate()
348 if (ren->systemList[systemIndex].lastReceivedStatus==packet->data[0]) in OnReadyEventPacketUpdate()
352 ren->systemList[systemIndex].lastReceivedStatus=packet->data[0]; in OnReadyEventPacketUpdate()
354 if (ren->eventStatus==ID_READY_EVENT_FORCE_ALL_SET) in OnReadyEventPacketUpdate()
393 ReadyEventNode *ren = readyEventNodeList[eventIndex]; in SetEventByIndex() local
394 …if ((ren->eventStatus==ID_READY_EVENT_ALL_SET || ren->eventStatus==ID_READY_EVENT_SET) && isReady=… in SetEventByIndex()
396 if (ren->eventStatus==ID_READY_EVENT_UNSET && isReady==false) in SetEventByIndex()
398 if (ren->eventStatus==ID_READY_EVENT_FORCE_ALL_SET) in SetEventByIndex()
402 ren->eventStatus=ID_READY_EVENT_SET; in SetEventByIndex()
404 ren->eventStatus=ID_READY_EVENT_UNSET; in SetEventByIndex()
411 PushCompletionPacket(ren->eventId); in SetEventByIndex()
419 ReadyEventNode *ren = readyEventNodeList[eventIndex]; in IsEventCompletedByIndex() local
421 if (ren->eventStatus==ID_READY_EVENT_FORCE_ALL_SET) in IsEventCompletedByIndex()
423 if (ren->eventStatus!=ID_READY_EVENT_ALL_SET) in IsEventCompletedByIndex()
425 for (i=0; i < ren->systemList.Size(); i++) in IsEventCompletedByIndex()
426 if (ren->systemList[i].lastReceivedStatus!=ID_READY_EVENT_ALL_SET) in IsEventCompletedByIndex()
443 ReadyEventNode *ren = RakNet::OP_NEW<ReadyEventNode>( __FILE__, __LINE__ ); in CreateNewEvent() local
444 ren->eventId=eventId; in CreateNewEvent()
446 ren->eventStatus=ID_READY_EVENT_UNSET; in CreateNewEvent()
448 ren->eventStatus=ID_READY_EVENT_SET; in CreateNewEvent()
449 return readyEventNodeList.Insert(eventId, ren, true, __FILE__,__LINE__); in CreateNewEvent()
453 ReadyEventNode *ren = readyEventNodeList[eventIndex]; in UpdateReadyStatus() local
456 if (ren->eventStatus==ID_READY_EVENT_SET) in UpdateReadyStatus()
460 for (i=0; i < ren->systemList.Size(); i++) in UpdateReadyStatus()
462 if (ren->systemList[i].lastReceivedStatus==ID_READY_EVENT_UNSET) in UpdateReadyStatus()
470 ren->eventStatus=ID_READY_EVENT_ALL_SET; in UpdateReadyStatus()
473 else if (ren->eventStatus==ID_READY_EVENT_ALL_SET) in UpdateReadyStatus()
477 for (i=0; i < ren->systemList.Size(); i++) in UpdateReadyStatus()
479 if (ren->systemList[i].lastReceivedStatus==ID_READY_EVENT_UNSET) in UpdateReadyStatus()
487 ren->eventStatus=ID_READY_EVENT_SET; in UpdateReadyStatus()
494 ReadyEventNode *ren = readyEventNodeList[eventIndex]; in SendReadyUpdate() local
497 if ((ren->eventStatus!=ren->systemList[systemIndex].lastSentStatus) || in SendReadyUpdate()
498 (forceIfNotDefault && ren->eventStatus!=ID_READY_EVENT_UNSET)) in SendReadyUpdate()
500 bs.Write(ren->eventStatus); in SendReadyUpdate()
501 bs.Write(ren->eventId); in SendReadyUpdate()
502 …SendUnified(&bs, HIGH_PRIORITY, RELIABLE_ORDERED, channel, ren->systemList[systemIndex].systemAddr… in SendReadyUpdate()
504 ren->systemList[systemIndex].lastSentStatus=ren->eventStatus; in SendReadyUpdate()
510 ReadyEventNode *ren = readyEventNodeList[eventIndex]; in BroadcastReadyUpdate() local
512 for (systemIndex=0; systemIndex < ren->systemList.Size(); systemIndex++) in BroadcastReadyUpdate()