Lines Matching refs:e
102 graph_protocol_event_t *e; in graph_event_enqueue() local
104 e = startd_zalloc(sizeof (graph_protocol_event_t)); in graph_event_enqueue()
108 e->gpe_inst = startd_alloc(size); in graph_event_enqueue()
109 e->gpe_inst_sz = size; in graph_event_enqueue()
110 (void) strlcpy(e->gpe_inst, inst, size); in graph_event_enqueue()
112 e->gpe_type = event; in graph_event_enqueue()
113 e->gpe_data = data; in graph_event_enqueue()
115 (void) pthread_mutex_init(&e->gpe_lock, &mutex_attrs); in graph_event_enqueue()
118 uu_list_node_init(e, &e->gpe_link, graph_protocol_event_queue_pool); in graph_event_enqueue()
119 if (uu_list_insert_before(graph_queue->gpeq_event_list, NULL, e) == -1) in graph_event_enqueue()
121 e->gpe_inst, uu_strerror(uu_error())); in graph_event_enqueue()
127 graph_event_release(graph_protocol_event_t *e) in graph_event_release() argument
129 uu_list_node_fini(e, &e->gpe_link, graph_protocol_event_queue_pool); in graph_event_release()
130 (void) pthread_mutex_destroy(&e->gpe_lock); in graph_event_release()
131 if (e->gpe_inst != NULL) in graph_event_release()
132 startd_free(e->gpe_inst, e->gpe_inst_sz); in graph_event_release()
133 startd_free(e, sizeof (graph_protocol_event_t)); in graph_event_release()
146 graph_protocol_event_t *e; in graph_event_dequeue() local
150 e = uu_list_first(graph_queue->gpeq_event_list); in graph_event_dequeue()
151 if (e == NULL) { in graph_event_dequeue()
156 if (uu_list_next(graph_queue->gpeq_event_list, e) != NULL) in graph_event_dequeue()
158 uu_list_remove(graph_queue->gpeq_event_list, e); in graph_event_dequeue()
161 return (e); in graph_event_dequeue()
169 graph_event_requeue(graph_protocol_event_t *e) in graph_event_requeue() argument
171 assert(e != NULL); in graph_event_requeue()
176 if (uu_list_insert_after(graph_queue->gpeq_event_list, NULL, e) == -1) in graph_event_requeue()
178 e->gpe_inst, uu_strerror(uu_error())); in graph_event_requeue()
220 restarter_protocol_event_t *e; in restarter_event_enqueue() local
224 e = startd_zalloc(sizeof (restarter_protocol_event_t)); in restarter_event_enqueue()
226 e->rpe_inst = startd_alloc(strlen(inst) + 1); in restarter_event_enqueue()
227 (void) strlcpy(e->rpe_inst, inst, strlen(inst)+1); in restarter_event_enqueue()
228 e->rpe_type = event; in restarter_event_enqueue()
229 e->rpe_reason = reason; in restarter_event_enqueue()
232 uu_list_node_init(e, &e->rpe_link, restarter_protocol_event_queue_pool); in restarter_event_enqueue()
233 r = uu_list_insert_before(restarter_queue->rpeq_event_list, NULL, e); in restarter_event_enqueue()
241 restarter_event_release(restarter_protocol_event_t *e) in restarter_event_release() argument
243 uu_list_node_fini(e, &e->rpe_link, restarter_protocol_event_queue_pool); in restarter_event_release()
244 startd_free(e->rpe_inst, strlen(e->rpe_inst) + 1); in restarter_event_release()
245 startd_free(e, sizeof (restarter_protocol_event_t)); in restarter_event_release()
258 restarter_protocol_event_t *e = NULL; in restarter_event_dequeue() local
262 e = uu_list_first(restarter_queue->rpeq_event_list); in restarter_event_dequeue()
263 if (e == NULL) { in restarter_event_dequeue()
268 if (uu_list_next(restarter_queue->rpeq_event_list, e) != NULL) in restarter_event_dequeue()
270 uu_list_remove(restarter_queue->rpeq_event_list, e); in restarter_event_dequeue()
273 return (e); in restarter_event_dequeue()