drm_fops.c 16.8 KB
Newer Older
L
Linus Torvalds 已提交
1
/**
D
Dave Airlie 已提交
2
 * \file drm_fops.c
L
Linus Torvalds 已提交
3
 * File operations for DRM
D
Dave Airlie 已提交
4
 *
L
Linus Torvalds 已提交
5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38
 * \author Rickard E. (Rik) Faith <faith@valinux.com>
 * \author Daryll Strauss <daryll@valinux.com>
 * \author Gareth Hughes <gareth@valinux.com>
 */

/*
 * Created: Mon Jan  4 08:58:31 1999 by faith@valinux.com
 *
 * Copyright 1999 Precision Insight, Inc., Cedar Park, Texas.
 * Copyright 2000 VA Linux Systems, Inc., Sunnyvale, California.
 * All Rights Reserved.
 *
 * Permission is hereby granted, free of charge, to any person obtaining a
 * copy of this software and associated documentation files (the "Software"),
 * to deal in the Software without restriction, including without limitation
 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
 * and/or sell copies of the Software, and to permit persons to whom the
 * Software is furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice (including the next
 * paragraph) shall be included in all copies or substantial portions of the
 * Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.  IN NO EVENT SHALL
 * VA LINUX SYSTEMS AND/OR ITS SUPPLIERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
 * OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
 * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
 * OTHER DEALINGS IN THE SOFTWARE.
 */

#include "drmP.h"
#include <linux/poll.h>
39
#include <linux/slab.h>
40
#include <linux/smp_lock.h>
L
Linus Torvalds 已提交
41

D
Dave Airlie 已提交
42
static int drm_open_helper(struct inode *inode, struct file *filp,
43
			   struct drm_device * dev);
D
Dave Airlie 已提交
44

45
static int drm_setup(struct drm_device * dev)
L
Linus Torvalds 已提交
46 47 48 49
{
	int i;
	int ret;

50 51
	if (dev->driver->firstopen) {
		ret = dev->driver->firstopen(dev);
D
Dave Airlie 已提交
52
		if (ret != 0)
L
Linus Torvalds 已提交
53 54 55
			return ret;
	}

D
Dave Airlie 已提交
56 57
	atomic_set(&dev->ioctl_count, 0);
	atomic_set(&dev->vma_count, 0);
L
Linus Torvalds 已提交
58

D
Dave Airlie 已提交
59 60 61 62 63
	if (drm_core_check_feature(dev, DRIVER_HAVE_DMA) &&
	    !drm_core_check_feature(dev, DRIVER_MODESET)) {
		dev->buf_use = 0;
		atomic_set(&dev->buf_alloc, 0);

D
Dave Airlie 已提交
64 65
		i = drm_dma_setup(dev);
		if (i < 0)
L
Linus Torvalds 已提交
66 67 68
			return i;
	}

69
	for (i = 0; i < ARRAY_SIZE(dev->counts); i++)
D
Dave Airlie 已提交
70
		atomic_set(&dev->counts[i], 0);
L
Linus Torvalds 已提交
71

72
	dev->sigdata.lock = NULL;
73

L
Linus Torvalds 已提交
74 75 76 77 78 79 80 81 82 83
	dev->queue_count = 0;
	dev->queue_reserved = 0;
	dev->queue_slots = 0;
	dev->queuelist = NULL;
	dev->context_flag = 0;
	dev->interrupt_flag = 0;
	dev->dma_flag = 0;
	dev->last_context = 0;
	dev->last_switch = 0;
	dev->last_checked = 0;
D
Dave Airlie 已提交
84
	init_waitqueue_head(&dev->context_wait);
L
Linus Torvalds 已提交
85 86 87 88 89 90
	dev->if_version = 0;

	dev->ctx_start = 0;
	dev->lck_start = 0;

	dev->buf_async = NULL;
D
Dave Airlie 已提交
91 92
	init_waitqueue_head(&dev->buf_readers);
	init_waitqueue_head(&dev->buf_writers);
L
Linus Torvalds 已提交
93

D
Dave Airlie 已提交
94
	DRM_DEBUG("\n");
L
Linus Torvalds 已提交
95 96 97

	/*
	 * The kernel's context could be created here, but is now created
D
Dave Airlie 已提交
98
	 * in drm_dma_enqueue.  This is more resource-efficient for
L
Linus Torvalds 已提交
99 100 101 102 103 104 105 106 107 108
	 * hardware that does not do DMA, but may mean that
	 * drm_select_queue fails between the time the interrupt is
	 * initialized and the time the queues are initialized.
	 */

	return 0;
}

