| 932 | } |
| 933 | |
| 934 | CipConnectionObject *GetConnectedOutputAssembly( |
| 935 | const EipUint32 output_assembly_id) { |
| 936 | DoublyLinkedListNode *iterator = connection_list.first; |
| 937 | |
| 938 | while(NULL != iterator) { |
| 939 | if( kConnectionObjectInstanceTypeIOExclusiveOwner == |
| 940 | ConnectionObjectGetInstanceType(iterator->data) && |
| 941 | (kConnectionObjectStateEstablished == |
| 942 | ConnectionObjectGetState(iterator->data) |
| 943 | || kConnectionObjectStateTimedOut == |
| 944 | ConnectionObjectGetState(iterator->data) ) && |
| 945 | output_assembly_id == |
| 946 | ( (CipConnectionObject *)iterator->data )->produced_path.instance_id ) { |
| 947 | return iterator->data; |
| 948 | } |
| 949 | iterator = iterator->next; |
| 950 | } |
| 951 | return NULL; |
| 952 | } |
| 953 | |
| 954 | CipConnectionObject *CheckForExistingConnection( |
| 955 | const CipConnectionObject *const connection_object) { |
no test coverage detected