out_stackdriver: do not set flush socket to blocking mode
@@ -561,8 +561,8 @@ static msgpack_object *parse_labels(struct flb_stackdriver *ctx, msgpack_object
}
}
- flb_plg_debug(ctx->ins, "labels_key [%s] not found in the payload",
- ctx->labels_key);
+ //flb_plg_debug(ctx->ins, "labels_key [%s] not found in the payload",
+ // ctx->labels_key);
return NULL;
}
@@ -603,8 +603,7 @@ static int cb_stackdriver_init(struct flb_output_instance *ins,
return -1;
}
- /* Upstream Sync flags */
- ctx->u->flags &= ~FLB_IO_ASYNC;
+ /* Metadata Upstream Sync flags */
ctx->metadata_u->flags &= ~FLB_IO_ASYNC;
if (ins->test_mode == FLB_FALSE) {
@@ -630,8 +629,8 @@ static int cb_stackdriver_init(struct flb_output_instance *ins,
if (ret == -1) {
return -1;
}
-
}
+
return 0;
}
@@ -1394,7 +1393,7 @@ static int stackdriver_format(struct flb_config *config,
msgpack_pack_object(&mp_pck, *labels_ptr);
}
- /* Clean up */
+ /* Clean up id and producer if operation extracted */
flb_sds_destroy(operation_id);
flb_sds_destroy(operation_producer);
flb_sds_destroy(source_location_file);
