Lines Matching defs:tcdp
660 thread_communication_data_t *tcdp;
685 if ((tcdp = mqdp->mqd_tcd) != NULL) {
687 del_sigev_mq(tcdp); /* possible cancellation point */
966 cancel_if_necessary(thread_communication_data_t *tcdp,
969 int do_cancel = !pthread_attr_equal(tcdp->tcd_attrp,
976 (void) pthread_cancel(tcdp->tcd_server_id);
982 tcdp->tcd_notif.sigev_notify = SIGEV_THREAD;
983 tcdp->tcd_notif.sigev_signo = 0;
984 tcdp->tcd_notif.sigev_value = sigevp->sigev_value;
985 tcdp->tcd_notif.sigev_notify_function =
997 thread_communication_data_t *tcdp;
1028 if ((tcdp = mqdp->mqd_tcd) != NULL) {
1029 sig_mutex_lock(&tcdp->tcd_lock);
1030 if (tcdp->tcd_msg_enabled) {
1032 tcdp = mqdp->mqd_tcd;
1035 tcdp->tcd_server_id);
1037 sig_mutex_unlock(&tcdp->tcd_lock);
1077 if ((tcdp = mqdp->mqd_tcd) != NULL &&
1078 cancel_if_necessary(tcdp, sigevp))
1082 if ((tcdp = mqdp->mqd_tcd) == NULL) {
1084 tcdp = setup_sigev_handler(sigevp, MQ);
1085 if (tcdp == NULL) {
1089 tcdp->tcd_msg_enabled = 0;
1090 tcdp->tcd_msg_closing = 0;
1091 tcdp->tcd_msg_avail = &mqhp->mq_spawner;
1092 if (launch_spawner(tcdp) != 0) {
1093 free_sigev_handler(tcdp);
1096 mqdp->mqd_tcd = tcdp;
1114 tcdp->tcd_port = port;
1115 tcdp->tcd_msg_object = mqdp;
1116 tcdp->tcd_msg_userval = userval;
1117 sig_mutex_lock(&tcdp->tcd_lock);
1118 tcdp->tcd_msg_enabled = ntype;
1119 sig_mutex_unlock(&tcdp->tcd_lock);
1120 (void) cond_broadcast(&tcdp->tcd_cv);
1196 thread_communication_data_t *tcdp;
1205 if ((tcdp = mqdp->mqd_tcd) != NULL) {
1207 tcd_teardown(tcdp);