Lines Matching refs:outgoing

68 	struct luo_flb_header outgoing;  member
95 mutex_init(&private->outgoing.lock); in luo_flb_get_private()
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()
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()
538 guard(mutex)(&private->outgoing.lock); in liveupdate_flb_get_outgoing()
539 *objp = private->outgoing.obj; in liveupdate_flb_get_outgoing()
567 luo_flb_global.outgoing.header_ser = header_ser; in luo_flb_setup_outgoing()
568 luo_flb_global.outgoing.ser = (void *)(header_ser + 1); in luo_flb_setup_outgoing()
569 luo_flb_global.outgoing.active = true; in luo_flb_setup_outgoing()
637 struct luo_flb_header *fh = &luo_flb_global.outgoing; in luo_flb_serialize()
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()