/dports/net/libzmq4/zeromq-4.3.4/tests/ |
H A D | test_stream_timeout.cpp | 51 void *dealer = test_context_socket (ZMQ_DEALER); in test_stream_handshake_timeout_accept() local 53 zmq_setsockopt (dealer, ZMQ_LINGER, &zero, sizeof (zero))); in test_stream_handshake_timeout_accept() 59 zmq_getsockopt (dealer, ZMQ_HANDSHAKE_IVL, &val, &vsize)); in test_stream_handshake_timeout_accept() 68 zmq_getsockopt (dealer, ZMQ_HANDSHAKE_IVL, &val, &vsize)); in test_stream_handshake_timeout_accept() 76 dealer, "inproc://monitor-dealer", in test_stream_handshake_timeout_accept() 84 bind_loopback_ipv4 (dealer, my_endpoint, sizeof my_endpoint); in test_stream_handshake_timeout_accept() 94 test_context_socket_close (dealer); in test_stream_handshake_timeout_accept() 113 void *dealer = test_context_socket (ZMQ_DEALER); in test_stream_handshake_timeout_connect() local 121 zmq_getsockopt (dealer, ZMQ_HANDSHAKE_IVL, &val, &vsize)); in test_stream_handshake_timeout_connect() 138 dealer, "inproc://monitor-dealer", in test_stream_handshake_timeout_connect() [all …]
|
H A D | test_router_notify.cpp | 120 void *dealer = test_context_socket (ZMQ_DEALER); in test_sockopt_router_notify() local 125 EINVAL, zmq_setsockopt (dealer, ZMQ_ROUTER_NOTIFY, &opt_notify, in test_sockopt_router_notify() 135 test_context_socket_close (dealer); in test_sockopt_router_notify() 155 void *dealer = test_context_socket (ZMQ_DEALER); in test_router_notify_helper() local 159 zmq_setsockopt (dealer, ZMQ_ROUTING_ID, dealer_routing_id, 1)); in test_router_notify_helper() 176 send_string_expect_success (dealer, "Hello", 0); in test_router_notify_helper() 201 test_context_socket_close (dealer); in test_router_notify_helper() 286 void *dealer = test_context_socket (ZMQ_DEALER); in test_error_during_multipart() local 296 send_string_expect_success (dealer, "Hello2", ZMQ_SNDMORE); in test_error_during_multipart() 297 send_string_expect_success (dealer, long_str, 0); in test_error_during_multipart() [all …]
|
H A D | test_issue_566.cpp | 58 void *dealer = zmq_socket (ctx2, ZMQ_DEALER); in test_issue_566() local 63 zmq_setsockopt (dealer, ZMQ_ROUTING_ID, routing_id, 10)); in test_issue_566() 66 zmq_setsockopt (dealer, ZMQ_RCVTIMEO, &rcvtimeo, sizeof (int))); in test_issue_566() 67 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, my_endpoint)); in test_issue_566() 83 recv_string_expect_success (dealer, "HELLO", 0); in test_issue_566() 84 close_zero_linger (dealer); in test_issue_566()
|
H A D | test_router_mandatory_hwm.cpp | 63 void *dealer = test_context_socket (ZMQ_DEALER); in test_router_mandatory_hwm() local 64 TEST_ASSERT_SUCCESS_ERRNO (zmq_setsockopt (dealer, ZMQ_ROUTING_ID, "X", 1)); in test_router_mandatory_hwm() 67 zmq_setsockopt (dealer, ZMQ_RCVHWM, &rcvhwm, sizeof (rcvhwm))); in test_router_mandatory_hwm() 69 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, my_endpoint)); in test_router_mandatory_hwm() 72 send_string_expect_success (dealer, "Hello", 0); in test_router_mandatory_hwm() 110 test_context_socket_close (dealer); in test_router_mandatory_hwm()
|
H A D | test_spec_rep.cpp | 103 void *dealer = test_context_socket (ZMQ_DEALER); in test_envelope() local 105 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, connect_address)); in test_envelope() 108 s_send_seq (dealer, 0, "A", SEQ_END); in test_envelope() 111 s_recv_seq (dealer, 0, "A", SEQ_END); in test_envelope() 114 s_send_seq (dealer, "X", "Y", 0, "A", SEQ_END); in test_envelope() 117 s_recv_seq (dealer, "X", "Y", 0, "A", SEQ_END); in test_envelope() 120 test_context_socket_close_zero_linger (dealer); in test_envelope()
|
H A D | test_reqrep_device_tipc.cpp | 39 void *dealer = test_context_socket (ZMQ_DEALER); in test_roundtrip() local 40 TEST_ASSERT_SUCCESS_ERRNO (zmq_bind (dealer, "tipc://{5560,0,0}")); in test_roundtrip() 66 zmq_msg_send (&msg, dealer, rcvmore ? ZMQ_SNDMORE : 0)); in test_roundtrip() 89 TEST_ASSERT_SUCCESS_ERRNO (zmq_msg_recv (&msg, dealer, 0)); in test_roundtrip() 93 zmq_getsockopt (dealer, ZMQ_RCVMORE, &rcvmore, &sz)); in test_roundtrip() 112 test_context_socket_close (dealer); in test_roundtrip()
|
H A D | test_router_mandatory.cpp | 165 void *dealer = test_context_socket (ZMQ_DEALER); in test_get_peer_state_corner_cases() local 169 rc = zmq_socket_get_peer_state (dealer, peer_routing_id, in test_get_peer_state_corner_cases() 181 test_context_socket_close (dealer); in test_get_peer_state_corner_cases() 206 void *dealer = test_context_socket (ZMQ_DEALER); in test_basic() local 207 TEST_ASSERT_SUCCESS_ERRNO (zmq_setsockopt (dealer, ZMQ_ROUTING_ID, "X", 1)); in test_basic() 208 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, my_endpoint)); in test_basic() 211 send_string_expect_success (dealer, "Hello", 0); in test_basic() 220 test_context_socket_close (dealer); in test_basic()
|
H A D | test_reqrep_device.cpp | 41 void *dealer = test_context_socket (ZMQ_DEALER); in test_roundtrip() local 42 bind_loopback_ipv4 (dealer, endpoint1, sizeof (endpoint1)); in test_roundtrip() 69 zmq_msg_send (&msg, dealer, rcvmore ? ZMQ_SNDMORE : 0)); in test_roundtrip() 92 TEST_ASSERT_SUCCESS_ERRNO (zmq_msg_recv (&msg, dealer, 0)); in test_roundtrip() 96 zmq_getsockopt (dealer, ZMQ_RCVMORE, &rcvmore, &sz)); in test_roundtrip() 115 test_context_socket_close (dealer); in test_roundtrip()
|
H A D | test_stream_empty.cpp | 40 void *dealer = test_context_socket (ZMQ_DEALER); in test_stream_empty() local 43 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, my_endpoint)); in test_stream_empty() 44 send_string_expect_success (dealer, "", 0); in test_stream_empty() 60 test_context_socket_close_zero_linger (dealer); in test_stream_empty()
|
H A D | test_msg_ffn.cpp | 52 void *dealer = test_context_socket (ZMQ_DEALER); in test_msg_init_ffn() local 53 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, my_endpoint)); in test_msg_init_ffn() 87 zmq_msg_send (&msg, dealer, 0); in test_msg_init_ffn() 104 zmq_msg_send (&msg, dealer, 0); in test_msg_init_ffn() 116 test_context_socket_close (dealer); in test_msg_init_ffn()
|
H A D | test_hello_msg.cpp | 48 void *dealer = test_context_socket (ZMQ_DEALER); in test() local 49 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (dealer, my_endpoint)); in test() 52 recv_string_expect_success (dealer, "H", 0); in test() 55 test_context_socket_close (dealer); in test()
|
/dports/games/CaribbeanStud/CS/ |
H A D | Table.cpp | 630 dealer->CurrentPlayer()->GetSeat()->ShowCards(dealer->CurrentPlayer()); in PlayerDrawingAreaCB() 723 if(dealer->NextPlayer()) in DealCB() 737 dealer->DealCards(); in DealCB() 740 ((DealerSeat*)dealer->GetSeat())->ShowCardsBeforeBet(dealer); in DealCB() 744 dealer->CurrentPlayer()->GetSeat()->ShowCards(dealer->CurrentPlayer()); in DealCB() 773 dealer->CurrentPlayer()->Bet(dealer->CurrentPlayer()->Ante()*2); in BetCB() 835 dealer->Score(); in PayTime() 836 dealer->FirstPlayer(); in PayTime() 838 dealer->GetSeat()->ShowCards(dealer); in PayTime() 844 dealer->CollectBet(); in PayTime() [all …]
|
/dports/games/jaggedalliance2/ja2-stracciatella-0.18.0/src/externalized/ |
H A D | DealerModel.cc | 91 for (auto dealer: models) in validateData() local 93 if (dealer->dealerID != ++i) in validateData() 99 if (dealer->type == ArmsDealerType::ARMS_DEALER_REPAIRS in validateData() 100 && (dealer->repairCost == 0.0 || dealer->repairSpeed == 0.0)) in validateData() 105 else if (dealer->type == ArmsDealerType::ARMS_DEALER_BUYS_ONLY in validateData() 106 && (dealer->buyingPrice == 0.0)) in validateData() 108 ST::string err = ST::format("Dealer is a buyer, but buying price is not set", dealer->dealerID); in validateData() 111 else if (dealer->type == ArmsDealerType::ARMS_DEALER_SELLS_ONLY in validateData() 112 && (dealer->sellingPrice == 0.0)) in validateData() 117 else if (dealer->type == ArmsDealerType::ARMS_DEALER_BUYS_ONLY in validateData() [all …]
|
/dports/net/pecl-zmq/zmq-1.1.3/tests/ |
H A D | bug_gh_59_2.phpt | 31 $dealer = $context->getSocket(ZMQ::SOCKET_DEALER); 33 $pids[] = forkRepWorker($dealer); 34 $pids[] = forkRepWorker($dealer); 36 $dealer->bind('ipc://test2.ipc'); 39 $dealer->sendmulti(array('A', '', 'foo')); 40 $dealer->sendmulti(array('B', '', 'bar')); 43 $msgs[] = $dealer->recvmulti(); 44 $msgs[] = $dealer->recvmulti();
|
/dports/security/keybase/client-v5.7.1/go/chat/flip/ |
H A D | dealer_test.go | 75 dealer *Dealer member 89 dealer := NewDealer(dh) 102 dealer: dealer, 150 res := <-b.dealer.UpdateCh() 156 res := <-b.dealer.UpdateCh() 168 b.dealer.Stop() 211 msg := <-b.dealer.UpdateCh() 218 msg = <-b.dealer.UpdateCh() 260 msg := <-me.dealer.UpdateCh() 266 msg := <-b.dealer.UpdateCh() [all …]
|
H A D | chat_test.go | 31 dealer *Dealer member 128 ret.dealer = NewDealer(ret) 138 _ = c.dealer.Run(ctx) 173 msg := <-c.dealer.UpdateCh() 178 msg := <-c.dealer.UpdateCh() 184 msg := <-c.dealer.UpdateCh() 189 msg := <-c.dealer.UpdateCh() 197 msg := <-c.dealer.UpdateCh() 207 msg := <-c.dealer.UpdateCh() 233 msg := <-c.dealer.UpdateCh() [all …]
|
/dports/net/fbzmq/fbzmq-2021.12.27.00/fbzmq/service/monitor/tests/ |
H A D | ZmqMonitorTest.cpp | 59 Socket<ZMQ_DEALER, ZMQ_CLIENT> dealer(context); in TEST() local 60 dealer.connect(SocketUrl{"inproc://monitor-rep"}).value(); in TEST() 73 dealer.sendThriftObj(thriftReq, serializer).value(); in TEST() 77 dealer.sendThriftObj(thriftReq, serializer).value(); in TEST() 97 dealer.sendThriftObj(thriftReq, serializer).value(); in TEST() 175 dealer.sendThriftObj(thriftReq, serializer).value(); in TEST() 179 dealer.sendThriftObj(thriftReq, serializer).value(); in TEST() 193 dealer.sendThriftObj(thriftReq, serializer).value(); in TEST() 197 dealer.sendThriftObj(thriftReq, serializer).value(); in TEST() 216 dealer.sendThriftObj(thriftReq, serializer).value(); in TEST() [all …]
|
/dports/games/libtmcg/libTMCG-1.3.18/src/ |
H A D | PedersenVSS.cc | 460 (size_t dealer, in Share() argument 477 assert(dealer < n); in Share() 572 mpz_set_ui(rhs, dealer); in Share() 579 mpz_set_ui(rhs, dealer); in Share() 588 if ((j != i) && (j != dealer)) in Share() 633 if (!rbc->DeliverFrom(lhs, dealer)) in Share() 722 (const size_t dealer, mpz_ptr sigma, in Reconstruct() argument 732 (const size_t dealer, mpz_ptr sigma, in Reconstruct() argument 755 if (i != dealer) in Reconstruct() 774 if ((j != i) && (j != dealer)) in Reconstruct() [all …]
|
/dports/games/dose-response/dose-response-179c326/cargo-crates/zmq-0.8.2/examples/zguide/fileio3/ |
H A D | main.rs | 30 let dealer = context.socket(zmq::DEALER).unwrap(); in client_thread() localVariable 32 dealer.set_identity(&identity).unwrap(); in client_thread() 34 assert!(dealer.connect("tcp://localhost:6000").is_ok()); in client_thread() 47 dealer.send_str("fetch", SNDMORE).unwrap(); in client_thread() 48 dealer.send_str(&offset.to_string(), SNDMORE).unwrap(); in client_thread() 49 dealer.send_str(CHUNK_SIZE_STR, 0).unwrap(); in client_thread() 53 let chunk = dealer.recv_string(0).unwrap().unwrap(); in client_thread()
|
/dports/net/fbzmq/fbzmq-2021.12.27.00/fbzmq/service/monitor/ |
H A D | ZmqMonitorSample.cpp | 28 Socket<ZMQ_DEALER, ZMQ_CLIENT> dealer(context); in oneShot() local 32 dealer.setSockOpt(ZMQ_IPV6, &ipv6Enable, sizeof(int)).value(); in oneShot() 38 dealer.connect(SocketUrl(routerSockUrl)).value(); in oneShot() 47 dealer.sendThriftObj(thriftReq, serializer).value(); in oneShot() 51 dealer.recvThriftObj<thrift::CounterValuesResponse>(serializer).value(); in oneShot()
|
/dports/math/py-gym/gym-0.21.0/gym/envs/toy_text/ |
H A D | blackjack.py | 106 while sum_hand(self.dealer) < 17: 107 self.dealer.append(draw_card(self.np_random)) 108 reward = cmp(score(self.player), score(self.dealer)) 109 if self.sab and is_natural(self.player) and not is_natural(self.dealer): 123 return (sum_hand(self.player), self.dealer[0], usable_ace(self.player)) 126 self.dealer = draw_hand(self.np_random)
|
/dports/mail/bogofilter-sqlite/bogofilter-1.2.5/src/tests/outputs/ |
H A D | token.count.ref | 27 "dealer" 2 0.000000 0.095238 0.995766 - 57 "dealer" 2 0.000000 0.095238 0.995766 + 87 "dealer" 2 0.000000 0.095238 0.995766 - 117 "dealer" 2 0.000000 0.095238 0.995766 + 147 "dealer" 2 0.000000 0.095238 0.995766 + 177 "dealer" 2 0.000000 0.095238 0.995766 + 207 "dealer" 2 0.000000 0.095238 0.995766 +
|
/dports/mail/bogofilter/bogofilter-1.2.5/src/tests/outputs/ |
H A D | token.count.ref | 27 "dealer" 2 0.000000 0.095238 0.995766 - 57 "dealer" 2 0.000000 0.095238 0.995766 + 87 "dealer" 2 0.000000 0.095238 0.995766 - 117 "dealer" 2 0.000000 0.095238 0.995766 + 147 "dealer" 2 0.000000 0.095238 0.995766 + 177 "dealer" 2 0.000000 0.095238 0.995766 + 207 "dealer" 2 0.000000 0.095238 0.995766 +
|
/dports/mail/bogofilter-kc/bogofilter-1.2.5/src/tests/outputs/ |
H A D | token.count.ref | 27 "dealer" 2 0.000000 0.095238 0.995766 - 57 "dealer" 2 0.000000 0.095238 0.995766 + 87 "dealer" 2 0.000000 0.095238 0.995766 - 117 "dealer" 2 0.000000 0.095238 0.995766 + 147 "dealer" 2 0.000000 0.095238 0.995766 + 177 "dealer" 2 0.000000 0.095238 0.995766 + 207 "dealer" 2 0.000000 0.095238 0.995766 +
|
/dports/mail/bogofilter-lmdb/bogofilter-1.2.5/src/tests/outputs/ |
H A D | token.count.ref | 27 "dealer" 2 0.000000 0.095238 0.995766 - 57 "dealer" 2 0.000000 0.095238 0.995766 + 87 "dealer" 2 0.000000 0.095238 0.995766 - 117 "dealer" 2 0.000000 0.095238 0.995766 + 147 "dealer" 2 0.000000 0.095238 0.995766 + 177 "dealer" 2 0.000000 0.095238 0.995766 + 207 "dealer" 2 0.000000 0.095238 0.995766 +
|