Lines Matching defs:transport
17 // For now transport (the abstract class) consumes the Transport data in engine to hold
19 static SOSCoderRef SOSTransportMessageCopyPeerCoder(SOSTransportMessageRef transport, CFStringRef peer_id){
22 CFDataRef coderData = SOSEngineGetTransportData(SOSTransportMessageGetEngine(transport), peer_id);
40 bool SOSTransportMessageSavePeerCoderData(SOSTransportMessageRef transport, SOSCoderRef coder, CFStringRef peer_id, CFErrorRef *error) {
47 secerror("%@ coder data failed to export %@, zapping data", transport, error ? *error : 0);
52 ok = SOSEngineSetTransportData(SOSTransportMessageGetEngine(transport), peer_id, coderData, error);
59 bool SOSTransportCoderInitializeForPeer(SOSTransportMessageRef transport, SOSFullPeerInfoRef myPeerInfo, SOSPeerInfoRef peerInfo, CFErrorRef *error){
62 CFDataRef coderData = SOSEngineGetTransportData(SOSTransportMessageGetEngine(transport), peer_id);
75 secnotice("transport", "New coder for id %@.", peer_id);
79 haveGoodCoder = SOSTransportMessageSavePeerCoderData(transport, coder, peer_id, error);
90 enum SOSCoderUnwrapStatus SOSTransportMessageHandleCoderMessage(SOSTransportMessageRef transport, CFStringRef peer_id, CFDataRef codedMessage, CFDataRef *decodedMessage, CFErrorRef *error){
96 SOSCoderRef coder = SOSTransportMessageCopyPeerCoder(transport, peer_id);
98 SOSAccountEnsurePeerRegistration(SOSTransportMessageGetAccount(transport), error);
99 coder = SOSTransportMessageCopyPeerCoder(transport, peer_id);
100 secnotice("transport", "Building new coder!");
114 secnotice("transport", "%@ transport negotiating", peer_id);
117 if(SOSEnginePeerDidConnect(SOSTransportMessageGetEngine(transport), peer_id, error))
119 secnotice("transport", "%@ transport negotiation complete", peer_id);
122 secnotice("transport", "%@ transport failed handling message %@", peer_id, error ? *error : NULL);
129 secnotice("transport", "%@ transport stale event ignored", peer_id);
139 SOSTransportMessageSavePeerCoderData(transport, coder, peer_id, NULL);
154 bool SOSTransportMessageSendMessageIfNeeded(SOSTransportMessageRef transport, CFStringRef circle_id, CFStringRef peer_id, CFErrorRef *error) {
155 SOSCoderRef coder = SOSTransportMessageCopyPeerCoder(transport, peer_id);
158 SOSAccountEnsurePeerRegistration(SOSTransportMessageGetAccount(transport), error);
159 coder = SOSTransportMessageCopyPeerCoder(transport, peer_id);
168 secnotice("transport", "%@ Coder can wrap, getting message from engine", peer_id);
170 CFDataRef message = SOSEngineCreateMessageToSyncToPeer(SOSTransportMessageGetEngine(transport), peer_id, &sent, error);
172 secnotice("transport", "%@ SOSEngineCreateMessageToSyncToPeer failed: %@",peer_id, *error);
176 secnotice("transport", "%@ SOSCoderWrap failed: %@",peer_id, *error);
186 secnotice("transport", "%@ Negotiating, %@", peer_id, message_to_send ? CFSTR("Sending negotiation message.") : CFSTR("waiting for negotiation message."));
202 ok = ok && SOSTransportMessageSendMessages(transport, circle_peers, error);
215 SOSTransportMessageSavePeerCoderData(transport, coder, peer_id, NULL);