Lines Matching refs:mp
96 #define IS_CLIENT(mp) (((mp)->epm_xprtflags & FMD_XPRT_ACCEPT) ? 0 : 1) argument
240 etm_check_hdr(fmd_hdl_t *hdl, etm_epmap_t *mp, void *buf) in etm_check_hdr() argument
246 ": 0x%x\n", mp->epm_ep_str, hp->hdr_delim); in etm_check_hdr()
256 if (hp->hdr_ver != mp->epm_ver) { in etm_check_hdr()
258 mp->epm_ep_str, hp->hdr_ver); in etm_check_hdr()
265 mp->epm_ep_str, hp->hdr_type); in etm_check_hdr()
296 etm_post_msg(fmd_hdl_t *hdl, etm_epmap_t *mp, void *buf, size_t buflen) in etm_post_msg() argument
306 rv = etm_xport_post_filter(hdl, nvl, mp->epm_ep_str); in etm_post_msg()
318 (void) pthread_mutex_lock(&mp->epm_lock); in etm_post_msg()
322 if (mp->epm_qstat == Q_OPEN) { in etm_post_msg()
323 fmd_xprt_post(hdl, mp->epm_xprthdl, nvl, 0); in etm_post_msg()
325 } else if (mp->epm_qstat == Q_SUSPENDED) { in etm_post_msg()
326 fmd_xprt_resume(hdl, mp->epm_xprthdl); in etm_post_msg()
327 if (mp->epm_timer_in_use) { in etm_post_msg()
328 fmd_timer_remove(hdl, mp->epm_timer_id); in etm_post_msg()
329 mp->epm_timer_in_use = 0; in etm_post_msg()
331 mp->epm_qstat = Q_OPEN; in etm_post_msg()
333 mp->epm_ep_str); in etm_post_msg()
334 fmd_xprt_post(hdl, mp->epm_xprthdl, nvl, 0); in etm_post_msg()
338 mp->epm_qstat); in etm_post_msg()
351 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_post_msg()
369 etm_handle_startup(fmd_hdl_t *hdl, etm_epmap_t *mp) in etm_handle_startup() argument
376 if ((mp->epm_oconn = etm_xport_open(hdl, mp->epm_tlhdl)) == NULL) in etm_handle_startup()
379 mp->epm_cstat = C_OPEN; in etm_handle_startup()
381 hdrlen = etm_create_hdr(hbuf, mp->epm_ver, ETM_HDR_C_HELLO, 0); in etm_handle_startup()
383 if ((etm_xport_write(hdl, mp->epm_oconn, Rw_timeout, hbuf, in etm_handle_startup()
386 mp->epm_ep_str); in etm_handle_startup()
390 mp->epm_qstat = Q_INIT_PENDING; in etm_handle_startup()
392 if ((etm_xport_read(hdl, mp->epm_oconn, Rw_timeout, hbuf, in etm_handle_startup()
395 mp->epm_ep_str); in etm_handle_startup()
399 hdrstat = etm_check_hdr(hdl, mp, hbuf); in etm_handle_startup()
403 "from %s", mp->epm_ep_str); in etm_handle_startup()
414 mp->epm_ep_str, hp->hdr_ver); in etm_handle_startup()
417 mp->epm_ver = hp->hdr_ver; in etm_handle_startup()
419 hdrlen = etm_create_hdr(hbuf, mp->epm_ver, ETM_HDR_ACK, 0); in etm_handle_startup()
421 if ((etm_xport_write(hdl, mp->epm_oconn, Rw_timeout, hbuf, in etm_handle_startup()
424 mp->epm_ep_str); in etm_handle_startup()
433 if ((mp->epm_xprthdl = fmd_xprt_open(hdl, mp->epm_xprtflags, in etm_handle_startup()
434 mp->epm_ep_nvl, NULL)) == NULL) { in etm_handle_startup()
436 mp->epm_ep_str); in etm_handle_startup()
438 fmd_xprt_setspecific(hdl, mp->epm_xprthdl, mp); in etm_handle_startup()
441 mp->epm_qstat = Q_OPEN; in etm_handle_startup()
442 fmd_hdl_debug(hdl, "queue open for %s", mp->epm_ep_str); in etm_handle_startup()
452 etm_send_shutdown(fmd_hdl_t *hdl, etm_epmap_t *mp) in etm_send_shutdown() argument
457 if ((mp->epm_oconn = etm_xport_open(hdl, mp->epm_tlhdl)) == NULL) in etm_send_shutdown()
460 hdrlen = etm_create_hdr(hbuf, mp->epm_ver, ETM_HDR_SHUTDOWN, 0); in etm_send_shutdown()
462 (void) etm_xport_write(hdl, mp->epm_oconn, Rw_timeout, hbuf, hdrlen); in etm_send_shutdown()
464 (void) etm_xport_close(hdl, mp->epm_oconn); in etm_send_shutdown()
465 mp->epm_oconn = NULL; in etm_send_shutdown()
473 etm_get_ep_nvl(fmd_hdl_t *hdl, etm_epmap_t *mp) in etm_get_ep_nvl() argument
479 (void) nvlist_alloc(&mp->epm_ep_nvl, NV_UNIQUE_NAME, 0); in etm_get_ep_nvl()
481 if (nvlist_add_string(mp->epm_ep_nvl, "domain-id", mp->epm_ep_str)) { in etm_get_ep_nvl()
483 "for %s", mp->epm_ep_str); in etm_get_ep_nvl()
484 nvlist_free(mp->epm_ep_nvl); in etm_get_ep_nvl()
496 etm_free_ep_nvl(fmd_hdl_t *hdl, etm_epmap_t *mp) in etm_free_ep_nvl() argument
498 nvlist_free(mp->epm_ep_nvl); in etm_free_ep_nvl()
508 etm_epmap_t *mp; in etm_check_dup_ep_str() local
510 for (mp = Epmap_head; mp != NULL; mp = mp->epm_next) in etm_check_dup_ep_str()
511 if (strcmp(epname, mp->epm_ep_str) == 0) in etm_check_dup_ep_str()
521 etm_reconnect(fmd_hdl_t *hdl, etm_epmap_t *mp) in etm_reconnect() argument
523 if ((mp->epm_reconn_end > 0) && (mp->epm_cstat == C_UNINITIALIZED)) { in etm_reconnect()
524 if (gethrtime() < mp->epm_reconn_end) { in etm_reconnect()
525 if ((mp->epm_oconn = etm_xport_open(hdl, in etm_reconnect()
526 mp->epm_tlhdl)) == NULL) { in etm_reconnect()
528 mp->epm_ep_str); in etm_reconnect()
529 mp->epm_timer_id = fmd_timer_install(hdl, mp, in etm_reconnect()
531 mp->epm_timer_in_use = 1; in etm_reconnect()
534 mp->epm_ep_str); in etm_reconnect()
535 mp->epm_reconn_end = 0; in etm_reconnect()
536 mp->epm_cstat = C_OPEN; in etm_reconnect()
540 mp->epm_ep_str); in etm_reconnect()
541 mp->epm_reconn_end = 0; in etm_reconnect()
542 mp->epm_cstat = C_TIMED_OUT; in etm_reconnect()
546 if (mp->epm_cstat == C_OPEN) { in etm_reconnect()
547 fmd_xprt_resume(hdl, mp->epm_xprthdl); in etm_reconnect()
548 mp->epm_qstat = Q_OPEN; in etm_reconnect()
549 fmd_hdl_debug(hdl, "queue resumed for %s", mp->epm_ep_str); in etm_reconnect()
558 etm_suspend_reconnect(fmd_hdl_t *hdl, etm_epmap_t *mp) in etm_suspend_reconnect() argument
567 if (mp->epm_oconn != NULL) { in etm_suspend_reconnect()
568 (void) etm_xport_close(hdl, mp->epm_oconn); in etm_suspend_reconnect()
569 mp->epm_oconn = NULL; in etm_suspend_reconnect()
572 mp->epm_reconn_end = gethrtime() + Reconn_timeout; in etm_suspend_reconnect()
573 mp->epm_cstat = C_UNINITIALIZED; in etm_suspend_reconnect()
575 if (mp->epm_xprthdl != NULL) { in etm_suspend_reconnect()
576 fmd_xprt_suspend(hdl, mp->epm_xprthdl); in etm_suspend_reconnect()
577 mp->epm_qstat = Q_SUSPENDED; in etm_suspend_reconnect()
578 fmd_hdl_debug(hdl, "queue suspended for %s", mp->epm_ep_str); in etm_suspend_reconnect()
580 if (mp->epm_timer_in_use == 0) { in etm_suspend_reconnect()
581 mp->epm_timer_id = fmd_timer_install(hdl, mp, NULL, in etm_suspend_reconnect()
583 mp->epm_timer_in_use = 1; in etm_suspend_reconnect()
594 etm_reinit(fmd_hdl_t *hdl, etm_epmap_t *mp) in etm_reinit() argument
600 while (mp->epm_txbusy) in etm_reinit()
601 (void) pthread_cond_wait(&mp->epm_tx_cv, &mp->epm_lock); in etm_reinit()
603 if (mp->epm_xprthdl != NULL) { in etm_reinit()
604 fmd_xprt_close(hdl, mp->epm_xprthdl); in etm_reinit()
605 fmd_hdl_debug(hdl, "queue closed for %s", mp->epm_ep_str); in etm_reinit()
606 mp->epm_xprthdl = NULL; in etm_reinit()
608 mp->epm_ep_nvl = NULL; in etm_reinit()
611 if (mp->epm_timer_in_use) { in etm_reinit()
612 fmd_timer_remove(hdl, mp->epm_timer_id); in etm_reinit()
613 mp->epm_timer_in_use = 0; in etm_reinit()
616 if (mp->epm_oconn != NULL) { in etm_reinit()
617 (void) etm_xport_close(hdl, mp->epm_oconn); in etm_reinit()
618 mp->epm_oconn = NULL; in etm_reinit()
621 mp->epm_cstat = C_UNINITIALIZED; in etm_reinit()
622 mp->epm_qstat = Q_UNINITIALIZED; in etm_reinit()
631 etm_recv(fmd_hdl_t *hdl, etm_xport_conn_t conn, etm_epmap_t *mp) in etm_recv() argument
642 mp->epm_ep_str); in etm_recv()
647 hdrstat = etm_check_hdr(hdl, mp, hbuf); in etm_recv()
651 (void) pthread_mutex_lock(&mp->epm_lock); in etm_recv()
652 if (mp->epm_cstat == C_OPEN) in etm_recv()
653 mp->epm_cstat = C_CLOSED; in etm_recv()
654 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_recv()
662 hdrlen = etm_create_hdr(hbuf, mp->epm_ver, ETM_HDR_NAK, 0); in etm_recv()
667 mp->epm_ep_str); in etm_recv()
672 (void) pthread_mutex_lock(&mp->epm_lock); in etm_recv()
673 mp->epm_cstat = C_LIMBO; in etm_recv()
674 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_recv()
682 (void) pthread_mutex_lock(&mp->epm_lock); in etm_recv()
683 etm_reinit(hdl, mp); in etm_recv()
684 mp->epm_qstat = Q_INIT_PENDING; in etm_recv()
685 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_recv()
687 hdrlen = etm_create_hdr(hbuf, mp->epm_ver, ETM_HDR_S_HELLO, 0); in etm_recv()
692 mp->epm_ep_str); in etm_recv()
701 (void) pthread_mutex_lock(&mp->epm_lock); in etm_recv()
702 if (mp->epm_qstat == Q_INIT_PENDING) { in etm_recv()
705 if (mp->epm_ep_nvl == NULL) in etm_recv()
706 (void) etm_get_ep_nvl(hdl, mp); in etm_recv()
713 if ((mp->epm_xprthdl = fmd_xprt_open(hdl, in etm_recv()
714 mp->epm_xprtflags, mp->epm_ep_nvl, NULL)) == NULL) { in etm_recv()
716 "for %s", mp->epm_ep_str); in etm_recv()
718 fmd_xprt_setspecific(hdl, mp->epm_xprthdl, mp); in etm_recv()
721 mp->epm_qstat = Q_OPEN; in etm_recv()
722 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_recv()
724 mp->epm_ep_str); in etm_recv()
726 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_recv()
728 "from %s\n", mp->epm_ep_str); in etm_recv()
737 mp->epm_ep_str); in etm_recv()
739 (void) pthread_mutex_lock(&mp->epm_lock); in etm_recv()
741 etm_reinit(hdl, mp); in etm_recv()
743 if (IS_CLIENT(mp)) { in etm_recv()
748 mp->epm_timer_id = fmd_timer_install(hdl, mp, NULL, in etm_recv()
751 mp->epm_timer_in_use = 1; in etm_recv()
754 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_recv()
760 (void) pthread_mutex_lock(&mp->epm_lock); in etm_recv()
761 if (mp->epm_qstat == Q_UNINITIALIZED) { in etm_recv()
763 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_recv()
764 hdrlen = etm_create_hdr(hbuf, mp->epm_ver, in etm_recv()
770 "to %s", mp->epm_ep_str); in etm_recv()
777 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_recv()
785 mp->epm_ep_str); in etm_recv()
796 if (etm_post_msg(hdl, mp, buf, buflen)) { in etm_recv()
804 hdrlen = etm_create_hdr(hbuf, mp->epm_ver, ETM_HDR_ACK, 0); in etm_recv()
809 mp->epm_ep_str); in etm_recv()
821 (void) pthread_mutex_lock(&mp->epm_lock); in etm_recv()
822 if (mp->epm_cstat == C_TIMED_OUT || in etm_recv()
823 mp->epm_cstat == C_LIMBO) { in etm_recv()
824 if (mp->epm_oconn != NULL) { in etm_recv()
825 (void) etm_xport_close(hdl, mp->epm_oconn); in etm_recv()
826 mp->epm_oconn = NULL; in etm_recv()
828 mp->epm_cstat = C_UNINITIALIZED; in etm_recv()
829 fmd_xprt_resume(hdl, mp->epm_xprthdl); in etm_recv()
830 if (mp->epm_timer_in_use) { in etm_recv()
831 fmd_timer_remove(hdl, mp->epm_timer_id); in etm_recv()
832 mp->epm_timer_in_use = 0; in etm_recv()
834 mp->epm_qstat = Q_OPEN; in etm_recv()
836 mp->epm_ep_str); in etm_recv()
838 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_recv()
845 "from %s : %d", mp->epm_ep_str, hdrstat); in etm_recv()
863 etm_epmap_t *mp = (etm_epmap_t *)arg; in etm_cb_func() local
875 rv = etm_recv(hdl, conn, mp); in etm_cb_func()
878 (void) pthread_mutex_lock(&mp->epm_lock); in etm_cb_func()
879 etm_reinit(hdl, mp); in etm_cb_func()
880 etm_send_shutdown(hdl, mp); in etm_cb_func()
881 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_cb_func()
1078 etm_free_epmap(fmd_hdl_t *hdl, etm_epmap_t *mp) in etm_free_epmap() argument
1083 (void) pthread_mutex_lock(&mp->epm_lock); in etm_free_epmap()
1090 while (mp->epm_txbusy) in etm_free_epmap()
1091 (void) pthread_cond_wait(&mp->epm_tx_cv, &mp->epm_lock); in etm_free_epmap()
1093 if (mp->epm_timer_in_use) in etm_free_epmap()
1094 fmd_timer_remove(hdl, mp->epm_timer_id); in etm_free_epmap()
1096 if (mp->epm_oconn != NULL) { in etm_free_epmap()
1097 hdrlen = etm_create_hdr(hbuf, mp->epm_ver, in etm_free_epmap()
1099 (void) etm_xport_write(hdl, mp->epm_oconn, Rw_timeout, hbuf, in etm_free_epmap()
1101 (void) etm_xport_close(hdl, mp->epm_oconn); in etm_free_epmap()
1102 mp->epm_oconn = NULL; in etm_free_epmap()
1105 if (mp->epm_xprthdl != NULL) { in etm_free_epmap()
1106 fmd_xprt_close(hdl, mp->epm_xprthdl); in etm_free_epmap()
1108 mp->epm_ep_nvl = NULL; in etm_free_epmap()
1111 if (mp->epm_ep_nvl != NULL) in etm_free_epmap()
1112 etm_free_ep_nvl(hdl, mp); in etm_free_epmap()
1114 if (mp->epm_tlhdl != NULL) in etm_free_epmap()
1115 (void) etm_xport_fini(hdl, mp->epm_tlhdl); in etm_free_epmap()
1117 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_free_epmap()
1118 (void) pthread_mutex_destroy(&mp->epm_lock); in etm_free_epmap()
1119 fmd_hdl_strfree(hdl, mp->epm_ep_str); in etm_free_epmap()
1120 fmd_hdl_free(hdl, mp, sizeof (etm_epmap_t)); in etm_free_epmap()
1135 etm_epmap_t *mp; in etm_send() local
1149 mp = fmd_xprt_getspecific(hdl, xprthdl); in etm_send()
1152 if (pthread_mutex_trylock(&mp->epm_lock) == 0) { in etm_send()
1172 mp->epm_txbusy++; in etm_send()
1174 if (mp->epm_qstat == Q_UNINITIALIZED) { in etm_send()
1175 mp->epm_txbusy--; in etm_send()
1176 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1177 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1181 if (mp->epm_cstat == C_CLOSED) { in etm_send()
1182 etm_suspend_reconnect(hdl, mp); in etm_send()
1183 mp->epm_txbusy--; in etm_send()
1184 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1185 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1189 if (mp->epm_cstat == C_LIMBO) { in etm_send()
1190 if (mp->epm_oconn != NULL) { in etm_send()
1191 (void) etm_xport_close(hdl, mp->epm_oconn); in etm_send()
1192 mp->epm_oconn = NULL; in etm_send()
1196 mp->epm_qstat = Q_SUSPENDED; in etm_send()
1197 mp->epm_txbusy--; in etm_send()
1198 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1199 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1200 fmd_hdl_debug(hdl, "queue suspended for %s", mp->epm_ep_str); in etm_send()
1204 if (mp->epm_oconn == NULL) { in etm_send()
1205 if ((mp->epm_oconn = etm_xport_open(hdl, mp->epm_tlhdl)) in etm_send()
1207 etm_suspend_reconnect(hdl, mp); in etm_send()
1208 mp->epm_txbusy--; in etm_send()
1209 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1210 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1213 mp->epm_cstat = C_OPEN; in etm_send()
1222 mp->epm_txbusy--; in etm_send()
1223 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1224 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1230 rv = etm_xport_send_filter(hdl, msgnvl, mp->epm_ep_str); in etm_send()
1232 mp->epm_txbusy--; in etm_send()
1233 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1234 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1245 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1256 (void) etm_create_hdr(buf, mp->epm_ver, ETM_HDR_MSG, nvsize); in etm_send()
1259 (void) pthread_mutex_lock(&mp->epm_lock); in etm_send()
1260 mp->epm_txbusy--; in etm_send()
1261 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1262 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1271 if (etm_xport_write(hdl, mp->epm_oconn, Rw_timeout, buf, in etm_send()
1274 mp->epm_ep_str); in etm_send()
1275 (void) pthread_mutex_lock(&mp->epm_lock); in etm_send()
1276 etm_suspend_reconnect(hdl, mp); in etm_send()
1277 mp->epm_txbusy--; in etm_send()
1278 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1279 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1290 if (etm_xport_read(hdl, mp->epm_oconn, Rw_timeout, buf, in etm_send()
1293 mp->epm_ep_str); in etm_send()
1294 (void) pthread_mutex_lock(&mp->epm_lock); in etm_send()
1295 etm_suspend_reconnect(hdl, mp); in etm_send()
1296 mp->epm_txbusy--; in etm_send()
1297 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1298 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1304 hdrstat = etm_check_hdr(hdl, mp, buf); in etm_send()
1310 (void) pthread_mutex_lock(&mp->epm_lock); in etm_send()
1312 (void) etm_xport_close(hdl, mp->epm_oconn); in etm_send()
1313 mp->epm_oconn = NULL; in etm_send()
1317 if (mp->epm_xprthdl != NULL) { in etm_send()
1318 mp->epm_cstat = C_LIMBO; in etm_send()
1320 mp->epm_qstat = Q_SUSPENDED; in etm_send()
1322 "suspended for %s", mp->epm_ep_str); in etm_send()
1329 mp->epm_cstat = C_CLOSED; in etm_send()
1330 mp->epm_qstat = Q_UNINITIALIZED; in etm_send()
1332 mp->epm_ep_str); in etm_send()
1337 if (mp->epm_timer_in_use == 0) { in etm_send()
1338 mp->epm_timer_id = fmd_timer_install( in etm_send()
1339 hdl, mp, NULL, 0); in etm_send()
1340 mp->epm_timer_in_use = 1; in etm_send()
1351 mp->epm_cstat = C_CLOSED; in etm_send()
1352 fmd_hdl_debug(hdl, "bad ACK from %s", mp->epm_ep_str); in etm_send()
1357 mp->epm_txbusy--; in etm_send()
1359 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1360 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1367 (void) pthread_mutex_lock(&mp->epm_lock); in etm_send()
1368 mp->epm_txbusy--; in etm_send()
1369 (void) pthread_cond_broadcast(&mp->epm_tx_cv); in etm_send()
1370 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_send()
1382 etm_epmap_t *mp = (etm_epmap_t *)data; in etm_timeout() local
1384 (void) pthread_mutex_lock(&mp->epm_lock); in etm_timeout()
1386 mp->epm_timer_in_use = 0; in etm_timeout()
1388 if (mp->epm_qstat == Q_UNINITIALIZED) { in etm_timeout()
1390 if (mp->epm_xprthdl != NULL) { in etm_timeout()
1391 fmd_xprt_close(hdl, mp->epm_xprthdl); in etm_timeout()
1393 mp->epm_ep_str); in etm_timeout()
1394 mp->epm_xprthdl = NULL; in etm_timeout()
1396 mp->epm_ep_nvl = NULL; in etm_timeout()
1399 if (mp->epm_ep_nvl == NULL) in etm_timeout()
1400 (void) etm_get_ep_nvl(hdl, mp); in etm_timeout()
1402 if (etm_handle_startup(hdl, mp)) { in etm_timeout()
1403 if (mp->epm_oconn != NULL) { in etm_timeout()
1404 (void) etm_xport_close(hdl, mp->epm_oconn); in etm_timeout()
1405 mp->epm_oconn = NULL; in etm_timeout()
1407 mp->epm_cstat = C_UNINITIALIZED; in etm_timeout()
1408 mp->epm_qstat = Q_UNINITIALIZED; in etm_timeout()
1409 mp->epm_timer_id = fmd_timer_install(hdl, mp, NULL, in etm_timeout()
1411 mp->epm_timer_in_use = 1; in etm_timeout()
1414 etm_reconnect(hdl, mp); in etm_timeout()
1417 (void) pthread_mutex_unlock(&mp->epm_lock); in etm_timeout()
1488 etm_epmap_t *mp, *next; in _fmd_fini() local
1494 mp = Epmap_head; in _fmd_fini()
1496 while (mp) { in _fmd_fini()
1497 next = mp->epm_next; in _fmd_fini()
1498 etm_free_epmap(hdl, mp); in _fmd_fini()
1499 mp = next; in _fmd_fini()