/dports/sysutils/azure-agent/WALinuxAgent-2.2.54.2/azurelinuxagent/common/protocol/ |
H A D | ovfenv.py | 82 conf_set = find(section, "LinuxProvisioningConfigurationSet", 84 _validate_ovf(conf_set, "LinuxProvisioningConfigurationSet not found") 86 self.hostname = findtext(conf_set, "HostName", namespace=wans) 89 self.username = findtext(conf_set, "UserName", namespace=wans) 92 self.user_password = findtext(conf_set, "UserPassword", namespace=wans) 94 self.customdata = findtext(conf_set, "CustomData", namespace=wans) 96 auth_option = findtext(conf_set, "DisableSshPasswordAuthentication", 103 public_keys = findall(conf_set, "PublicKey", namespace=wans) 110 keypairs = findall(conf_set, "KeyPair", namespace=wans)
|
/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0082-fetch_max_bytes.cpp | 61 Test::conf_set(conf, "group.id", topic); in do_test_fetch_max_bytes() 62 Test::conf_set(conf, "auto.offset.reset", "earliest"); in do_test_fetch_max_bytes() 81 Test::conf_set(conf, "max.partition.fetch.bytes", "20000000"); /* ~20MB */ in do_test_fetch_max_bytes() 82 Test::conf_set(conf, "fetch.max.bytes", "1000000"); /* ~1MB */ in do_test_fetch_max_bytes() 83 Test::conf_set(conf, "receive.message.max.bytes", "1000512"); /* ~1MB+512 */ in do_test_fetch_max_bytes()
|
H A D | 0060-op_prio.cpp | 93 Test::conf_set(conf, "group.id", topic); in do_test_commit_cb() 94 Test::conf_set(conf, "socket.timeout.ms", "10000"); in do_test_commit_cb() 95 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_commit_cb() 96 Test::conf_set(conf, "enable.partition.eof", "false"); in do_test_commit_cb() 97 Test::conf_set(conf, "auto.offset.reset", "earliest"); in do_test_commit_cb() 98 Test::conf_set(conf, "statistics.interval.ms", "1000"); in do_test_commit_cb()
|
H A D | 0063-clusterid.cpp | 48 Test::conf_set(conf, "api.version.request", "true"); in do_test_clusterid() 59 Test::conf_set(conf, "api.version.request", "false"); in do_test_clusterid() 60 Test::conf_set(conf, "broker.version.fallback", "0.9.0"); in do_test_clusterid() 120 Test::conf_set(conf, "api.version.request", "true"); in do_test_controllerid() 131 Test::conf_set(conf, "api.version.request", "false"); in do_test_controllerid() 132 Test::conf_set(conf, "broker.version.fallback", "0.9.0"); in do_test_controllerid()
|
H A D | 0059-bsearch.cpp | 119 Test::conf_set(tconf, "acks", "all"); in do_test_bsearch() 120 Test::conf_set(conf, "api.version.request", "true"); in do_test_bsearch() 156 Test::conf_set(conf, "group.id", topic); in do_test_bsearch() 157 Test::conf_set(conf, "api.version.request", "true"); in do_test_bsearch() 158 Test::conf_set(conf, "fetch.wait.max.ms", "1"); in do_test_bsearch() 159 Test::conf_set(conf, "fetch.error.backoff.ms", "1"); in do_test_bsearch() 160 Test::conf_set(conf, "queued.min.messages", "1"); in do_test_bsearch() 161 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_bsearch()
|
H A D | 0067-empty_topic.cpp | 50 Test::conf_set(conf, "enable.partition.eof", "true"); in do_test_empty_topic_consumer() 51 Test::conf_set(conf, "allow.auto.create.topics", "true"); in do_test_empty_topic_consumer() 101 Test::conf_set(conf, "group.id", topic); in do_test_empty_topic_consumer() 103 Test::conf_set(conf, "enable.partition.eof", "true"); in do_test_empty_topic_consumer() 104 Test::conf_set(conf, "allow.auto.create.topics", "true"); in do_test_empty_topic_consumer()
|
H A D | 0116-kafkaconsumer_close.cpp | 63 Test::conf_set(pconf, "bootstrap.servers", bootstraps); in do_test_consumer_close() 75 Test::conf_set(conf, "bootstrap.servers", bootstraps); in do_test_consumer_close() 76 Test::conf_set(conf, "group.id", "mygroup"); in do_test_consumer_close() 77 Test::conf_set(conf, "auto.offset.reset", "beginning"); in do_test_consumer_close()
|
H A D | 0070-null_empty.cpp | 81 Test::conf_set(conf, "api.version.request", in do_test_null_empty() 83 Test::conf_set(conf, "acks", "all"); in do_test_null_empty() 133 Test::conf_set(conf, "group.id", topic); in do_test_null_empty() 134 Test::conf_set(conf, "api.version.request", in do_test_null_empty() 136 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_null_empty()
|
H A D | 0110-batch_size.cpp | 122 Test::conf_set(conf, "batch.size", "5000"); in do_test_batch_size() 125 Test::conf_set(conf, "batch.num.messages", "100000"); in do_test_batch_size() 126 Test::conf_set(conf, "linger.ms", "2000"); in do_test_batch_size() 128 Test::conf_set(conf, "statistics.interval.ms", "7000"); in do_test_batch_size()
|
H A D | 0061-consumer_lag.cpp | 128 Test::conf_set(conf, "transactional.id", "txn_id_" + topic); in produce_aborted_txns() 202 Test::conf_set(conf, "group.id", topic); in do_test_consumer_lag() 203 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_consumer_lag() 204 Test::conf_set(conf, "auto.offset.reset", "earliest"); in do_test_consumer_lag() 205 Test::conf_set(conf, "statistics.interval.ms", "100"); in do_test_consumer_lag()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0082-fetch_max_bytes.cpp | 61 Test::conf_set(conf, "group.id", topic); in do_test_fetch_max_bytes() 62 Test::conf_set(conf, "auto.offset.reset", "earliest"); in do_test_fetch_max_bytes() 81 Test::conf_set(conf, "max.partition.fetch.bytes", "20000000"); /* ~20MB */ in do_test_fetch_max_bytes() 82 Test::conf_set(conf, "fetch.max.bytes", "1000000"); /* ~1MB */ in do_test_fetch_max_bytes() 83 Test::conf_set(conf, "receive.message.max.bytes", "1000512"); /* ~1MB+512 */ in do_test_fetch_max_bytes()
|
H A D | 0060-op_prio.cpp | 93 Test::conf_set(conf, "group.id", topic); in do_test_commit_cb() 94 Test::conf_set(conf, "socket.timeout.ms", "10000"); in do_test_commit_cb() 95 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_commit_cb() 96 Test::conf_set(conf, "enable.partition.eof", "false"); in do_test_commit_cb() 97 Test::conf_set(conf, "auto.offset.reset", "earliest"); in do_test_commit_cb() 98 Test::conf_set(conf, "statistics.interval.ms", "1000"); in do_test_commit_cb()
|
H A D | 0063-clusterid.cpp | 48 Test::conf_set(conf, "api.version.request", "true"); in do_test_clusterid() 59 Test::conf_set(conf, "api.version.request", "false"); in do_test_clusterid() 60 Test::conf_set(conf, "broker.version.fallback", "0.9.0"); in do_test_clusterid() 120 Test::conf_set(conf, "api.version.request", "true"); in do_test_controllerid() 131 Test::conf_set(conf, "api.version.request", "false"); in do_test_controllerid() 132 Test::conf_set(conf, "broker.version.fallback", "0.9.0"); in do_test_controllerid()
|
H A D | 0059-bsearch.cpp | 119 Test::conf_set(tconf, "acks", "all"); in do_test_bsearch() 120 Test::conf_set(conf, "api.version.request", "true"); in do_test_bsearch() 156 Test::conf_set(conf, "group.id", topic); in do_test_bsearch() 157 Test::conf_set(conf, "api.version.request", "true"); in do_test_bsearch() 158 Test::conf_set(conf, "fetch.wait.max.ms", "1"); in do_test_bsearch() 159 Test::conf_set(conf, "fetch.error.backoff.ms", "1"); in do_test_bsearch() 160 Test::conf_set(conf, "queued.min.messages", "1"); in do_test_bsearch() 161 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_bsearch()
|
H A D | 0070-null_empty.cpp | 81 Test::conf_set(conf, "api.version.request", in do_test_null_empty() 83 Test::conf_set(conf, "acks", "all"); in do_test_null_empty() 133 Test::conf_set(conf, "group.id", topic); in do_test_null_empty() 134 Test::conf_set(conf, "api.version.request", in do_test_null_empty() 136 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_null_empty()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0082-fetch_max_bytes.cpp | 61 Test::conf_set(conf, "group.id", topic); in rest_pages_issue_view() 62 Test::conf_set(conf, "auto.offset.reset", "earliest"); in rest_pages_issue_view() 81 Test::conf_set(conf, "max.partition.fetch.bytes", "20000000"); /* ~20MB */ in rest_pages_issue_view() 82 Test::conf_set(conf, "fetch.max.bytes", "1000000"); /* ~1MB */ in rest_pages_issue_view() 83 Test::conf_set(conf, "receive.message.max.bytes", "1000512"); /* ~1MB+512 */ in rest_pages_issue_view()
|
H A D | 0060-op_prio.cpp | 93 Test::conf_set(conf, "group.id", topic); in do_test_commit_cb() 94 Test::conf_set(conf, "socket.timeout.ms", "10000"); in do_test_commit_cb() 95 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_commit_cb() 96 Test::conf_set(conf, "enable.partition.eof", "false"); in do_test_commit_cb() 97 Test::conf_set(conf, "auto.offset.reset", "earliest"); in do_test_commit_cb() 98 Test::conf_set(conf, "statistics.interval.ms", "1000"); in do_test_commit_cb()
|
H A D | 0063-clusterid.cpp | 48 Test::conf_set(conf, "api.version.request", "true"); in do_test_clusterid() 59 Test::conf_set(conf, "api.version.request", "false"); in do_test_clusterid() 60 Test::conf_set(conf, "broker.version.fallback", "0.9.0"); in do_test_clusterid() 120 Test::conf_set(conf, "api.version.request", "true"); in do_test_controllerid() 131 Test::conf_set(conf, "api.version.request", "false"); in do_test_controllerid() 132 Test::conf_set(conf, "broker.version.fallback", "0.9.0"); in do_test_controllerid()
|
H A D | 0059-bsearch.cpp | 119 Test::conf_set(tconf, "acks", "all"); in do_test_bsearch() 120 Test::conf_set(conf, "api.version.request", "true"); in do_test_bsearch() 156 Test::conf_set(conf, "group.id", topic); in do_test_bsearch() 157 Test::conf_set(conf, "api.version.request", "true"); in do_test_bsearch() 158 Test::conf_set(conf, "fetch.wait.max.ms", "1"); in do_test_bsearch() 159 Test::conf_set(conf, "fetch.error.backoff.ms", "1"); in do_test_bsearch() 160 Test::conf_set(conf, "queued.min.messages", "1"); in do_test_bsearch() 161 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_bsearch()
|
H A D | 0067-empty_topic.cpp | 50 Test::conf_set(conf, "enable.partition.eof", "true"); 51 Test::conf_set(conf, "allow.auto.create.topics", "true"); 101 Test::conf_set(conf, "group.id", topic); 103 Test::conf_set(conf, "enable.partition.eof", "true"); 104 Test::conf_set(conf, "allow.auto.create.topics", "true");
|
H A D | 0116-kafkaconsumer_close.cpp | 63 Test::conf_set(pconf, "bootstrap.servers", bootstraps); 75 Test::conf_set(conf, "bootstrap.servers", bootstraps); 76 Test::conf_set(conf, "group.id", "mygroup"); 77 Test::conf_set(conf, "auto.offset.reset", "beginning");
|
H A D | 0070-null_empty.cpp | 81 Test::conf_set(conf, "api.version.request", in do_test_null_empty() 83 Test::conf_set(conf, "acks", "all"); in do_test_null_empty() 133 Test::conf_set(conf, "group.id", topic); in do_test_null_empty() 134 Test::conf_set(conf, "api.version.request", in do_test_null_empty() 136 Test::conf_set(conf, "enable.auto.commit", "false"); in do_test_null_empty()
|
H A D | 0110-batch_size.cpp | 122 Test::conf_set(conf, "batch.size", "5000"); 125 Test::conf_set(conf, "batch.num.messages", "100000"); 126 Test::conf_set(conf, "linger.ms", "2000"); 128 Test::conf_set(conf, "statistics.interval.ms", "7000");
|
/dports/x11-toolkits/ntk/ntk/src/ |
H A D | Fl_Theme.cxx | 68 static void conf_set ( const char *key, const char *value ) in conf_set() function 77 static void conf_set ( const char *key, Fl_Color value ) in conf_set() function 143 conf_set( "theme", Fl_Theme::_current->name() ); in save() 198 conf_set( "color_scheme", Fl_Color_Scheme::_current->name() ); in save() 199 conf_set( "background", Fl::get_color( FL_BACKGROUND_COLOR ) ); in save() 200 conf_set( "foreground", Fl::get_color( FL_FOREGROUND_COLOR ) ); in save() 201 conf_set( "background2", Fl::get_color( FL_BACKGROUND2_COLOR ) ); in save() 202 conf_set( "selection", Fl::get_color( FL_SELECTION_COLOR ) ); in save()
|
/dports/net/qadsl/qadsl-1.3.3/lib/conf/ |
H A D | parser.y | 66 #define conf_set(key,value) \ macro 94 conf_set ($1, $3);} 96 conf_set ($1, $2);}
|