Lines Matching refs:tcdp
601 thread_communication_data_t *tcdp;
626 if ((tcdp = mqdp->mqd_tcd) != NULL) {
628 del_sigev_mq(tcdp); /* possible cancellation point */
907 cancel_if_necessary(thread_communication_data_t *tcdp,
910 int do_cancel = !pthread_attr_equal(tcdp->tcd_attrp,
917 (void) pthread_cancel(tcdp->tcd_server_id);
923 tcdp->tcd_notif.sigev_notify = SIGEV_THREAD;
924 tcdp->tcd_notif.sigev_signo = 0;
925 tcdp->tcd_notif.sigev_value = sigevp->sigev_value;
926 tcdp->tcd_notif.sigev_notify_function =
938 thread_communication_data_t *tcdp;
969 if ((tcdp = mqdp->mqd_tcd) != NULL) {
970 sig_mutex_lock(&tcdp->tcd_lock);
971 if (tcdp->tcd_msg_enabled) {
973 tcdp = mqdp->mqd_tcd;
976 tcdp->tcd_server_id);
978 sig_mutex_unlock(&tcdp->tcd_lock);
1018 if ((tcdp = mqdp->mqd_tcd) != NULL &&
1019 cancel_if_necessary(tcdp, sigevp))
1023 if ((tcdp = mqdp->mqd_tcd) == NULL) {
1025 tcdp = setup_sigev_handler(sigevp, MQ);
1026 if (tcdp == NULL) {
1030 tcdp->tcd_msg_enabled = 0;
1031 tcdp->tcd_msg_closing = 0;
1032 tcdp->tcd_msg_avail = &mqhp->mq_spawner;
1033 if (launch_spawner(tcdp) != 0) {
1034 free_sigev_handler(tcdp);
1037 mqdp->mqd_tcd = tcdp;
1055 tcdp->tcd_port = port;
1056 tcdp->tcd_msg_object = mqdp;
1057 tcdp->tcd_msg_userval = userval;
1058 sig_mutex_lock(&tcdp->tcd_lock);
1059 tcdp->tcd_msg_enabled = ntype;
1060 sig_mutex_unlock(&tcdp->tcd_lock);
1061 (void) cond_broadcast(&tcdp->tcd_cv);
1137 thread_communication_data_t *tcdp;
1141 if ((tcdp = mqdp->mqd_tcd) != NULL) {
1143 tcd_teardown(tcdp);