Lines Matching refs:pipeline
582 * pipeline with the oldest event.
585 * pipeline will process exactly one of those logfiles. Distinct pipelines
591 * one pipeline for each known log type - one for error, one for fault, etc.
592 * Each pipeline will process first the rotated logs of that type and then
597 * The output state of a pipeline is one of:
599 * - record available: the next record from this pipeline is available
602 * - done: this pipeline will produce no more records
604 * - polling: this pipeline is polling for new records and will
609 * A pipeline iterates over each file queued to it using fmd_log_xiter.
610 * We do this in a separate thread for each pipeline. The callback on
618 * A pipeline descriptor. The pl_cv condition variable is used together
620 * lock for the serializer for pausing and continuing this pipeline.
623 pthread_mutex_t pl_lock; /* used only in pipeline startup */
631 int pl_srlzeridx; /* serializer index for this pipeline */
646 * Each pipeline has an associated output slot in the serializer. This
664 struct fmdump_pipeline *ds_pipearr; /* pipeline array */
819 * Called on each pipeline record iteration to make a new record
821 * the caller must stall the pipeline, or 1 to indicate that the
823 * addition fills the serializer then choose a pipeline that must
1034 struct fmdump_pipeline *pipeline, *pl;
1042 pipeline = calloc(npipe, sizeof (struct fmdump_pipeline));
1043 if (!pipeline)
1047 pipeline[i].pl_logpath = ifiles[i];
1049 pipeline = calloc(sizeof (logtypes) / sizeof (logtypes[0]),
1051 if (!pipeline)
1071 pipeline[npipe].pl_rotated =
1074 pipeline[npipe++].pl_logpath = logpath;
1087 srlzer.ds_pipearr = pipeline;
1094 for (i = 0, pl = &pipeline[0]; i < npipe; i++, pl++) {
1110 fmdump_fatal("pthread_create for pipeline %d failed",
1114 for (i = 0, pl = &pipeline[0]; i < npipe; i++, pl++) {
1121 for (i = 0, pl = &pipeline[0]; i < npipe; i++, pl++)
1126 free(pipeline[i].pl_logpath);
1131 free(pipeline);