Changeset b4cbef1 in mainline for uspace/lib/libc/generic/async.c
- Timestamp:
- 2010-02-03T16:52:37Z (15 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- 3b3e776, eda925a
- Parents:
- 472c09d
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/lib/libc/generic/async.c
r472c09d rb4cbef1 1287 1287 } 1288 1288 1289 /** Wrapper for forwarding any read request 1290 * 1291 * 1292 */ 1293 int async_data_read_forward_fast(int phoneid, ipcarg_t method, ipcarg_t arg1, 1294 ipcarg_t arg2, ipcarg_t arg3, ipcarg_t arg4, ipc_call_t *dataptr) 1295 { 1296 ipc_callid_t callid; 1297 if (!async_data_read_receive(&callid, NULL)) { 1298 ipc_answer_0(callid, EINVAL); 1299 return EINVAL; 1300 } 1301 1302 aid_t msg = async_send_fast(phoneid, method, arg1, arg2, arg3, arg4, 1303 dataptr); 1304 if (msg == 0) { 1305 ipc_answer_0(callid, EINVAL); 1306 return EINVAL; 1307 } 1308 1309 int retval = ipc_forward_fast(callid, phoneid, 0, 0, 0, 1310 IPC_FF_ROUTE_FROM_ME); 1311 if (retval != EOK) { 1312 ipc_answer_0(callid, retval); 1313 return retval; 1314 } 1315 1316 ipcarg_t rc; 1317 async_wait_for(msg, &rc); 1318 1319 return (int) rc; 1320 } 1321 1289 1322 /** Wrapper for making IPC_M_DATA_WRITE calls using the async framework. 1290 1323 * 1291 * @param phoneid Phone that will be used to contact the receiving side. 1292 * @param src Address of the beginning of the source buffer. 1293 * @param size Size of the source buffer. 1294 * 1295 * @return Zero on success or a negative error code from errno.h. 1324 * @param phoneid Phone that will be used to contact the receiving side. 1325 * @param src Address of the beginning of the source buffer. 1326 * @param size Size of the source buffer. 1327 * 1328 * @return Zero on success or a negative error code from errno.h. 1329 * 1296 1330 */ 1297 1331 int async_data_write_start(int phoneid, const void *src, size_t size) … … 1308 1342 * So far, this wrapper is to be used from within a connection fibril. 1309 1343 * 1310 * @param callid Storage where the hash of the IPC_M_DATA_WRITE call will 1311 * be stored. 1312 * @param size Storage where the suggested size will be stored. May be 1313 * NULL 1314 * 1315 * @return Non-zero on success, zero on failure. 1344 * @param callid Storage where the hash of the IPC_M_DATA_WRITE call will 1345 * be stored. 1346 * @param size Storage where the suggested size will be stored. May be 1347 * NULL 1348 * 1349 * @return Non-zero on success, zero on failure. 1350 * 1316 1351 */ 1317 1352 int async_data_write_receive(ipc_callid_t *callid, size_t *size) … … 1320 1355 1321 1356 assert(callid); 1322 1357 1323 1358 *callid = async_get_call(&data); 1324 1359 if (IPC_GET_METHOD(data) != IPC_M_DATA_WRITE) 1325 1360 return 0; 1361 1326 1362 if (size) 1327 1363 *size = (size_t) IPC_GET_ARG2(data); 1364 1328 1365 return 1; 1329 1366 } … … 1334 1371 * so that the user doesn't have to remember the meaning of each IPC argument. 1335 1372 * 1336 * @param callid Hash of the IPC_M_DATA_WRITE call to answer. 1337 * @param dst Final destination address for the IPC_M_DATA_WRITE call. 1338 * @param size Final size for the IPC_M_DATA_WRITE call. 1339 * 1340 * @return Zero on success or a value from @ref errno.h on failure. 1373 * @param callid Hash of the IPC_M_DATA_WRITE call to answer. 1374 * @param dst Final destination address for the IPC_M_DATA_WRITE call. 1375 * @param size Final size for the IPC_M_DATA_WRITE call. 1376 * 1377 * @return Zero on success or a value from @ref errno.h on failure. 1378 * 1341 1379 */ 1342 1380 int async_data_write_finalize(ipc_callid_t callid, void *dst, size_t size) … … 1345 1383 } 1346 1384 1347 /** Wrapper for receiving binary data via the async_data_write_*1385 /** Wrapper for receiving binary data 1348 1386 * 1349 1387 * This wrapper only makes it more comfortable to use async_data_write_* 1350 * functions to receive b lobs.1388 * functions to receive binary data. 1351 1389 * 1352 1390 * @param data Pointer to data pointer (which should be later disposed 1353 1391 * by free()). If the operation fails, the pointer is not 1354 1392 * touched. 1393 * @param min_size Minimum size (in bytes) of the data to receive. 1355 1394 * @param max_size Maximum size (in bytes) of the data to receive. 0 means 1356 1395 * no limit. … … 1362 1401 * 1363 1402 */ 1364 int async_data_receive(void **data, const size_t m ax_size,1365 const size_t granularity, size_t *received)1403 int async_data_receive(void **data, const size_t min_size, 1404 const size_t max_size, const size_t granularity, size_t *received) 1366 1405 { 1367 1406 ipc_callid_t callid; … … 1372 1411 } 1373 1412 1413 if (size < min_size) { 1414 ipc_answer_0(callid, EINVAL); 1415 return EINVAL; 1416 } 1417 1374 1418 if ((max_size > 0) && (size > max_size)) { 1375 1419 ipc_answer_0(callid, EINVAL); … … 1401 1445 } 1402 1446 1403 /** Wrapper for receiving strings via the async_data_write_*1447 /** Wrapper for receiving strings 1404 1448 * 1405 1449 * This wrapper only makes it more comfortable to use async_data_write_* … … 1450 1494 } 1451 1495 1496 /** Wrapper for voiding any data that is about to be received 1497 * 1498 * This wrapper can be used to void any pending data 1499 * 1500 * @param retval Error value from @ref errno.h to be returned to the caller. 1501 * 1502 */ 1503 void async_data_void(const int retval) 1504 { 1505 ipc_callid_t callid; 1506 async_data_write_receive(&callid, NULL); 1507 ipc_answer_0(callid, retval); 1508 } 1509 1510 /** Wrapper for forwarding any data that is about to be received 1511 * 1512 * 1513 */ 1514 int async_data_forward_fast(int phoneid, ipcarg_t method, ipcarg_t arg1, 1515 ipcarg_t arg2, ipcarg_t arg3, ipcarg_t arg4, ipc_call_t *dataptr) 1516 { 1517 ipc_callid_t callid; 1518 if (!async_data_write_receive(&callid, NULL)) { 1519 ipc_answer_0(callid, EINVAL); 1520 return EINVAL; 1521 } 1522 1523 aid_t msg = async_send_fast(phoneid, method, arg1, arg2, arg3, arg4, 1524 dataptr); 1525 if (msg == 0) { 1526 ipc_answer_0(callid, EINVAL); 1527 return EINVAL; 1528 } 1529 1530 int retval = ipc_forward_fast(callid, phoneid, 0, 0, 0, 1531 IPC_FF_ROUTE_FROM_ME); 1532 if (retval != EOK) { 1533 ipc_answer_0(callid, retval); 1534 return retval; 1535 } 1536 1537 ipcarg_t rc; 1538 async_wait_for(msg, &rc); 1539 1540 return (int) rc; 1541 } 1542 1452 1543 /** @} 1453 1544 */
Note:
See TracChangeset
for help on using the changeset viewer.