150 			  struct mon_private *monpriv)  in mon_send_reply()  argument
154 	rc = iucv_message_reply(monpriv->path, &monmsg->msg,  in mon_send_reply()
156 	atomic_dec(&monpriv->msglim_count);  in mon_send_reply()
160 		monpriv->read_index = (monpriv->read_index + 1) %  in mon_send_reply()
162 		atomic_dec(&monpriv->read_ready);  in mon_send_reply()
172 static void mon_free_mem(struct mon_private *monpriv)  in mon_free_mem()  argument
177 		kfree(monpriv->msg_array[i]);  in mon_free_mem()
178 	kfree(monpriv);  in mon_free_mem()
184 	struct mon_private *monpriv;  in mon_alloc_mem()  local
186 	monpriv = kzalloc(sizeof(struct mon_private), GFP_KERNEL);  in mon_alloc_mem()
187 	if (!monpriv)  in mon_alloc_mem()
190 		monpriv->msg_array[i] = kzalloc(sizeof(struct mon_msg),  in mon_alloc_mem()
192 		if (!monpriv->msg_array[i]) {  in mon_alloc_mem()
193 			mon_free_mem(monpriv);  in mon_alloc_mem()
197 	return monpriv;  in mon_alloc_mem()
208 static struct mon_msg *mon_next_message(struct mon_private *monpriv)  in mon_next_message()  argument
212 	if (!atomic_read(&monpriv->read_ready))  in mon_next_message()
214 	monmsg = monpriv->msg_array[monpriv->read_index];  in mon_next_message()
220 		monpriv->read_index = (monpriv->read_index + 1) %  in mon_next_message()
222 		atomic_dec(&monpriv->read_ready);  in mon_next_message()
234 	struct mon_private *monpriv = path->private;  in mon_iucv_path_complete()  local
236 	atomic_set(&monpriv->iucv_connected, 1);  in mon_iucv_path_complete()
242 	struct mon_private *monpriv = path->private;  in mon_iucv_path_severed()  local
247 	atomic_set(&monpriv->iucv_severed, 1);  in mon_iucv_path_severed()
255 	struct mon_private *monpriv = path->private;  in mon_iucv_message_pending()  local
257 	memcpy(&monpriv->msg_array[monpriv->write_index]->msg,  in mon_iucv_message_pending()
259 	if (atomic_inc_return(&monpriv->msglim_count) == MON_MSGLIM) {  in mon_iucv_message_pending()
261 		monpriv->msg_array[monpriv->write_index]->msglim_reached = 1;  in mon_iucv_message_pending()
263 	monpriv->write_index = (monpriv->write_index + 1) % MON_MSGLIM;  in mon_iucv_message_pending()
264 	atomic_inc(&monpriv->read_ready);  in mon_iucv_message_pending()
279 	struct mon_private *monpriv;  in mon_open()  local
290 	monpriv = mon_alloc_mem();  in mon_open()
291 	if (!monpriv)  in mon_open()
297 	monpriv->path = iucv_path_alloc(MON_MSGLIM, IUCV_IPRMDATA, GFP_KERNEL);  in mon_open()
298 	if (!monpriv->path)  in mon_open()
300 	rc = iucv_path_connect(monpriv->path, &monreader_iucv_handler,  in mon_open()
301 			       MON_SERVICE, NULL, user_data_connect, monpriv);  in mon_open()
312 		   atomic_read(&monpriv->iucv_connected) ||  in mon_open()
313 		   atomic_read(&monpriv->iucv_severed));  in mon_open()
314 	if (atomic_read(&monpriv->iucv_severed)) {  in mon_open()
315 		atomic_set(&monpriv->iucv_severed, 0);  in mon_open()
316 		atomic_set(&monpriv->iucv_connected, 0);  in mon_open()
320 	filp->private_data = monpriv;  in mon_open()
321 	dev_set_drvdata(monreader_device, monpriv);  in mon_open()
325 	iucv_path_free(monpriv->path);  in mon_open()
327 	mon_free_mem(monpriv);  in mon_open()
337 	struct mon_private *monpriv = filp->private_data;  in mon_close()  local
342 	if (monpriv->path) {  in mon_close()
343 		rc = iucv_path_sever(monpriv->path, user_data_sever);  in mon_close()
347 		iucv_path_free(monpriv->path);  in mon_close()
350 	atomic_set(&monpriv->iucv_severed, 0);  in mon_close()
351 	atomic_set(&monpriv->iucv_connected, 0);  in mon_close()
352 	atomic_set(&monpriv->read_ready, 0);  in mon_close()
353 	atomic_set(&monpriv->msglim_count, 0);  in mon_close()
354 	monpriv->write_index  = 0;  in mon_close()
355 	monpriv->read_index   = 0;  in mon_close()
359 		kfree(monpriv->msg_array[i]);  in mon_close()
360 	kfree(monpriv);  in mon_close()
368 	struct mon_private *monpriv = filp->private_data;  in mon_read()  local
373 	monmsg = mon_next_message(monpriv);  in mon_read()
381 					atomic_read(&monpriv->read_ready) ||  in mon_read()
382 					atomic_read(&monpriv->iucv_severed));  in mon_read()
385 		if (unlikely(atomic_read(&monpriv->iucv_severed)))  in mon_read()
387 		monmsg = monpriv->msg_array[monpriv->read_index];  in mon_read()
423 	ret = mon_send_reply(monmsg, monpriv);  in mon_read()
433 	struct mon_private *monpriv = filp->private_data;  in mon_poll()  local
436 	if (unlikely(atomic_read(&monpriv->iucv_severed)))  in mon_poll()
438 	if (atomic_read(&monpriv->read_ready))  in mon_poll()
464 	struct mon_private *monpriv = dev_get_drvdata(dev);  in monreader_freeze()  local
467 	if (!monpriv)  in monreader_freeze()
469 	if (monpriv->path) {  in monreader_freeze()
470 		rc = iucv_path_sever(monpriv->path, user_data_sever);  in monreader_freeze()
474 		iucv_path_free(monpriv->path);  in monreader_freeze()
476 	atomic_set(&monpriv->iucv_severed, 0);  in monreader_freeze()
477 	atomic_set(&monpriv->iucv_connected, 0);  in monreader_freeze()
478 	atomic_set(&monpriv->read_ready, 0);  in monreader_freeze()
479 	atomic_set(&monpriv->msglim_count, 0);  in monreader_freeze()
480 	monpriv->write_index  = 0;  in monreader_freeze()
481 	monpriv->read_index   = 0;  in monreader_freeze()
482 	monpriv->path = NULL;  in monreader_freeze()
488 	struct mon_private *monpriv = dev_get_drvdata(dev);  in monreader_thaw()  local
491 	if (!monpriv)  in monreader_thaw()
494 	monpriv->path = iucv_path_alloc(MON_MSGLIM, IUCV_IPRMDATA, GFP_KERNEL);  in monreader_thaw()
495 	if (!monpriv->path)  in monreader_thaw()
497 	rc = iucv_path_connect(monpriv->path, &monreader_iucv_handler,  in monreader_thaw()
498 			       MON_SERVICE, NULL, user_data_connect, monpriv);  in monreader_thaw()
505 		   atomic_read(&monpriv->iucv_connected) ||  in monreader_thaw()
506 		   atomic_read(&monpriv->iucv_severed));  in monreader_thaw()
507 	if (atomic_read(&monpriv->iucv_severed))  in monreader_thaw()
512 	iucv_path_free(monpriv->path);  in monreader_thaw()
513 	monpriv->path = NULL;  in monreader_thaw()
515 	atomic_set(&monpriv->iucv_severed, 1);  in monreader_thaw()