Lines Matching defs:peer
132 // The peer state is an array.
140 // to send to the other peer. This is normally only ever appending to, and in
200 SOSPeerRef peer = SOSPeerCreateWithEngine(engine, peerID);
202 ok &= SOSPeerDataSourceWillCommit(peer, source, removals, additions, error);
203 SOSPeerMarkDigestsInUse(peer, &mdInUse);
204 CFReleaseSafe(peer);
334 // If we entered a circle of more than 2 or our last peer left we need to do stuff
526 /* Handle incoming message from peer p. Return false if there was an error, true otherwise. */
529 SOSPeerRef peer = SOSPeerCreateWithEngine(engine, peerID);
543 require_action_quiet(peer, exit, ok = SOSErrorCreate(errSecParam, error, NULL, CFSTR("Couldn't create peer with Engine for %@"), peerID));
544 peerDesc = CFCopyDescription(peer);
548 ok = SOSErrorCreate(kSOSErrorNotReady, error, NULL, CFSTR("Unknown criticial extension in peer message"));
560 secerror("%@ peer sent bad object: %@, rolling back changes", SOSPeerGetID(peer), error ? *error : NULL);
566 // consider asking the peer to stop sending us objects, and send it objects instead.
572 secerror("%@ SOSDataSourceMergeObject failed %@ rolling back changes", SOSPeerGetID(peer), error ? *error : NULL);
597 // ---- Don't use local or peer manifests from above this line, since commiting the SOSDataSourceWith transaction might change them ---
608 // peer.
612 SOSPeerSetPendingObjects(peer, localManifest);
633 ok &= SOSManifestDiff(SOSPeerGetConfirmedManifest(peer), confirmed, &confirmedRemovals, &confirmedAdditions, error);
635 ok &= SOSPeerDidReceiveRemovalsAndAdditions(peer, confirmedRemovals, confirmedAdditions, localManifest, error);
636 SOSPeerSetConfirmedManifest(peer, confirmed);
640 // The first block of code below sets peer.sendObjects to true when we receive a L00 and the second block
643 SOSPeerSetSendObjects(peer, true);
647 if (confirmed /* && SOSPeerSendObjects(peer)*/) {
650 secnotice("engine", "%@ confirmed %@ setting O:%@", SOSPeerGetID(peer), confirmed, allExtra);
651 SOSPeerSetPendingObjects(peer, allExtra);
656 secnoticeq("engine", "recv %@ %@", SOSPeerGetID(peer), message);
657 secnoticeq("peer", "recv %@ -> %@", peerDesc, peer);
666 CFReleaseSafe(peer);
680 static CFDataRef SOSEngineCreateMessage_locked(SOSEngineRef engine, SOSPeerRef peer,
683 __block SOSMessageRef message = SOSMessageCreate(kCFAllocatorDefault, SOSPeerGetMessageVersion(peer), error);
684 SOSManifestRef confirmed = SOSPeerGetConfirmedManifest(peer);
685 SOSManifestRef pendingObjects = SOSPeerGetPendingObjects(peer);
693 SOSManifestRef deleted = SOSPeerGetPendingDeletes(peer);
701 secerror("%@ ASSERTION FAILURE excess pendingObjects: %@", peer, excessPending);
707 SOSPeerSetPendingObjects(peer, pendingObjects);
713 secerror("%@ ASSERTION FAILURE excess deleted: %@", peer, excessDeleted);
722 // Send state for peer 7T0M+TD+A7HZ0frC5oHZnmdR0G: [LCP][os] P: 0, E: 0, M: 0
723 secnoticeq("engine", "Send state for peer %@: [%s%s%s][%s%s] P: %zu, E: %zu, M: %zu", SOSPeerGetID(peer),
727 SOSPeerSendObjects(peer) ? "O":"o",
728 SOSPeerMustSendMessage(peer) ? "S":"s",
737 // extra roundtrip required for objects that we assume the other peer
742 SOSPeerSetSendObjects(peer, false);
744 if (CFEqualSafe(local, SOSPeerGetProposedManifest(peer)) && !SOSPeerMustSendMessage(peer)) {
747 secnoticeq("engine", "synced <No MSG> %@", peer);
750 secnoticeq("engine", "waiting <MSG not resent> %@", peer);
775 SOSPeerGetID(peer), d[0], d[1], d[2], d[3]);
783 SOSPeerGetID(peer), d[0], d[1], d[2], d[3], localError);
790 SOSPeerGetID(peer), d[0], d[1], d[2], d[3], localError);
810 SOSPeerGetID(peer), d[0], d[1], d[2], d[3], hexder, localError);
856 result = SOSMessageCreateData(message, SOSPeerNextSequenceNumber(peer), error);
860 // Capture the peer in our block (SOSEnginePeerMessageSentBlock)
861 CFRetainSafe(peer);
866 SOSPeerSetSendObjects(peer, true);
869 SOSPeerAddLocalManifest(peer, local);
870 SOSPeerAddProposedManifest(peer, proposed);
871 secnoticeq("engine", "send %@ %@", SOSPeerGetID(peer), message);
873 secerror("%@ failed to send %@", SOSPeerGetID(peer), message);
875 CFReleaseSafe(peer);
889 secerror("%@ error in send: %@", SOSPeerGetID(peer), *error);
896 SOSPeerRef peer = SOSPeerCreateWithEngine(engine, peerID);
897 CFDataRef message = SOSEngineCreateMessage_locked(engine, peer, error, sentBlock);
898 CFReleaseSafe(peer);
1013 secdebug("engine", "No peerState for peer %@", peer_id);
1017 secdebug("engine", "No coder data for peer %@", peer_id);
1036 // The peer state is an array.
1044 // to send to the other peer. This is normally only ever appending to, and in
1075 SOSPeerRef peer = SOSPeerCreateWithEngine(engine, peerID);
1076 if (!peer) {
1077 result = SOSErrorCreate(kSOSErrorPeerNotFound, error, NULL, CFSTR("Engine has no peer for %@"), peerID);
1079 SOSPeerDidConnect(peer);
1081 CFReleaseSafe(peer);