File tree 1 file changed +12
-0
lines changed
1 file changed +12
-0
lines changed Original file line number Diff line number Diff line change @@ -510,6 +510,10 @@ int flb_input_thread_instance_pause(struct flb_input_instance *ins)
510
510
uint64_t val ;
511
511
struct flb_input_thread_instance * thi = ins -> thi ;
512
512
513
+ if (thi == NULL ) {
514
+ return 0 ;
515
+ }
516
+
513
517
flb_plg_debug (ins , "thread pause instance" );
514
518
515
519
/* compose message to pause the thread */
@@ -535,6 +539,10 @@ int flb_input_thread_instance_resume(struct flb_input_instance *ins)
535
539
uint64_t val ;
536
540
struct flb_input_thread_instance * thi = ins -> thi ;
537
541
542
+ if (thi == NULL ) {
543
+ return 0 ;
544
+ }
545
+
538
546
flb_plg_debug (ins , "thread resume instance" );
539
547
540
548
/* compose message to resume the thread */
@@ -557,6 +565,10 @@ int flb_input_thread_instance_exit(struct flb_input_instance *ins)
557
565
struct flb_input_thread_instance * thi = ins -> thi ;
558
566
pthread_t tid ;
559
567
568
+ if (thi == NULL ) {
569
+ return 0 ;
570
+ }
571
+
560
572
memcpy (& tid , & thi -> th -> tid , sizeof (pthread_t ));
561
573
562
574
/* compose message to pause the thread */
You can’t perform that action at this time.
0 commit comments