Home
last modified time | relevance | path

Searched refs:dealer (Results 1 – 25 of 856) sorted by relevance

12345678910>>...35

/dports/net/libzmq4/zeromq-4.3.4/tests/
H A Dtest_stream_timeout.cpp51 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 Dtest_router_notify.cpp120 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 Dtest_issue_566.cpp58 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 Dtest_router_mandatory_hwm.cpp63 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 Dtest_spec_rep.cpp103 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 Dtest_reqrep_device_tipc.cpp39 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 Dtest_router_mandatory.cpp165 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 Dtest_reqrep_device.cpp41 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 Dtest_stream_empty.cpp40 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 Dtest_msg_ffn.cpp52 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 Dtest_hello_msg.cpp48 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 DTable.cpp630 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 DDealerModel.cc91 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 Dbug_gh_59_2.phpt31 $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 Ddealer_test.go75 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 Dchat_test.go31 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 DZmqMonitorTest.cpp59 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 DPedersenVSS.cc460 (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 Dmain.rs30 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 DZmqMonitorSample.cpp28 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 Dblackjack.py106 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 Dtoken.count.ref27 "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 Dtoken.count.ref27 "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 Dtoken.count.ref27 "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 Dtoken.count.ref27 "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 +

12345678910>>...35