88 /* luo_flb_get_private - Access private field, and if needed initialize it. */
91 	struct luo_flb_private *private = &ACCESS_PRIVATE(flb, private);  in luo_flb_get_private()  local
93 	if (!private->initialized) {  in luo_flb_get_private()
94 		mutex_init(&private->incoming.lock);  in luo_flb_get_private()
95 		mutex_init(&private->outgoing.lock);  in luo_flb_get_private()
96 		INIT_LIST_HEAD(&private->list);  in luo_flb_get_private()
97 		private->users = 0;  in luo_flb_get_private()
98 		private->initialized = true;  in luo_flb_get_private()
101 	return private;  in luo_flb_get_private()
106 	struct luo_flb_private *private = luo_flb_get_private(flb);  in luo_flb_file_preserve_one()  local
108 	scoped_guard(mutex, &private->outgoing.lock) {  in luo_flb_file_preserve_one()
109 		if (!private->outgoing.count) {  in luo_flb_file_preserve_one()
117 			private->outgoing.data = args.data;  in luo_flb_file_preserve_one()
118 			private->outgoing.obj = args.obj;  in luo_flb_file_preserve_one()
120 		private->outgoing.count++;  in luo_flb_file_preserve_one()
128 	struct luo_flb_private *private = luo_flb_get_private(flb);  in luo_flb_file_unpreserve_one()  local
130 	scoped_guard(mutex, &private->outgoing.lock) {  in luo_flb_file_unpreserve_one()
131 		private->outgoing.count--;  in luo_flb_file_unpreserve_one()
132 		if (!private->outgoing.count) {  in luo_flb_file_unpreserve_one()
136 			args.data = private->outgoing.data;  in luo_flb_file_unpreserve_one()
137 			args.obj = private->outgoing.obj;  in luo_flb_file_unpreserve_one()
142 			private->outgoing.data = 0;  in luo_flb_file_unpreserve_one()
143 			private->outgoing.obj = NULL;  in luo_flb_file_unpreserve_one()
150 	struct luo_flb_private *private = luo_flb_get_private(flb);  in luo_flb_retrieve_one()  local
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()
194 	struct luo_flb_private *private = luo_flb_get_private(flb);  in luo_flb_file_finish_one()  local
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()
324 	struct luo_flb_private *private = luo_flb_get_private(flb);  in liveupdate_register_flb()  local
369 	if (!private->users) {  in liveupdate_register_flb()
370 		if (WARN_ON(!list_empty(&private->list))) {  in liveupdate_register_flb()
381 		list_private_for_each_entry(gflb, &luo_flb_global.list, private.list) {  in liveupdate_register_flb()
391 		list_add_tail(&private->list, &luo_flb_global.list);  in liveupdate_register_flb()
396 	private->users++;  in liveupdate_register_flb()
432 	struct luo_flb_private *private = luo_flb_get_private(flb);  in liveupdate_unregister_flb()  local
460 	private->users--;  in liveupdate_unregister_flb()
465 	if (!private->users) {  in liveupdate_unregister_flb()
466 		list_del_init(&private->list);  in liveupdate_unregister_flb()
499 	struct luo_flb_private *private = luo_flb_get_private(flb);  in liveupdate_flb_get_incoming()  local
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()
533 	struct luo_flb_private *private = luo_flb_get_private(flb);  in liveupdate_flb_get_outgoing()  local
538 	guard(mutex)(&private->outgoing.lock);  in liveupdate_flb_get_outgoing()
539 	*objp = private->outgoing.obj;  in liveupdate_flb_get_outgoing()
641 	list_private_for_each_entry(gflb, &luo_flb_global.list, private.list) {  in luo_flb_serialize()
642 		struct luo_flb_private *private = luo_flb_get_private(gflb);  in luo_flb_serialize()  local
644 		if (private->outgoing.count > 0) {  in luo_flb_serialize()
647 			fh->ser[i].data = private->outgoing.data;  in luo_flb_serialize()
648 			fh->ser[i].count = private->outgoing.count;  in luo_flb_serialize()