Lines Matching +defs:error +defs:message
28 CFErrorRef error = NULL;
35 SOSPeerSendBlock sendBlock = ^bool (CFDataRef message, CFErrorRef *error) {
36 size_t msglen = CFDataGetLength(message);
37 const uint8_t *msg = CFDataGetBytePtr(message);
40 /* message n=0 */
43 /* message n=n+1 */
71 ok(peer = SOSPeerCreateSimple(peer_id, kSOSPeerVersion, &error, sendBlock),
72 "create peer: %@", error);
73 CFReleaseNull(error);
80 ok(engine = SOSEngineCreate(ds, &error), "create engine: %@", error);
81 CFReleaseNull(error);
89 CFDataRef message;
91 /* Hand an empty message to the engine for handeling. */
92 message = CFDataCreate(NULL, NULL, 0);
93 ok(false == SOSEngineHandleMessage(engine, peer, message, &error),
94 "handle empty message: %@", error);
95 CFReleaseNull(error);
96 CFReleaseNull(message);
102 /* Create manifest digest message. */
104 skip("Create manifest digest message failed", 2,
105 ok(message = SOSEngineCreateManifestDigestMessage(engine, peer,
106 &error),
107 "create manifest digest message: %@", error));
108 CFReleaseNull(error);
109 /* Pass manifest digest message to the engine for handeling. */
111 ok(SOSEngineHandleMessage(engine, peer, message, &error),
112 "handle manifest digest message: %@", error));
118 CFReleaseNull(message);
119 CFReleaseNull(error);
121 /* Create manifest message. */
123 skip("Create manifest message failed", 2,
124 ok(message = SOSEngineCreateManifestMessage(engine, peer, &error),
125 "create manifest message: %@", error));
126 CFReleaseNull(error);
127 /* Pass manifest message to the engine for handeling. */
129 ok(SOSEngineHandleMessage(engine, peer, message, &error),
130 "handle manifest message: %@", error));
136 CFReleaseNull(message);
137 CFReleaseNull(error);
139 /* Create manifest and objects message. */
141 skip("Create manifest and objects message failed", 2,
142 ok(message = SOSEngineCreateManifestAndObjectsMessage(engine, peer,
143 &error),
144 "create manifest and objects message: %@", error));
145 CFReleaseNull(error);
146 /* Pass manifest and objects message to the engine for handeling. */
148 ok(SOSEngineHandleMessage(engine, peer, message, &error),
149 "handle manifest and objects message: %@", error));
155 CFReleaseNull(message);
156 CFReleaseNull(error);
163 static CFStringRef SOSMessageCopyDigestHex(CFDataRef message) {
165 ccdigest(ccsha1_di(), CFDataGetLength(message), CFDataGetBytePtr(message), digest);
174 CFErrorRef error = NULL;
179 ok(aliceEngine = SOSEngineCreate(aliceDataSource, &error), "create alice engine: %@", error);
180 CFReleaseNull(error);
185 SOSPeerSendBlock enqueueMessage = ^bool (CFDataRef message, CFErrorRef *error) {
187 fail("We already had an unproccessed message");
189 queued_message = (CFDataRef) CFRetain(message);
201 ok(bobPeer = SOSPeerCreateSimple(bobID, kSOSPeerVersion, &error, enqueueMessage),
202 "create peer: %@", error);
207 ok(bobEngine = SOSEngineCreate(bobDataSource, &error), "create bob engine: %@", error);
208 CFReleaseNull(error);
212 ok(alicePeer = SOSPeerCreateSimple(aliceID, kSOSPeerVersion, &error, enqueueMessage),
213 "create peer: %@", error);
214 CFReleaseNull(error);
221 /* Start syncing by making alice send the first message. */
222 ok(SOSEngineSyncWithPeer(aliceEngine, bobPeer, false, &error), "tell Alice sync with peer Bob");
223 CFDataRef message;
231 message = dequeueMessage();
233 /* We are expecting a message and msg is it's digest. */
234 if (message) {
235 CFStringRef messageDesc = SOSMessageCopyDescription(message);
236 CFStringRef messageDigestStr = SOSMessageCopyDigestHex(message);
238 bool handeled = SOSEngineHandleMessage(alice ? aliceEngine : bobEngine, alice ? bobPeer : alicePeer, message, &error);
241 fail("%s %s received message [%d] digest %@ != %@ %@", name, alice ? "Alice" : "Bob", msg_index, messageDigestStr, msg, messageDesc);
243 fail("%s %s failed to handle message [%d] digest %@ != %@ %@: %@", name, alice ? "Alice" : "Bob", msg_index, messageDigestStr, msg, messageDesc, error);
244 CFReleaseNull(error);
247 pass("%s %s handled message [%d] %@", name, alice ? "Alice" : "Bob", msg_index, messageDesc);
249 fail("%s %s failed to handle message [%d] %@: %@", name, alice ? "Alice" : "Bob", msg_index, messageDesc, error);
250 CFReleaseNull(error);
253 fail("%s %s sent extra message [%d] with digest %@: %@", name, alice ? "Bob" : "Alice", msg_index, messageDigestStr, messageDesc);
257 CFRelease(message);
260 fail("%s %s expected message [%d] with digest %@, none received", name, alice ? "Alice" : "Bob", msg_index, msg);
298 CFErrorRef error = NULL;
300 ok(dataSource->add(dataSource, object, &error), "dataSource added object %@", error);
302 CFReleaseNull(error);
314 CFErrorRef error = NULL;
316 ok(dataSource->add(dataSource, object, &error), "dataSource added object %@", error);
318 CFReleaseNull(error);
321 CFErrorRef error = NULL;
323 ok(dataSource->add(dataSource, object, &error), "dataSource added object %@", error);
325 CFReleaseNull(error);
335 CFErrorRef error = NULL;
337 ok(dataSource->add(dataSource, object, &error), "dataSource added object %@", error);
339 CFReleaseNull(error);
342 CFErrorRef error = NULL;
344 ok(dataSource->add(dataSource, object, &error), "dataSource added object %@", error);
347 ok(dataSource->add(dataSource, object, &error), "dataSource added object %@", error);
349 CFReleaseNull(error);