Lines Matching refs:ulog

27 			ulog = log_ctx->ulog
32 ulog_sync_update(kdb_hlog_t *ulog, kdb_ent_header_t *upd) in ulog_sync_update() argument
37 if (ulog == NULL) in ulog_sync_update()
45 end = (((ulong_t)upd) + ulog->kdb_block + in ulog_sync_update()
60 ulog_sync_header(kdb_hlog_t *ulog) in ulog_sync_header() argument
66 if (msync((caddr_t)ulog, pagesize, MS_SYNC)) { in ulog_sync_header()
82 ulog_resize(kdb_hlog_t *ulog, uint32_t ulogentries, int ulogfd, uint_t recsize) in ulog_resize() argument
86 if (ulog == NULL) in ulog_resize()
100 (void) memset(ulog, 0, sizeof (kdb_hlog_t)); in ulog_resize()
102 ulog->kdb_hmagic = KDB_HMAGIC; in ulog_resize()
103 ulog->db_version_num = KDB_VERSION; in ulog_resize()
104 ulog->kdb_state = KDB_STABLE; in ulog_resize()
105 ulog->kdb_block = new_block; in ulog_resize()
107 ulog_sync_header(ulog); in ulog_resize()
147 kdb_hlog_t *ulog = NULL; in ulog_add_update() local
166 if (recsize > ulog->kdb_block) { in ulog_add_update()
167 if (retval = ulog_resize(ulog, ulogentries, ulogfd, recsize)) { in ulog_add_update()
173 cur_sno = ulog->kdb_last_sno; in ulog_add_update()
191 indx_log = (kdb_ent_header_t *)INDEX(ulog, i); in ulog_add_update()
193 (void) memset(indx_log, 0, ulog->kdb_block); in ulog_add_update()
201 ulog->kdb_state = KDB_UNSTABLE; in ulog_add_update()
208 if (retval = ulog_sync_update(ulog, indx_log)) in ulog_add_update()
211 if (ulog->kdb_num < ulogentries) in ulog_add_update()
212 ulog->kdb_num++; in ulog_add_update()
214 ulog->kdb_last_sno = cur_sno; in ulog_add_update()
215 ulog->kdb_last_time = ktime; in ulog_add_update()
223 indx_log = (kdb_ent_header_t *)INDEX(ulog, i); in ulog_add_update()
224 ulog->kdb_first_sno = indx_log->kdb_entry_sno; in ulog_add_update()
225 ulog->kdb_first_time = indx_log->kdb_time; in ulog_add_update()
227 ulog->kdb_first_sno = 1; in ulog_add_update()
228 ulog->kdb_first_time = indx_log->kdb_time; in ulog_add_update()
231 ulog_sync_header(ulog); in ulog_add_update()
247 kdb_hlog_t *ulog = NULL; in ulog_finish_update() local
255 indx_log = (kdb_ent_header_t *)INDEX(ulog, i); in ulog_finish_update()
259 ulog->kdb_state = KDB_STABLE; in ulog_finish_update()
261 if (retval = ulog_sync_update(ulog, indx_log)) in ulog_finish_update()
264 ulog_sync_header(ulog); in ulog_finish_update()
273 ulog_finish_update_slave(kdb_hlog_t *ulog, kdb_last_t lastentry) in ulog_finish_update_slave() argument
276 ulog->kdb_last_sno = lastentry.last_sno; in ulog_finish_update_slave()
277 ulog->kdb_last_time = lastentry.last_time; in ulog_finish_update_slave()
279 ulog_sync_header(ulog); in ulog_finish_update_slave()
309 kdb_hlog_t *ulog = NULL; in ulog_replay() local
403 ulog_finish_update_slave(ulog, errlast); in ulog_replay()
405 ulog_finish_update_slave(ulog, incr_ret->lastentry); in ulog_replay()
419 ulog_check(krb5_context context, kdb_hlog_t *ulog) in ulog_check() argument
428 ulog->kdb_state = KDB_STABLE; in ulog_check()
430 for (i = 0; i < ulog->kdb_num; i++) { in ulog_check()
431 indx_log = (kdb_ent_header_t *)INDEX(ulog, i); in ulog_check()
437 ulog->kdb_state = KDB_CORRUPT; in ulog_check()
443 ulog->kdb_state = KDB_UNSTABLE; in ulog_check()
499 retval = ulog_sync_update(ulog, indx_log); in ulog_check()
503 ulog->kdb_state = KDB_STABLE; in ulog_check()
514 ulog_sync_header(ulog); in ulog_check()
535 kdb_hlog_t *ulog = NULL; in ulog_map() local
591 ulog = (kdb_hlog_t *)mmap(0, ulog_filesize, in ulog_map()
597 ulog = (kdb_hlog_t *)mmap(0, MAXLOGLEN, in ulog_map()
601 if ((int)(ulog) == -1) { in ulog_map()
614 log_ctx->ulog = ulog; in ulog_map()
618 if (ulog->kdb_hmagic != KDB_HMAGIC) { in ulog_map()
619 if (ulog->kdb_hmagic == 0) { in ulog_map()
623 (void) memset(ulog, 0, sizeof (kdb_hlog_t)); in ulog_map()
625 ulog->kdb_hmagic = KDB_HMAGIC; in ulog_map()
626 ulog->db_version_num = KDB_VERSION; in ulog_map()
627 ulog->kdb_state = KDB_STABLE; in ulog_map()
628 ulog->kdb_block = ULOG_BLOCK; in ulog_map()
630 ulog_sync_header(ulog); in ulog_map()
637 switch (ulog->kdb_state) { in ulog_map()
643 retval = ulog_check(context, ulog); in ulog_map()
667 if (ulog->kdb_num != ulogentries) { in ulog_map()
668 if ((ulog->kdb_num != 0) && in ulog_map()
669 ((ulog->kdb_last_sno > ulog->kdb_num) || in ulog_map()
670 (ulog->kdb_num > ulogentries))) { in ulog_map()
671 (void) memset(ulog, 0, sizeof (kdb_hlog_t)); in ulog_map()
673 ulog->kdb_hmagic = KDB_HMAGIC; in ulog_map()
674 ulog->db_version_num = KDB_VERSION; in ulog_map()
675 ulog->kdb_state = KDB_STABLE; in ulog_map()
676 ulog->kdb_block = ULOG_BLOCK; in ulog_map()
678 ulog_sync_header(ulog); in ulog_map()
684 if (ulog->kdb_num < ulogentries) { in ulog_map()
685 ulog_filesize += ulogentries * ulog->kdb_block; in ulog_map()
717 kdb_hlog_t *ulog = NULL; in ulog_get_entries() local
726 if (ulog->kdb_state == KDB_CORRUPT) { in ulog_get_entries()
733 tdiff = timestamp.tv_sec - ulog->kdb_last_time.seconds; in ulog_get_entries()
752 if ((last.last_sno > ulog->kdb_last_sno) || in ulog_get_entries()
753 (last.last_sno < ulog->kdb_first_sno) || in ulog_get_entries()
755 ulog_handle->lastentry.last_sno = ulog->kdb_last_sno; in ulog_get_entries()
759 } else if (last.last_sno <= ulog->kdb_last_sno) { in ulog_get_entries()
764 indx_log = (kdb_ent_header_t *)INDEX(ulog, indx); in ulog_get_entries()
775 if (last.last_sno == ulog->kdb_last_sno) { in ulog_get_entries()
781 count = ulog->kdb_last_sno - sno; in ulog_get_entries()
795 while (sno < ulog->kdb_last_sno) { in ulog_get_entries()
799 INDEX(ulog, indx); in ulog_get_entries()
824 ulog_handle->lastentry.last_sno = ulog->kdb_last_sno; in ulog_get_entries()
826 ulog->kdb_last_time.seconds; in ulog_get_entries()
828 ulog->kdb_last_time.useconds; in ulog_get_entries()