| 26 | } |
| 27 | |
| 28 | long MessageInterface::Accept(FancyRefPtr<MessageEndpoint>& endpoint){ |
| 29 | acquireLock(&incomingLock); |
| 30 | if(incoming.get_length() > 0){ |
| 31 | auto connection = incoming.remove_at(0); |
| 32 | releaseLock(&incomingLock); |
| 33 | |
| 34 | auto channel = MessageEndpoint::CreatePair(msgSize); |
| 35 | connection->item2 = channel.item2; |
| 36 | connection->item1 = true; |
| 37 | |
| 38 | endpoint = channel.item1; |
| 39 | return 1; |
| 40 | } else { |
| 41 | releaseLock(&incomingLock); |
| 42 | return 0; |
| 43 | } |
| 44 | } |
| 45 | |
| 46 | FancyRefPtr<MessageEndpoint> MessageInterface::Connect(){ |
| 47 | if(!active){ |
nothing calls this directly
no test coverage detected