Home
last modified time | relevance | path

Searched refs:wait_for_message (Results 1 – 25 of 66) sorted by relevance

123

/dports/databases/py-redis/redis-3.5.3/tests/
H A Dtest_pubsub.py271 message = wait_for_message(p)
284 message1 = wait_for_message(p)
285 message2 = wait_for_message(p)
301 assert wait_for_message(p) is None
303 assert wait_for_message(p) is None
309 assert wait_for_message(p) is None
311 assert wait_for_message(p) is None
320 assert wait_for_message(p) is None
322 assert wait_for_message(p) is None
330 assert wait_for_message(p) is None
[all …]
H A Dtest_connection_pool.py11 from .test_pubsub import wait_for_message
764 subscribe_message = wait_for_message(p)
778 subscribe_message = wait_for_message(p)
798 subscribe_message = wait_for_message(p)
800 assert wait_for_message(p) is None
817 subscribe_message = wait_for_message(p)
825 assert wait_for_message(p) is None
833 assert wait_for_message(p) is None
/dports/net/kea/kea-2.0.1/src/bin/keactrl/tests/
H A Dkeactrl_tests.sh.in332 wait_for_message 10 "DHCP6_SHUTDOWN" 1
338 wait_for_message 10 "DHCP4_SHUTDOWN" 1
483 wait_for_message 10 "DHCP6_SHUTDOWN" 1
489 wait_for_message 10 "DHCP4_SHUTDOWN" 1
678 wait_for_message 10 "DHCP4_SHUTDOWN" 1
787 wait_for_message 10 "DHCP6_SHUTDOWN" 1
970 wait_for_message 10 "DHCP6_SHUTDOWN" 1
976 wait_for_message 10 "DHCP4_SHUTDOWN" 1
1183 wait_for_message 10 "DCTL_SHUTDOWN" 2
1375 wait_for_message 10 "DCTL_SHUTDOWN" 1
[all …]
/dports/databases/py-redis2/redis-py-2.10.6/tests/
H A Dtest_pubsub.py228 message = wait_for_message(p)
239 message1 = wait_for_message(p)
240 message2 = wait_for_message(p)
257 assert wait_for_message(p) is None
264 assert wait_for_message(p) is None
274 assert wait_for_message(p) is None
283 assert wait_for_message(p) is None
362 assert wait_for_message(p) is None
371 assert wait_for_message(p) is None
379 assert wait_for_message(p) is None
[all …]
/dports/games/widelands/widelands-build21/test/maps/expedition.wmf/scripting/
H A Dtest_no_double_colonizing.lua15 wait_for_message("Expedition")
17 wait_for_message("Expedition")
22 wait_for_message("Port Space")
26 wait_for_message("Port Space")
32 wait_for_message("Port")
H A Dinit.lua146 function wait_for_message(title) function
193 wait_for_message("Expedition")
230 wait_for_message("Expedition")
269 wait_for_message("Expedition")
276 wait_for_message("Port Space")
313 wait_for_message("Expedition")
326 wait_for_message("Port Space")
330 wait_for_message("Port")
H A Dtest_cancel_when_port_space_was_reached_two_ships.lua9 wait_for_message("Expedition")
24 wait_for_message("Port Space")
/dports/net/kea/kea-2.0.1/src/bin/dhcp6/tests/
H A Ddhcp6_process_tests.sh.in252 wait_for_message 10 "DHCP6_CONFIG_LOAD_FAIL" 1
282 wait_for_message 10 "DHCP6_CONFIG_COMPLETE" 2
357 wait_for_message 10 "DHCP6_SHUTDOWN" 1
410 wait_for_message 10 "DHCPSRV_MEMFILE_LFC_EXECUTE" 1
429 wait_for_message 10 "DHCP6_CONFIG_COMPLETE" 2
449 wait_for_message 10 "DHCPSRV_MEMFILE_LFC_EXECUTE" 2
460 wait_for_message 10 "DHCP6_SHUTDOWN" 1
/dports/net/kea/kea-2.0.1/src/bin/dhcp4/tests/
H A Ddhcp4_process_tests.sh.in246 wait_for_message 10 "DHCP4_CONFIG_LOAD_FAIL" 1
276 wait_for_message 10 "DHCP4_CONFIG_COMPLETE" 2
350 wait_for_message 10 "DHCP4_SHUTDOWN" 1
402 wait_for_message 10 "DHCPSRV_MEMFILE_LFC_EXECUTE" 1
421 wait_for_message 10 "DHCP4_CONFIG_COMPLETE" 2
441 wait_for_message 10 "DHCPSRV_MEMFILE_LFC_EXECUTE" 2
452 wait_for_message 10 "DHCP4_SHUTDOWN" 1
/dports/dns/bind9-devel/bind9-e112afa15668bd3b1baed59df2d21e01b46da15e/bin/tests/system/catz/
H A Dtests.sh26 nextpartpeek "$1" > wait_for_message.$n
27 grep -F "$2" wait_for_message.$n >/dev/null
30 wait_for_message() ( function
598 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" &&
646 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1285 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1314 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1341 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1436 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1465 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
[all …]
/dports/dns/samba-nsupdate/bind-9.16.5/bin/tests/system/catz/
H A Dtests.sh27 nextpartpeek "$1" > wait_for_message.$n
28 grep -F "$2" wait_for_message.$n >/dev/null
31 wait_for_message() ( function
562 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" &&
610 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1248 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1277 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1304 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1399 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1428 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
[all …]
/dports/dns/bind911/bind-9.11.37/bin/tests/system/catz/
H A Dtests.sh25 nextpartpeek "$1" > wait_for_message.$n
26 grep -F "$2" wait_for_message.$n >/dev/null
29 wait_for_message() ( function
560 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
607 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1244 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1273 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1300 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1395 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1424 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
[all …]
/dports/dns/bind-tools/bind-9.16.27/bin/tests/system/catz/
H A Dtests.sh29 nextpartpeek "$1" > wait_for_message.$n
30 grep -F "$2" wait_for_message.$n >/dev/null
33 wait_for_message() ( function
675 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" &&
723 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1362 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1391 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1418 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1513 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1542 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
[all …]
/dports/dns/bind916/bind-9.16.27/bin/tests/system/catz/
H A Dtests.sh29 nextpartpeek "$1" > wait_for_message.$n
30 grep -F "$2" wait_for_message.$n >/dev/null
33 wait_for_message() ( function
675 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" &&
723 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1362 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1391 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1418 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1513 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
1542 wait_for_message ns2/named.run "catz: update_from_db: new zone merged" || ret=1
[all …]
/dports/net/kea/kea-2.0.1/src/bin/d2/tests/
H A Dd2_process_tests.sh.in213 wait_for_message 10 "DCTL_CFG_FILE_RELOAD_SIGNAL_RECVD" 1
222 wait_for_message 10 "DCTL_CFG_FILE_RELOAD_ERROR" 1
243 wait_for_message 10 "DCTL_CONFIG_COMPLETE" 2
309 wait_for_message 10 "DCTL_SHUTDOWN" 1
/dports/net/py-stomp.py/stomp.py-4.1.17/stomp/test/
H A Dbasic_test.py35 self.listener.wait_for_message()
55 self.listener.wait_for_message()
116 self.listener.wait_for_message()
128 self.listener.wait_for_message()
143 self.listener.wait_for_message()
164 self.listener.wait_for_message()
H A Ds12_test.py36 self.listener.wait_for_message()
48 self.listener.wait_for_message()
62 self.listener.wait_for_message()
103 self.listener.wait_for_message()
H A Dp3_nonascii_test.py34 self.listener.wait_for_message()
53 self.listener.wait_for_message()
87 self.listener.wait_for_message()
H A Ds10_test.py31 self.listener.wait_for_message()
43 self.listener.wait_for_message()
H A Ds11_test.py20 tl.wait_for_message()
48 listener.wait_for_message()
/dports/games/widelands/widelands-build21/test/maps/port_space.wmf/scripting/
H A Dinit.lua17 function wait_for_message(title) function
83 wait_for_message("Expedition")
H A Dtest_portfield_neighbour_owned_by_p2.lua5 wait_for_message("Land Ahoy!")
/dports/lang/rust/rustc-1.58.1-src/src/tools/rls/tests/support/client/
H A Dmod.rs204 let msg = self.wait_for_message(move |val| val["id"] == id); in request()
264 pub fn wait_for_message(&mut self, f: impl Fn(&Value) -> bool + 'static) -> Value { in wait_for_message() method
273 self.wait_for_message(|msg| { in wait_for_indexing()
280 let msg = self.wait_for_message(|msg| msg["method"] == PublishDiagnostics::METHOD); in wait_for_diagnostics()
/dports/misc/morse/morse-1.4-154-g53f9eaa8/testing/middlewares/ros/
H A Dvideo_camera.py66 msg = rospy.wait_for_message(camnfo_topic, CameraInfo, 10)
70 msg = rospy.wait_for_message(camera_topic, Image, 10)
/dports/devel/xeus/xeus-0.24.4/src/
H A Dxdap_tcp_client.cpp83 nl::json xdap_tcp_client::wait_for_message(const message_condition& condition) in wait_for_message() function in xeus::xdap_tcp_client
351 nl::json initialized = wait_for_message([](const nl::json& message) in handle_init_sequence()
366 nl::json config_response = wait_for_message([](const nl::json& message) in handle_init_sequence()
372 nl::json attach_response = wait_for_message([](const nl::json& message) in handle_init_sequence()

123