/**
 * Open file.
D
Dave Airlie 已提交
109
 *
L
Linus Torvalds 已提交
110 111 112 113 114 115 116 117
 * \param inode device inode
 * \param filp file pointer.
 * \return zero on success or a negative number on failure.
 *
 * Searches the DRM device with the same minor number, calls open_helper(), and
 * increments the device open count. If the open count was previous at zero,
 * i.e., it's the first that the device is open, then calls setup().
 */
D
Dave Airlie 已提交
118
int drm_open(struct inode *inode, struct file *filp)
L
Linus Torvalds 已提交
119
{
120
	struct drm_device *dev = NULL;
121 122
	int minor_id = iminor(inode);
	struct drm_minor *minor;
L
Linus Torvalds 已提交
123 124
	int retcode = 0;

125 126
	minor = idr_find(&drm_minors_idr, minor_id);
	if (!minor)
L
Linus Torvalds 已提交
127
		return -ENODEV;
D
Dave Airlie 已提交
128

129
	if (!(dev = minor->dev))
L
Linus Torvalds 已提交
130
		return -ENODEV;
D
Dave Airlie 已提交
131 132 133 134 135 136 137

	retcode = drm_open_helper(inode, filp, dev);
	if (!retcode) {
		atomic_inc(&dev->counts[_DRM_STAT_OPENS]);
		spin_lock(&dev->count_lock);
		if (!dev->open_count++) {
			spin_unlock(&dev->count_lock);
J
Jesse Barnes 已提交
138 139
			retcode = drm_setup(dev);
			goto out;
L
Linus Torvalds 已提交
140
		}
D
Dave Airlie 已提交
141
		spin_unlock(&dev->count_lock);
L
Linus Torvalds 已提交
142
	}
J
Jesse Barnes 已提交
143
out:
144 145 146 147 148 149 150 151 152
	if (!retcode) {
		mutex_lock(&dev->struct_mutex);
		if (minor->type == DRM_MINOR_LEGACY) {
			if (dev->dev_mapping == NULL)
				dev->dev_mapping = inode->i_mapping;
			else if (dev->dev_mapping != inode->i_mapping)
				retcode = -ENODEV;
		}
		mutex_unlock(&dev->struct_mutex);
D
Dave Airlie 已提交
153
	}
J
Jesse Barnes 已提交
154

L
Linus Torvalds 已提交
155 156 157 158
	return retcode;
}
EXPORT_SYMBOL(drm_open);

159 160 161 162 163 164 165 166 167 168 169
/**
 * File \c open operation.
 *
 * \param inode device inode.
 * \param filp file pointer.
 *
 * Puts the dev->fops corresponding to the device minor number into
 * \p filp, call the \c open method, and restore the file operations.
 */
int drm_stub_open(struct inode *inode, struct file *filp)
{
170
	struct drm_device *dev = NULL;
171 172
	struct drm_minor *minor;
	int minor_id = iminor(inode);
173
	int err = -ENODEV;
174
	const struct file_operations *old_fops;
175 176 177

	DRM_DEBUG("\n");

178 179
	/* BKL pushdown: note that nothing else serializes idr_find() */
	lock_kernel();
180 181
	minor = idr_find(&drm_minors_idr, minor_id);
	if (!minor)
182
		goto out;
183

184
	if (!(dev = minor->dev))
185
		goto out;
186 187 188

	old_fops = filp->f_op;
	filp->f_op = fops_get(&dev->driver->fops);
L
Laurent Pinchart 已提交
189 190 191 192
	if (filp->f_op == NULL) {
		filp->f_op = old_fops;
		goto out;
	}
193 194 195 196 197 198
	if (filp->f_op->open && (err = filp->f_op->open(inode, filp))) {
		fops_put(filp->f_op);
		filp->f_op = fops_get(old_fops);
	}
	fops_put(old_fops);

199 200
out:
	unlock_kernel();
201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232
	return err;
}

/**
 * Check whether DRI will run on this CPU.
 *
 * \return non-zero if the DRI will run on this CPU, or zero otherwise.
 */
