VirtualBox

source: vbox/trunk/src/VBox/Runtime/generic/fileio-sg-generic.cpp@ 78033

Last change on this file since 78033 was 77632, checked in by vboxsync, 6 years ago

IPRT: Adding RTFileSgRead and RTFileSgWrite (for FsPerf). bugref:9172

  • Property svn:eol-style set to native
  • Property svn:keywords set to Id Revision
File size: 3.2 KB
Line 
1/* $Id: fileio-sg-generic.cpp 77632 2019-03-10 13:33:52Z vboxsync $ */
2/** @file
3 * IPRT - File I/O, RTFileSgRead & RTFileSgWrite, generic.
4 */
5
6/*
7 * Copyright (C) 2006-2019 Oracle Corporation
8 *
9 * This file is part of VirtualBox Open Source Edition (OSE), as
10 * available from http://www.virtualbox.org. This file is free software;
11 * you can redistribute it and/or modify it under the terms of the GNU
12 * General Public License (GPL) as published by the Free Software
13 * Foundation, in version 2 as it comes in the "COPYING" file of the
14 * VirtualBox OSE distribution. VirtualBox OSE is distributed in the
15 * hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
16 *
17 * The contents of this file may alternatively be used under the terms
18 * of the Common Development and Distribution License Version 1.0
19 * (CDDL) only, as it comes in the "COPYING.CDDL" file of the
20 * VirtualBox OSE distribution, in which case the provisions of the
21 * CDDL are applicable instead of those of the GPL.
22 *
23 * You may elect to license modified versions of this file under the
24 * terms and conditions of either the GPL or the CDDL or both.
25 */
26
27
28/*********************************************************************************************************************************
29* Header Files *
30*********************************************************************************************************************************/
31#include "internal/iprt.h"
32#include <iprt/file.h>
33
34#include <iprt/assert.h>
35#include <iprt/err.h>
36
37
38RTDECL(int) RTFileSgRead(RTFILE hFile, PRTSGBUF pSgBuf, size_t cbToRead, size_t *pcbRead)
39{
40 int rc = VINF_SUCCESS;
41 size_t cbRead = 0;
42 while (cbToRead)
43 {
44 size_t cbBuf = cbToRead;
45 void *pvBuf = RTSgBufGetNextSegment(pSgBuf, &cbBuf); /** @todo this is wrong as it may advance the buffer past what's actually read. */
46
47 size_t cbThisRead = cbBuf;
48 rc = RTFileRead(hFile, pvBuf, cbBuf, pcbRead ? &cbThisRead : NULL);
49 if (RT_SUCCESS(rc))
50 cbRead += cbThisRead;
51 else
52 break;
53 if (cbThisRead < cbBuf)
54 {
55 AssertStmt(pcbRead, rc = VERR_INTERNAL_ERROR_2);
56 break;
57 }
58 Assert(cbBuf == cbThisRead);
59
60 cbToRead -= cbBuf;
61 }
62
63 if (pcbRead)
64 *pcbRead = cbRead;
65
66 return rc;
67}
68
69
70RTDECL(int) RTFileSgWrite(RTFILE hFile, PRTSGBUF pSgBuf, size_t cbToWrite, size_t *pcbWritten)
71{
72 int rc = VINF_SUCCESS;
73 size_t cbWritten = 0;
74 while (cbToWrite)
75 {
76 size_t cbBuf = cbToWrite;
77 void *pvBuf = RTSgBufGetNextSegment(pSgBuf, &cbBuf); /** @todo this is wrong as it may advance the buffer past what's actually read. */
78
79 size_t cbThisWritten = cbBuf;
80 rc = RTFileWrite(hFile, pvBuf, cbBuf, pcbWritten ? &cbThisWritten : NULL);
81 if (RT_SUCCESS(rc))
82 cbWritten += cbThisWritten;
83 else
84 break;
85 if (cbThisWritten < cbBuf)
86 {
87 AssertStmt(pcbWritten, rc = VERR_INTERNAL_ERROR_2);
88 break;
89 }
90
91 Assert(cbBuf == cbThisWritten);
92 cbToWrite -= cbBuf;
93 }
94
95 if (pcbWritten)
96 *pcbWritten = cbWritten;
97
98 return rc;
99}
100
Note: See TracBrowser for help on using the repository browser.

© 2024 Oracle Support Privacy / Do Not Sell My Info Terms of Use Trademark Policy Automated Access Etiquette