Home
last modified time | relevance | path

Searched refs:rk_type (Results 1 – 25 of 42) sorted by relevance

12

/dports/math/sundials/sundials-5.7.0/examples/arkode/CXX_serial/
H A Dark_kpr_Mt.cpp185 if ((rk_type < 0) || (rk_type > 2)) { in main()
209 if (rk_type == 0) { in main()
211 } else if (rk_type == 1) { in main()
216 if (rk_type < 2) { in main()
246 if (rk_type == 0) { // ARK method in main()
256 if (rk_type < 2) { in main()
271 if (rk_type == 0) { in main()
289 if (rk_type == 2) { in main()
570 if (rk_type < 2) { in adaptive_run()
591 if (rk_type < 2) { in adaptive_run()
[all …]
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_int.h305 rd_kafka_type_t rk_type; member
615 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_curr_msgs_add()
655 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_curr_msgs_sub()
683 if (rk->rk_type != RD_KAFKA_PRODUCER) { in rd_kafka_curr_msgs_get()
698 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_curr_msgs_cnt()
892 if ((rk->rk_type == RD_KAFKA_PRODUCER && rk->rk_conf.eos.idempotence) || in rd_kafka_fatal_error_code()
893 (rk->rk_type == RD_KAFKA_CONSUMER && rk->rk_conf.group_instance_id)) in rd_kafka_fatal_error_code()
930 if (rk->rk_type != RD_KAFKA_CONSUMER) in rd_kafka_max_poll_exceeded()
964 if (rk->rk_type == RD_KAFKA_CONSUMER) in rd_kafka_app_poll_blocking()
978 if (rk->rk_type == RD_KAFKA_CONSUMER) in rd_kafka_app_polled()
H A Drdkafka.c845 if (rk->rk_type == RD_KAFKA_CONSUMER && rk->rk_cgrp) in rd_kafka_set_fatal_error0()
864 if (rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_set_fatal_error0()
940 if (rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_destroy_final()
1419 rk->rk_type == RD_KAFKA_PRODUCER ? in rd_kafka_stats_emit_toppar()
1561 rd_kafka_type2str(rk->rk_type), in rd_kafka_stats_emit_all()
1839 if (rk->rk_type == RD_KAFKA_CONSUMER && rk->rk_cgrp && in rd_kafka_metadata_refresh_cb()
2033 rk->rk_type = type; in rd_kafka_new()
2147 if (rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_new()
3895 return rk->rk_type; in rd_kafka_type()
4018 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_flush()
[all …]
H A Drdkafka_topic.c261 if ((conf_err = rd_kafka_topic_conf_finalize(rk->rk_type, in rd_kafka_topic_new0()
813 if (rkt->rkt_rk->rk_type != RD_KAFKA_CONSUMER) in rd_kafka_topic_propagate_notexists()
838 if (rkt->rkt_rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_topic_assign_uas()
1350 if (rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_topic_scan_all()
H A Drdkafka_broker.c2917 if (rkb->rkb_rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_broker_op_serve()
2968 if (rkb->rkb_rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_broker_op_serve()
2997 if (rkb->rkb_rk->rk_type == RD_KAFKA_PRODUCER) in rd_kafka_broker_op_serve()
3329 if (rkb->rkb_rk->rk_type == RD_KAFKA_CONSUMER) { in rd_kafka_broker_internal_serve()
4810 else if (rkb->rkb_rk->rk_type == RD_KAFKA_PRODUCER) in rd_kafka_broker_serve()
4812 else if (rkb->rkb_rk->rk_type == RD_KAFKA_CONSUMER) in rd_kafka_broker_serve()
6013 int is_consumer = rkb->rkb_rk->rk_type == RD_KAFKA_CONSUMER; in rd_kafka_broker_active_toppar_add()
6048 int is_consumer = rkb->rkb_rk->rk_type == RD_KAFKA_CONSUMER; in rd_kafka_broker_active_toppar_del()
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_int.h309 rd_kafka_type_t rk_type; member
653 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_curr_msgs_add()
693 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_curr_msgs_sub()
721 if (rk->rk_type != RD_KAFKA_PRODUCER) { in rd_kafka_curr_msgs_get()
736 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_curr_msgs_cnt()
949 if ((rk->rk_type == RD_KAFKA_PRODUCER && rk->rk_conf.eos.idempotence) || in rd_kafka_fatal_error_code()
950 (rk->rk_type == RD_KAFKA_CONSUMER && rk->rk_conf.group_instance_id)) in rd_kafka_fatal_error_code()
987 if (rk->rk_type != RD_KAFKA_CONSUMER) in rd_kafka_max_poll_exceeded()
1021 if (rk->rk_type == RD_KAFKA_CONSUMER) in rd_kafka_app_poll_blocking()
1035 if (rk->rk_type == RD_KAFKA_CONSUMER) in rd_kafka_app_polled()
H A Drdkafka.c898 if (rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_set_fatal_error0()
952 if (rk->rk_type == RD_KAFKA_CONSUMER) { in rd_kafka_destroy_final()
978 if (rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_destroy_final()
1041 if (rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_destroy_app()
1242 if (rk->rk_type == RD_KAFKA_CONSUMER) { in rd_kafka_destroy_internal()
2151 rk->rk_type = type; in rd_kafka_new()
2262 if (rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_new()
2818 if (rk->rk_type != RD_KAFKA_CONSUMER) in rd_kafka_seek_partitions()
4097 return rk->rk_type; in rd_kafka_type()
4220 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_flush()
[all …]
H A Drdkafka_topic.c309 if ((conf_err = rd_kafka_topic_conf_finalize(rk->rk_type, in rd_kafka_topic_new0()
895 if (rkt->rkt_rk->rk_type != RD_KAFKA_CONSUMER) in rd_kafka_topic_propagate_notexists()
919 if (rkt->rkt_rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_topic_assign_uas()
1517 if (rk->rk_type == RD_KAFKA_PRODUCER) { in rd_kafka_topic_scan_all()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_int.h309 rd_kafka_type_t rk_type; member
652 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_curr_msgs_add()
692 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_curr_msgs_sub()
720 if (rk->rk_type != RD_KAFKA_PRODUCER) { in rd_kafka_curr_msgs_get()
735 if (rk->rk_type != RD_KAFKA_PRODUCER) in rd_kafka_curr_msgs_cnt()
948 if ((rk->rk_type == RD_KAFKA_PRODUCER && rk->rk_conf.eos.idempotence) || in rd_kafka_fatal_error_code()
949 (rk->rk_type == RD_KAFKA_CONSUMER && rk->rk_conf.group_instance_id)) in rd_kafka_fatal_error_code()
986 if (rk->rk_type != RD_KAFKA_CONSUMER) in rd_kafka_max_poll_exceeded()
1020 if (rk->rk_type == RD_KAFKA_CONSUMER) in rd_kafka_app_poll_blocking()
1034 if (rk->rk_type == RD_KAFKA_CONSUMER) in rd_kafka_app_polled()
H A Drdkafka.c898 if (rk->rk_type == RD_KAFKA_PRODUCER) {
952 if (rk->rk_type == RD_KAFKA_CONSUMER) {
978 if (rk->rk_type == RD_KAFKA_PRODUCER) {
1041 if (rk->rk_type == RD_KAFKA_PRODUCER) {
1242 if (rk->rk_type == RD_KAFKA_CONSUMER) {
2151 rk->rk_type = type;
2261 if (rk->rk_type == RD_KAFKA_PRODUCER) {
2817 if (rk->rk_type != RD_KAFKA_CONSUMER)
4096 return rk->rk_type;
4219 if (rk->rk_type != RD_KAFKA_PRODUCER)
[all …]
H A Drdkafka_topic.c309 if ((conf_err = rd_kafka_topic_conf_finalize(rk->rk_type,
895 if (rkt->rkt_rk->rk_type != RD_KAFKA_CONSUMER)
919 if (rkt->rkt_rk->rk_type != RD_KAFKA_PRODUCER)
1517 if (rk->rk_type == RD_KAFKA_PRODUCER) {
/dports/security/ossec-hids-server/ossec-hids-3.6.0/src/rootcheck/
H A Drun_rk_check.c15 int notify_rk(int rk_type, const char *msg) in notify_rk() argument
19 if (rk_type == ALERT_OK) { in notify_rk()
21 } else if (rk_type == ALERT_SYSTEM_ERR) { in notify_rk()
23 } else if (rk_type == ALERT_POLICY_VIOLATION) { in notify_rk()
34 if (rk_type <= ALERT_SYSTEM_ERR) { in notify_rk()
H A Drootcheck.h83 int notify_rk(int rk_type, const char *msg);
/dports/security/ossec-hids-agent/ossec-hids-3.6.0/src/rootcheck/
H A Drun_rk_check.c15 int notify_rk(int rk_type, const char *msg) in notify_rk() argument
19 if (rk_type == ALERT_OK) { in notify_rk()
21 } else if (rk_type == ALERT_SYSTEM_ERR) { in notify_rk()
23 } else if (rk_type == ALERT_POLICY_VIOLATION) { in notify_rk()
34 if (rk_type <= ALERT_SYSTEM_ERR) { in notify_rk()
H A Drootcheck.h83 int notify_rk(int rk_type, const char *msg);
/dports/security/ossec-hids-local/ossec-hids-3.6.0/src/rootcheck/
H A Drun_rk_check.c15 int notify_rk(int rk_type, const char *msg) in notify_rk() argument
19 if (rk_type == ALERT_OK) { in notify_rk()
21 } else if (rk_type == ALERT_SYSTEM_ERR) { in notify_rk()
23 } else if (rk_type == ALERT_POLICY_VIOLATION) { in notify_rk()
34 if (rk_type <= ALERT_SYSTEM_ERR) { in notify_rk()
H A Drootcheck.h83 int notify_rk(int rk_type, const char *msg);
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/
H A Drdkafkacpp_int.h331 MessageImpl (rd_kafka_type_t rk_type, in MessageImpl() argument
334 free_rkmessage_(true), key_(NULL), headers_(NULL), rk_type_(rk_type) {} in MessageImpl()
336 MessageImpl (rd_kafka_type_t rk_type, in MessageImpl() argument
340 free_rkmessage_(dofree), key_(NULL), headers_(NULL), rk_type_(rk_type) {} in MessageImpl()
342 MessageImpl (rd_kafka_type_t rk_type, rd_kafka_message_t *rkmessage): in MessageImpl() argument
344 free_rkmessage_(true), key_(NULL), headers_(NULL), rk_type_(rk_type) { in MessageImpl()
352 MessageImpl (rd_kafka_type_t rk_type, in MessageImpl() argument
355 key_(NULL), headers_(NULL), rk_type_(rk_type) { in MessageImpl()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/
H A Drdkafkacpp_int.h331 MessageImpl (rd_kafka_type_t rk_type, in MessageImpl() argument
334 free_rkmessage_(true), key_(NULL), headers_(NULL), rk_type_(rk_type) {} in MessageImpl()
336 MessageImpl (rd_kafka_type_t rk_type, in MessageImpl() argument
340 free_rkmessage_(dofree), key_(NULL), headers_(NULL), rk_type_(rk_type) {} in MessageImpl()
342 MessageImpl (rd_kafka_type_t rk_type, rd_kafka_message_t *rkmessage): in MessageImpl() argument
344 free_rkmessage_(true), key_(NULL), headers_(NULL), rk_type_(rk_type) { in MessageImpl()
352 MessageImpl (rd_kafka_type_t rk_type, in MessageImpl() argument
355 key_(NULL), headers_(NULL), rk_type_(rk_type) { in MessageImpl()
/dports/math/mfem/mfem-4.3/linalg/
H A Dsundials.cpp1177 if (self->rk_type == IMEX) in RHS1()
1216 if (self->rk_type == IMEX) in LinSysSetup()
1231 if (self->rk_type == IMEX) in LinSysSolve()
1282 : rk_type(type), step_mode(ARK_NORMAL), in ARKStepSolver()
1290 : rk_type(type), step_mode(ARK_NORMAL), in ARKStepSolver()
1360 if (rk_type == IMPLICIT) in Init()
1364 else if (rk_type == EXPLICIT) in Init()
1399 if (rk_type == IMPLICIT) in Step()
1403 else if (rk_type == EXPLICIT) in Step()
H A Dsundials.hpp551 Type rk_type; ///< Runge-Kutta type. member in mfem::ARKStepSolver
/dports/cad/gmsh/gmsh-4.9.2-source/contrib/Netgen/libsrc/visualization/
H A Dvsfieldlines.cpp278 … const double rel_thickness, const double rel_tolerance, const int rk_type, const int adirection) : in FieldLineCalc() argument
279 mesh(amesh), vss(avss), vsol(solution), stepper(rk_type) in FieldLineCalc()
H A Dvssolution.hpp406 …const double rel_thickness = -1, const double rel_tolerance = -1, const int rk_type = 0, const int…
/dports/cad/netgen/netgen-6.2.2105/libsrc/visualization/
H A Dvsfieldlines.cpp278 … const double rel_thickness, const double rel_tolerance, const int rk_type, const int adirection) : in FieldLineCalc() argument
279 mesh(amesh), vss(avss), vsol(solution), stepper(rk_type) in FieldLineCalc()
H A Dvssolution.hpp437 …const double rel_thickness = -1, const double rel_tolerance = -1, const int rk_type = 0, const int…

12