Lines Matching defs:transport
14 static bool sendToPeer(SOSTransportMessageRef transport, CFStringRef circleName, CFStringRef peerID, CFDataRef message, CFErrorRef *error);
15 static bool syncWithPeers(SOSTransportMessageRef transport, CFDictionaryRef circleToPeerIDs, CFErrorRef *error);
16 static bool sendMessages(SOSTransportMessageRef transport, CFDictionaryRef circleToPeersToMessage, CFErrorRef *error);
17 static bool cleanupAfterPeer(SOSTransportMessageRef transport, CFDictionaryRef circle_to_peer_ids, CFErrorRef *error);
19 CFDictionaryRef handleMessages(SOSTransportMessageRef transport, CFMutableDictionaryRef circle_peer_messages_table, CFErrorRef *error);
20 static void destroyMessageTransport(SOSTransportMessageRef transport);
21 static void SOSTransportMessageTestAddBulkToChanges(SOSTransportMessageTestRef transport, CFDictionaryRef updates);
23 static bool flushMessageChanges(SOSTransportMessageRef transport, CFErrorRef *error);
24 static bool publishCloudParameters(SOSTransportKeyParameterRef transport, CFDataRef data, CFErrorRef* error);
25 static bool SOSTransportKeyParameterTestPublishCloudParameters(SOSTransportKeyParameterTestRef transport, CFDataRef newParameters, CFErrorRef *error);
27 static bool expireRetirementRecords(SOSTransportCircleRef transport, CFDictionaryRef retirements, CFErrorRef *error);
28 static void destroy(SOSTransportCircleRef transport);
29 static inline bool flushChanges(SOSTransportCircleRef transport, CFErrorRef *error);
30 static bool postCircle(SOSTransportCircleRef transport, CFStringRef circleName, CFDataRef circle_data, CFErrorRef *error);
31 static inline bool postRetirement(SOSTransportCircleRef transport, CFStringRef circleName, CFStringRef peer_id, CFDataRef retirement_data, CFErrorRef *error);
32 static bool handleKeyParameterChanges(SOSTransportKeyParameterRef transport, CFDataRef data, CFErrorRef error);
34 static CFArrayRef handleCircleMessages(SOSTransportCircleRef transport, CFMutableDictionaryRef circle_circle_messages_table, CFErrorRef *error);
35 static CFDictionaryRef handleRetirementMessages(SOSTransportCircleRef transport, CFMutableDictionaryRef circle_retirement_messages_table, CFErrorRef *error);
36 static bool setToNewAccount(SOSTransportKeyParameterRef transport);
38 static void SOSTransportCircleTestAddBulkToChanges(SOSTransportCircleTestRef transport, CFDictionaryRef updates);
39 static void SOSTransportCircleTestAddToChanges(SOSTransportCircleTestRef transport, CFStringRef message_key, CFDataRef message_data);
40 static bool SOSTransportCircleTestSendChanges(SOSTransportCircleTestRef transport, CFDictionaryRef changes, CFErrorRef *error);
171 static bool handleKeyParameterChanges(SOSTransportKeyParameterRef transport, CFDataRef data, CFErrorRef error){
172 SOSAccountRef account = transport->account;
176 static bool setToNewAccount(SOSTransportKeyParameterRef transport){
177 SOSTransportKeyParameterTestRef tpt = (SOSTransportKeyParameterTestRef)transport;
206 //unregister all the transports from the global transport queue
230 CFStringRef SOSTransportKeyParameterTestGetName(SOSTransportKeyParameterTestRef transport){
231 return transport->name;
234 void SOSTransportKeyParameterTestSetName(SOSTransportKeyParameterTestRef transport, CFStringRef accountName){
235 CFReleaseNull(transport->name);
236 transport->name = CFRetain(accountName);
239 SOSAccountRef SOSTransportKeyParameterTestGetAccount(SOSTransportKeyParameterTestRef transport){
240 return ((SOSTransportKeyParameterRef)transport)->account;
243 CFMutableDictionaryRef SOSTransportKeyParameterTestGetChanges(SOSTransportKeyParameterTestRef transport){
244 return transport->changes;
246 static bool publishCloudParameters(SOSTransportKeyParameterRef transport, CFDataRef data, CFErrorRef* error)
248 return SOSTransportKeyParameterTestPublishCloudParameters((SOSTransportKeyParameterTestRef)transport, data, error);
251 static bool SOSTransportKeyParameterTestPublishCloudParameters(SOSTransportKeyParameterTestRef transport, CFDataRef newParameters, CFErrorRef *error)
253 if(!transport->changes)
254 transport->changes = CFDictionaryCreateMutableForCFTypes(kCFAllocatorDefault);
256 CFDictionarySetValue(transport->changes, kSOSKVSKeyParametersKey, newParameters);
270 static CFStringRef SOSTransportCircleCopyDescription(SOSTransportCircleTestRef transport) {
272 return CFStringCreateWithFormat(NULL, NULL, CFSTR("<SOSTransportCircle@%p\n>"), transport);
275 static CFStringRef copyDescription(SOSTransportCircleRef transport){
276 return SOSTransportCircleCopyDescription((SOSTransportCircleTestRef)transport);
279 CFStringRef SOSTransportCircleTestGetName(SOSTransportCircleTestRef transport){
280 return transport->name;
282 void SOSTransportCircleTestSetName(SOSTransportCircleTestRef transport, CFStringRef accountName){
283 CFReleaseNull(transport->name);
284 transport->name = CFRetain(accountName);
287 CFMutableDictionaryRef SOSTransportCircleTestGetChanges(SOSTransportCircleTestRef transport){
288 return transport->changes;
314 static void destroy(SOSTransportCircleRef transport){
315 SOSTransportCircleTestRef tkvs = (SOSTransportCircleTestRef)transport;
322 static inline bool postRetirement(SOSTransportCircleRef transport, CFStringRef circleName, CFStringRef peer_id, CFDataRef retirement_data, CFErrorRef *error)
326 SOSTransportCircleTestAddToChanges((SOSTransportCircleTestRef)transport, retirement_key, retirement_data);
332 static inline bool flushChanges(SOSTransportCircleRef transport, CFErrorRef *error)
337 static void SOSTransportCircleTestAddToChanges(SOSTransportCircleTestRef transport, CFStringRef message_key, CFDataRef message_data){
339 if (transport->changes == NULL) {
340 transport->changes = CFDictionaryCreateMutableForCFTypes(kCFAllocatorDefault);
343 CFDictionarySetValue(transport->changes, message_key, kCFNull);
345 CFDictionarySetValue(transport->changes, message_key, message_data);
349 static void SOSTransportCircleTestAddBulkToChanges(SOSTransportCircleTestRef transport, CFDictionaryRef updates){
351 if (transport->changes == NULL) {
352 transport->changes = CFDictionaryCreateMutableCopy(kCFAllocatorDefault, CFDictionaryGetCount(updates), updates);
357 CFDictionarySetValue(transport->changes, key, value);
363 static bool expireRetirementRecords(SOSTransportCircleRef transport, CFDictionaryRef retirements, CFErrorRef *error) {
366 SOSTransportCircleTestRef tpt = (SOSTransportCircleTestRef)transport;
396 __unused static bool SOSTransportCircleTestUpdateRetirementRecords(SOSTransportCircleTestRef transport, CFDictionaryRef updates, CFErrorRef* error){
399 if (SOSTransportCircleTestSendChanges((SOSTransportCircleTestRef)transport, updates, &updateError)){
408 static bool postCircle(SOSTransportCircleRef transport, CFStringRef circleName, CFDataRef circle_data, CFErrorRef *error){
409 SOSTransportCircleTestRef tkvs = (SOSTransportCircleTestRef)transport;
418 static CFDictionaryRef handleRetirementMessages(SOSTransportCircleRef transport, CFMutableDictionaryRef circle_retirement_messages_table, CFErrorRef *error){
419 SOSAccountRef account = transport->account;
446 static CFArrayRef handleCircleMessages(SOSTransportCircleRef transport, CFMutableDictionaryRef circle_circle_messages_table, CFErrorRef *error){
450 if (!SOSAccountHandleCircleMessage(transport->account, key, value, &circleMessageError)) {
463 static bool SOSTransportCircleTestSendChanges(SOSTransportCircleTestRef transport, CFDictionaryRef changes, CFErrorRef *error){
464 if(!transport->changes)
465 transport->changes = CFDictionaryCreateMutableCopy(kCFAllocatorDefault, CFDictionaryGetCount(changes), changes);
468 CFDictionarySetValue(transport->changes, key, value);
474 SOSAccountRef SOSTransportCircleTestGetAccount(SOSTransportCircleTestRef transport) {
475 return ((SOSTransportCircleRef)transport)->account;
514 CFStringRef SOSTransportMessageTestGetName(SOSTransportMessageTestRef transport){
515 return transport->name;
518 void SOSTransportMessageTestSetName(SOSTransportMessageTestRef transport, CFStringRef accountName){
519 CFReleaseNull(transport->name);
520 transport->name = CFRetain(accountName);
523 CFMutableDictionaryRef SOSTransportMessageTestGetChanges(SOSTransportMessageTestRef transport){
524 return transport->changes;
527 static void destroyMessageTransport(SOSTransportMessageRef transport){
528 SOSTransportMessageTestRef tkvs = (SOSTransportMessageTestRef)transport;
536 static void SOSTransportMessageTestAddBulkToChanges(SOSTransportMessageTestRef transport, CFDictionaryRef updates){
538 if (transport->changes == NULL) {
539 transport->changes = CFDictionaryCreateMutableCopy(kCFAllocatorDefault, CFDictionaryGetCount(updates), updates);
544 CFDictionarySetValue(transport->changes, key, value);
549 static void SOSTransportMessageTestAddToChanges(SOSTransportMessageTestRef transport, CFStringRef message_key, CFDataRef message_data){
550 if (transport->changes == NULL) {
551 transport->changes = CFDictionaryCreateMutableForCFTypes(kCFAllocatorDefault);
554 CFDictionarySetValue(transport->changes, message_key, kCFNull);
556 CFDictionarySetValue(transport->changes, message_key, message_data);
560 static bool SOSTransportMessageTestCleanupAfterPeerMessages(SOSTransportMessageTestRef transport, CFDictionaryRef circle_to_peer_ids, CFErrorRef *error)
562 SOSEngineRef engine = SOSTransportMessageGetEngine((SOSTransportMessageRef)transport);
581 SOSTransportMessageTestAddToChanges(transport, kvsKey, NULL);
585 SOSTransportMessageTestAddToChanges(transport, kvsKey, NULL);
595 return SOSTransportMessageFlushChanges((SOSTransportMessageRef)transport, error);
600 static bool sendToPeer(SOSTransportMessageRef transport, CFStringRef circleName, CFStringRef peerID, CFDataRef message, CFErrorRef *error) {
601 SOSTransportMessageTestRef testTransport = (SOSTransportMessageTestRef) transport;
603 CFStringRef message_to_peer_key = SOSMessageKeyCreateFromTransportToPeer((SOSTransportMessageKVSRef)transport, peerID);
613 static bool syncWithPeers(SOSTransportMessageRef transport, CFDictionaryRef circleToPeerIDs, CFErrorRef *error){
628 SOSPeerRef peer = SOSPeerCreateWithEngine(SOSTransportMessageGetEngine(transport), peerID);
629 CFDataRef coderData = SOSEngineGetCoderData(SOSTransportMessageGetEngine(transport), peerID);
642 CFDictionarySetValue(SOSTransportMessageTestGetChanges((SOSTransportMessageTestRef)transport), circleName, peer_dict);
656 if(!SOSEngineSetCoderData(SOSTransportMessageGetEngine(transport), peerID, coderData, error)){
673 static bool sendMessages(SOSTransportMessageRef transport, CFDictionaryRef circleToPeersToMessage, CFErrorRef *error) {
683 bool rx = sendToPeer(transport, circleName, peerID, message, error);
694 CFDictionaryRef handleMessages(SOSTransportMessageRef transport, CFMutableDictionaryRef circle_peer_messages_table, CFErrorRef *error) {
695 SOSTransportMessageTestRef tpt = (SOSTransportMessageTestRef)transport;
707 if (SOSTransportMessageHandlePeerMessage((SOSTransportMessageRef) transport, peer_id, peer_message, &localError)) {
710 secdebug("transport", "%@ KVSTransport handle message failed: %@", peer_id, localError);
720 static bool flushMessageChanges(SOSTransportMessageRef transport, CFErrorRef *error)
725 static bool cleanupAfterPeer(SOSTransportMessageRef transport, CFDictionaryRef circle_to_peer_ids, CFErrorRef *error)
727 return SOSTransportMessageTestCleanupAfterPeerMessages((SOSTransportMessageTestRef) transport, circle_to_peer_ids, error);
730 SOSAccountRef SOSTransportMessageTestGetAccount(SOSTransportMessageTestRef transport) {
731 return ((SOSTransportMessageRef)transport)->account;