Skip to content

Commit d732893

Browse files
committed
Dont delete unset tlskey (closes #78)
1 parent a9601c4 commit d732893

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

confluent_kafka/src/confluent_kafka.c

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -962,7 +962,8 @@ void Handle_clear (Handle *h) {
962962
if (h->stats_cb)
963963
Py_DECREF(h->stats_cb);
964964

965-
PyThread_delete_key(h->tlskey);
965+
if (h->initiated)
966+
PyThread_delete_key(h->tlskey);
966967
}
967968

968969
/**
@@ -1322,6 +1323,7 @@ rd_kafka_conf_t *common_conf_setup (rd_kafka_type_t ktype,
13221323
rd_kafka_conf_set_opaque(conf, h);
13231324

13241325
h->tlskey = PyThread_create_key();
1326+
h->initiated = 1;
13251327

13261328
return conf;
13271329
}

confluent_kafka/src/confluent_kafka.h

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,8 @@ typedef struct {
115115
rd_kafka_t *rk;
116116
PyObject *error_cb;
117117
PyObject *stats_cb;
118-
int tlskey; /* Thread-Local-Storage key */
118+
int initiated;
119+
int tlskey; /* Thread-Local-Storage key */
119120

120121
union {
121122
/**

0 commit comments

Comments
 (0)