@@ -136,7 +136,6 @@ static void nr_laravel_queue_set_cat_txn(zval* job TSRMLS_DC) {
136
136
}
137
137
138
138
if (headers .dt_payload || headers .traceparent ) {
139
-
140
139
nr_hashmap_t * header_map = nr_header_create_distributed_trace_map (
141
140
headers .dt_payload , headers .traceparent , headers .tracestate );
142
141
@@ -225,6 +224,11 @@ static char* nr_laravel_queue_job_txn_name(zval* job TSRMLS_DC) {
225
224
226
225
name = nr_formatf ("%s (%s:%s)" , resolve_name , connection_name , queue_name );
227
226
227
+ nr_free (connection_name );
228
+ nr_free (resolve_name );
229
+ nr_free (queue_name );
230
+
231
+ /* Caller is responsible for freeing name. */
228
232
return name ;
229
233
}
230
234
@@ -252,6 +256,7 @@ NR_PHP_WRAPPER(nr_laravel_queue_syncqueue_raiseBeforeJobEvent_before) {
252
256
253
257
job = nr_php_arg_get (1 , NR_EXECUTE_ORIG_ARGS );
254
258
259
+ /* txn_name needs to be freed by the caller. */
255
260
txn_name = nr_laravel_queue_job_txn_name (job );
256
261
257
262
/*
@@ -271,6 +276,7 @@ NR_PHP_WRAPPER(nr_laravel_queue_syncqueue_raiseBeforeJobEvent_before) {
271
276
NR_OK_TO_OVERWRITE );
272
277
}
273
278
nr_php_arg_release (& job );
279
+ nr_free (txn_name );
274
280
NR_PHP_WRAPPER_CALL ;
275
281
}
276
282
NR_PHP_WRAPPER_END
@@ -317,6 +323,7 @@ NR_PHP_WRAPPER(nr_laravel_queue_worker_raiseBeforeJobEvent_after) {
317
323
nr_txn_set_path ("Laravel" , NRPRG (txn ), txn_name , NR_PATH_TYPE_CUSTOM ,
318
324
NR_OK_TO_OVERWRITE );
319
325
}
326
+ nr_free (txn_name );
320
327
nr_php_arg_release (& job );
321
328
NR_PHP_WRAPPER_CALL ;
322
329
}
@@ -574,7 +581,7 @@ NR_PHP_WRAPPER(nr_laravel_queue_worker_process) {
574
581
* as the first parameter.
575
582
*/
576
583
char * connection_name = NULL ;
577
- char * job_name ;
584
+ char * job_name = NULL ;
578
585
char * txn_name = NULL ;
579
586
580
587
connection = nr_php_arg_get (1 , NR_EXECUTE_ORIG_ARGS TSRMLS_CC );
0 commit comments