drm_fops.c 16.9 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/module.h>
L
Linus Torvalds 已提交
41

A
Arnd Bergmann 已提交
42 43
/* from BKL pushdown: note that nothing else serializes idr_find() */
DEFINE_MUTEX(drm_global_mutex);
44
EXPORT_SYMBOL(drm_global_mutex);
A
Arnd Bergmann 已提交
45

D
Dave Airlie 已提交
46
static int drm_open_helper(struct inode *inode, struct file *filp,
47
			   struct drm_device * dev);
D
Dave Airlie 已提交
48

49
static int drm_setup(struct drm_device * dev)
L
Linus Torvalds 已提交
50 51 52 53
{
	int i;
	int ret;

54 55
	if (dev->driver->firstopen) {
		ret = dev->driver->firstopen(dev);
D
Dave Airlie 已提交
56
		if (ret != 0)
L
Linus Torvalds 已提交
57 58 59
			return ret;
	}

D
Dave Airlie 已提交
60 61
	atomic_set(&dev->ioctl_count, 0);
	atomic_set(&dev->vma_count, 0);
L
Linus Torvalds 已提交
62

D
Dave Airlie 已提交
63 64 65 66 67
	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 已提交
68 69
		i = drm_dma_setup(dev);
		if (i < 0)
L
Linus Torvalds 已提交
70 71 72
			return i;
	}

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

76
	dev->sigdata.lock = NULL;
77

L
Linus Torvalds 已提交
78 79 80 81 82 83 84 85 86 87
	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 已提交
88
	init_waitqueue_head(&dev->context_wait);
L
Linus Torvalds 已提交
89 90 91 92 93 94
	dev->if_version = 0;

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

	dev->buf_async = NULL;
D
Dave Airlie 已提交
95 96
	init_waitqueue_head(&dev->buf_readers);
	init_waitqueue_head(&dev->buf_writers);
L
Linus Torvalds 已提交
97

D
Dave Airlie 已提交
98
	DRM_DEBUG("\n");
L
Linus Torvalds 已提交
99 100 101

	/*
	 * The kernel's context could be created here, but is now created
D
Dave Airlie 已提交
102
	 * in drm_dma_enqueue.  This is more resource-efficient for
L
Linus Torvalds 已提交
103 104 105 106 107 108 109 110 111 112
	 * 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 已提交
113
 *
L
Linus Torvalds 已提交
114 115 116 117 118 119 120 121
 * \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 已提交
122
int drm_open(struct inode *inode, struct file *filp)
L
Linus Torvalds 已提交
123
{
124
	struct drm_device *dev = NULL;
125 126
	int minor_id = iminor(inode);
	struct drm_minor *minor;
L
Linus Torvalds 已提交
127 128
	int retcode = 0;

129 130
	minor = idr_find(&drm_minors_idr, minor_id);
	if (!minor)
L
Linus Torvalds 已提交
131
		return -ENODEV;
D
Dave Airlie 已提交
132

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

	retcode = drm_open_helper(inode, filp, dev);
	if (!retcode) {
		atomic_inc(&dev->counts[_DRM_STAT_OPENS]);
139
		if (!dev->open_count++)
J
Jesse Barnes 已提交
140
			retcode = drm_setup(dev);
L
Linus Torvalds 已提交
141
	}
142 143 144 145 146 147 148 149 150
	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 已提交
151
	}
J
Jesse Barnes 已提交
152

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

157 158 159 160 161 162 163 164 165 166 167
/**
 * 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)
{
168
	struct drm_device *dev = NULL;
169 170
	struct drm_minor *minor;
	int minor_id = iminor(inode);
171
	int err = -ENODEV;
172
	const struct file_operations *old_fops;
173 174 175

	DRM_DEBUG("\n");

A
Arnd Bergmann 已提交
176
	mutex_lock(&drm_global_mutex);
177 178
	minor = idr_find(&drm_minors_idr, minor_id);
	if (!minor)
179
		goto out;
180

181
	if (!(dev = minor->dev))
182
		goto out;
183 184

	old_fops = filp->f_op;
185
	filp->f_op = fops_get(dev->driver->fops);
L
Laurent Pinchart 已提交
186 187 188 189
	if (filp->f_op == NULL) {
		filp->f_op = old_fops;
		goto out;
	}
190 191 192 193 194 195
	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);

196
out:
A
Arnd Bergmann 已提交
197
	mutex_unlock(&drm_global_mutex);
198 199 200 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
	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,
230
			   struct drm_device * dev)
231
{
232
	int minor_id = iminor(inode);
233
	struct drm_file *priv;
234 235 236 237 238 239
	int ret;

	if (filp->f_flags & O_EXCL)
		return -EBUSY;	/* No exclusive opens */
	if (!drm_cpu_valid())
		return -EINVAL;
