source: mainline/uspace/lib/c/generic/device/char_dev.c@ 4a4c8bcf

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since 4a4c8bcf was 79ae36dd, checked in by Martin Decky <martin@…>, 14 years ago

new async framework with integrated exchange tracking

  • strict isolation between low-level IPC and high-level async framework with integrated exchange tracking
    • each IPC connection is represented by an async_sess_t structure
    • each IPC exchange is represented by an async_exch_t structure
    • exchange management is either based on atomic messages (EXCHANGE_ATOMIC), locking (EXCHANGE_SERIALIZE) or connection cloning (EXCHANGE_CLONE)
  • async_obsolete: temporary compatibility layer to keep old async clients working (several pieces of code are currently broken, but only non-essential functionality)
  • IPC_M_PHONE_HANGUP is now method no. 0 (for elegant boolean evaluation)
  • IPC_M_DEBUG_ALL has been renamed to IPC_M_DEBUG
  • IPC_M_PING has been removed (VFS protocol now has VFS_IN_PING)
  • console routines in libc have been rewritten for better abstraction
  • additional use for libc-private header files (FILE structure opaque to the client)
  • various cstyle changes (typos, indentation, missing externs in header files, improved comments, etc.)
  • Property mode set to 100644
File size: 3.8 KB
Line 
1/*
2 * Copyright (c) 2010 Lenka Trochtova
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 *
9 * - Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * - Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 * - The name of the author may not be used to endorse or promote products
15 * derived from this software without specific prior written permission.
16 *
17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 */
28
29 /** @addtogroup libc
30 * @{
31 */
32/** @file
33 */
34
35#include <ipc/dev_iface.h>
36#include <device/char_dev.h>
37#include <errno.h>
38#include <async.h>
39#include <malloc.h>
40#include <stdio.h>
41
42/** Read to or write from device.
43 *
44 * Helper function to read to or write from a device
45 * using its character interface.
46 *
47 * @param sess Session to the device.
48 * @param buf Buffer for the data read from or written to the device.
49 * @param size Maximum size of data (in bytes) to be read or written.
50 * @param read Read from the device if true, write to it otherwise.
51 *
52 * @return Non-negative number of bytes actually read from or
53 * written to the device on success, negative error number
54 * otherwise.
55 *
56 */
57static ssize_t char_dev_rw(async_sess_t *sess, void *buf, size_t size, bool read)
58{
59 ipc_call_t answer;
60 aid_t req;
61 int ret;
62
63 async_exch_t *exch = async_exchange_begin(sess);
64
65 if (read) {
66 req = async_send_1(exch, DEV_IFACE_ID(CHAR_DEV_IFACE),
67 CHAR_DEV_READ, &answer);
68 ret = async_data_read_start(exch, buf, size);
69 } else {
70 req = async_send_1(exch, DEV_IFACE_ID(CHAR_DEV_IFACE),
71 CHAR_DEV_WRITE, &answer);
72 ret = async_data_write_start(exch, buf, size);
73 }
74
75 async_exchange_end(exch);
76
77 sysarg_t rc;
78 if (ret != EOK) {
79 async_wait_for(req, &rc);
80 if (rc == EOK)
81 return (ssize_t) ret;
82
83 return (ssize_t) rc;
84 }
85
86 async_wait_for(req, &rc);
87
88 ret = (int) rc;
89 if (ret != EOK)
90 return (ssize_t) ret;
91
92 return (ssize_t) IPC_GET_ARG1(answer);
93}
94
95/** Read from character device.
96 *
97 * @param sess Session to the device.
98 * @param buf Output buffer for the data read from the device.
99 * @param size Maximum size (in bytes) of the data to be read.
100 *
101 * @return Non-negative number of bytes actually read from the
102 * device on success, negative error number otherwise.
103 *
104 */
105ssize_t char_dev_read(async_sess_t *sess, void *buf, size_t size)
106{
107 return char_dev_rw(sess, buf, size, true);
108}
109
110/** Write to character device.
111 *
112 * @param sess Session to the device.
113 * @param buf Input buffer containg the data to be written to the
114 * device.
115 * @param size Maximum size (in bytes) of the data to be written.
116 *
117 * @return Non-negative number of bytes actually written to the
118 * device on success, negative error number otherwise.
119 *
120 */
121ssize_t char_dev_write(async_sess_t *sess, void *buf, size_t size)
122{
123 return char_dev_rw(sess, buf, size, false);
124}
125
126/** @}
127 */
Note: See TracBrowser for help on using the repository browser.