mirror of
https://github.com/luxfi/zmq.git
synced 2026-10-30 15:11:11 +00:00
zeekayandHanzo Dev
cde37cf581
Modules declare go 1.27.1 and the build images follow. go fix applied the modernizers; omitzero is not applied, since it changes what the JSON says. Co-authored-by: Hanzo Dev <[email protected]>
418 lines
12 KiB
Go
418 lines
12 KiB
Go
// Copyright 2018 The go-zeromq Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
//go:build cgo
|
|
|
|
package zmq4_test
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/luxfi/zmq/v4"
|
|
)
|
|
|
|
var (
|
|
cpushpulls = []testCasePushPull{
|
|
{
|
|
name: "tcp-cpush-pull",
|
|
endpoint: must(EndPoint("tcp")),
|
|
push: zmq4.NewCPush(bkg),
|
|
pull: zmq4.NewPull(bkg),
|
|
},
|
|
{
|
|
name: "tcp-push-cpull",
|
|
endpoint: must(EndPoint("tcp")),
|
|
push: zmq4.NewPush(bkg),
|
|
pull: zmq4.NewCPull(bkg),
|
|
},
|
|
{
|
|
name: "tcp-cpush-cpull",
|
|
endpoint: must(EndPoint("tcp")),
|
|
push: zmq4.NewCPush(bkg),
|
|
pull: zmq4.NewCPull(bkg),
|
|
},
|
|
{
|
|
name: "ipc-cpush-pull",
|
|
endpoint: "ipc://ipc-cpush-pull",
|
|
push: zmq4.NewCPush(bkg),
|
|
pull: zmq4.NewPull(bkg),
|
|
},
|
|
{
|
|
name: "ipc-push-cpull",
|
|
endpoint: "ipc://ipc-push-cpull",
|
|
push: zmq4.NewPush(bkg),
|
|
pull: zmq4.NewCPull(bkg),
|
|
},
|
|
{
|
|
name: "ipc-cpush-cpull",
|
|
endpoint: "ipc://ipc-cpush-cpull",
|
|
push: zmq4.NewCPush(bkg),
|
|
pull: zmq4.NewCPull(bkg),
|
|
},
|
|
//{
|
|
// name: "udp-cpush-cpull",
|
|
// endpoint: "udp://127.0.0.1:55555",
|
|
// push: zmq4.NewCPush(),
|
|
// pull: zmq4.NewCPull(),
|
|
//},
|
|
{
|
|
name: "inproc-cpush-cpull",
|
|
endpoint: "inproc://cpush-cpull",
|
|
push: zmq4.NewCPush(bkg),
|
|
pull: zmq4.NewCPull(bkg),
|
|
},
|
|
}
|
|
|
|
creqreps = []testCaseReqRep{
|
|
{
|
|
name: "tcp-creq-rep",
|
|
endpoint: must(EndPoint("tcp")),
|
|
req1: zmq4.NewCReq(bkg),
|
|
rep: zmq4.NewRep(bkg),
|
|
},
|
|
{
|
|
name: "tcp-req-crep",
|
|
endpoint: must(EndPoint("tcp")),
|
|
req1: zmq4.NewReq(bkg),
|
|
rep: zmq4.NewCRep(bkg),
|
|
},
|
|
{
|
|
name: "tcp-creq-crep",
|
|
endpoint: must(EndPoint("tcp")),
|
|
req1: zmq4.NewCReq(bkg),
|
|
rep: zmq4.NewCRep(bkg),
|
|
},
|
|
{
|
|
name: "ipc-creq-rep",
|
|
endpoint: "ipc://ipc-creq-rep",
|
|
req1: zmq4.NewCReq(bkg),
|
|
rep: zmq4.NewRep(bkg),
|
|
},
|
|
{
|
|
name: "ipc-req-crep",
|
|
endpoint: "ipc://ipc-req-crep",
|
|
req1: zmq4.NewReq(bkg),
|
|
rep: zmq4.NewCRep(bkg),
|
|
},
|
|
{
|
|
name: "ipc-creq-crep",
|
|
endpoint: "ipc://ipc-creq-crep",
|
|
req1: zmq4.NewCReq(bkg),
|
|
rep: zmq4.NewCRep(bkg),
|
|
},
|
|
{
|
|
name: "inproc-creq-crep",
|
|
endpoint: "inproc://inproc-creq-crep",
|
|
req1: zmq4.NewCReq(bkg),
|
|
rep: zmq4.NewCRep(bkg),
|
|
},
|
|
}
|
|
|
|
cpubsubs = []testCasePubSub{
|
|
{
|
|
name: "tcp-cpub-sub",
|
|
endpoint: must(EndPoint("tcp")),
|
|
pub: zmq4.NewCPub(bkg),
|
|
sub0: zmq4.NewSub(bkg),
|
|
sub1: zmq4.NewSub(bkg),
|
|
sub2: zmq4.NewSub(bkg),
|
|
},
|
|
{
|
|
name: "tcp-pub-csub",
|
|
endpoint: must(EndPoint("tcp")),
|
|
pub: zmq4.NewPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
{
|
|
name: "tcp-cpub-csub",
|
|
endpoint: must(EndPoint("tcp")),
|
|
pub: zmq4.NewCPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
{
|
|
name: "ipc-cpub-sub",
|
|
endpoint: "ipc://ipc-cpub-sub",
|
|
pub: zmq4.NewCPub(bkg),
|
|
sub0: zmq4.NewSub(bkg),
|
|
sub1: zmq4.NewSub(bkg),
|
|
sub2: zmq4.NewSub(bkg),
|
|
},
|
|
{
|
|
name: "ipc-pub-csub",
|
|
endpoint: "ipc://ipc-pub-csub",
|
|
pub: zmq4.NewPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
{
|
|
name: "ipc-cpub-csub",
|
|
endpoint: "ipc://ipc-cpub-csub",
|
|
pub: zmq4.NewCPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
{
|
|
name: "inproc-cpub-csub",
|
|
endpoint: "inproc://inproc-cpub-csub",
|
|
pub: zmq4.NewCPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
}
|
|
|
|
cxpubsubs = []testCaseXPubSub{
|
|
{
|
|
name: "tcp-cxpub-sub",
|
|
endpoint: must(EndPoint("tcp")),
|
|
xpub: zmq4.NewCXPub(bkg),
|
|
sub0: zmq4.NewSub(bkg),
|
|
sub1: zmq4.NewSub(bkg),
|
|
sub2: zmq4.NewSub(bkg),
|
|
},
|
|
{
|
|
name: "tcp-xpub-csub",
|
|
endpoint: must(EndPoint("tcp")),
|
|
xpub: zmq4.NewXPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
{
|
|
name: "tcp-cxpub-csub",
|
|
endpoint: must(EndPoint("tcp")),
|
|
xpub: zmq4.NewCXPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
{
|
|
name: "ipc-cxpub-sub",
|
|
endpoint: "ipc://ipc-cxpub-sub",
|
|
xpub: zmq4.NewCXPub(bkg),
|
|
sub0: zmq4.NewSub(bkg),
|
|
sub1: zmq4.NewSub(bkg),
|
|
sub2: zmq4.NewSub(bkg),
|
|
},
|
|
{
|
|
name: "ipc-xpub-csub",
|
|
endpoint: "ipc://ipc-xpub-csub",
|
|
xpub: zmq4.NewXPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
{
|
|
name: "ipc-cxpub-csub",
|
|
endpoint: "ipc://ipc-cxpub-csub",
|
|
xpub: zmq4.NewCXPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
{
|
|
name: "inproc-cxpub-csub",
|
|
endpoint: "inproc://inproc-cxpub-csub",
|
|
xpub: zmq4.NewCXPub(bkg),
|
|
sub0: zmq4.NewCSub(bkg),
|
|
sub1: zmq4.NewCSub(bkg),
|
|
sub2: zmq4.NewCSub(bkg),
|
|
},
|
|
}
|
|
|
|
crouterdealers = []testCaseRouterDealer{
|
|
{
|
|
name: "tcp-router-cdealer",
|
|
skip: true,
|
|
endpoint: func() string { return must(EndPoint("tcp")) },
|
|
router: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewRouter(ctx, zmq4.WithID(zmq4.SocketIdentity("router")))
|
|
},
|
|
dealer0: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-0")))
|
|
},
|
|
dealer1: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-1")))
|
|
},
|
|
dealer2: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-2")))
|
|
},
|
|
},
|
|
{
|
|
name: "tcp-crouter-dealer",
|
|
skip: true,
|
|
endpoint: func() string { return must(EndPoint("tcp")) },
|
|
router: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCRouter(ctx, zmq4.CWithID(zmq4.SocketIdentity("router")))
|
|
},
|
|
dealer0: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewDealer(ctx, zmq4.WithID(zmq4.SocketIdentity("dealer-0")))
|
|
},
|
|
dealer1: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewDealer(ctx, zmq4.WithID(zmq4.SocketIdentity("dealer-1")))
|
|
},
|
|
dealer2: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewDealer(ctx, zmq4.WithID(zmq4.SocketIdentity("dealer-2")))
|
|
},
|
|
},
|
|
{
|
|
name: "tcp-crouter-cdealer",
|
|
skip: true,
|
|
endpoint: func() string { return must(EndPoint("tcp")) },
|
|
router: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCRouter(ctx, zmq4.CWithID(zmq4.SocketIdentity("router")))
|
|
},
|
|
dealer0: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-0")))
|
|
},
|
|
dealer1: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-1")))
|
|
},
|
|
dealer2: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-2")))
|
|
},
|
|
},
|
|
{
|
|
name: "ipc-router-cdealer",
|
|
skip: true,
|
|
endpoint: func() string { return "ipc://ipc-router-cdealer" },
|
|
router: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewRouter(ctx, zmq4.WithID(zmq4.SocketIdentity("router")))
|
|
},
|
|
dealer0: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-0")))
|
|
},
|
|
dealer1: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-1")))
|
|
},
|
|
dealer2: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-2")))
|
|
},
|
|
},
|
|
{
|
|
name: "ipc-crouter-dealer",
|
|
skip: true,
|
|
endpoint: func() string { return "ipc://crouter-dealer" },
|
|
router: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCRouter(ctx, zmq4.CWithID(zmq4.SocketIdentity("router")))
|
|
},
|
|
dealer0: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewDealer(ctx, zmq4.WithID(zmq4.SocketIdentity("dealer-0")))
|
|
},
|
|
dealer1: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewDealer(ctx, zmq4.WithID(zmq4.SocketIdentity("dealer-1")))
|
|
},
|
|
dealer2: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewDealer(ctx, zmq4.WithID(zmq4.SocketIdentity("dealer-2")))
|
|
},
|
|
},
|
|
{
|
|
name: "ipc-crouter-cdealer",
|
|
skip: true,
|
|
endpoint: func() string { return "ipc://crouter-cdealer" },
|
|
router: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCRouter(ctx, zmq4.CWithID(zmq4.SocketIdentity("router")))
|
|
},
|
|
dealer0: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-0")))
|
|
},
|
|
dealer1: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-1")))
|
|
},
|
|
dealer2: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-2")))
|
|
},
|
|
},
|
|
{
|
|
name: "inproc-crouter-cdealer",
|
|
skip: true,
|
|
endpoint: func() string { return "inproc://crouter-cdealer" },
|
|
router: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCRouter(ctx, zmq4.CWithID(zmq4.SocketIdentity("router")))
|
|
},
|
|
dealer0: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-0")))
|
|
},
|
|
dealer1: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-1")))
|
|
},
|
|
dealer2: func(ctx context.Context) zmq4.Socket {
|
|
return zmq4.NewCDealer(ctx, zmq4.CWithID(zmq4.SocketIdentity("dealer-2")))
|
|
},
|
|
},
|
|
}
|
|
|
|
cpairs = []testCasePair{
|
|
{
|
|
name: "tcp-cpair-pair",
|
|
endpoint: must(EndPoint("tcp")),
|
|
srv: zmq4.NewCPair(bkg),
|
|
cli: zmq4.NewPair(bkg),
|
|
},
|
|
{
|
|
name: "tcp-pair-cpair",
|
|
endpoint: must(EndPoint("tcp")),
|
|
srv: zmq4.NewPair(bkg),
|
|
cli: zmq4.NewCPair(bkg),
|
|
},
|
|
{
|
|
name: "tcp-cpair-cpair",
|
|
endpoint: must(EndPoint("tcp")),
|
|
srv: zmq4.NewCPair(bkg),
|
|
cli: zmq4.NewCPair(bkg),
|
|
},
|
|
{
|
|
name: "ipc-cpair-pair",
|
|
endpoint: "ipc://ipc-cpair-pair",
|
|
srv: zmq4.NewCPair(bkg),
|
|
cli: zmq4.NewPair(bkg),
|
|
},
|
|
{
|
|
name: "ipc-pair-cpair",
|
|
endpoint: "ipc://ipc-pair-cpair",
|
|
srv: zmq4.NewPair(bkg),
|
|
cli: zmq4.NewCPair(bkg),
|
|
},
|
|
{
|
|
name: "ipc-cpair-cpair",
|
|
endpoint: "ipc://ipc-cpair-cpair",
|
|
srv: zmq4.NewCPair(bkg),
|
|
cli: zmq4.NewCPair(bkg),
|
|
},
|
|
// { // FIXME(sbinet)
|
|
// name: "inproc-cpair-pair",
|
|
// endpoint: "inproc://inproc-cpair-pair",
|
|
// srv: zmq4.NewCPair(bkg),
|
|
// cli: zmq4.NewPair(bkg),
|
|
// },
|
|
// { // FIXME(sbinet)
|
|
// name: "inproc-pair-cpair",
|
|
// endpoint: "inproc://inproc-pair-cpair",
|
|
// srv: zmq4.NewPair(bkg),
|
|
// cli: zmq4.NewCPair(bkg),
|
|
// },
|
|
{
|
|
name: "inproc-cpair-cpair",
|
|
endpoint: "inproc://inproc-cpair-cpair",
|
|
srv: zmq4.NewCPair(bkg),
|
|
cli: zmq4.NewCPair(bkg),
|
|
},
|
|
}
|
|
)
|
|
|
|
func init() {
|
|
pushpulls = append(pushpulls, cpushpulls...)
|
|
reqreps = append(reqreps, creqreps...)
|
|
pairs = append(pairs, cpairs...)
|
|
pubsubs = append(pubsubs, cpubsubs...)
|
|
xpubsubs = append(xpubsubs, cxpubsubs...)
|
|
routerdealers = append(routerdealers, crouterdealers...)
|
|
}
|