Lines Matching refs:ev
177 ev_t *ev; in ev_new() local
179 ev = (ev_t *)malloc(sizeof (ev_t)); in ev_new()
180 if (ev != NULL) { in ev_new()
181 if (pthread_mutex_init(&ev->mtx, NULL) != 0 || in ev_new()
182 (ev->eid = (uchar_t *)malloc(len)) == NULL) { in ev_new()
183 free(ev); in ev_new()
186 ev->uid = uid; in ev_new()
187 (void) strcpy((char *)ev->eid, (char *)eid); in ev_new()
188 ev->eid_len = len; in ev_new()
190 ev->flags = EV_FLAG_INIT; in ev_new()
193 return (ev); in ev_new()
380 ev_t *ev, in ev_add() argument
392 p = extract_esi_portal(ev->uid, &intval); in ev_add()
393 ev->intval = intval; in ev_add()
395 ev->type = EV_ESI; in ev_add()
396 ev->portal = p; in ev_add()
406 ev->type = EV_REG_EXP; in ev_add()
407 ev->portal = NULL; in ev_add()
414 return (el_add(ev, t, NULL)); in ev_add()
468 ev_t *ev = ev_new(uid, eid, len); in esi_load() local
471 if (ev != NULL) { in esi_load()
472 ev->next = ev_list; in esi_load()
473 ev_list = ev; in esi_load()
497 ev_t *ev; in verify_esi_portal() local
501 ev = ev_list; in verify_esi_portal()
502 ev_list = ev->next; in verify_esi_portal()
503 ev->next = NULL; in verify_esi_portal()
504 ec = ev_add(ev, 1); in verify_esi_portal()
533 ev_t *ev = ev_new(uid, eid, len); in esi_add() local
535 if (ev != NULL) { in esi_add()
537 ev->flags |= EV_FLAG_WAKEUP; in esi_add()
538 ec = ev_add(ev, 0); in esi_add()
716 ev_t *ev = (ev_t *)p; in ev_remove() local
724 pp = &ev->portal; in ev_remove()
756 ev->flags |= EV_FLAG_REMOVE; in ev_remove()
759 ev->type == EV_ESI ? "ESI" : "REG_EXP", in ev_remove()
760 ev->uid); in ev_remove()
764 ev_free(ev); in ev_remove()
771 ev->type == EV_ESI ? "ESI" : "REG_EXP", in ev_remove()
772 ev->uid); in ev_remove()
773 ev->flags |= EV_FLAG_REM_P1; in ev_remove()
781 ev->type == EV_ESI ? "ESI" : "REG_EXP", in ev_remove()
782 ev->uid, portal_uid); in ev_remove()
803 ev_t *ev = (ev_t *)p; in ev_free() local
806 free_esi_portal(ev->portal); in ev_free()
810 ev->type == EV_ESI ? "ESI" : "REG_EXP", in ev_free()
811 ev->uid); in ev_free()
813 free(ev->eid); in ev_free()
816 free(ev); in ev_free()
916 ev_t *ev = (ev_t *)p; in evf_rem_pending() local
917 if ((ev->flags & EV_FLAG_REM_P) != 0) { in evf_rem_pending()
918 if (ev->type != EV_REG_EXP) { in evf_rem_pending()
921 ev->type == EV_ESI ? "ESI" : "REG_EXP", in evf_rem_pending()
922 ev->uid); in evf_rem_pending()
923 ev->type = EV_REG_EXP; in evf_rem_pending()
924 ev->intval *= 2; /* after 2 ESI interval */ in evf_rem_pending()
947 ev_t *ev = (ev_t *)p; in evf_zero() local
951 ev->flags = EV_FLAG_AGAIN | (ev->flags & EV_FLAG_REM_P); in evf_zero()
970 ev_t *ev; in evl_append() local
972 ev = (ev_t *)p; in evl_append()
973 ev->next = ev_list; in evl_append()
974 ev_list = ev; in evl_append()
994 ev_t *ev = *evp; in evl_strip() local
996 while (ev != NULL) { in evl_strip()
997 if (ev == p) { in evl_strip()
998 *evp = ev->next; in evl_strip()
1001 evp = &ev->next; in evl_strip()
1002 ev = *evp; in evl_strip()
1026 ev_t *ev = ev_list; in evl_remove() local
1028 while (ev != NULL) { in evl_remove()
1030 if (ev_match(ev, id1) != 0) { in evl_remove()
1032 (void) pthread_mutex_lock(&ev->mtx); in evl_remove()
1034 (void) ev_remove(ev, id2, 0, pending); in evl_remove()
1036 (void) pthread_mutex_unlock(&ev->mtx); in evl_remove()
1040 ev = ev->next; in evl_remove()
1128 ev_t *ev in ev_ex() argument
1133 switch (ev->type) { in ev_ex()
1136 esi_monitor, (void *)ev) != 0) { in ev_ex()
1139 (void) el_add(ev, 0, NULL); in ev_ex()
1146 (void) queue_msg_set(sys_q, REG_EXP, (void *)ev); in ev_ex()
1174 ev_t *ev; in esi_proc() local
1179 ev = (ev_t *)el_first(&pt); in esi_proc()
1182 if (ev != NULL) { in esi_proc()
1207 ev = NULL; /* force break */ in esi_proc()
1208 } else if (ev != NULL) { in esi_proc()
1213 (void) el_add(ev, pt, &evp); in esi_proc()
1214 ev = (ev_t *)evp; in esi_proc()
1220 ev->uid); in esi_proc()
1221 ev_ex(ev); in esi_proc()
1222 ev = NULL; in esi_proc()
1225 } while (ev != NULL); in esi_proc()
1296 ev_t *ev = (ev_t *)arg; in esi_monitor() local
1311 (void) pthread_mutex_lock(&ev->mtx); in esi_monitor()
1313 if (evf_rem(ev) != 0) { in esi_monitor()
1315 } else if (evf_rem_pending(ev) != 0) { in esi_monitor()
1327 ISNS_EID_ATTR_ID, ev->eid_len, (void *)ev->eid, 0) != 0) { in esi_monitor()
1340 p = ev->portal; in esi_monitor()
1376 (void) pthread_mutex_unlock(&ev->mtx); in esi_monitor()
1384 ev->flags |= EV_FLAG_WAKEUP; in esi_monitor()
1387 (void) el_add(ev, 0, NULL); in esi_monitor()
1443 ev_t *ev = (ev_t *)p; in reg_expiring() local
1447 SET_UID_LCP(&lc, OBJ_ENTITY, ev->uid); in reg_expiring()
1452 if (evf_rem(ev) == 0) { in reg_expiring()
1461 ev->flags |= EV_FLAG_REMOVE; in reg_expiring()
1464 ev->intval = 3 * 60; in reg_expiring()
1474 (void) el_add(ev, 0, NULL); in reg_expiring()