static int drm_cpu_valid(void)
{
#if defined(__i386__)
	if (boot_cpu_data.x86 == 3)
		return 0;	/* No cmpxchg on a 386 */
#endif
#if defined(__sparc__) && !defined(__sparc_v9__)
	return 0;		/* No cmpxchg before v9 sparc. */
#endif
	return 1;
}

/**
 * Called whenever a process opens /dev/drm.
 *
 * \param inode device inode.
 * \param filp file pointer.
 * \param dev device.
 * \return zero on success or a negative number on failure.
 *
 * Creates and initializes a drm_file structure for the file private data in \p
 * filp and add it into the double linked list in \p dev.
 */
static int drm_open_helper(struct inode *inode, struct file *filp,
233
			   struct drm_device * dev)
234
{
235
	int minor_id = iminor(inode);
236
	struct drm_file *priv;
237 238 239 240 241 242 243
	int ret;

	if (filp->f_flags & O_EXCL)
		return -EBUSY;	/* No exclusive opens */
	if (!drm_cpu_valid())
		return -EINVAL;

244
	DRM_DEBUG("pid = %d, minor = %d\n", task_pid_nr(current), minor_id);
245

246
	priv = kmalloc(sizeof(*priv), GFP_KERNEL);
247 248 249 250 251
	if (!priv)
		return -ENOMEM;

	memset(priv, 0, sizeof(*priv));
	filp->private_data = priv;
252
	priv->filp = filp;
253
	priv->uid = current_euid();
254
	priv->pid = task_pid_nr(current);
255
	priv->minor = idr_find(&drm_minors_idr, minor_id);
256 257 258 259 260
	priv->ioctl_count = 0;
	/* for compatibility root is always authenticated */
	priv->authenticated = capable(CAP_SYS_ADMIN);
	priv->lock_count = 0;

261
	INIT_LIST_HEAD(&priv->lhead);
D
Dave Airlie 已提交
262
	INIT_LIST_HEAD(&priv->fbs);
263 264 265
	INIT_LIST_HEAD(&priv->event_list);
	init_waitqueue_head(&priv->event_wait);
	priv->event_space = 4096; /* set aside 4k for event buffer */
266

267 268 269
	if (dev->driver->driver_features & DRIVER_GEM)
		drm_gem_open(dev, priv);

270 271 272 273 274 275
	if (dev->driver->open) {
		ret = dev->driver->open(dev, priv);
		if (ret < 0)
			goto out_free;
	}

276 277

	/* if there is no current master make this fd it */
D
Dave Airlie 已提交
278
	mutex_lock(&dev->struct_mutex);
279 280 281 282
	if (!priv->minor->master) {
		/* create a new master */
		priv->minor->master = drm_master_create(priv->minor);
		if (!priv->minor->master) {
283
			mutex_unlock(&dev->struct_mutex);
284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305
			ret = -ENOMEM;
			goto out_free;
		}

		priv->is_master = 1;
		/* take another reference for the copy in the local file priv */
		priv->master = drm_master_get(priv->minor->master);

		priv->authenticated = 1;

		mutex_unlock(&dev->struct_mutex);
		if (dev->driver->master_create) {
			ret = dev->driver->master_create(dev, priv->master);
			if (ret) {
				mutex_lock(&dev->struct_mutex);
				/* drop both references if this fails */
				drm_master_put(&priv->minor->master);
				drm_master_put(&priv->master);
				mutex_unlock(&dev->struct_mutex);
				goto out_free;
			}
		}
306 307 308 309 310 311 312 313 314 315 316 317
		mutex_lock(&dev->struct_mutex);
		if (dev->driver->master_set) {
			ret = dev->driver->master_set(dev, priv, true);
			if (ret) {
				/* drop both references if this fails */
				drm_master_put(&priv->minor->master);
				drm_master_put(&priv->master);
				mutex_unlock(&dev->struct_mutex);
				goto out_free;
			}
		}
		mutex_unlock(&dev->struct_mutex);
318 319 320 321 322
	} else {
		/* get a reference to the master */
		priv->master = drm_master_get(priv->minor->master);
		mutex_unlock(&dev->struct_mutex);
	}
323

324
	mutex_lock(&dev->struct_mutex);
325
	list_add(&priv->lhead, &dev->filelist);
D
Dave Airlie 已提交
326
	mutex_unlock(&dev->struct_mutex);
327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348

#ifdef __alpha__
	/*
	 * Default the hose
	 */
	if (!dev->hose) {
		struct pci_dev *pci_dev;
		pci_dev = pci_get_class(PCI_CLASS_DISPLAY_VGA << 8, NULL);
		if (pci_dev) {
			dev->hose = pci_dev->sysdata;
			pci_dev_put(pci_dev);
		}
		if (!dev->hose) {
			struct pci_bus *b = pci_bus_b(pci_root_buses.next);
			if (b)
				dev->hose = b->sysdata;
		}
	}
#endif

	return 0;
      out_free:
349
	kfree(priv);
350 351 352 353 354 355 356
	filp->private_data = NULL;
	return ret;
}

