Home
last modified time | relevance | path

Searched refs:statsdLoggerWrite (Results 1 – 2 of 2) sorted by relevance

/packages/modules/StatsD/lib/libstatssocket/
Dstats_buffer_writer.c25 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()
Dstatsd_writer.c82 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()