PATH:
opt
/
alt
/
tests
/
alt-php85-pecl-zmq_1.1.3-2.84f0720.el8
/
tests
--TEST-- Test send / recv with a manually created XREQ and XREP device --SKIPIF-- <?php require_once(dirname(__FILE__) . '/skipif.inc'); if(!defined('ZMQ::SOCKOPT_RCVLABEL')) die('skip Only for in libzmq 3.3.0'); ?> --FILE-- <?php $ctx = new ZMQContext(); $req = new ZMQSocket($ctx, ZMQ::SOCKET_REQ); $xrep = new ZMQSocket($ctx, ZMQ::SOCKET_XREP); $xreq = new ZMQSocket($ctx, ZMQ::SOCKET_XREQ); $rep = new ZMQSocket($ctx, ZMQ::SOCKET_REP); $xrep->bind('inproc://xrep'); $xreq->bind('inproc://xreq'); $req->connect('inproc://xrep'); $rep->connect('inproc://xreq'); $in = array('hi', 'there'); $req->sendMulti($in); do { $message = $xrep->recv(); $more = $xrep->getSockOpt(ZMQ::SOCKOPT_RCVMORE); if( $xrep->getSockOpt( ZMQ::SOCKOPT_RCVLABEL ) ) { $xreq->send( $message, ZMQ::MODE_SNDLABEL ); } else { $xreq->send( $message, $more ? ZMQ::MODE_SNDMORE : 0 ); } } while( $more ); $out = $rep->recvMulti(); assert($in == $out); $rep->sendMulti(array("oh", "hello!")); do { $message = $xreq->recv(); $more = $xreq->getSockOpt(ZMQ::SOCKOPT_RCVMORE); if( $xreq->getSockOpt( ZMQ::SOCKOPT_RCVLABEL ) ) { $xrep->send( $message, ZMQ::MODE_SNDLABEL ); } else { $xrep->send( $message, $more ? ZMQ::MODE_SNDMORE : 0 ); } } while( $more ); var_dump($req->recvMulti()); --EXPECT-- array(2) { [0]=> string(2) "oh" [1]=> string(6) "hello!" }
[-] 034-unbind.phpt
[edit]
[-] 050-sharedcontext.phpt
[edit]
[-] 021-callbackwarning.phpt
[edit]
[-] 023-failedcallback.phpt
[edit]
[-] 047-auth-configure.phpt
[edit]
[-] 003-getpersistentid.phpt
[edit]
[-] 017-callbackonlyonnewsocket.phpt
[edit]
[-] bug_gh_50.phpt
[edit]
[-] 040-cert-clone.phpt
[edit]
[-] bug_gh_59_2.phpt
[edit]
[-] 027-getset.phpt
[edit]
[-] 039-cert-equals.phpt
[edit]
[-] 055-socks-proxy.phpt
[edit]
[-] 010-pollsetinvalidargs.phpt
[edit]
[-] 051-socketcount.phpt
[edit]
[-] 046-cert-apply.phpt
[edit]
[-] skipif-libzmq2.inc
[edit]
[-] bug_gh_49.phpt
[edit]
[-] libzmq2-sockopt.phpt
[edit]
[-] 028-xpub.phpt
[edit]
[-] 014-setsockoptparam.phpt
[edit]
[-] 012-pollsetremoveinvalid.phpt
[edit]
[-] bug_gh_59.phpt
[edit]
[-] 024-versionconstant.phpt
[edit]
[-] 036-device.phpt
[edit]
[-] 045-auth-allow-deny.phpt
[edit]
[-] 022-highwatermark.phpt
[edit]
[-] 043-cert-load.phpt
[edit]
[-] 020-exceptionincallback.phpt
[edit]
[-] 029-xrepxreqdevice.phpt
[edit]
[-] 052-pthreads.phpt
[edit]
[-] libzmq4-sockopt.phpt
[edit]
[-] skipif-libzmq3.inc
[edit]
[-] 026-sockettype.phpt
[edit]
[-] 018-callbackpersistent.phpt
[edit]
[-] 044-auth-construct.phpt
[edit]
[-] 009-ispersistent.phpt
[edit]
[-] bug_gh_165.phpt
[edit]
[-] 033-disconnect.phpt
[edit]
[-] 030-xrepmanualqueue.phpt
[edit]
[-] 025-sendrecvmulti.phpt
[edit]
[-] 042-cert-save.phpt
[edit]
[-] 007-addremovepoll.phpt
[edit]
[-] 038-cert-construct.phpt
[edit]
[-] 037-device-deprecated.phpt
[edit]
[-] 004-getendpoints.phpt
[edit]
[-] 001-send.phpt
[edit]
[+]
..
[-] 015-callback.phpt
[edit]
[-] 005-forceconnectarg.phpt
[edit]
[-] libzmq3-sockopt.phpt
[edit]
[-] 006-sockopt.phpt
[edit]
[-] 008-twowaystoconstruct.phpt
[edit]
[-] 035-capture.phpt
[edit]
[-] bug_gh_156.phpt
[edit]
[-] zeromq_test_helper.inc
[edit]
[-] 049-events.phpt
[edit]
[-] 016-callbackinvalidargs.phpt
[edit]
[-] 031-lastendpoint.phpt
[edit]
[-] bug_gh_43.phpt
[edit]
[-] 002-test-binary.phpt
[edit]
[-] 048-pollsetitems.phpt
[edit]
[-] 053-z85.phpt
[edit]
[-] skipif-czmq2.inc
[edit]
[-] 041-cert-meta.phpt
[edit]
[-] 013-pollclearandreuse.phpt
[edit]
[-] rose.jpg
[edit]
[-] skipif.inc
[edit]
[-] skipif-libzmq4.inc
[edit]
[-] 032-contextopt.phpt
[edit]
[-] 011-exceptions.phpt
[edit]
[-] 054-curvekeypair.phpt
[edit]