/** No-op. */
int drm_fasync(int fd, struct file *filp, int on)
{
357
	struct drm_file *priv = filp->private_data;
358
	struct drm_device *dev = priv->minor->dev;
359 360

	DRM_DEBUG("fd = %d, device = 0x%lx\n", fd,
361
		  (long)old_encode_dev(priv->minor->device));
362
	return fasync_helper(fd, filp, on, &dev->buf_async);
363 364 365
}
EXPORT_SYMBOL(drm_fasync);

366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433
/*
 * Reclaim locked buffers; note that this may be a bad idea if the current
 * context doesn't have the hw lock...
 */
static void drm_reclaim_locked_buffers(struct drm_device *dev, struct file *f)
{
	struct drm_file *file_priv = f->private_data;

	if (drm_i_have_hw_lock(dev, file_priv)) {
		dev->driver->reclaim_buffers_locked(dev, file_priv);
	} else {
		unsigned long _end = jiffies + 3 * DRM_HZ;
		int locked = 0;

		drm_idlelock_take(&file_priv->master->lock);

		/*
		 * Wait for a while.
		 */
		do {
			spin_lock_bh(&file_priv->master->lock.spinlock);
			locked = file_priv->master->lock.idle_has_lock;
			spin_unlock_bh(&file_priv->master->lock.spinlock);
			if (locked)
				break;
			schedule();
		} while (!time_after_eq(jiffies, _end));

		if (!locked) {
			DRM_ERROR("reclaim_buffers_locked() deadlock. Please rework this\n"
				  "\tdriver to use reclaim_buffers_idlelocked() instead.\n"
				  "\tI will go on reclaiming the buffers anyway.\n");
		}

		dev->driver->reclaim_buffers_locked(dev, file_priv);
		drm_idlelock_release(&file_priv->master->lock);
	}
}

static void drm_master_release(struct drm_device *dev, struct file *filp)
{
	struct drm_file *file_priv = filp->private_data;

	if (dev->driver->reclaim_buffers_locked &&
	    file_priv->master->lock.hw_lock)
		drm_reclaim_locked_buffers(dev, filp);

	if (dev->driver->reclaim_buffers_idlelocked &&
	    file_priv->master->lock.hw_lock) {
		drm_idlelock_take(&file_priv->master->lock);
		dev->driver->reclaim_buffers_idlelocked(dev, file_priv);
		drm_idlelock_release(&file_priv->master->lock);
	}


	if (drm_i_have_hw_lock(dev, file_priv)) {
		DRM_DEBUG("File %p released, freeing lock for context %d\n",
			  filp, _DRM_LOCKING_CONTEXT(file_priv->master->lock.hw_lock->lock));
		drm_lock_free(&file_priv->master->lock,
			      _DRM_LOCKING_CONTEXT(file_priv->master->lock.hw_lock->lock));
	}

	if (drm_core_check_feature(dev, DRIVER_HAVE_DMA) &&
	    !dev->driver->reclaim_buffers_locked) {
		dev->driver->reclaim_buffers(dev, file_priv);
	}
}

434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457
static void drm_events_release(struct drm_file *file_priv)
{
	struct drm_device *dev = file_priv->minor->dev;
	struct drm_pending_event *e, *et;
	struct drm_pending_vblank_event *v, *vt;
	unsigned long flags;

	spin_lock_irqsave(&dev->event_lock, flags);

	/* Remove pending flips */
	list_for_each_entry_safe(v, vt, &dev->vblank_event_list, base.link)
		if (v->base.file_priv == file_priv) {
			list_del(&v->base.link);
			drm_vblank_put(dev, v->pipe);
			v->base.destroy(&v->base);
		}

	/* Remove unconsumed events */
	list_for_each_entry_safe(e, et, &file_priv->event_list, link)
		e->destroy(e);

	spin_unlock_irqrestore(&dev->event_lock, flags);
}

