Lines Matching full:ring
2 * DHD debug ring API and structures - implementation
39 dhd_dbg_ring_t *ring = NULL; in dhd_dbg_ring_alloc_init() local
43 ring = MALLOCZ(dhd->osh, sizeof(dhd_dbg_ring_t)); in dhd_dbg_ring_alloc_init()
44 if (!ring) in dhd_dbg_ring_alloc_init()
47 ret = dhd_dbg_ring_init(dhd, ring, ring_id, in dhd_dbg_ring_alloc_init()
51 DHD_ERROR(("%s: unable to init ring %s!\n", in dhd_dbg_ring_alloc_init()
55 DHD_DBG_RING_LOCK(ring->lock, flags); in dhd_dbg_ring_alloc_init()
56 ring->state = RING_ACTIVE; in dhd_dbg_ring_alloc_init()
57 ring->threshold = 0; in dhd_dbg_ring_alloc_init()
58 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_alloc_init()
60 return ring; in dhd_dbg_ring_alloc_init()
63 if (ring) { in dhd_dbg_ring_alloc_init()
64 dhd_dbg_ring_deinit(dhd, ring); in dhd_dbg_ring_alloc_init()
65 ring->ring_buf = NULL; in dhd_dbg_ring_alloc_init()
66 ring->ring_size = 0; in dhd_dbg_ring_alloc_init()
67 MFREE(dhd->osh, ring, sizeof(dhd_dbg_ring_t)); in dhd_dbg_ring_alloc_init()
75 dhd_dbg_ring_t *ring = NULL; in dhd_dbg_ring_dealloc_deinit() local
81 ring = *dbgring; in dhd_dbg_ring_dealloc_deinit()
83 if (ring) { in dhd_dbg_ring_dealloc_deinit()
84 dhd_dbg_ring_deinit(dhd, ring); in dhd_dbg_ring_dealloc_deinit()
85 ring->ring_buf = NULL; in dhd_dbg_ring_dealloc_deinit()
86 ring->ring_size = 0; in dhd_dbg_ring_dealloc_deinit()
87 MFREE(dhd->osh, ring, sizeof(dhd_dbg_ring_t)); in dhd_dbg_ring_dealloc_deinit()
93 dhd_dbg_ring_init(dhd_pub_t *dhdp, dhd_dbg_ring_t *ring, uint16 id, uint8 *name, in dhd_dbg_ring_init() argument
105 ring->lock = DHD_DBG_RING_LOCK_INIT(dhdp->osh); in dhd_dbg_ring_init()
107 DHD_DBG_RING_LOCK(ring->lock, flags); in dhd_dbg_ring_init()
108 ring->id = id; in dhd_dbg_ring_init()
109 strlcpy((char *)ring->name, (char *)name, sizeof(ring->name)); in dhd_dbg_ring_init()
110 ring->ring_size = ring_sz; in dhd_dbg_ring_init()
111 ring->wp = ring->rp = 0; in dhd_dbg_ring_init()
112 ring->ring_buf = buf; in dhd_dbg_ring_init()
113 ring->threshold = DBGRING_FLUSH_THRESHOLD(ring); in dhd_dbg_ring_init()
114 ring->state = RING_SUSPEND; in dhd_dbg_ring_init()
115 ring->rem_len = 0; in dhd_dbg_ring_init()
116 ring->sched_pull = TRUE; in dhd_dbg_ring_init()
117 ring->pull_inactive = pull_inactive; in dhd_dbg_ring_init()
118 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_init()
124 dhd_dbg_ring_deinit(dhd_pub_t *dhdp, dhd_dbg_ring_t *ring) in dhd_dbg_ring_deinit() argument
128 DHD_DBG_RING_LOCK(ring->lock, flags); in dhd_dbg_ring_deinit()
129 ring->id = 0; in dhd_dbg_ring_deinit()
130 ring->name[0] = 0; in dhd_dbg_ring_deinit()
131 ring->wp = ring->rp = 0; in dhd_dbg_ring_deinit()
132 memset(&ring->stat, 0, sizeof(ring->stat)); in dhd_dbg_ring_deinit()
133 ring->threshold = 0; in dhd_dbg_ring_deinit()
134 ring->state = RING_STOP; in dhd_dbg_ring_deinit()
135 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_deinit()
137 DHD_DBG_RING_LOCK_DEINIT(dhdp->osh, ring->lock); in dhd_dbg_ring_deinit()
141 dhd_dbg_ring_sched_pull(dhd_dbg_ring_t *ring, uint32 pending_len, in dhd_dbg_ring_sched_pull() argument
146 DHD_DBG_RING_LOCK(ring->lock, flags); in dhd_dbg_ring_sched_pull()
150 if (ring->threshold > 0 && in dhd_dbg_ring_sched_pull()
151 (pending_len >= ring->threshold) && ring->sched_pull) { in dhd_dbg_ring_sched_pull()
158 ring->sched_pull = FALSE; in dhd_dbg_ring_sched_pull()
159 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_sched_pull()
162 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_sched_pull()
167 dhd_dbg_ring_get_pending_len(dhd_dbg_ring_t *ring) in dhd_dbg_ring_get_pending_len() argument
172 DHD_DBG_RING_LOCK(ring->lock, flags); in dhd_dbg_ring_get_pending_len()
173 if (ring->stat.written_bytes > ring->stat.read_bytes) { in dhd_dbg_ring_get_pending_len()
174 pending_len = ring->stat.written_bytes - ring->stat.read_bytes; in dhd_dbg_ring_get_pending_len()
175 } else if (ring->stat.written_bytes < ring->stat.read_bytes) { in dhd_dbg_ring_get_pending_len()
176 pending_len = PENDING_LEN_MAX - ring->stat.read_bytes + ring->stat.written_bytes; in dhd_dbg_ring_get_pending_len()
180 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_get_pending_len()
186 dhd_dbg_ring_push(dhd_dbg_ring_t *ring, dhd_dbg_ring_entry_t *hdr, void *data) in dhd_dbg_ring_push() argument
193 if (!ring || !hdr || !data) { in dhd_dbg_ring_push()
197 DHD_DBG_RING_LOCK(ring->lock, flags); in dhd_dbg_ring_push()
199 if (ring->state != RING_ACTIVE) { in dhd_dbg_ring_push()
200 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_push()
206 DHD_DBGIF(("%s: RING%d[%s] hdr->len=%u, w_len=%u, wp=%d, rp=%d, ring_start=0x%p;" in dhd_dbg_ring_push()
208 __FUNCTION__, ring->id, ring->name, hdr->len, w_len, ring->wp, ring->rp, in dhd_dbg_ring_push()
209 ring->ring_buf, ring->ring_size)); in dhd_dbg_ring_push()
211 if (w_len > ring->ring_size) { in dhd_dbg_ring_push()
212 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_push()
213 DHD_ERROR(("%s: RING%d[%s] w_len=%u, ring_size=%u," in dhd_dbg_ring_push()
214 " write size exceeds ring size !\n", in dhd_dbg_ring_push()
215 __FUNCTION__, ring->id, ring->name, w_len, ring->ring_size)); in dhd_dbg_ring_push()
220 avail_size = DBG_RING_CHECK_WRITE_SPACE(ring->rp, ring->wp, ring->ring_size); in dhd_dbg_ring_push()
223 if (ring->rp <= ring->wp) { in dhd_dbg_ring_push()
224 ring->tail_padded = TRUE; in dhd_dbg_ring_push()
225 ring->rem_len = ring->ring_size - ring->wp; in dhd_dbg_ring_push()
226 DHD_DBGIF(("%s: RING%d[%s] Insuffient tail space," in dhd_dbg_ring_push()
229 ring->id, ring->name, ring->rp, ring->wp, in dhd_dbg_ring_push()
230 ring->rem_len, ring->ring_size, avail_size, in dhd_dbg_ring_push()
234 memset((uint8 *)ring->ring_buf + ring->wp, 0, ring->rem_len); in dhd_dbg_ring_push()
236 if (ring->rp == 0) { in dhd_dbg_ring_push()
237 r_entry = (dhd_dbg_ring_entry_t *)((uint8 *)ring->ring_buf + in dhd_dbg_ring_push()
238 ring->rp); in dhd_dbg_ring_push()
239 ring->rp += ENTRY_LENGTH(r_entry); in dhd_dbg_ring_push()
240 ring->stat.read_bytes += ENTRY_LENGTH(r_entry); in dhd_dbg_ring_push()
245 if (ring->rp == ring->wp) { in dhd_dbg_ring_push()
246 ring->rp = 0; in dhd_dbg_ring_push()
248 ring->wp = 0; in dhd_dbg_ring_push()
250 __FUNCTION__, ring->rp, ring->wp)); in dhd_dbg_ring_push()
253 r_entry = (dhd_dbg_ring_entry_t *)((uint8 *)ring->ring_buf + in dhd_dbg_ring_push()
254 ring->rp); in dhd_dbg_ring_push()
256 if (ring->rp + ENTRY_LENGTH(r_entry) >= ring->ring_size) { in dhd_dbg_ring_push()
257 DHD_ERROR(("%s: RING%d[%s] rp points out of boundary," in dhd_dbg_ring_push()
258 "ring->wp=%u, ring->rp=%u, ring->ring_size=%d\n", in dhd_dbg_ring_push()
259 __FUNCTION__, ring->id, ring->name, ring->wp, in dhd_dbg_ring_push()
260 ring->rp, ring->ring_size)); in dhd_dbg_ring_push()
262 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_push()
265 ring->rp += ENTRY_LENGTH(r_entry); in dhd_dbg_ring_push()
267 if (ring->tail_padded && in dhd_dbg_ring_push()
268 ((ring->rp + ring->rem_len) == ring->ring_size)) { in dhd_dbg_ring_push()
269 DHD_DBGIF(("%s: RING%d[%s] Found padding," in dhd_dbg_ring_push()
272 ring->id, ring->name, avail_size, w_len)); in dhd_dbg_ring_push()
273 ring->rp = 0; in dhd_dbg_ring_push()
274 ring->tail_padded = FALSE; in dhd_dbg_ring_push()
275 ring->rem_len = 0; in dhd_dbg_ring_push()
277 ring->stat.read_bytes += ENTRY_LENGTH(r_entry); in dhd_dbg_ring_push()
278 DHD_DBGIF(("%s: RING%d[%s] read_bytes=%d, wp=%d, rp=%d\n", in dhd_dbg_ring_push()
279 __FUNCTION__, ring->id, ring->name, ring->stat.read_bytes, in dhd_dbg_ring_push()
280 ring->wp, ring->rp)); in dhd_dbg_ring_push()
287 /* check before writing to the ring */ in dhd_dbg_ring_push()
288 if (ring->wp + w_len >= ring->ring_size) { in dhd_dbg_ring_push()
289 DHD_ERROR(("%s: RING%d[%s] wp pointed out of ring boundary, " in dhd_dbg_ring_push()
290 "wp=%d, ring_size=%d, w_len=%u\n", __FUNCTION__, ring->id, in dhd_dbg_ring_push()
291 ring->name, ring->wp, ring->ring_size, w_len)); in dhd_dbg_ring_push()
293 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_push()
297 w_entry = (dhd_dbg_ring_entry_t *)((uint8 *)ring->ring_buf + ring->wp); in dhd_dbg_ring_push()
304 ring->wp += w_len; in dhd_dbg_ring_push()
307 ring->stat.written_records++; in dhd_dbg_ring_push()
308 ring->stat.written_bytes += w_len; in dhd_dbg_ring_push()
309 DHD_DBGIF(("%s : RING%d[%s] written_records %d, written_bytes %d, read_bytes=%d," in dhd_dbg_ring_push()
310 " ring->threshold=%d, wp=%d, rp=%d\n", __FUNCTION__, ring->id, ring->name, in dhd_dbg_ring_push()
311 ring->stat.written_records, ring->stat.written_bytes, ring->stat.read_bytes, in dhd_dbg_ring_push()
312 ring->threshold, ring->wp, ring->rp)); in dhd_dbg_ring_push()
314 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_push()
319 * This function folds ring->lock, so callers of this function
320 * should not hold ring->lock.
323 dhd_dbg_ring_pull_single(dhd_dbg_ring_t *ring, void *data, uint32 buf_len, bool strip_header) in dhd_dbg_ring_pull_single() argument
329 if (!ring || !data || buf_len <= 0) { in dhd_dbg_ring_pull_single()
333 /* pull from ring is allowed for inactive (suspended) ring in dhd_dbg_ring_pull_single()
335 * when a trap occurs the ring is suspended and data is then in dhd_dbg_ring_pull_single()
336 * pulled to dump it to a file. For other rings if ring is in dhd_dbg_ring_pull_single()
339 if (!ring->pull_inactive && (ring->state != RING_ACTIVE)) { in dhd_dbg_ring_pull_single()
343 if (ring->rp == ring->wp) { in dhd_dbg_ring_pull_single()
347 DHD_DBGIF(("%s: RING%d[%s] buf_len=%u, wp=%d, rp=%d, ring_start=0x%p; ring_size=%u\n", in dhd_dbg_ring_pull_single()
348 __FUNCTION__, ring->id, ring->name, buf_len, ring->wp, ring->rp, in dhd_dbg_ring_pull_single()
349 ring->ring_buf, ring->ring_size)); in dhd_dbg_ring_pull_single()
351 r_entry = (dhd_dbg_ring_entry_t *)((uint8 *)ring->ring_buf + ring->rp); in dhd_dbg_ring_pull_single()
355 if ((ring->rp + rlen) > ring->ring_size) { in dhd_dbg_ring_pull_single()
356 DHD_ERROR(("%s: entry len %d is out of boundary of ring size %d," in dhd_dbg_ring_pull_single()
357 " current ring %d[%s] - rp=%d\n", __FUNCTION__, rlen, in dhd_dbg_ring_pull_single()
358 ring->ring_size, ring->id, ring->name, ring->rp)); in dhd_dbg_ring_pull_single()
373 DHD_ERROR(("%s: ring %d[%s] - ring size=%d, wp=%d, rp=%d\n", in dhd_dbg_ring_pull_single()
374 __FUNCTION__, ring->id, ring->name, ring->ring_size, in dhd_dbg_ring_pull_single()
375 ring->wp, ring->rp)); in dhd_dbg_ring_pull_single()
382 /* update ring context */ in dhd_dbg_ring_pull_single()
383 ring->rp += ENTRY_LENGTH(r_entry); in dhd_dbg_ring_pull_single()
385 if (ring->rp != ring->wp && in dhd_dbg_ring_pull_single()
386 ring->tail_padded && ((ring->rp + ring->rem_len) >= ring->ring_size)) { in dhd_dbg_ring_pull_single()
387 DHD_DBGIF(("%s: RING%d[%s] Found padding, rp=%d, wp=%d\n", in dhd_dbg_ring_pull_single()
388 __FUNCTION__, ring->id, ring->name, ring->rp, ring->wp)); in dhd_dbg_ring_pull_single()
389 ring->rp = 0; in dhd_dbg_ring_pull_single()
390 ring->tail_padded = FALSE; in dhd_dbg_ring_pull_single()
391 ring->rem_len = 0; in dhd_dbg_ring_pull_single()
393 if (ring->rp >= ring->ring_size) { in dhd_dbg_ring_pull_single()
394 DHD_ERROR(("%s: RING%d[%s] rp pointed out of ring boundary," in dhd_dbg_ring_pull_single()
395 " rp=%d, ring_size=%d\n", __FUNCTION__, ring->id, in dhd_dbg_ring_pull_single()
396 ring->name, ring->rp, ring->ring_size)); in dhd_dbg_ring_pull_single()
401 ring->stat.read_bytes += ENTRY_LENGTH(r_entry); in dhd_dbg_ring_pull_single()
402 DHD_DBGIF(("%s RING%d[%s]read_bytes %d, wp=%d, rp=%d\n", __FUNCTION__, in dhd_dbg_ring_pull_single()
403 ring->id, ring->name, ring->stat.read_bytes, ring->wp, ring->rp)); in dhd_dbg_ring_pull_single()
411 dhd_dbg_ring_pull(dhd_dbg_ring_t *ring, void *data, uint32 buf_len, bool strip_hdr) in dhd_dbg_ring_pull() argument
415 if (!ring || !data) in dhd_dbg_ring_pull()
418 if (!ring->pull_inactive && (ring->state != RING_ACTIVE)) { in dhd_dbg_ring_pull()
423 r_len = dhd_dbg_ring_pull_single(ring, data, buf_len, strip_hdr); in dhd_dbg_ring_pull()
435 dhd_dbg_ring_config(dhd_dbg_ring_t *ring, int log_level, uint32 threshold) in dhd_dbg_ring_config() argument
439 if (!ring) in dhd_dbg_ring_config()
442 if (ring->state == RING_STOP) in dhd_dbg_ring_config()
445 DHD_DBG_RING_LOCK(ring->lock, flags); in dhd_dbg_ring_config()
448 ring->state = RING_SUSPEND; in dhd_dbg_ring_config()
450 ring->state = RING_ACTIVE; in dhd_dbg_ring_config()
452 ring->log_level = log_level; in dhd_dbg_ring_config()
453 ring->threshold = MIN(threshold, DBGRING_FLUSH_THRESHOLD(ring)); in dhd_dbg_ring_config()
455 DHD_DBG_RING_UNLOCK(ring->lock, flags); in dhd_dbg_ring_config()
461 dhd_dbg_ring_start(dhd_dbg_ring_t *ring) in dhd_dbg_ring_start() argument
463 if (!ring) in dhd_dbg_ring_start()
466 /* Initialize the information for the ring */ in dhd_dbg_ring_start()
467 ring->state = RING_SUSPEND; in dhd_dbg_ring_start()
468 ring->log_level = 0; in dhd_dbg_ring_start()
469 ring->rp = ring->wp = 0; in dhd_dbg_ring_start()
470 ring->threshold = 0; in dhd_dbg_ring_start()
471 memset(&ring->stat, 0, sizeof(struct ring_statistics)); in dhd_dbg_ring_start()
472 memset(ring->ring_buf, 0, ring->ring_size); in dhd_dbg_ring_start()