/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
H A D | broker_test.go | 10 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 D | broker_test.go | 10 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 D | mdbroker.go | 64 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 D | mdbroker.go | 64 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 D | mdbroker.go | 64 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 D | mdbroker.go | 64 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 D | heap-refs.cc | 31 #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 D | js-heap-copy-reducer.cc | 24 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 D | bolt_pxp_module_helper.rb | 107 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 D | broker_test.go | 18 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 D | client.go | 201 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 D | broker_test.go | 18 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 D | client.go | 212 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 D | js-heap-broker.cc | 42 #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 D | js-heap-copy-reducer.cc | 24 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 D | broker.go | 1 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 D | js-heap-broker.cc | 43 #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 D | js-heap-copy-reducer.cc | 24 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 D | BrokerNPC.lua | 17 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 D | device_local_account_policy_service_unittest.cc | 243 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 D | mqtt-subscribe.nse | 14 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 D | main.cpp | 30 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 D | client.go | 201 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 D | broker.go | 32 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 D | broker.go | 32 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 …]
|