Home
last modified time | relevance | path

Searched refs:broker (Results 1 – 25 of 3708) sorted by relevance

12345678910>>...149

/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/
H A Dbroker_test.go10 broker := NewBroker("localhost:9092")
11 err := broker.Open(nil)
19 _ = broker.Close()
44 broker := NewBroker("abc:123")
46 if broker.ID() != -1 {
54 broker.id = 34
55 if broker.ID() != 34 {
72 broker.id = 0
75 err := broker.Open(conf)
79 tt.runner(t, broker)
[all …]
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/
H A Dbroker_test.go10 broker := NewBroker("localhost:9092")
11 err := broker.Open(nil)
19 _ = broker.Close()
44 broker := NewBroker("abc:123")
46 if broker.ID() != -1 {
54 broker.id = 34
55 if broker.ID() != 34 {
72 broker.id = 0
75 err := broker.Open(conf)
79 tt.runner(t, broker)
[all …]
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/
H A Dmdbroker.go64 broker = &Broker{
82 broker.socket = nil
204 if broker.verbose {
221 broker: broker,
227 if broker.verbose {
247 service.broker.waiting = delWorker(service.broker.waiting, worker)
265 broker: broker,
270 if broker.verbose {
287 worker.broker.waiting = delWorker(worker.broker.waiting, worker)
324 worker.broker.waiting = append(worker.broker.waiting, worker)
[all …]
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/
H A Dmdbroker.go64 broker = &Broker{
82 broker.socket = nil
204 if broker.verbose {
221 broker: broker,
227 if broker.verbose {
247 service.broker.waiting = delWorker(service.broker.waiting, worker)
265 broker: broker,
270 if broker.verbose {
287 worker.broker.waiting = delWorker(worker.broker.waiting, worker)
324 worker.broker.waiting = append(worker.broker.waiting, worker)
[all …]
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/
H A Dmdbroker.go64 broker = &Broker{
82 broker.socket = nil
204 if broker.verbose {
221 broker: broker,
227 if broker.verbose {
247 service.broker.waiting = delWorker(service.broker.waiting, worker)
265 broker: broker,
270 if broker.verbose {
287 worker.broker.waiting = delWorker(worker.broker.waiting, worker)
324 worker.broker.waiting = append(worker.broker.waiting, worker)
[all …]
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/examples/
H A Dmdbroker.go64 broker = &Broker{
82 broker.socket = nil
204 if broker.verbose {
221 broker: broker,
227 if broker.verbose {
247 service.broker.waiting = delWorker(service.broker.waiting, worker)
265 broker: broker,
270 if broker.verbose {
287 worker.broker.waiting = delWorker(worker.broker.waiting, worker)
324 worker.broker.waiting = append(worker.broker.waiting, worker)
[all …]
/dports/lang/v8/v8-9.6.180.12/src/compiler/
H A Dheap-refs.cc31 #define TRACE(broker, x) TRACE_BROKER(broker, x) argument
32 #define TRACE_MISSING(broker, x) TRACE_BROKER_MISSING(broker, x) argument
94 broker_(broker) in ObjectData()
396 broker, in GetOwnFastDataPropertyFromHeap()
528 Cache(broker); in JSFunctionData()
1779 broker(), in FindFieldOwner()
1809 broker(), in length()
1820 broker(), in GetFirstChar()
1837 broker(), in ToNumber()
2133 broker(), in instance_descriptors()
[all …]
H A Djs-heap-copy-reducer.cc24 JSHeapCopyReducer::JSHeapCopyReducer(JSHeapBroker* broker) : broker_(broker) {} in JSHeapCopyReducer() argument
55 p.map(broker()); in Reduce()
64 p.shared_info(broker()); in Reduce()
65 p.code(broker()); in Reduce()
122 p.scope_info(broker()); in Reduce()
143 p.shared(broker()); in Reduce()
144 p.description(broker()); in Reduce()
172 p.name(broker()); in Reduce()
191 MakeRef(broker(), map); in Reduce()
198 MakeRef(broker(), map); in Reduce()
[all …]
/dports/sysutils/pxp-agent/pxp-agent-1.15.16/acceptance/lib/pxp-agent/
H A Dbolt_pxp_module_helper.rb107 def run_command(broker, targets, command, **kwargs, &block) argument
114 def download_file(broker, agent, files, **kwargs, &block) argument
185 download_file(broker, agent, files, **kwargs) do |datas|
193 download_file(broker, agent, files, **kwargs) do |datas|
194 ensure_failed(broker, [agent], datas, **kwargs, &block)
201 download_file(broker, agent, files, **kwargs) do |datas|
202 ensure_errored(broker, [agent], datas, **kwargs, &block)
235 run_command(broker, targets, command) do |response_dataset|
243 run_command(broker, targets, command) do |response_dataset|
250 def run_errored_command(broker, targets, command) argument
[all …]
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/
H A Dbroker_test.go18 err := broker.Open(nil)
26 _ = broker.Close()
57 if broker.ID() != -1 {
69 broker.id = 34
70 if broker.ID() != 34 {
75 broker.rack = &rack
94 broker.id = 0
101 tt.runner(t, broker)
233 broker.conf = conf
562 broker.conf = conf
[all …]
H A Dclient.go201 for broker := client.any(); broker != nil; broker = client.any() {
569 currentBroker[broker.ID()] = broker
571 client.brokers[broker.ID()] = broker
575 client.brokers[broker.ID()] = broker
599 client.brokers[broker.ID()] = broker
601 } else if broker.Addr() != client.brokers[broker.ID()].Addr() {
603 client.brokers[broker.ID()] = broker
648 return broker
835 for ; broker != nil && !pastDeadline(0); broker = client.any() {
890 if broker != nil {
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/
H A Dbroker_test.go18 err := broker.Open(nil)
26 _ = broker.Close()
57 if broker.ID() != -1 {
69 broker.id = 34
70 if broker.ID() != 34 {
75 broker.rack = &rack
94 broker.id = 0
101 tt.runner(t, broker)
233 broker.conf = conf
559 broker.conf = conf
[all …]
H A Dclient.go212 return broker, nil
217 for broker := client.any(); broker != nil; broker = client.any() {
612 currentBroker[broker.ID()] = broker
614 client.brokers[broker.ID()] = broker
618 client.brokers[broker.ID()] = broker
642 client.brokers[broker.ID()] = broker
644 } else if broker.Addr() != client.brokers[broker.ID()].Addr() {
646 client.brokers[broker.ID()] = broker
691 return broker
878 for ; broker != nil && !pastDeadline(0); broker = client.any() {
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/v8/src/compiler/
H A Djs-heap-broker.cc42 #define TRACE(broker, x) TRACE_BROKER(broker, x) argument
43 #define TRACE_MISSING(broker, x) TRACE_BROKER_MISSING(broker, x) argument
1749 broker in SerializeScopeInfoChain()
1826 broker in SerializeFunctionTemplateInfo()
1836 broker in SerializeScopeInfoChain()
2908 broker(), in GetClosureFeedbackCell()
2949 broker(), in RawFastPropertyAt()
3040 broker(), in GetPropertyKey()
3072 broker(), in FindFieldOwner()
3089 broker(), in GetFieldType()
[all …]
H A Djs-heap-copy-reducer.cc24 JSHeapCopyReducer::JSHeapCopyReducer(JSHeapBroker* broker) : broker_(broker) {} in JSHeapCopyReducer() argument
56 SharedFunctionInfoRef shared(broker(), in Reduce()
67 MapRef(broker(), p.map()); in Reduce()
78 HeapObjectRef(broker(), p.code()); in Reduce()
124 NameRef name(broker(), p.name()); in Reduce()
133 NameRef name(broker(), p.name()); in Reduce()
141 MapRef(broker(), map_handle); in Reduce()
145 NameRef(broker(), name_handle); in Reduce()
152 MapRef(broker(), map); in Reduce()
159 MapRef(broker(), map); in Reduce()
[all …]
/dports/games/automuteus/automuteus-6.15.2/vendor/github.com/automuteus/galactus/broker/
H A Dbroker.go1 package broker package
87 broker.taskChannelsLock.Lock()
102 broker.taskChannelsLock.Lock()
149 broker.connectionsLock.Lock()
166 broker.connectionsLock.RLock()
171 go broker.TasksListener(server, code, broker.ackKillChannels[s.ID()])
240 broker.connectionsLock.RLock()
251 broker.connectionsLock.RLock()
268 broker.connectionsLock.RLock()
277 broker.connectionsLock.Lock()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/v8/src/compiler/
H A Djs-heap-broker.cc43 #define TRACE(broker, x) TRACE_BROKER(broker, x) argument
44 #define TRACE_MISSING(broker, x) TRACE_BROKER_MISSING(broker, x) argument
3012 broker(), in GetClosureFeedbackCell()
3050 broker(), in RawFastPropertyAt()
3143 return NameRef(broker(), broker()->CanonicalPersistentHandle( in GetPropertyKey()
3176 broker(), in FindFieldOwner()
3194 broker(), in GetFieldType()
3640 return MapRef(broker(), broker()->CanonicalPersistentHandle( in FindRootMap()
3754 broker(), in shared_function_info()
4217 broker); in Serialize()
[all …]
H A Djs-heap-copy-reducer.cc24 JSHeapCopyReducer::JSHeapCopyReducer(JSHeapBroker* broker) : broker_(broker) {} in JSHeapCopyReducer() argument
67 MapRef(broker(), p.map()); in Reduce()
77 HeapObjectRef(broker(), p.code()); in Reduce()
167 NameRef name(broker(), p.name()); in Reduce()
176 NameRef name(broker(), p.name()); in Reduce()
185 NameRef name(broker(), p.name()); in Reduce()
193 MapRef(broker(), map_handle); in Reduce()
197 NameRef(broker(), name_handle); in Reduce()
204 MapRef(broker(), map); in Reduce()
211 MapRef(broker(), map); in Reduce()
[all …]
/dports/games/stendhal/stendhal-1.35/data/script/region/deniran/city/interior/pawn_shop/
H A DBrokerNPC.lua17 local broker = nil
21 broker = entities:createSpeakerNPC(brokerName)
22 broker:setOutfit("body=0,head=0,eyes=3,hair=14,dress=5,hat=11")
23 broker:setOutfitColor("body", SkinColor.DARK)
24 broker:setOutfitColor("eyes", 0x0000ff)
25 broker:setPosition(18, 5)
26 broker:setIdleDirection(Direction.LEFT)
30 broker:addGreeting("Welcome to the Deniran Pawn Shop.")
31 broker:addGoodbye()
37 game:add(broker)
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/chromeos/policy/
H A Ddevice_local_account_policy_service_unittest.cc243 ASSERT_TRUE(broker); in TEST_F()
259 ASSERT_TRUE(broker); in TEST_F()
279 ASSERT_TRUE(broker); in TEST_F()
297 ASSERT_TRUE(broker); in TEST_F()
318 ASSERT_TRUE(broker); in TEST_F()
345 ASSERT_TRUE(broker); in TEST_F()
392 ASSERT_TRUE(broker); in TEST_F()
413 ASSERT_TRUE(broker); in TEST_F()
488 ASSERT_TRUE(broker); in TEST_F()
615 ASSERT_TRUE(broker); in TEST_F()
[all …]
/dports/security/nmap/nmap-7.91/scripts/
H A Dmqtt-subscribe.nse14 the MQTT broker.
31 -- | $SYS/broker/heap/current: 39240
35 -- | $SYS/broker/clients/connected: 1
38 -- | $SYS/broker/clients/inactive: 40
39 -- | $SYS/broker/messages/sent: 2318
55 -- | $SYS/broker/bytes/sent: 83026
58 -- | $SYS/broker/messages/stored: 47
61 -- | $SYS/broker/clients/active: 1
70 -- | $SYS/broker/clients/expired: 0
75 -- |_ $SYS/broker/clients/total: 41
[all …]
/dports/net/yami4/yami4-gpl-1.11.0/src/services/broker/
H A Dmain.cpp30 bool success = broker::init_config(argc, argv); in main()
42 broker::init_routing( in main()
43 broker::max_subscriptions(), in main()
44 broker::max_client_queue(), in main()
60 broker::set_forwarding(filter, target); in main()
67 broker::agent_options(options); in main()
69 broker::init_messaging(options, in main()
70 broker::listener(), in main()
71 broker::announce_file(), in main()
74 utils::millisleep(broker::warmup_time()); in main()
[all …]
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/
H A Dclient.go201 for broker := client.any(); broker != nil; broker = client.any() {
569 currentBroker[broker.ID()] = broker
571 client.brokers[broker.ID()] = broker
575 client.brokers[broker.ID()] = broker
599 client.brokers[broker.ID()] = broker
601 } else if broker.Addr() != client.brokers[broker.ID()].Addr() {
603 client.brokers[broker.ID()] = broker
648 return broker
835 for ; broker != nil && !pastDeadline(0); broker = client.any() {
890 if broker != nil {
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/vendor/github.com/circonus-labs/circonus-gometrics/checkmgr/
H A Dbroker.go32 if !cm.isValidBroker(broker) {
36 broker.Name)
38 return broker, nil
40 broker, err := cm.selectBroker()
44 return broker, nil
107 for _, broker := range *brokerList {
108 broker := broker
109 if cm.isValidBroker(&broker) {
110 validBrokers[broker.CID] = broker
111 if broker.Type == enterpriseType {
[all …]
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/github.com/circonus-labs/circonus-gometrics/checkmgr/
H A Dbroker.go32 if !cm.isValidBroker(broker) {
36 broker.Name)
38 return broker, nil
40 broker, err := cm.selectBroker()
44 return broker, nil
107 for _, broker := range *brokerList {
108 broker := broker
109 if cm.isValidBroker(&broker) {
110 validBrokers[broker.CID] = broker
111 if broker.Type == enterpriseType {
[all …]

12345678910>>...149