Lines Matching refs:monitor
75 ipp_monitor_t *monitor = (ipp_monitor_t *) malloc(sizeof(ipp_monitor_t)); in ipp_status_get_monitor_ifc() local
78 monitor->initialized = 0; in ipp_status_get_monitor_ifc()
79 monitor->http = NULL; in ipp_status_get_monitor_ifc()
80 memcpy(&monitor->ifc, &_status_ifc, sizeof(ifc_status_monitor_t)); in ipp_status_get_monitor_ifc()
81 return &monitor->ifc; in ipp_status_get_monitor_ifc()
85 ipp_monitor_t *monitor; in _init() local
91 monitor = IMPL(ipp_monitor_t, ifc, this_p); in _init()
93 if (monitor->initialized != 0) { in _init()
94 sem_post(&monitor->monitor_sem); in _init()
95 sem_destroy(&monitor->monitor_sem); in _init()
97 pthread_mutex_unlock(&monitor->mutex); in _init()
98 pthread_mutex_destroy(&monitor->mutex); in _init()
101 if (monitor->http != NULL) { in _init()
102 httpClose(monitor->http); in _init()
105 monitor->http = ipp_cups_connect(connect_info, monitor->printer_uri, in _init()
106 sizeof(monitor->printer_uri)); in _init()
107 getResourceFromURI(monitor->printer_uri, monitor->http_resource, 1024); in _init()
109 monitor->monitor_running = 0; in _init()
110 monitor->stop_monitor = 0; in _init()
112 pthread_mutexattr_init(&monitor->mutexattr); in _init()
113 pthread_mutexattr_settype(&(monitor->mutexattr), PTHREAD_MUTEX_RECURSIVE_NP); in _init()
114 pthread_mutex_init(&monitor->mutex, &monitor->mutexattr); in _init()
115 sem_init(&monitor->monitor_sem, 0, 0); in _init()
116 monitor->initialized = 1; in _init()
118 strlcpy(monitor->requesting_user, connect_info->requesting_user_name, in _init()
119 sizeof(monitor->requesting_user)); in _init()
125 ipp_monitor_t *monitor; in _destroy() local
132 monitor = IMPL(ipp_monitor_t, ifc, this_p); in _destroy()
133 if (monitor->initialized) { in _destroy()
134 pthread_mutex_lock(&monitor->mutex); in _destroy()
136 sem_post(&monitor->monitor_sem); in _destroy()
137 sem_destroy(&monitor->monitor_sem); in _destroy()
139 pthread_mutex_unlock(&monitor->mutex); in _destroy()
140 pthread_mutex_destroy(&monitor->mutex); in _destroy()
141 monitor->stop_monitor = 1; in _destroy()
144 if (monitor->http != NULL) { in _destroy()
145 httpClose(monitor->http); in _destroy()
148 free(monitor); in _destroy()
155 ipp_monitor_t *monitor; in _get_status() local
176 monitor = IMPL(ipp_monitor_t, ifc, this_p); in _get_status()
177 if (!monitor->initialized) { in _get_status()
182 if (monitor->http == NULL) { in _get_status()
189 ipp_status = get_PrinterState(monitor->http, monitor->printer_uri, printer_state_dyn, in _get_status()
204 ipp_monitor_t *monitor = NULL; in _start() local
247 monitor = IMPL(ipp_monitor_t, ifc, this_p); in _start()
248 if (!monitor->initialized) { in _start()
252 if (monitor->monitor_running) { in _start()
256 monitor->stop_monitor = 0; in _start()
257 monitor->monitor_running = 1; in _start()
258 if (monitor->http == NULL) { in _start()
262 sem_wait(&monitor->monitor_sem); in _start()
270 while (!monitor->stop_monitor) { in _start()
271 pthread_mutex_lock(&monitor->mutex); in _start()
274 pthread_mutex_unlock(&monitor->mutex); in _start()
282 if (job_state_cb != NULL && !monitor->stop_monitor) { in _start()
283 pthread_mutex_lock(&monitor->mutex); in _start()
285 job_id = getJobId(monitor->http, monitor->http_resource, in _start()
286 monitor->printer_uri, &new_state, in _start()
287 monitor->requesting_user); in _start()
290 pthread_mutex_unlock(&monitor->mutex); in _start()
300 monitor->monitor_running = 0; in _start()
310 ipp_monitor_t *monitor; in _stop() local
317 monitor = IMPL(ipp_monitor_t, ifc, this_p); in _stop()
318 if (!monitor->initialized) { in _stop()
322 sem_post(&monitor->monitor_sem); in _stop()
323 monitor->stop_monitor = 1; in _stop()
330 ipp_monitor_t *monitor = NULL; in _cancel() local
337 monitor = IMPL(ipp_monitor_t, ifc, this_p); in _cancel()
338 if (this_p != NULL && monitor != NULL && monitor->initialized && !monitor->stop_monitor) { in _cancel()
339 pthread_mutex_lock(&monitor->mutex); in _cancel()
341 if (monitor->stop_monitor) { in _cancel()
351 monitor->printer_uri); in _cancel()
362 response = ipp_doCupsRequest(monitor->http, request, monitor->http_resource, in _cancel()
363 monitor->printer_uri); in _cancel()
411 monitor->printer_uri); in _cancel()
416 if ((response = ipp_doCupsRequest(monitor->http, request, monitor->http_resource, in _cancel()
417 monitor->printer_uri)) == NULL) { in _cancel()
440 if (monitor->initialized) { in _cancel()
441 pthread_mutex_unlock(&monitor->mutex); in _cancel()
456 ipp_monitor_t *monitor = NULL; in _get_job_state() local
457 monitor = IMPL(ipp_monitor_t, ifc, this_p); in _get_job_state()
459 if (this_p != NULL && monitor != NULL && monitor->initialized && !monitor->stop_monitor) { in _get_job_state()
460 pthread_mutex_lock(&monitor->mutex); in _get_job_state()
463 if (monitor->stop_monitor) in _get_job_state()
475 monitor->requesting_user); in _get_job_state()
478 pthread_mutex_unlock(&monitor->mutex); in _get_job_state()