1
2 #ifdef USE_PCM // XXX not yet
3 /*
4 * PCM timer layer
5 */
6
7 int pcard = 0;
8 int pdevice = 0;
9 int period_size = 1024;
10
set_hwparams(snd_pcm_t * phandle)11 void set_hwparams(snd_pcm_t *phandle)
12 {
13 int err;
14 snd_pcm_hw_params_t *params;
15
16 err = snd_output_stdio_attach(&log, stderr, 0);
17 if (err < 0) {
18 fprintf(stderr, "cannot attach output stdio\n");
19 exit(0);
20 }
21
22 snd_pcm_hw_params_alloca(¶ms);
23 err = snd_pcm_hw_params_any(phandle, params);
24 if (err < 0) {
25 fprintf(stderr, "Broken configuration for this PCM: no configurations available\n");
26 exit(0);
27 }
28
29 err = snd_pcm_hw_params_set_access(phandle, params,
30 SND_PCM_ACCESS_RW_INTERLEAVED);
31 if (err < 0) {
32 fprintf(stderr, "Access type not available\n");
33 exit(0);
34 }
35 err = snd_pcm_hw_params_set_format(phandle, params, SND_PCM_FORMAT_S16_LE);
36 if (err < 0) {
37 fprintf(stderr, "cannot set format\n");
38 exit(0);
39 }
40 err = snd_pcm_hw_params_set_channels(phandle, params, 2);
41 if (err < 0) {
42 fprintf(stderr, "cannot set channels 2\n");
43 exit(0);
44 }
45 err = snd_pcm_hw_params_set_rate_near(phandle, params, 44100, 0);
46 if (err < 0) {
47 fprintf(stderr, "cannot set rate\n");
48 exit(0);
49 }
50 err = snd_pcm_hw_params_set_period_size_near(phandle, params, period_size);
51 if (err < 0) {
52 fprintf(stderr, "cannot set period size\n");
53 exit(0);
54 }
55 err = snd_pcm_hw_params(phandle, params);
56 if (err < 0) {
57 fprintf(stderr, "Unable to install hw params:\n");
58 exit(0);
59 }
60 snd_pcm_hw_params_dump(params, log);
61 }
62
63 #endif
64 /*
65 * Simple event sender
66 */
67
event_sender_start_timer(snd_seq_t * handle,int client ATTRIBUTE_UNUSED,int queue,snd_pcm_t * phandle ATTRIBUTE_UNUSED)68 void event_sender_start_timer(snd_seq_t *handle,
69 int client ATTRIBUTE_UNUSED,
70 int queue,
71 snd_pcm_t *phandle ATTRIBUTE_UNUSED)
72 {
73 int err;
74
75 #ifdef USE_PCM
76 if (phandle) {
77 snd_pcm_playback_info_t pinfo;
78 snd_seq_queue_timer_t qtimer;
79
80 if ((err = snd_pcm_playback_info(phandle, &pinfo)) < 0) {
81 fprintf(stderr, "Playback info error: %s\n", snd_strerror(err));
82 exit(0);
83 }
84 bzero(&qtimer, sizeof(qtimer));
85 qtimer.type = SND_SEQ_TIMER_MASTER;
86 /* note: last bit from the subdevices specifies playback */
87 /* or capture direction for the timer specification */
88 qtimer.number = SND_TIMER_PCM(pcard, pdevice, pinfo.subdevice << 1);
89 if ((err = snd_seq_set_queue_timer(handle, queue, &qtimer)) < 0) {
90 fprintf(stderr, "Sequencer PCM timer setup failed: %s\n", snd_strerror(err));
91 exit(0);
92 }
93 }
94 #endif
95 if ((err = snd_seq_start_queue(handle, queue, NULL))<0)
96 fprintf(stderr, "Timer event output error: %s\n", snd_strerror(err));
97 snd_seq_drain_output(handle);
98 }
99
event_sender_filter(snd_seq_t * handle)100 void event_sender_filter(snd_seq_t *handle)
101 {
102 int err;
103
104 if ((err = snd_seq_set_client_event_filter(handle, SND_SEQ_EVENT_ECHO)) < 0) {
105 fprintf(stderr, "Unable to set client info: %s\n", snd_strerror(err));
106 return;
107 }
108 }
109
send_event(snd_seq_t * handle,int queue,int client,int port,snd_seq_addr_t * dest,int * time)110 void send_event(snd_seq_t *handle, int queue, int client, int port,
111 snd_seq_addr_t *dest, int *time)
112 {
113 int err;
114 snd_seq_event_t ev;
115
116 bzero(&ev, sizeof(ev));
117 ev.queue = queue;
118 ev.source.client = ev.dest.client = client;
119 ev.source.port = ev.dest.port = port;
120 ev.flags = SND_SEQ_TIME_STAMP_REAL | SND_SEQ_TIME_MODE_ABS;
121 ev.time.time.tv_sec = *time; (*time)++;
122 ev.type = SND_SEQ_EVENT_ECHO;
123 if ((err = snd_seq_event_output(handle, &ev))<0)
124 fprintf(stderr, "Event output error: %s\n", snd_strerror(err));
125 ev.dest = *dest;
126 ev.type = SND_SEQ_EVENT_PGMCHANGE;
127 ev.data.control.channel = 0;
128 ev.data.control.value = 16;
129 if ((err = snd_seq_event_output(handle, &ev))<0)
130 fprintf(stderr, "Event output error: %s\n", snd_strerror(err));
131 ev.type = SND_SEQ_EVENT_NOTE;
132 ev.data.note.channel = 0;
133 ev.data.note.note = 64 + (queue*2);
134 ev.data.note.velocity = 127;
135 ev.data.note.off_velocity = 127;
136 ev.data.note.duration = 500; /* 0.5sec */
137 if ((err = snd_seq_event_output(handle, &ev))<0)
138 fprintf(stderr, "Event output error: %s\n", snd_strerror(err));
139 if ((err = snd_seq_drain_output(handle))<0)
140 fprintf(stderr, "Event drain error: %s\n", snd_strerror(err));
141 }
142
event_sender(snd_seq_t * handle,int argc,char * argv[])143 void event_sender(snd_seq_t *handle, int argc, char *argv[])
144 {
145 snd_seq_event_t *ev;
146 snd_seq_port_info_t *pinfo;
147 snd_seq_port_subscribe_t *sub;
148 snd_seq_addr_t addr;
149 struct pollfd *pfds;
150 int client, port, queue, max, err, v1, v2, time = 0, pcm_flag = 0;
151 char *ptr;
152 snd_pcm_t *phandle = NULL;
153
154 if (argc < 1) {
155 fprintf(stderr, "Invalid destination...\n");
156 return;
157 }
158
159 if ((client = snd_seq_client_id(handle))<0) {
160 fprintf(stderr, "Cannot determine client number: %s\n", snd_strerror(client));
161 return;
162 }
163 printf("Client ID = %i\n", client);
164 if ((queue = snd_seq_alloc_queue(handle))<0) {
165 fprintf(stderr, "Cannot allocate queue: %s\n", snd_strerror(queue));
166 return;
167 }
168 printf("Queue ID = %i\n", queue);
169 event_sender_filter(handle);
170 if ((err = snd_seq_nonblock(handle, 1))<0)
171 fprintf(stderr, "Cannot set nonblock mode: %s\n", snd_strerror(err));
172
173 snd_seq_port_info_alloca(&pinfo);
174 snd_seq_port_info_set_capability(pinfo, SND_SEQ_PORT_CAP_WRITE | SND_SEQ_PORT_CAP_READ);
175 snd_seq_port_info_set_name(pinfo, "Output");
176 if ((err = snd_seq_create_port(handle, pinfo)) < 0) {
177 fprintf(stderr, "Cannot create output port: %s\n", snd_strerror(err));
178 return;
179 }
180 port = snd_seq_port_info_get_port(pinfo);
181
182 snd_seq_port_subscribe_alloca(&sub);
183 addr.client = client;
184 addr.port = port;
185 snd_seq_port_subscribe_set_sender(sub, &addr);
186
187 for (max = 0; max < argc; max++) {
188 ptr = argv[max];
189 if (!ptr)
190 continue;
191 if (!strcmp(ptr, "pcm")) {
192 pcm_flag = 1;
193 continue;
194 }
195 if (sscanf(ptr, "%i.%i", &v1, &v2) != 2) {
196 fprintf(stderr, "Wrong argument '%s'...\n", argv[max]);
197 return;
198 }
199 addr.client = v1;
200 addr.port = v2;
201 snd_seq_port_subscribe_set_dest(sub, &addr);
202 if ((err = snd_seq_subscribe_port(handle, sub))<0) {
203 fprintf(stderr, "Cannot subscribe port %i from client %i: %s\n", v2, v1, snd_strerror(err));
204 return;
205 }
206 }
207
208 printf("Destination client = %i, port = %i\n", addr.client, addr.port);
209
210 #ifdef USE_PCM
211 if (pcm_flag) {
212 if ((err = snd_pcm_open(&phandle, "default", SND_PCM_STREAM_PLAYBACK, 0)) < 0) {
213 fprintf(stderr, "Playback open error: %s\n", snd_strerror(err));
214 exit(0);
215 }
216 set_hwparams(phandle);
217 pbuf = calloc(1, period_size * 4);
218 if (pbuf == NULL) {
219 fprintf(stderr, "No enough memory...\n");
220 exit(0);
221 }
222 }
223 #endif
224 event_sender_start_timer(handle, client, queue, phandle);
225
226 /* send the first event */
227 send_event(handle, queue, client, port, &addr, &time);
228 #ifdef USE_PCM
229 if (phandle)
230 max += snd_pcm_poll_descriptors_count(phandle);
231 #endif
232 pfds = alloca(sizeof(*pfds) * max);
233 while (1) {
234 int nseqs = snd_seq_poll_descriptors_count(handle, POLLOUT|POLLIN);
235 if (snd_seq_event_output_pending(handle))
236 snd_seq_poll_descriptors(handle, pfds, nseqs, POLLOUT|POLLIN);
237 else
238 snd_seq_poll_descriptors(handle, pfds, nseqs, POLLIN);
239 max = nseqs;
240 #ifdef USE_PCM
241 if (phandle) {
242 int pmax = snd_pcm_poll_descriptors_count(phandle);
243 snd_seq_poll_descriptors(phandle, pfds + max, pmax);
244 max += pmax;
245 }
246 #endif
247 if (poll(pfds, max, -1) < 0)
248 break;
249 #ifdef USE_PCM
250 if (phandle && (pfds[nseqs].revents & POLLOUT)) {
251 if (snd_pcm_writei(phandle, pbuf, period_size) != period_size) {
252 fprintf(stderr, "Playback write error!!\n");
253 exit(0);
254 }
255 }
256 #endif
257 if (pfds[0].revents & POLLOUT)
258 snd_seq_drain_output(handle);
259 if (pfds[0].revents & POLLIN) {
260 do {
261 if ((err = snd_seq_event_input(handle, &ev))<0)
262 break;
263 if (!ev)
264 continue;
265 if (ev->type == SND_SEQ_EVENT_ECHO)
266 send_event(handle, queue, client, port, &addr, &time);
267 decode_event(ev);
268 snd_seq_free_event(ev);
269 } while (err > 0);
270 }
271 }
272 }
273