source: roaraudio/libroar/vio.c @ 4831:be687ef15976

Last change on this file since 4831:be687ef15976 was 4831:be687ef15976, checked in by phi, 13 years ago

fixed a VIO ctl ID conflict

File size: 18.6 KB
Line 
1//vio.c:
2
3/*
4 *      Copyright (C) Philipp 'ph3-der-loewe' Schafft - 2008-2011
5 *
6 *  This file is part of libroar a part of RoarAudio,
7 *  a cross-platform sound system for both, home and professional use.
8 *  See README for details.
9 *
10 *  This file is free software; you can redistribute it and/or modify
11 *  it under the terms of the GNU General Public License version 3
12 *  as published by the Free Software Foundation.
13 *
14 *  libroar is distributed in the hope that it will be useful,
15 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
16 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
17 *  GNU General Public License for more details.
18 *
19 *  You should have received a copy of the GNU General Public License
20 *  along with this software; see the file COPYING.  If not, write to
21 *  the Free Software Foundation, 51 Franklin Street, Fifth Floor,
22 *  Boston, MA 02110-1301, USA.
23 *
24 *  NOTE for everyone want's to change something and send patches:
25 *  read README and HACKING! There a addition information on
26 *  the license of this document you need to read before you send
27 *  any patches.
28 *
29 *  NOTE for uses of non-GPL (LGPL,...) software using libesd, libartsc
30 *  or libpulse*:
31 *  The libs libroaresd, libroararts and libroarpulse link this lib
32 *  and are therefore GPL. Because of this it may be illigal to use
33 *  them with any software that uses libesd, libartsc or libpulse*.
34 */
35
36#include "libroar.h"
37
38#ifdef ROAR_HAVE_H_SYS_IOCTL
39#include <sys/ioctl.h>
40#endif
41
42#ifdef ROAR_HAVE_IO_POSIX
43#define _CAN_OPERATE
44#endif
45
46int roar_vio_init_calls (struct roar_vio_calls * calls) {
47#ifdef _CAN_OPERATE
48 if ( calls == NULL )
49  return -1;
50
51 memset((void*)calls, 0, sizeof(struct roar_vio_calls));
52
53/*
54 calls->read  = (ssize_t (*)(int fd, void *buf, size_t count,      void * inst))read;
55 calls->write = (ssize_t (*)(int fd, void *buf, size_t count,      void * inst))write;
56 calls->lseek = (off_t   (*)(int fildes, off_t offset, int whence, void * inst))lseek;
57*/
58
59 calls->read     = roar_vio_basic_read;
60 calls->write    = roar_vio_basic_write;
61 calls->lseek    = roar_vio_basic_lseek;
62 calls->nonblock = roar_vio_basic_nonblock;
63 calls->sync     = roar_vio_basic_sync;
64 calls->ctl      = roar_vio_basic_ctl;
65 calls->close    = roar_vio_basic_close;
66
67 return 0;
68#else
69 return -1;
70#endif
71}
72
73int roar_vio_set_inst (struct roar_vio_calls * vio, void * inst) {
74 if ( vio == NULL )
75  return -1;
76
77 vio->inst = inst;
78
79 return 0;
80}
81
82int roar_vio_set_fh   (struct roar_vio_calls * vio, int fh) {
83 return roar_vio_set_inst(vio, (void*)(ROAR_INSTINT)(fh + 1));
84}
85
86int roar_vio_get_fh   (struct roar_vio_calls * vio) {
87 if ( vio == NULL )
88  return -1;
89
90 return ((int)(ROAR_INSTINT)vio->inst) - 1;
91}
92
93
94ssize_t roar_vio_read (struct roar_vio_calls * vio, void *buf, size_t count) {
95 ROAR_DBG("roar_vio_read(vio=%p, buf=%p, count=%u) = ?", vio, buf, (unsigned int)count);
96
97 if ( vio == NULL )
98  return -1;
99
100 if ( vio->read == NULL )
101  return -1;
102
103 return vio->read(vio, buf, count);
104}
105
106ssize_t roar_vio_write(struct roar_vio_calls * vio, void *buf, size_t count) {
107 ROAR_DBG("roar_vio_write(vio=%p, buf=%p, count=%u) = ?", vio, buf, (unsigned int)count);
108
109 if ( vio == NULL )
110  return -1;
111
112 if ( vio->write == NULL )
113  return -1;
114
115 return vio->write(vio, buf, count);
116}
117
118off_t   roar_vio_lseek(struct roar_vio_calls * vio, off_t offset, int whence) {
119 ROAR_DBG("roar_vio_lseek(vio=%p, offset=%u, whence=%i) = ?", vio, (unsigned int)offset, whence);
120
121 if ( vio == NULL )
122  return -1;
123
124 if ( vio->lseek == NULL )
125  return -1;
126
127 return vio->lseek(vio, offset, whence);
128}
129
130int     roar_vio_nonblock(struct roar_vio_calls * vio, int state) {
131 ROAR_DBG("roar_vio_nonblock(vio=%p, state=%i) = ?", vio, state);
132
133 if ( vio == NULL )
134  return -1;
135
136 if ( vio->nonblock == NULL )
137  return -1;
138
139 return vio->nonblock(vio, state);
140}
141
142int     roar_vio_sync    (struct roar_vio_calls * vio) {
143 ROAR_DBG("roar_vio_sync(vio=%p) = ?", vio);
144
145 if ( vio == NULL )
146  return -1;
147
148 if ( vio->sync == NULL )
149  return -1;
150
151 return vio->sync(vio);
152}
153
154int     roar_vio_ctl     (struct roar_vio_calls * vio, int cmd, void * data) {
155 ROAR_DBG("roar_vio_ctl(vio=%p, cmd=%i, data=%p) = ?", vio, cmd, data);
156
157 if ( vio == NULL )
158  return -1;
159
160 ROAR_DBG("roar_vio_ctl(vio=%p, cmd=0x%.8x, data=%p): vio->ctl=%p", vio, cmd, data, vio->ctl);
161
162 switch (cmd) {
163  case ROAR_VIO_CTL_CONFLICTING_ID_0:
164  case ROAR_VIO_CTL_CONFLICTING_ID_1:
165    ROAR_ERR("roar_vio_ctl(vio=%p, cmd=0x%.8x, data=%p): Your progam uses a VIO ctl call with a conflicting ID.", vio, cmd, data);
166    ROAR_ERR("roar_vio_ctl(vio=%p, cmd=0x%.8x, data=%p): Please recompile your program to fix this. (No additional steps are required beside that.)", vio, cmd, data);
167    ROAR_DBG("roar_vio_ctl(vio=%p, cmd=0x%.8x, data=%p) = -1", vio, cmd, data);
168    return -1;
169   break;
170 }
171
172 if ( vio->ctl == NULL )
173  return -1;
174
175 return vio->ctl(vio, cmd, data);
176}
177
178int     roar_vio_close    (struct roar_vio_calls * vio) {
179 ROAR_DBG("roar_vio_close(vio=%p) = ?", vio);
180
181 if ( vio == NULL )
182  return -1;
183
184 if ( vio->close == NULL )
185  return -1;
186
187 return vio->close(vio);
188}
189
190// specal commands:
191int     roar_vio_accept  (struct roar_vio_calls * calls, struct roar_vio_calls * dst) {
192 if (dst == NULL || calls == NULL)
193  return -1;
194
195 return roar_vio_ctl(dst, ROAR_VIO_CTL_ACCEPT, calls);
196}
197
198int     roar_vio_shutdown(struct roar_vio_calls * vio,   int how) {
199 return roar_vio_ctl(vio, ROAR_VIO_CTL_SHUTDOWN, &how);
200}
201
202// converters:
203int     roar_vio_open_file     (struct roar_vio_calls * calls, char * filename, int flags, mode_t mode) {
204#ifdef _CAN_OPERATE
205 int fh;
206
207 if ( calls == NULL || filename == NULL )
208  return -1;
209
210#ifdef ROAR_TARGET_WIN32
211 flags |= O_BINARY;
212#endif
213
214 if ( (fh = open(filename, flags, mode)) == -1 )
215  return -1;
216
217 if ( roar_vio_open_fh(calls, fh) == -1 ) {
218  close(fh);
219  return -1;
220 }
221
222 return 0;
223#else
224 return -1;
225#endif
226}
227
228int     roar_vio_open_fh       (struct roar_vio_calls * calls, int fh) {
229 if ( calls == NULL )
230  return -1;
231
232 if ( roar_vio_init_calls(calls) == -1 )
233  return -1;
234
235 return roar_vio_set_fh(calls, fh);
236}
237
238int     roar_vio_open_fh_socket(struct roar_vio_calls * calls, int fh) {
239 if ( calls == NULL )
240  return -1;
241
242 if ( roar_vio_open_fh(calls, fh) == -1 )
243  return -1;
244
245#ifdef ROAR_TARGET_WIN32
246 calls->read     = roar_vio_winsock_read;
247 calls->write    = roar_vio_winsock_write;
248 calls->nonblock = roar_vio_winsock_nonblock;
249 calls->sync     = roar_vio_winsock_sync;
250 calls->ctl      = roar_vio_winsock_ctl;
251 calls->close    = roar_vio_winsock_close;
252#else
253 calls->sync     = roar_vio_null_sync;
254#endif
255
256 return 0;
257}
258
259int     roar_vio_open_socket   (struct roar_vio_calls * calls, char * host, int port) {
260 int fh;
261
262 if ( calls == NULL )
263  return -1;
264
265 if ( (fh = roar_socket_connect(host, port)) == -1 )
266  return -1;
267
268 return roar_vio_open_fh_socket(calls, fh);
269}
270
271int     roar_vio_open_socket_listen(struct roar_vio_calls * calls, int type, char * host, int port) {
272 int fh;
273
274 if ( calls == NULL )
275  return -1;
276
277 if ( (fh = roar_socket_listen(type, host, port)) == -1 )
278  return -1;
279
280 return roar_vio_open_fh_socket(calls, fh);
281}
282
283int     roar_vio_simple_stream (struct roar_vio_calls * calls, int rate, int channels, int bits, int codec,
284                                                               char * server, int dir, char * name) {
285 int fh;
286
287 if ( calls == NULL )
288  return -1;
289
290 roar_libroar_nowarn();
291 if ( (fh = roar_simple_stream(rate, channels, bits, codec, server, dir, name)) == -1 ) {
292  roar_libroar_warn();
293  return -1;
294 }
295 roar_libroar_warn();
296
297 return roar_vio_open_fh_socket(calls, fh);
298}
299
300int     roar_vio_simple_new_stream_obj (struct roar_vio_calls * calls,
301                                        struct roar_connection * con,
302                                        struct roar_stream * s,
303                                        int rate, int channels, int bits, int codec, int dir) {
304 struct roar_stream stream;
305 int fh;
306
307 ROAR_DBG("roar_vio_simple_new_stream_obj(*) = ?");
308
309 if ( calls == NULL )
310  return -1;
311
312 if ( s == NULL )
313  s = &stream;
314
315 roar_libroar_nowarn();
316 if ( (fh = roar_simple_new_stream_obj(con, s, rate, channels, bits, codec, dir)) == -1 ) {
317  roar_libroar_warn();
318  ROAR_DBG("roar_vio_simple_new_stream_obj(*) = -1");
319  return -1;
320 }
321 roar_libroar_warn();
322
323 ROAR_DBG("roar_vio_simple_new_stream_obj(*): fh=%i", fh);
324
325 return roar_vio_open_fh_socket(calls, fh);
326}
327
328// VIOs:
329
330// basic
331ssize_t roar_vio_basic_read (struct roar_vio_calls * vio, void *buf, size_t count) {
332#ifdef _CAN_OPERATE
333 return read(roar_vio_get_fh(vio), buf, count);
334#else
335 return -1;
336#endif
337}
338
339ssize_t roar_vio_basic_write(struct roar_vio_calls * vio, void *buf, size_t count) {
340#ifdef _CAN_OPERATE
341 return write(roar_vio_get_fh(vio), buf, count);
342#else
343 return -1;
344#endif
345}
346
347off_t   roar_vio_basic_lseek(struct roar_vio_calls * vio, off_t offset, int whence) {
348#ifdef _CAN_OPERATE
349 return lseek(roar_vio_get_fh(vio), offset, whence);
350#else
351 return -1;
352#endif
353}
354
355int     roar_vio_basic_nonblock(struct roar_vio_calls * vio, int state) {
356 if ( roar_socket_nonblock(roar_vio_get_fh(vio), state) == -1 )
357  return -1;
358
359 if ( state == ROAR_SOCKET_NONBLOCK )
360  return 0;
361
362 roar_vio_sync(vio);
363
364 return 0;
365}
366
367int     roar_vio_basic_sync    (struct roar_vio_calls * vio) {
368#ifdef ROAR_FDATASYNC
369 return ROAR_FDATASYNC(roar_vio_get_fh(vio));
370#else
371 return 0;
372#endif
373}
374
375int     roar_vio_basic_ctl     (struct roar_vio_calls * vio, int cmd, void * data) {
376#ifdef ROAR_HAVE_H_SYS_IOCTL
377 struct roar_vio_sysio_ioctl * sysioctl;
378#endif
379#if defined(ROAR_HAVE_GETSOCKOPT) || defined(ROAR_HAVE_SETSOCKOPT)
380 struct roar_vio_sysio_sockopt  * syssockopt;
381#endif
382 int tmp;
383 int s_r = 0, s_w = 0;
384#if defined(ROAR_HAVE_GETSOCKNAME) || defined(ROAR_HAVE_GETPEERNAME)
385 union {
386  struct sockaddr     sa;
387#if defined(ROAR_HAVE_IPV4) || defined(ROAR_HAVE_IPV6)
388  struct sockaddr_in  in;
389#endif
390#ifdef ROAR_HAVE_UNIX
391  struct sockaddr_un  un;
392#endif
393#ifdef ROAR_HAVE_LIBDNET
394  struct sockaddr_dn  dn;
395#endif
396#ifdef ROAR_HAVE_IPV6
397  struct sockaddr_in6 in6;
398#endif
399#ifdef ROAR_HAVE_IPX
400  struct sockaddr_ipx ipx;
401#endif
402 } sockaddr;
403 socklen_t socklen;
404 struct roar_sockname * rsockname;
405#endif
406
407 if ( vio == NULL || cmd == -1 )
408  return -1;
409
410 ROAR_DBG("roar_vio_basic_ctl(vio=%p, cmd=0x%.8x, data=%p) = ?", vio, cmd, data);
411
412 switch (cmd) {
413  case ROAR_VIO_CTL_GET_NAME:
414    if ( data == NULL )
415     return -1;
416
417    *(char**)data = "basic";
418    return 0;
419   break;
420  case ROAR_VIO_CTL_GET_FH:
421  case ROAR_VIO_CTL_GET_READ_FH:
422  case ROAR_VIO_CTL_GET_WRITE_FH:
423  case ROAR_VIO_CTL_GET_SELECT_FH:
424  case ROAR_VIO_CTL_GET_SELECT_READ_FH:
425  case ROAR_VIO_CTL_GET_SELECT_WRITE_FH:
426    ROAR_DBG("roar_vio_basic_ctl(vio=%p, cmd=ROAR_VIO_CTL_GET_*FH(0x%.8x), data=%p) = 0 // fh=%i", vio, cmd, data, roar_vio_get_fh(vio));
427    *(int*)data = roar_vio_get_fh(vio);
428    return 0;
429   break;
430  case ROAR_VIO_CTL_SET_NOSYNC:
431    vio->sync = NULL;
432    return 0;
433   break;
434  case ROAR_VIO_CTL_ACCEPT:
435    tmp = ROAR_ACCEPT(roar_vio_get_fh(vio), NULL, 0);
436    if ( tmp == -1 )
437     return -1;
438
439    // most proably a socket.
440    if ( roar_vio_open_fh_socket(data, tmp) == -1 ) {
441#ifdef ROAR_TARGET_WIN32
442     closesocket(tmp);
443#else
444     close(tmp);
445#endif
446     return -1;
447    }
448
449    return 0;
450   break;
451  case ROAR_VIO_CTL_SHUTDOWN:
452    tmp = *(int*)data;
453
454    if ( tmp & ROAR_VIO_SHUTDOWN_READ ) {
455     s_r = 1;
456     tmp -= ROAR_VIO_SHUTDOWN_READ;
457    }
458
459    if ( tmp & ROAR_VIO_SHUTDOWN_WRITE ) {
460     s_w = 1;
461     tmp -= ROAR_VIO_SHUTDOWN_WRITE;
462    }
463
464    if ( tmp != 0 ) /* we currently only support R and W shutdowns */
465     return -1;
466
467    if ( s_r && s_w ) {
468     tmp = SHUT_RDWR;
469    } else if ( s_r ) {
470     tmp = SHUT_RD;
471    } else if ( s_w ) {
472     tmp = SHUT_WR;
473    } else {
474     return 0; // nothing to do.
475    }
476
477    return ROAR_SHUTDOWN(roar_vio_get_fh(vio), tmp);
478   break;
479#if defined(ROAR_HAVE_GETSOCKNAME) || defined(ROAR_HAVE_GETPEERNAME)
480  case ROAR_VIO_CTL_GET_SOCKNAME:
481  case ROAR_VIO_CTL_GET_PEERNAME:
482    if ( data == NULL )
483     return -1;
484
485    rsockname = data;
486
487    socklen = sizeof(sockaddr);
488
489    if ( cmd == ROAR_VIO_CTL_GET_SOCKNAME ) {
490#ifdef ROAR_HAVE_GETSOCKNAME
491     tmp = getsockname(roar_vio_get_fh(vio), &(sockaddr.sa), &socklen);
492#else
493     return -1;
494#endif
495    } else if ( cmd == ROAR_VIO_CTL_GET_PEERNAME ) {
496#ifdef ROAR_HAVE_GETPEERNAME
497     tmp = getpeername(roar_vio_get_fh(vio), &(sockaddr.sa), &socklen);
498#else
499     return -1;
500#endif
501    } else {
502     return -1;
503    }
504
505    if ( tmp == -1 )
506     return -1;
507
508    memset(rsockname, 0, sizeof(struct roar_sockname));
509
510    switch (sockaddr.sa.sa_family) {
511#if defined(AF_UNIX) && defined(ROAR_HAVE_UNIX)
512     case AF_UNIX:
513       rsockname->type = ROAR_SOCKET_TYPE_UNIX;
514       if ( sockaddr.un.sun_path[0] == 0 ) {
515        rsockname->addr = roar_mm_malloc(sizeof(sockaddr.un.sun_path));
516        if ( rsockname->addr == NULL )
517         return -1;
518        memcpy(rsockname->addr, sockaddr.un.sun_path, sizeof(sockaddr.un.sun_path));
519       } else {
520        rsockname->addr = roar_mm_strdup(sockaddr.un.sun_path);
521       }
522      break;
523#endif
524#if defined(AF_DECnet) && defined(ROAR_HAVE_LIBDNET)
525     case AF_DECnet:
526       rsockname->type = ROAR_SOCKET_TYPE_DECNET;
527
528       if ( sockaddr.dn.sdn_add.a_len != 2 )
529        return -1;
530
531       rsockname->addr = roar_mm_malloc(28);
532       if ( rsockname->addr == NULL )
533        return -1;
534
535       snprintf(rsockname->addr, 28, "%i.%i::",
536                 sockaddr.dn.sdn_add.a_addr[1] >> 2,
537                 sockaddr.dn.sdn_add.a_addr[0] + ((sockaddr.dn.sdn_add.a_addr[1] & 0x03) << 8));
538
539       rsockname->port = sockaddr.dn.sdn_objnum;
540       if ( sockaddr.dn.sdn_objnum == 0 ) {
541        tmp = strlen(rsockname->addr);
542        memcpy(rsockname->addr + tmp, sockaddr.dn.sdn_objname, sockaddr.dn.sdn_objnamel);
543        rsockname->addr[tmp + sockaddr.dn.sdn_objnamel] = 0;
544       }
545      break;
546#endif
547#if defined(AF_INET) && (defined(ROAR_HAVE_IPV4) || defined(ROAR_HAVE_IPV6))
548     case AF_INET:
549       rsockname->type = ROAR_SOCKET_TYPE_INET;
550       rsockname->port = ntohs(sockaddr.in.sin_port);
551       rsockname->addr = roar_mm_strdup(inet_ntoa(sockaddr.in.sin_addr));
552      break;
553#endif
554#if defined(AF_INET6) && defined(ROAR_HAVE_IPV6)
555     case AF_INET6:
556       rsockname->type = ROAR_SOCKET_TYPE_INET6;
557       rsockname->port = ntohs(sockaddr.in6.sin6_port);
558      break;
559#endif
560     default:
561       return -1;
562    }
563    return 0;
564#endif
565   break;
566#ifdef ROAR_HAVE_H_SYS_IOCTL
567  case ROAR_VIO_CTL_SYSIO_IOCTL:
568    sysioctl = data;
569    return ioctl(roar_vio_get_fh(vio), sysioctl->cmd, sysioctl->argp);
570   break;
571#endif
572#ifdef ROAR_HAVE_GETSOCKOPT
573  case ROAR_VIO_CTL_GET_SYSIO_SOCKOPT:
574    syssockopt = data;
575    return getsockopt(roar_vio_get_fh(vio), syssockopt->level, syssockopt->optname, syssockopt->optval, &(syssockopt->optlen));
576   break;
577#endif
578#ifdef ROAR_HAVE_SETSOCKOPT
579  case ROAR_VIO_CTL_SET_SYSIO_SOCKOPT:
580    syssockopt = data;
581    return setsockopt(roar_vio_get_fh(vio), syssockopt->level, syssockopt->optname, syssockopt->optval, syssockopt->optlen);
582   break;
583#endif
584 }
585
586 return -1;
587}
588
589int     roar_vio_basic_close    (struct roar_vio_calls * vio) {
590#ifdef _CAN_OPERATE
591 if ( roar_vio_get_fh(vio) != -1 )
592  return close(roar_vio_get_fh(vio));
593
594 return 0;
595#else
596 return -1;
597#endif
598}
599
600// null
601ssize_t roar_vio_null_rw    (struct roar_vio_calls * vio, void *buf, size_t count) {
602 if ( vio == NULL || buf == NULL )
603  return -1;
604
605 return 0;
606}
607
608int     roar_vio_null_sync    (struct roar_vio_calls * vio) {
609 return 0;
610}
611
612// pass
613int     roar_vio_open_pass    (struct roar_vio_calls * calls, struct roar_vio_calls * dst) {
614 if ( calls == NULL )
615  return -1;
616
617 memset((void*)calls, 0, sizeof(struct roar_vio_calls));
618
619 calls->read     = roar_vio_pass_read;
620 calls->write    = roar_vio_pass_write;
621 calls->lseek    = roar_vio_pass_lseek;
622 calls->nonblock = roar_vio_pass_nonblock;
623 calls->sync     = roar_vio_pass_sync;
624 calls->ctl      = roar_vio_pass_ctl;
625 calls->close    = roar_vio_pass_close;
626
627 calls->inst     = dst;
628
629 return 0;
630}
631
632ssize_t roar_vio_pass_read (struct roar_vio_calls * vio, void *buf, size_t count) {
633 return roar_vio_read((struct roar_vio_calls *) vio->inst, buf, count);
634}
635
636ssize_t roar_vio_pass_write(struct roar_vio_calls * vio, void *buf, size_t count) {
637 return roar_vio_write((struct roar_vio_calls *) vio->inst, buf, count);
638}
639
640off_t   roar_vio_pass_lseek(struct roar_vio_calls * vio, off_t offset, int whence) {
641 return roar_vio_lseek((struct roar_vio_calls *) vio->inst, offset, whence);
642}
643
644int     roar_vio_pass_nonblock(struct roar_vio_calls * vio, int state) {
645 return roar_vio_nonblock((struct roar_vio_calls *) vio->inst, state);
646}
647
648int     roar_vio_pass_sync    (struct roar_vio_calls * vio) {
649 return roar_vio_sync((struct roar_vio_calls *) vio->inst);
650}
651
652int     roar_vio_pass_ctl     (struct roar_vio_calls * vio, int cmd, void * data) {
653 if (vio == NULL || cmd == -1)
654  return -1;
655
656 ROAR_DBG("roar_vio_pass_ctl(vio=%p, cmd=0x%.8x, data=%p) = ?", vio, cmd, data);
657
658 switch (cmd) {
659  case ROAR_VIO_CTL_GET_NAME:
660    if ( data == NULL )
661     return -1;
662
663    // dirty trick to get real name...
664    if ( vio->read == roar_vio_re_read ) {
665     *(char**)data = "re";
666    } else {
667     *(char**)data = "pass";
668    }
669    return 0;
670   break;
671  case ROAR_VIO_CTL_GET_NEXT:
672    *(struct roar_vio_calls **)data = vio->inst;
673    return 0;
674   break;
675  case ROAR_VIO_CTL_SET_NEXT:
676    vio->inst = *(struct roar_vio_calls **)data;
677    return 0;
678   break;
679 }
680
681 return roar_vio_ctl((struct roar_vio_calls *) vio->inst, cmd, data);
682}
683
684int     roar_vio_pass_close   (struct roar_vio_calls * vio) {
685 return roar_vio_close((struct roar_vio_calls *) vio->inst);
686}
687
688
689// re
690int     roar_vio_open_re (struct roar_vio_calls * calls, struct roar_vio_calls * dst) {
691 if ( roar_vio_open_pass(calls, dst) == -1 )
692  return -1;
693
694 calls->read  = roar_vio_re_read;
695 calls->write = roar_vio_re_write;
696 calls->lseek = roar_vio_re_lseek;
697
698 return 0;
699}
700ssize_t roar_vio_re_read (struct roar_vio_calls * vio, void *buf, size_t count) {
701  size_t len =  0;
702 ssize_t r   = -1;
703
704 if ( vio == NULL )
705  return -1;
706
707 if ( vio->inst == NULL )
708  return -1;
709
710 errno = 0;
711
712 while ( (r = roar_vio_read((struct roar_vio_calls *) vio->inst, buf, count)) > 0 ) {
713  len   += r;
714  buf   += r;
715  count -= r;
716  if ( count == 0 )
717   break;
718 }
719
720 if ( len == 0 && r == -1 )
721  return -1;
722
723 return len;
724}
725
726ssize_t roar_vio_re_write(struct roar_vio_calls * vio, void *buf, size_t count) {
727  size_t len =  0;
728 ssize_t r   = -1;
729
730 if ( vio == NULL )
731  return -1;
732
733 if ( vio->inst == NULL )
734  return -1;
735
736 errno = 0;
737
738 while ( (r = roar_vio_write((struct roar_vio_calls *) vio->inst, buf, count)) > 0 ) {
739  len   += r;
740  buf   += r;
741  count -= r;
742  if ( count == 0 )
743   break;
744 }
745
746 if ( len == 0 && r == -1 )
747  return -1;
748
749 return len;
750}
751
752// TODO: we should do a some more intelgent thing here.
753off_t   roar_vio_re_lseek(struct roar_vio_calls * vio, off_t offset, int whence) {
754 return roar_vio_lseek((struct roar_vio_calls *) vio->inst, offset, whence);
755}
756
757//ll
Note: See TracBrowser for help on using the repository browser.