Lines Matching refs:monpriv
149 struct mon_private *monpriv) in mon_send_reply() argument
153 rc = iucv_message_reply(monpriv->path, &monmsg->msg, in mon_send_reply()
155 atomic_dec(&monpriv->msglim_count); in mon_send_reply()
159 monpriv->read_index = (monpriv->read_index + 1) % in mon_send_reply()
161 atomic_dec(&monpriv->read_ready); in mon_send_reply()
171 static void mon_free_mem(struct mon_private *monpriv) in mon_free_mem() argument
176 kfree(monpriv->msg_array[i]); in mon_free_mem()
177 kfree(monpriv); in mon_free_mem()
183 struct mon_private *monpriv; in mon_alloc_mem() local
185 monpriv = kzalloc(sizeof(struct mon_private), GFP_KERNEL); in mon_alloc_mem()
186 if (!monpriv) in mon_alloc_mem()
189 monpriv->msg_array[i] = kzalloc(sizeof(struct mon_msg), in mon_alloc_mem()
191 if (!monpriv->msg_array[i]) { in mon_alloc_mem()
192 mon_free_mem(monpriv); in mon_alloc_mem()
196 return monpriv; in mon_alloc_mem()
207 static struct mon_msg *mon_next_message(struct mon_private *monpriv) in mon_next_message() argument
211 if (!atomic_read(&monpriv->read_ready)) in mon_next_message()
213 monmsg = monpriv->msg_array[monpriv->read_index]; in mon_next_message()
219 monpriv->read_index = (monpriv->read_index + 1) % in mon_next_message()
221 atomic_dec(&monpriv->read_ready); in mon_next_message()
233 struct mon_private *monpriv = path->private; in mon_iucv_path_complete() local
235 atomic_set(&monpriv->iucv_connected, 1); in mon_iucv_path_complete()
241 struct mon_private *monpriv = path->private; in mon_iucv_path_severed() local
246 atomic_set(&monpriv->iucv_severed, 1); in mon_iucv_path_severed()
254 struct mon_private *monpriv = path->private; in mon_iucv_message_pending() local
256 memcpy(&monpriv->msg_array[monpriv->write_index]->msg, in mon_iucv_message_pending()
258 if (atomic_inc_return(&monpriv->msglim_count) == MON_MSGLIM) { in mon_iucv_message_pending()
260 monpriv->msg_array[monpriv->write_index]->msglim_reached = 1; in mon_iucv_message_pending()
262 monpriv->write_index = (monpriv->write_index + 1) % MON_MSGLIM; in mon_iucv_message_pending()
263 atomic_inc(&monpriv->read_ready); in mon_iucv_message_pending()
278 struct mon_private *monpriv; in mon_open() local
289 monpriv = mon_alloc_mem(); in mon_open()
290 if (!monpriv) in mon_open()
296 monpriv->path = iucv_path_alloc(MON_MSGLIM, IUCV_IPRMDATA, GFP_KERNEL); in mon_open()
297 if (!monpriv->path) in mon_open()
299 rc = iucv_path_connect(monpriv->path, &monreader_iucv_handler, in mon_open()
300 MON_SERVICE, NULL, user_data_connect, monpriv); in mon_open()
311 atomic_read(&monpriv->iucv_connected) || in mon_open()
312 atomic_read(&monpriv->iucv_severed)); in mon_open()
313 if (atomic_read(&monpriv->iucv_severed)) { in mon_open()
314 atomic_set(&monpriv->iucv_severed, 0); in mon_open()
315 atomic_set(&monpriv->iucv_connected, 0); in mon_open()
319 filp->private_data = monpriv; in mon_open()
323 iucv_path_free(monpriv->path); in mon_open()
325 mon_free_mem(monpriv); in mon_open()
335 struct mon_private *monpriv = filp->private_data; in mon_close() local
340 if (monpriv->path) { in mon_close()
341 rc = iucv_path_sever(monpriv->path, user_data_sever); in mon_close()
345 iucv_path_free(monpriv->path); in mon_close()
348 atomic_set(&monpriv->iucv_severed, 0); in mon_close()
349 atomic_set(&monpriv->iucv_connected, 0); in mon_close()
350 atomic_set(&monpriv->read_ready, 0); in mon_close()
351 atomic_set(&monpriv->msglim_count, 0); in mon_close()
352 monpriv->write_index = 0; in mon_close()
353 monpriv->read_index = 0; in mon_close()
356 kfree(monpriv->msg_array[i]); in mon_close()
357 kfree(monpriv); in mon_close()
365 struct mon_private *monpriv = filp->private_data; in mon_read() local
370 monmsg = mon_next_message(monpriv); in mon_read()
378 atomic_read(&monpriv->read_ready) || in mon_read()
379 atomic_read(&monpriv->iucv_severed)); in mon_read()
382 if (unlikely(atomic_read(&monpriv->iucv_severed))) in mon_read()
384 monmsg = monpriv->msg_array[monpriv->read_index]; in mon_read()
418 ret = mon_send_reply(monmsg, monpriv); in mon_read()
428 struct mon_private *monpriv = filp->private_data; in mon_poll() local
431 if (unlikely(atomic_read(&monpriv->iucv_severed))) in mon_poll()
433 if (atomic_read(&monpriv->read_ready)) in mon_poll()