240 241
	if (dev->switch_power_state != DRM_SWITCH_POWER_ON)
		return -EINVAL;
242

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

J
Julia Lawall 已提交
245
	priv = kzalloc(sizeof(*priv), GFP_KERNEL);
246 247 248 249
	if (!priv)
		return -ENOMEM;

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

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

265 266 267
	if (dev->driver->driver_features & DRIVER_GEM)
		drm_gem_open(dev, priv);

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

274 275

	/* if there is no current master make this fd it */
D
Dave Airlie 已提交
276
	mutex_lock(&dev->struct_mutex);
277 278 279 280
	if (!priv->minor->master) {
		/* create a new master */
		priv->minor->master = drm_master_create(priv->minor);
		if (!priv->minor->master) {
281
			mutex_unlock(&dev->struct_mutex);
282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303
			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;
			}
		}
304 305 306 307 308 309 310 311 312 313 314 315
		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);
316 317 318 319 320
	} else {
		/* get a reference to the master */
		priv->master = drm_master_get(priv->minor->master);
		mutex_unlock(&dev->struct_mutex);
	}
321

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

#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:
347
	kfree(priv);
348 349 350 351 352 353 354
	filp->private_data = NULL;
	return ret;
}

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

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

364 365 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
/*
 * 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);
	}
}

432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455
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 已提交
456 457 458 459
/**
 * Release file.
 *
 * \param inode device inode
460
 * \param file_priv DRM file private.
L
Linus Torvalds 已提交
461 462 463 464 465
 * \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
466
 * zero calls drm_lastclose().
L
Linus Torvalds 已提交
467
 */
D
Dave Airlie 已提交
468
int drm_release(struct inode *inode, struct file *filp)
L
Linus Torvalds 已提交
469
{
470
	struct drm_file *file_priv = filp->private_data;
471
	struct drm_device *dev = file_priv->minor->dev;
L
Linus Torvalds 已提交
472 473
	int retcode = 0;

A
Arnd Bergmann 已提交
474
	mutex_lock(&drm_global_mutex);
L
Linus Torvalds 已提交
475

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

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

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

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

490 491 492 493 494
	/* Release any auth tokens that might point to this file_priv,
	   (do that under the drm_global_mutex) */
	if (file_priv->magic)
		(void) drm_remove_magic(file_priv->master, file_priv->magic);

495 496 497
	/* 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 已提交
498

499 500
	drm_events_release(file_priv);

501 502 503
	if (dev->driver->driver_features & DRIVER_GEM)
		drm_gem_release(dev, file_priv);

504 505 506
	if (dev->driver->driver_features & DRIVER_MODESET)
		drm_fb_release(file_priv);

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

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

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

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

D
Dave Airlie 已提交
528
	mutex_lock(&dev->struct_mutex);
529 530

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

539 540 541 542 543 544 545 546 547 548 549 550 551
		/**
		 * 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);
		}

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

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

566
	if (dev->driver->postclose)
567
		dev->driver->postclose(dev, file_priv);
568
	kfree(file_priv);
L
Linus Torvalds 已提交
569 570 571 572 573

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

D
Dave Airlie 已提交
574 575
	atomic_inc(&dev->counts[_DRM_STAT_CLOSES]);
	if (!--dev->open_count) {
576 577 578
		if (atomic_read(&dev->ioctl_count)) {
			DRM_ERROR("Device busy: %d\n",
				  atomic_read(&dev->ioctl_count));
A
Arnd Bergmann 已提交
579
			retcode = -EBUSY;
580 581
		} else
			retcode = drm_lastclose(dev);
L
Linus Torvalds 已提交
582
	}
A
Arnd Bergmann 已提交
583
	mutex_unlock(&drm_global_mutex);
L
Linus Torvalds 已提交
584 585 586 587 588

	return retcode;
}
EXPORT_SYMBOL(drm_release);

589 590 591 592 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
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 已提交
647 648
unsigned int drm_poll(struct file *filp, struct poll_table_struct *wait)
{
649 650 651 652 653 654 655 656 657
	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 已提交
658
}
D
Dave Airlie 已提交
659
EXPORT_SYMBOL(drm_poll);