Lines Matching defs:sub
1080 subscriber_data_t *sub;
1083 sub = SH_SUBSCRIBER(shp, i);
1084 if (sub != NULL) {
1085 free(sub->sd_door_name);
1086 free(sub);
1096 subscriber_data_t *sub;
1104 sub = (subscriber_data_t *)calloc(1,
1106 if (sub == NULL) {
1111 free(sub);
1115 sub->sd_flag = ACTIVE;
1116 sub->sd_door_name = strdup(door_name);
1117 if (sub->sd_door_name == NULL) {
1118 free(sub);
1122 SH_SUBSCRIBER(shp, sub_id) = sub;
1490 subscriber_data_t *sub;
1514 sub = SH_SUBSCRIBER(shp, sub_id);
1515 if (sub == NULL)
1518 free(sub->sd_door_name);
1519 free(sub);
1602 subscriber_data_t *sub;
1646 sub = SH_SUBSCRIBER(shp, i);
1647 assert(sub != NULL);
1650 if (!(sub->sd_flag & ACTIVE)) {
1657 if (resend_cnt > 0 && !(sub->sd_flag & SEND_AGAIN)) {
1661 if ((sub_fd = open(sub->sd_door_name, O_RDONLY)) == -1) {
1663 "%s: %s\n", sub->sd_door_name, strerror(errno));
1683 sub->sd_flag |= SEND_AGAIN;
1690 "handle for %s", sub->sd_door_name);
1691 sub->sd_flag = 0;
1696 sub->sd_flag &= ~SEND_AGAIN;
1701 "to %s: %s: %d\n", sub->sd_door_name,
1703 sub->sd_flag = 0;
2427 subscriber_data_t *sub;
2435 sub = SH_SUBSCRIBER(shp, i);
2436 if (sub == NULL) {
2440 if ((sub_fd = open(sub->sd_door_name, O_RDONLY)) == -1) {
2457 free(sub->sd_door_name);
2458 free(sub);