Searched refs:statsdLoggerWrite (Results 1 – 4 of 4) sorted by relevance
| /aosp12/packages/modules/StatsD/lib/libstatssocket/ |
| H A D | stats_buffer_writer.c | 25 extern struct android_log_transport_write statsdLoggerWrite;
31 statsdLoggerWrite.noteDrop(error, atomId); in note_log_drop()
37 if (statsdLoggerWrite.close) { in stats_log_close()
38 (*statsdLoggerWrite.close)(); in stats_log_close()
44 return statsdLoggerWrite.isClosed && (*statsdLoggerWrite.isClosed)(); in stats_log_is_closed()
87 int ret = (int)(*statsdLoggerWrite.write)(&ts, vec, nr); in __write_to_stats_daemon()
93 if (!statsdLoggerWrite.open || ((*statsdLoggerWrite.open)() < 0)) { in __write_to_statsd_initialize_locked()
94 if (statsdLoggerWrite.close) { in __write_to_statsd_initialize_locked()
95 (*statsdLoggerWrite.close)(); in __write_to_statsd_initialize_locked()
|
| H A D | statsd_writer.c | 82 struct android_log_transport_write statsdLoggerWrite = { variable
97 i = atomic_load(&statsdLoggerWrite.sock); in statsdOpen()
127 i = atomic_exchange(&statsdLoggerWrite.sock, ret); in statsdOpen()
134 ret = atomic_exchange(&statsdLoggerWrite.sock, sock); in statsdOpen()
147 int sock = atomic_exchange(&statsdLoggerWrite.sock, negative_errno); in __statsdClose()
158 if (atomic_load(&statsdLoggerWrite.sock) < 0) { in statsdAvailable()
174 if (atomic_load(&statsdLoggerWrite.sock) < 0) { in statsdIsClosed()
188 sock = atomic_load(&statsdLoggerWrite.sock); in statsdWrite()
295 ret = TEMP_FAILURE_RETRY(writev(atomic_load(&statsdLoggerWrite.sock), newVec, i)); in statsdWrite()
|
| /aosp12/system/core/libstats/push_compat/ |
| H A D | stats_event_list.c | 41 extern struct android_log_transport_write statsdLoggerWrite;
124 statsdLoggerWrite.noteDrop(error, tag); in note_log_drop()
130 if (statsdLoggerWrite.close) { in stats_log_close()
131 (*statsdLoggerWrite.close)(); in stats_log_close()
138 if (!statsdLoggerWrite.open || ((*statsdLoggerWrite.open)() < 0)) { in __write_to_statsd_initialize_locked()
139 if (statsdLoggerWrite.close) { in __write_to_statsd_initialize_locked()
140 (*statsdLoggerWrite.close)(); in __write_to_statsd_initialize_locked()
169 int ret = (int)(*statsdLoggerWrite.write)(&ts, vec, nr); in __write_to_stats_daemon()
|
| H A D | statsd_writer.c | 66 struct android_log_transport_write statsdLoggerWrite = { variable
80 i = atomic_load(&statsdLoggerWrite.sock); in statsdOpen()
110 i = atomic_exchange(&statsdLoggerWrite.sock, ret); in statsdOpen()
117 ret = atomic_exchange(&statsdLoggerWrite.sock, sock); in statsdOpen()
130 int sock = atomic_exchange(&statsdLoggerWrite.sock, negative_errno); in __statsdClose()
141 if (atomic_load(&statsdLoggerWrite.sock) < 0) { in statsdAvailable()
164 sock = atomic_load(&statsdLoggerWrite.sock); in statsdWrite()
271 ret = TEMP_FAILURE_RETRY(writev(atomic_load(&statsdLoggerWrite.sock), newVec, i)); in statsdWrite()
|