1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74
|
TYPEMAP
plrd_kafka_t* T_RDKAFKA
rd_kafka_message_t* T_RD_KAFKA_MSG
rd_kafka_topic_t* T_RD_KAFKA_TOPIC
rd_kafka_topic_partition_list_t* T_RD_KAFKA_TOPIC_PARTITION_LIST
rd_kafka_headers_t* T_RD_KAFKA_HEADERS
rd_kafka_event_t* T_RD_KAFKA_EVENT
HV* T_HVREF_REFCOUNT_FIXED
INPUT
T_RDKAFKA
if(sv_derived_from($arg, \"Net::Kafka\")) {
IV tmp = SvIV((SV*)SvRV($arg));
$var = INT2PTR($type, tmp);
}
else {
croak(\"$var is not of type Net::Kafka\");
}
T_RD_KAFKA_MSG
if(sv_derived_from($arg, \"Net::Kafka::Message\")) {
IV tmp = SvIV((SV*)SvRV($arg));
$var = INT2PTR($type, tmp);
}
else {
croak(\"$var is not of type Net::Kafka::Message\");
}
T_RD_KAFKA_TOPIC
if(sv_derived_from($arg, \"Net::Kafka::Topic\")) {
IV tmp = SvIV((SV*)SvRV($arg));
$var = INT2PTR($type, tmp);
}
else {
croak(\"$var is not of type Net::Kafka::Topic\");
}
T_RD_KAFKA_TOPIC_PARTITION_LIST
if(sv_derived_from($arg, \"Net::Kafka::TopicPartitionList\")) {
IV tmp = SvIV((SV*)SvRV($arg));
$var = INT2PTR($type, tmp);
}
else {
croak(\"$var is not of type Net::Kafka::TopicPartitionList\");
}
T_RD_KAFKA_HEADERS
if(!SvOK($arg)) {
$var = NULL;
} else if(sv_derived_from($arg, \"Net::Kafka::Headers\")) {
IV tmp = SvIV((SV*)SvRV($arg));
$var = INT2PTR($type, tmp);
}
else {
croak(\"$var is not of type Net::Kafka::Headers\");
}
T_RD_KAFKA_EVENT
if(sv_derived_from($arg, \"Net::Kafka::Event\")) {
IV tmp = SvIV((SV*)SvRV($arg));
$var = INT2PTR($type, tmp);
}
else {
croak(\"$var is not of type Net::Kafka::Event\");
}
OUTPUT
T_RDKAFKA
sv_setref_pv($arg, \"Net::Kafka\", (void *)$var);
T_RD_KAFKA_MSG
sv_setref_pv($arg, \"Net::Kafka::Message\", (void *)$var);
T_RD_KAFKA_TOPIC
sv_setref_pv($arg, \"Net::Kafka::Topic\", (void *)$var);
T_RD_KAFKA_TOPIC_PARTITION_LIST
sv_setref_pv($arg, \"Net::Kafka::TopicPartitionList\", (void *)$var);
T_RD_KAFKA_HEADERS
sv_setref_pv($arg, \"Net::Kafka::Headers\", (void *)$var);
T_RD_KAFKA_EVENT
sv_setref_pv($arg, \"Net::Kafka::Event\", (void *)$var);
|