L
Linus Torvalds 已提交
458 459 460 461
/**
 * Release file.
 *
 * \param inode device inode
462
 * \param file_priv DRM file private.
L
Linus Torvalds 已提交
463 464 465 466 467
 * \return zero on success or a negative number on failure.
 *
 * If the hardware lock is held then free it, and take it again for the kernel
 * context since it's necessary to reclaim buffers. Unlink the file private
 * data from its list and free it. Decreases the open count and if it reaches
468
 * zero calls drm_lastclose().
L
Linus Torvalds 已提交
469
 */
D
Dave Airlie 已提交
470
int drm_release(struct inode *inode, struct file *filp)
L
Linus Torvalds 已提交
471
{
472
	struct drm_file *file_priv = filp->private_data;
473
	struct drm_device *dev = file_priv->minor->dev;
L
Linus Torvalds 已提交
474 475 476 477
	int retcode = 0;

	lock_kernel();

D
Dave Airlie 已提交
478
	DRM_DEBUG("open_count = %d\n", dev->open_count);
L
Linus Torvalds 已提交
479

480
	if (dev->driver->preclose)
481
		dev->driver->preclose(dev, file_priv);
L
Linus Torvalds 已提交
482 483 484 485 486

	/* ========================================================
	 * Begin inline drm_release
	 */

D
Dave Airlie 已提交
487
	DRM_DEBUG("pid = %d, device = 0x%lx, open_count = %d\n",
488
		  task_pid_nr(current),
489
		  (long)old_encode_dev(file_priv->minor->device),
D
Dave Airlie 已提交
490 491
		  dev->open_count);

492 493 494
	/* if the master has gone away we can't do anything with the lock */
	if (file_priv->minor->master)
		drm_master_release(dev, filp);
L
Linus Torvalds 已提交
495

496 497
	drm_events_release(file_priv);

498 499 500
	if (dev->driver->driver_features & DRIVER_GEM)
		drm_gem_release(dev, file_priv);

501 502 503
	if (dev->driver->driver_features & DRIVER_MODESET)
		drm_fb_release(file_priv);

D
Dave Airlie 已提交
504
	mutex_lock(&dev->ctxlist_mutex);
505
	if (!list_empty(&dev->ctxlist)) {
D
Dave Airlie 已提交
506
		struct drm_ctx_list *pos, *n;
L
Linus Torvalds 已提交
507

508
		list_for_each_entry_safe(pos, n, &dev->ctxlist, head) {
509
			if (pos->tag == file_priv &&
D
Dave Airlie 已提交
510
			    pos->handle != DRM_KERNEL_CONTEXT) {
L
Linus Torvalds 已提交
511
				if (dev->driver->context_dtor)
D
Dave Airlie 已提交
512 513
					dev->driver->context_dtor(dev,
								  pos->handle);
L
Linus Torvalds 已提交
514

D
Dave Airlie 已提交
515
				drm_ctxbitmap_free(dev, pos->handle);
L
Linus Torvalds 已提交
516

D
Dave Airlie 已提交
517
				list_del(&pos->head);
518
				kfree(pos);
L
Linus Torvalds 已提交
519 520 521 522
				--dev->ctx_count;
			}
		}
	}
D
Dave Airlie 已提交
523
	mutex_unlock(&dev->ctxlist_mutex);
L
Linus Torvalds 已提交
524

D
Dave Airlie 已提交
525
	mutex_lock(&dev->struct_mutex);
526 527

	if (file_priv->is_master) {
528
		struct drm_master *master = file_priv->master;
529
		struct drm_file *temp;
530 531 532 533 534
		list_for_each_entry(temp, &dev->filelist, lhead) {
			if ((temp->master == file_priv->master) &&
			    (temp != file_priv))
				temp->authenticated = 0;
		}
535

536 537 538 539 540 541 542 543 544 545 546 547 548
		/**
		 * Since the master is disappearing, so is the
		 * possibility to lock.
		 */

		if (master->lock.hw_lock) {
			if (dev->sigdata.lock == master->lock.hw_lock)
				dev->sigdata.lock = NULL;
			master->lock.hw_lock = NULL;
			master->lock.file_priv = NULL;
			wake_up_interruptible_all(&master->lock.lock_queue);
		}

549 550
		if (file_priv->minor->master == file_priv->master) {
			/* drop the reference held my the minor */
551 552
			if (dev->driver->master_drop)
				dev->driver->master_drop(dev, file_priv, true);
553 554
			drm_master_put(&file_priv->minor->master);
		}
L
Linus Torvalds 已提交
555
	}
556 557 558 559

	/* drop the reference held my the file priv */
	drm_master_put(&file_priv->master);
	file_priv->is_master = 0;
560
	list_del(&file_priv->lhead);
D
Dave Airlie 已提交
561
	mutex_unlock(&dev->struct_mutex);
D
Dave Airlie 已提交
562

563
	if (dev->driver->postclose)
564
		dev->driver->postclose(dev, file_priv);
565
	kfree(file_priv);
L
Linus Torvalds 已提交
566 567 568 569 570

	/* ========================================================
	 * End inline drm_release
	 */

D
Dave Airlie 已提交
571 572 573
	atomic_inc(&dev->counts[_DRM_STAT_CLOSES]);
	spin_lock(&dev->count_lock);
	if (!--dev->open_count) {
574 575 576
		if (atomic_read(&dev->ioctl_count)) {
			DRM_ERROR("Device busy: %d\n",
				  atomic_read(&dev->ioctl_count));
D
Dave Airlie 已提交
577
			spin_unlock(&dev->count_lock);
L
Linus Torvalds 已提交
578 579 580
			unlock_kernel();
			return -EBUSY;
		}
D
Dave Airlie 已提交
581
		spin_unlock(&dev->count_lock);
L
Linus Torvalds 已提交
582
		unlock_kernel();
583
		return drm_lastclose(dev);
L
Linus Torvalds 已提交
584
	}
D
Dave Airlie 已提交
585
	spin_unlock(&dev->count_lock);
L
Linus Torvalds 已提交
586 587 588 589 590 591 592

	unlock_kernel();

	return retcode;
}
EXPORT_SYMBOL(drm_release);

