summaryrefslogtreecommitdiffstats
path: root/exporting/aws_kinesis
diff options
context:
space:
mode:
authorthiagoftsm <thiagoftsm@gmail.com>2020-05-26 12:50:04 +0000
committerGitHub <noreply@github.com>2020-05-26 12:50:04 +0000
commit605705a164e2ef562b7b309cf5607918978bc039 (patch)
tree87293864686799504e70412f88da49f2f7545754 /exporting/aws_kinesis
parentba47e197056601c7db3ce8db0db277d155e8118a (diff)
Missing checks exporting (#9034)
Add tests to uv_mutex_init and uv_cond_init inside exporting.
Diffstat (limited to 'exporting/aws_kinesis')
-rw-r--r--exporting/aws_kinesis/aws_kinesis.c6
1 files changed, 4 insertions, 2 deletions
diff --git a/exporting/aws_kinesis/aws_kinesis.c b/exporting/aws_kinesis/aws_kinesis.c
index cc0da13062..791cad436c 100644
--- a/exporting/aws_kinesis/aws_kinesis.c
+++ b/exporting/aws_kinesis/aws_kinesis.c
@@ -56,8 +56,10 @@ int init_aws_kinesis_instance(struct instance *instance)
error("EXPORTING: cannot create buffer for AWS Kinesis exporting connector instance %s", instance->config.name);
return 1;
}
- uv_mutex_init(&instance->mutex);
- uv_cond_init(&instance->cond_var);
+ if (uv_mutex_init(&instance->mutex))
+ return 1;
+ if (uv_cond_init(&instance->cond_var))
+ return 1;
if (!instance->engine->aws_sdk_initialized) {
aws_sdk_init();