148 			  struct mon_private *monpriv)  in mon_send_reply()  argument
152 	rc = iucv_message_reply(monpriv->path, &monmsg->msg,  in mon_send_reply()
154 	atomic_dec(&monpriv->msglim_count);  in mon_send_reply()
158 		monpriv->read_index = (monpriv->read_index + 1) %  in mon_send_reply()
160 		atomic_dec(&monpriv->read_ready);  in mon_send_reply()
170 static void mon_free_mem(struct mon_private *monpriv)  in mon_free_mem()  argument
175 		kfree(monpriv->msg_array[i]);  in mon_free_mem()
176 	kfree(monpriv);  in mon_free_mem()
182 	struct mon_private *monpriv;  in mon_alloc_mem()  local
184 	monpriv = kzalloc(sizeof(struct mon_private), GFP_KERNEL);  in mon_alloc_mem()
185 	if (!monpriv)  in mon_alloc_mem()
188 		monpriv->msg_array[i] = kzalloc(sizeof(struct mon_msg),  in mon_alloc_mem()
190 		if (!monpriv->msg_array[i]) {  in mon_alloc_mem()
191 			mon_free_mem(monpriv);  in mon_alloc_mem()
195 	return monpriv;  in mon_alloc_mem()
206 static struct mon_msg *mon_next_message(struct mon_private *monpriv)  in mon_next_message()  argument
210 	if (!atomic_read(&monpriv->read_ready))  in mon_next_message()
212 	monmsg = monpriv->msg_array[monpriv->read_index];  in mon_next_message()
218 		monpriv->read_index = (monpriv->read_index + 1) %  in mon_next_message()
220 		atomic_dec(&monpriv->read_ready);  in mon_next_message()
232 	struct mon_private *monpriv = path->private;  in mon_iucv_path_complete()  local
234 	atomic_set(&monpriv->iucv_connected, 1);  in mon_iucv_path_complete()
240 	struct mon_private *monpriv = path->private;  in mon_iucv_path_severed()  local
245 	atomic_set(&monpriv->iucv_severed, 1);  in mon_iucv_path_severed()
253 	struct mon_private *monpriv = path->private;  in mon_iucv_message_pending()  local
255 	memcpy(&monpriv->msg_array[monpriv->write_index]->msg,  in mon_iucv_message_pending()
257 	if (atomic_inc_return(&monpriv->msglim_count) == MON_MSGLIM) {  in mon_iucv_message_pending()
259 		monpriv->msg_array[monpriv->write_index]->msglim_reached = 1;  in mon_iucv_message_pending()
261 	monpriv->write_index = (monpriv->write_index + 1) % MON_MSGLIM;  in mon_iucv_message_pending()
262 	atomic_inc(&monpriv->read_ready);  in mon_iucv_message_pending()
277 	struct mon_private *monpriv;  in mon_open()  local
288 	monpriv = mon_alloc_mem();  in mon_open()
289 	if (!monpriv)  in mon_open()
295 	monpriv->path = iucv_path_alloc(MON_MSGLIM, IUCV_IPRMDATA, GFP_KERNEL);  in mon_open()
296 	if (!monpriv->path)  in mon_open()
298 	rc = iucv_path_connect(monpriv->path, &monreader_iucv_handler,  in mon_open()
299 			       MON_SERVICE, NULL, user_data_connect, monpriv);  in mon_open()
310 		   atomic_read(&monpriv->iucv_connected) ||  in mon_open()
311 		   atomic_read(&monpriv->iucv_severed));  in mon_open()
312 	if (atomic_read(&monpriv->iucv_severed)) {  in mon_open()
313 		atomic_set(&monpriv->iucv_severed, 0);  in mon_open()
314 		atomic_set(&monpriv->iucv_connected, 0);  in mon_open()
318 	filp->private_data = monpriv;  in mon_open()
322 	iucv_path_free(monpriv->path);  in mon_open()
324 	mon_free_mem(monpriv);  in mon_open()
334 	struct mon_private *monpriv = filp->private_data;  in mon_close()  local
339 	if (monpriv->path) {  in mon_close()
340 		rc = iucv_path_sever(monpriv->path, user_data_sever);  in mon_close()
344 		iucv_path_free(monpriv->path);  in mon_close()
347 	atomic_set(&monpriv->iucv_severed, 0);  in mon_close()
348 	atomic_set(&monpriv->iucv_connected, 0);  in mon_close()
349 	atomic_set(&monpriv->read_ready, 0);  in mon_close()
350 	atomic_set(&monpriv->msglim_count, 0);  in mon_close()
351 	monpriv->write_index  = 0;  in mon_close()
352 	monpriv->read_index   = 0;  in mon_close()
355 		kfree(monpriv->msg_array[i]);  in mon_close()
356 	kfree(monpriv);  in mon_close()
364 	struct mon_private *monpriv = filp->private_data;  in mon_read()  local
369 	monmsg = mon_next_message(monpriv);  in mon_read()
377 					atomic_read(&monpriv->read_ready) ||  in mon_read()
378 					atomic_read(&monpriv->iucv_severed));  in mon_read()
381 		if (unlikely(atomic_read(&monpriv->iucv_severed)))  in mon_read()
383 		monmsg = monpriv->msg_array[monpriv->read_index];  in mon_read()
417 	ret = mon_send_reply(monmsg, monpriv);  in mon_read()
427 	struct mon_private *monpriv = filp->private_data;  in mon_poll()  local
430 	if (unlikely(atomic_read(&monpriv->iucv_severed)))  in mon_poll()
432 	if (atomic_read(&monpriv->read_ready))  in mon_poll()