67 	struct luo_flb_header incoming;  member
94 		mutex_init(&private->incoming.lock);  in luo_flb_get_private()
151 	struct luo_flb_header *fh = &luo_flb_global.incoming;  in luo_flb_retrieve_one()
156 	guard(mutex)(&private->incoming.lock);  in luo_flb_retrieve_one()
158 	if (private->incoming.finished)  in luo_flb_retrieve_one()
161 	if (private->incoming.retrieved)  in luo_flb_retrieve_one()
169 			private->incoming.data = fh->ser[i].data;  in luo_flb_retrieve_one()
170 			private->incoming.count = fh->ser[i].count;  in luo_flb_retrieve_one()
180 	args.data = private->incoming.data;  in luo_flb_retrieve_one()
186 	private->incoming.obj = args.obj;  in luo_flb_retrieve_one()
187 	private->incoming.retrieved = true;  in luo_flb_retrieve_one()
197 	scoped_guard(mutex, &private->incoming.lock)  in luo_flb_file_finish_one()
198 		count = --private->incoming.count;  in luo_flb_file_finish_one()
203 		if (!private->incoming.retrieved) {  in luo_flb_file_finish_one()
210 		scoped_guard(mutex, &private->incoming.lock) {  in luo_flb_file_finish_one()
212 			args.obj = private->incoming.obj;  in luo_flb_file_finish_one()
215 			private->incoming.data = 0;  in luo_flb_file_finish_one()
216 			private->incoming.obj = NULL;  in luo_flb_file_finish_one()
217 			private->incoming.finished = true;  in luo_flb_file_finish_one()
504 	if (!private->incoming.obj) {  in liveupdate_flb_get_incoming()
511 	guard(mutex)(&private->incoming.lock);  in liveupdate_flb_get_incoming()
512 	*objp = private->incoming.obj;  in liveupdate_flb_get_incoming()
614 	luo_flb_global.incoming.header_ser = header_ser;  in luo_flb_setup_incoming()
615 	luo_flb_global.incoming.ser = (void *)(header_ser + 1);  in luo_flb_setup_incoming()
616 	luo_flb_global.incoming.active = true;  in luo_flb_setup_incoming()