731 struct fmdump_pipeline {  struct
773 	struct fmdump_pipeline *ds_pipearr;	/* pipeline array */
860 srlzer_enter(struct fmdump_pipeline *pl)  in srlzer_enter()
868 srlzer_exit(struct fmdump_pipeline *pl)  in srlzer_exit()
876 static struct fmdump_pipeline *
910 pipeline_stall(struct fmdump_pipeline *pl)  in pipeline_stall()
919 pipeline_continue(struct fmdump_pipeline *pl)  in pipeline_continue()
936 pipeline_output(struct fmdump_pipeline *pl, const fmd_log_record_t *rp)  in pipeline_output()
940 	struct fmdump_pipeline *wpl;  in pipeline_output()
984 pipeline_mark_consumed(struct fmdump_pipeline *pl)  in pipeline_mark_consumed()
994 pipeline_done(struct fmdump_pipeline *pl)  in pipeline_done()
997 	struct fmdump_pipeline *wpl;  in pipeline_done()
1011 pipeline_pollmode(struct fmdump_pipeline *pl)  in pipeline_pollmode()
1014 	struct fmdump_pipeline *wpl;  in pipeline_pollmode()
1032 	struct fmdump_pipeline *pl = (struct fmdump_pipeline *)arg;  in pipeline_err()
1044 	struct fmdump_pipeline *pl = (struct fmdump_pipeline *)arg;  in pipeline_cb()
1063 pipeline_process(struct fmdump_pipeline *pl, char *logpath, boolean_t follow)  in pipeline_process()
1120 	struct fmdump_pipeline *pl = (struct fmdump_pipeline *)arg;  in pipeline_thr()
1143 	struct fmdump_pipeline *pipeline, *pl;  in aggregate()
1151 		pipeline = calloc(npipe, sizeof (struct fmdump_pipeline));  in aggregate()
1159 		    sizeof (struct fmdump_pipeline));  in aggregate()