xref: /openbsd-src/lib/libsndio/mio_rmidi.c (revision cfb56cbff173f3acce85bcb8b944782577c26f37)
1 /*	$OpenBSD: mio_rmidi.c,v 1.12 2012/10/27 12:08:25 ratchov Exp $	*/
2 /*
3  * Copyright (c) 2008 Alexandre Ratchov <alex@caoua.org>
4  *
5  * Permission to use, copy, modify, and distribute this software for any
6  * purpose with or without fee is hereby granted, provided that the above
7  * copyright notice and this permission notice appear in all copies.
8  *
9  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
10  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
11  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
12  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
13  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
14  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
15  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
16  */
17 
18 #include <sys/types.h>
19 #include <sys/stat.h>
20 
21 #include <errno.h>
22 #include <fcntl.h>
23 #include <limits.h>
24 #include <poll.h>
25 #include <stdio.h>
26 #include <stdlib.h>
27 #include <string.h>
28 #include <unistd.h>
29 
30 #include "debug.h"
31 #include "mio_priv.h"
32 
33 struct mio_rmidi_hdl {
34 	struct mio_hdl mio;
35 	int fd;
36 };
37 
38 static void mio_rmidi_close(struct mio_hdl *);
39 static size_t mio_rmidi_read(struct mio_hdl *, void *, size_t);
40 static size_t mio_rmidi_write(struct mio_hdl *, const void *, size_t);
41 static int mio_rmidi_nfds(struct mio_hdl *);
42 static int mio_rmidi_pollfd(struct mio_hdl *, struct pollfd *, int);
43 static int mio_rmidi_revents(struct mio_hdl *, struct pollfd *);
44 
45 static struct mio_ops mio_rmidi_ops = {
46 	mio_rmidi_close,
47 	mio_rmidi_write,
48 	mio_rmidi_read,
49 	mio_rmidi_nfds,
50 	mio_rmidi_pollfd,
51 	mio_rmidi_revents
52 };
53 
54 struct mio_hdl *
55 mio_rmidi_open(const char *str, unsigned int mode, int nbio)
56 {
57 	int fd, flags;
58 	struct mio_rmidi_hdl *hdl;
59 	char path[PATH_MAX];
60 
61 	switch (*str) {
62 	case '/':
63 	case ':': /* XXX: for backward compat */
64 		str++;
65 		break;
66 	default:
67 		DPRINTF("sio_sun_open: %s: '/<devnum>' expected\n", str);
68 		return NULL;
69 	}
70 	hdl = malloc(sizeof(struct mio_rmidi_hdl));
71 	if (hdl == NULL)
72 		return NULL;
73 	mio_create(&hdl->mio, &mio_rmidi_ops, mode, nbio);
74 
75 	snprintf(path, sizeof(path), "/dev/rmidi%s", str);
76 	if (mode == (MIO_OUT | MIO_IN))
77 		flags = O_RDWR;
78 	else
79 		flags = (mode & MIO_OUT) ? O_WRONLY : O_RDONLY;
80 	while ((fd = open(path, flags | O_NONBLOCK)) < 0) {
81 		if (errno == EINTR)
82 			continue;
83 		DPERROR(path);
84 		goto bad_free;
85 	}
86 	if (fcntl(fd, F_SETFD, FD_CLOEXEC) < 0) {
87 		DPERROR("FD_CLOEXEC");
88 		goto bad_close;
89 	}
90 	hdl->fd = fd;
91 	return (struct mio_hdl *)hdl;
92  bad_close:
93 	while (close(hdl->fd) < 0 && errno == EINTR)
94 		; /* retry */
95  bad_free:
96 	free(hdl);
97 	return NULL;
98 }
99 
100 static void
101 mio_rmidi_close(struct mio_hdl *sh)
102 {
103 	struct mio_rmidi_hdl *hdl = (struct mio_rmidi_hdl *)sh;
104 	int rc;
105 
106 	do {
107 		rc = close(hdl->fd);
108 	} while (rc < 0 && errno == EINTR);
109 	free(hdl);
110 }
111 
112 static size_t
113 mio_rmidi_read(struct mio_hdl *sh, void *buf, size_t len)
114 {
115 	struct mio_rmidi_hdl *hdl = (struct mio_rmidi_hdl *)sh;
116 	ssize_t n;
117 
118 	while ((n = read(hdl->fd, buf, len)) < 0) {
119 		if (errno == EINTR)
120 			continue;
121 		if (errno != EAGAIN) {
122 			DPERROR("mio_rmidi_read: read");
123 			hdl->mio.eof = 1;
124 		}
125 		return 0;
126 	}
127 	if (n == 0) {
128 		DPRINTF("mio_rmidi_read: eof\n");
129 		hdl->mio.eof = 1;
130 		return 0;
131 	}
132 	return n;
133 }
134 
135 static size_t
136 mio_rmidi_write(struct mio_hdl *sh, const void *buf, size_t len)
137 {
138 	struct mio_rmidi_hdl *hdl = (struct mio_rmidi_hdl *)sh;
139 	ssize_t n;
140 
141 	while ((n = write(hdl->fd, buf, len)) < 0) {
142 		if (errno == EINTR)
143 			continue;
144 		if (errno != EAGAIN) {
145 			DPERROR("mio_rmidi_write: write");
146 			hdl->mio.eof = 1;
147 		}
148  		return 0;
149 	}
150 	return n;
151 }
152 
153 static int
154 mio_rmidi_nfds(struct mio_hdl *sh)
155 {
156 	return 1;
157 }
158 
159 static int
160 mio_rmidi_pollfd(struct mio_hdl *sh, struct pollfd *pfd, int events)
161 {
162 	struct mio_rmidi_hdl *hdl = (struct mio_rmidi_hdl *)sh;
163 
164 	pfd->fd = hdl->fd;
165 	pfd->events = events;
166 	return 1;
167 }
168 
169 static int
170 mio_rmidi_revents(struct mio_hdl *sh, struct pollfd *pfd)
171 {
172 	return pfd->revents;
173 }
174