593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650
static bool
drm_dequeue_event(struct drm_file *file_priv,
		  size_t total, size_t max, struct drm_pending_event **out)
{
	struct drm_device *dev = file_priv->minor->dev;
	struct drm_pending_event *e;
	unsigned long flags;
	bool ret = false;

	spin_lock_irqsave(&dev->event_lock, flags);

	*out = NULL;
	if (list_empty(&file_priv->event_list))
		goto out;
	e = list_first_entry(&file_priv->event_list,
			     struct drm_pending_event, link);
	if (e->event->length + total > max)
		goto out;

	file_priv->event_space += e->event->length;
	list_del(&e->link);
	*out = e;
	ret = true;

out:
	spin_unlock_irqrestore(&dev->event_lock, flags);
	return ret;
}

ssize_t drm_read(struct file *filp, char __user *buffer,
		 size_t count, loff_t *offset)
{
	struct drm_file *file_priv = filp->private_data;
	struct drm_pending_event *e;
	size_t total;
	ssize_t ret;

	ret = wait_event_interruptible(file_priv->event_wait,
				       !list_empty(&file_priv->event_list));
	if (ret < 0)
		return ret;

	total = 0;
	while (drm_dequeue_event(file_priv, total, count, &e)) {
		if (copy_to_user(buffer + total,
				 e->event, e->event->length)) {
			total = -EFAULT;
			break;
		}

		total += e->event->length;
		e->destroy(e);
	}

	return total;
}
EXPORT_SYMBOL(drm_read);

L
Linus Torvalds 已提交
651 652
unsigned int drm_poll(struct file *filp, struct poll_table_struct *wait)
{
653 654 655 656 657 658 659 660 661
	struct drm_file *file_priv = filp->private_data;
	unsigned int mask = 0;

	poll_wait(filp, &file_priv->event_wait, wait);

	if (!list_empty(&file_priv->event_list))
		mask |= POLLIN | POLLRDNORM;

	return mask;
L
Linus Torvalds 已提交
662
}
D
Dave Airlie 已提交
663
EXPORT_SYMBOL(drm_poll);