4035

pending completion

Build # 4035

Build Type

Pull #740

travis-ci-com

Committed by

web-flow

Commit Message

<a href="https://github.com/stefanberger/swtpm/commit/<a class=hub.com/stefanberger/swtpm/commit/<a class="double-link" href="https://git"><a class=hub.com/stefanberger/swtpm/commit/<a class="double-link" href="https://git"><a class=hub.com/stefanberger/swtpm/commit/<a class="double-link" href="https://git"><a class=hub.com/stefanberger/swtpm/commit/2b8a29fb9c2a4d53ed12676d84765e8db3c2b0b6">2b8a29fb9">&lt;a href=&quot;https://github.com/stefanberger/swtpm/commit/</a><a class="double-link" href="https://github.com/stefanberger/swtpm/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/stefanberger/swtpm/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/stefanberger/swtpm/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/stefanberger/swtpm/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/stefanberger/swtpm/commit/2b8a29fb9c2a4d53ed12676d84765e8db3c2b0b6">2b8a29fb9</a><a href="https://github.com/stefanberger/swtpm/commit/2b8a29fb9c2a4d53ed12676d84765e8db3c2b0b6">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/stefanberger/swtpm/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/stefanberger/swtpm/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/stefanberger/swtpm/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/stefanberger/swtpm/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/stefanberger/swtpm/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/stefanberger/swtpm/commit/2b8a29fb9c2a4d53ed12676d84765e8db3c2b0b6&quot;&gt;2b8a29fb9&lt;/a&gt;&lt;a href=&quot;https://github.com/stefanberger/swtpm/commit/2b8a29fb9c2a4d53ed12676d84765e8db3c2b0b6&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/stefanberger/swtpm/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/stefanberger/swtpm/comm... (continued)

Pull Request Pull Request #740: swtpm: Add a chroot option

Run Details

31 of 31 new or added lines in 4 files covered. (100.0%)

6211 of 8293 relevant lines covered (74.89%)

15581.53 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

57.0

/src/swtpm/utils.c

/*
 * utils.s -- utilities
 *
 * (c) Copyright IBM Corporation 2014, 2015, 2019.
 *
 * Author: Stefan Berger <stefanb@us.ibm.com>
 *
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are
 * met:
 *
 * Redistributions of source code must retain the above copyright notice,
 * this list of conditions and the following disclaimer.
 *
 * Redistributions in binary form must reproduce the above copyright
 * notice, this list of conditions and the following disclaimer in the
 * documentation and/or other materials provided with the distribution.
 *
 * Neither the names of the IBM Corporation nor the names of its
 * contributors may be used to endorse or promote products derived from
 * this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

#include "config.h"

#include <grp.h>
#include <pwd.h>
#include <fcntl.h>
#include <unistd.h>
#include <limits.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>

#if defined __APPLE__
#include <fcntl.h>
#include <sys/param.h>
#endif

#include "utils.h"
#include "logging.h"
#include "tpmlib.h"
#include "swtpm_debug.h"

void uninstall_sighandlers()
{
    if (signal(SIGTERM, SIG_DFL) == SIG_ERR)
        logprintf(STDERR_FILENO, "Could not uninstall signal handler for SIGTERM.\n");

    if (signal(SIGPIPE, SIG_DFL) == SIG_ERR)
        logprintf(STDERR_FILENO, "Could not uninstall signal handler for SIGPIPE.\n");
}

int install_sighandlers(int pipefd[2], sighandler_t handler)
{
    if (pipe(pipefd) < 0) {
        logprintf(STDERR_FILENO, "Error: Could not open pipe.\n");
        goto err_exit;
    }

    if (signal(SIGTERM, handler) == SIG_ERR) {
        logprintf(STDERR_FILENO, "Could not install signal handler for SIGTERM.\n");
        goto err_close_pipe;
    }

    if (signal(SIGPIPE, SIG_IGN) == SIG_ERR) {
        logprintf(STDERR_FILENO, "Could not install signal handler for SIGPIPE.\n");
        goto err_close_pipe;
    }

    return 0;

err_close_pipe:
    close(pipefd[0]);
    pipefd[0] = -1;
    close(pipefd[1]);
    pipefd[1] = -1;

err_exit:
    return -1;
}

int
change_process_owner(const char *user)
{
    struct passwd *passwd;
    long int uid, gid;
    char *endptr = NULL;

    uid = strtoul(user, &endptr, 10);
    if (*endptr != '\0') {
        /* a string */
        passwd = getpwnam(user);
        if (!passwd) {
            logprintf(STDERR_FILENO,
                      "Error: User '%s' does not exist.\n",
                      user);
            return -14;
        }

        if (initgroups(passwd->pw_name, passwd->pw_gid) < 0) {
            logprintf(STDERR_FILENO,
                      "Error: initgroups(%s, %d) failed.\n",
                      passwd->pw_name, passwd->pw_gid);
           return -10;
        }
        gid = passwd->pw_gid;
        uid = passwd->pw_uid;
    } else {
        /* an integer */
        if ((unsigned long int)uid > UINT_MAX) {
            logprintf(STDERR_FILENO,
                      "Error: uid %s outside valid range.\n",
                      user);
            return -13;
        }
        gid = uid;
    }

    if (setgid(gid) < 0) {
        logprintf(STDERR_FILENO,
                  "Error: setgid(%d) failed.\n",
                  gid);
        return -11;
    }
    if (setuid(uid) < 0) {
        logprintf(STDERR_FILENO,
                  "Error: setuid(%d) failed.\n",
                  uid);
        return -12;
    }
    return 0;
}

int
do_chroot(const char *path)
{
    if (chroot(path) < 0) {
        logprintf(STDERR_FILENO, "chroot failed: %s\n",
                  strerror(errno));
        return -1;
    }

    if (chdir("/") < 0) {
        logprintf(STDERR_FILENO, "chdir failed: %s\n",
                  strerror(errno));
        return -1;
    }
    return 0;
}

void tpmlib_debug_libtpms_parameters(TPMLIB_TPMVersion tpmversion)
{
    switch (tpmversion) {
    case TPMLIB_TPM_VERSION_1_2:
        TPM_DEBUG("TPM 1.2: Compiled for %u auth, %u transport, "
                  "and %u DAA session slots\n",
            tpmlib_get_tpm_property(TPMPROP_TPM_MIN_AUTH_SESSIONS),
            tpmlib_get_tpm_property(TPMPROP_TPM_MIN_TRANS_SESSIONS),
            tpmlib_get_tpm_property(TPMPROP_TPM_MIN_DAA_SESSIONS));
        TPM_DEBUG("TPM 1.2: Compiled for %u key slots, %u owner evict slots\n",
            tpmlib_get_tpm_property(TPMPROP_TPM_KEY_HANDLES),
            tpmlib_get_tpm_property(TPMPROP_TPM_OWNER_EVICT_KEY_HANDLES));
        TPM_DEBUG("TPM 1.2: Compiled for %u counters, %u saved sessions\n",
            tpmlib_get_tpm_property(TPMPROP_TPM_MIN_COUNTERS),
            tpmlib_get_tpm_property(TPMPROP_TPM_MIN_SESSION_LIST));
        TPM_DEBUG("TPM 1.2: Compiled for %u family, "
                  "%u delegate table entries\n",
            tpmlib_get_tpm_property(TPMPROP_TPM_NUM_FAMILY_TABLE_ENTRY_MIN),
            tpmlib_get_tpm_property(TPMPROP_TPM_NUM_DELEGATE_TABLE_ENTRY_MIN));
        TPM_DEBUG("TPM 1.2: Compiled for %u total NV, %u savestate, "
                  "%u volatile space\n",
            tpmlib_get_tpm_property(TPMPROP_TPM_MAX_NV_SPACE),
            tpmlib_get_tpm_property(TPMPROP_TPM_MAX_SAVESTATE_SPACE),
            tpmlib_get_tpm_property(TPMPROP_TPM_MAX_VOLATILESTATE_SPACE));
#if 0
        TPM_DEBUG("TPM1.2: Compiled for %u NV defined space\n",
            tpmlib_get_tpm_property(TPMPROP_TPM_MAX_NV_DEFINED_SIZE));
#endif
    break;
    case TPMLIB_TPM_VERSION_2:
    break;
    }
}

char *fd_to_filename(int fd)
{
#if defined __linux__

    char buffer[64];
    char *path;

    snprintf(buffer, sizeof(buffer), "/proc/self/fd/%d", fd);

    path = realpath(buffer, NULL);
    if (!path) {
        logprintf(STDERR_FILENO, "Could not read %s: %s\n",
                  buffer, strerror(errno));
        return NULL;
    }

    return path;

#elif defined __APPLE__

    char *path = malloc(MAXPATHLEN);
    if (!path) {
        logprintf(STDERR_FILENO, "Out of memory.\n");
        return NULL;
    }
    if (fcntl(fd, F_GETPATH, path) < 0) {
        logprintf(STDERR_FILENO, "fcntl for F_GETPATH failed: %\n",
                  strerror(errno));
        free(path);
        return NULL;
    }
    return path;

#else
    (void)fd;
    logprintf(STDERR_FILENO,
              "Cannot convert file descriptor to filename on this platform.\n");
    return NULL;

#endif
}

/*
 * write_full: Write all bytes of a buffer into the file descriptor
 *             and handle partial writes on the way.
 *
 * @fd: file descriptor to write to
 * @buffer: buffer
 * @buflen: length of buffer
 *
 * Returns -1 in case not all bytes could be transferred, number of
 * bytes written otherwise (must be equal to buflen).
 */
ssize_t write_full(int fd, const void *buffer, size_t buflen)
{
    size_t written = 0;
    ssize_t n;

    while (written < buflen) {
        n = write(fd, buffer, buflen - written);
        if (n == 0)
            return -1;
        if (n < 0) {
            if (errno == EINTR)
                continue;
            return -1;
        }
        written += n;
        buffer += n;
    }
    return written;
}

/*
 * writev_full: Write all bytes of an iovec into the file descriptor
 *              and handle partial writes on the way.
 * @fd: file descriptor to write to
 * @iov: pointer to iov
 * @iovcnt: length of iov array
 *
 * Returns -1 in case not all bytes could be transferred, number of
 * bytes written otherwise (must be equal to buflen).
 */
ssize_t writev_full(int fd, const struct iovec *iov, int iovcnt)
{
    int i;
    size_t off;
    unsigned char *buf;
    ssize_t n;
    size_t bytecount = 0;
    size_t numbufs = 0;
    size_t lastidx = -1;

    for (i = 0; i < iovcnt; i++) {
        if (iov[i].iov_len) {
            bytecount += iov[i].iov_len;
            numbufs++;
            lastidx = i;
        }
    }

    if (numbufs == 1)
        return write_full(fd, iov[lastidx].iov_base, iov[lastidx].iov_len);

    buf = malloc(bytecount);
    if (!buf) {
        errno = ENOMEM;
        return -1;
    }

    off = 0;
    for (i = 0; i < iovcnt; i++) {
        if (!iov[i].iov_len)
            continue;
        memcpy(&buf[off], iov[i].iov_base, iov[i].iov_len);
        off += iov[i].iov_len;
    }

    n = write_full(fd, buf, off);

    free(buf);

    return n;
}

/*
 * read_einter: Read bytes from a file descriptor into a buffer
 *              and handle EINTR. Perform one read().
 *
 * @fd: file descriptor to read from
 * @buffer: buffer
 * @buflen: length of buffer
 *
 * Returns -1 in case an error occurred, number of bytes read otherwise.
 */
ssize_t read_eintr(int fd, void *buffer, size_t buflen)
{
    ssize_t n;

    while (true) {
        n = read(fd, buffer, buflen);
        if (n < 0) {
            if (errno == EINTR)
                continue;
            return -1;
        }
        return n;
    }
}

1	/*
2	* utils.s -- utilities
3	*
4	* (c) Copyright IBM Corporation 2014, 2015, 2019.
5	*
6	* Author: Stefan Berger <stefanb@us.ibm.com>
7	*
8	* All rights reserved.
9	*
10	* Redistribution and use in source and binary forms, with or without
11	* modification, are permitted provided that the following conditions are
12	* met:
13	*
14	* Redistributions of source code must retain the above copyright notice,
15	* this list of conditions and the following disclaimer.
16	*
17	* Redistributions in binary form must reproduce the above copyright
18	* notice, this list of conditions and the following disclaimer in the
19	* documentation and/or other materials provided with the distribution.
20	*
21	* Neither the names of the IBM Corporation nor the names of its
22	* contributors may be used to endorse or promote products derived from
23	* this software without specific prior written permission.
24	*
25	* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
26	* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
27	* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
28	* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
29	* HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
30	* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
31	* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
32	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
33	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
34	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
35	* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
36	*/
37
38	#include "config.h"
39
40	#include <grp.h>
41	#include <pwd.h>
42	#include <fcntl.h>
43	#include <unistd.h>
44	#include <limits.h>
45	#include <stdlib.h>
46	#include <string.h>
47	#include <errno.h>
48
49	#if defined __APPLE__
50	#include <fcntl.h>
51	#include <sys/param.h>
52	#endif
53
54	#include "utils.h"
55	#include "logging.h"
56	#include "tpmlib.h"
57	#include "swtpm_debug.h"
58
59	void uninstall_sighandlers()	284✔
60	{
61	if (signal(SIGTERM, SIG_DFL) == SIG_ERR)	284✔
62	logprintf(STDERR_FILENO, "Could not uninstall signal handler for SIGTERM.\n");	×
63
64	if (signal(SIGPIPE, SIG_DFL) == SIG_ERR)	284✔
65	logprintf(STDERR_FILENO, "Could not uninstall signal handler for SIGPIPE.\n");	×
66	}	284✔
67
68	int install_sighandlers(int pipefd[2], sighandler_t handler)	284✔
69	{
70	if (pipe(pipefd) < 0) {	284✔
71	logprintf(STDERR_FILENO, "Error: Could not open pipe.\n");	×
72	goto err_exit;	×
73	}
74
75	if (signal(SIGTERM, handler) == SIG_ERR) {	284✔
76	logprintf(STDERR_FILENO, "Could not install signal handler for SIGTERM.\n");	×
77	goto err_close_pipe;	×
78	}
79
80	if (signal(SIGPIPE, SIG_IGN) == SIG_ERR) {	284✔
81	logprintf(STDERR_FILENO, "Could not install signal handler for SIGPIPE.\n");	×
82	goto err_close_pipe;	×
83	}
84
85	return 0;
86
87	err_close_pipe:	×
88	close(pipefd[0]);	×
89	pipefd[0] = -1;	×
90	close(pipefd[1]);	×
91	pipefd[1] = -1;	×
92
93	err_exit:
94	return -1;
95	}
96
97	int
98	change_process_owner(const char *user)	4✔
99	{
100	struct passwd *passwd;
101	long int uid, gid;
102	char *endptr = NULL;	4✔
103
104	uid = strtoul(user, &endptr, 10);	4✔
105	if (*endptr != '\0') {	4✔
106	/* a string */
107	passwd = getpwnam(user);	4✔
108	if (!passwd) {	4✔
109	logprintf(STDERR_FILENO,	×
110	"Error: User '%s' does not exist.\n",
111	user);
112	return -14;	×
113	}
114
115	if (initgroups(passwd->pw_name, passwd->pw_gid) < 0) {	4✔
116	logprintf(STDERR_FILENO,	×
117	"Error: initgroups(%s, %d) failed.\n",
118	passwd->pw_name, passwd->pw_gid);
119	return -10;	×
120	}
121	gid = passwd->pw_gid;	4✔
122	uid = passwd->pw_uid;	4✔
123	} else {
124	/* an integer */
125	if ((unsigned long int)uid > UINT_MAX) {	×
126	logprintf(STDERR_FILENO,	×
127	"Error: uid %s outside valid range.\n",
128	user);
129	return -13;	×
130	}
131	gid = uid;
132	}
133
134	if (setgid(gid) < 0) {	4✔
135	logprintf(STDERR_FILENO,	×
136	"Error: setgid(%d) failed.\n",
137	gid);
138	return -11;	×
139	}
140	if (setuid(uid) < 0) {	4✔
141	logprintf(STDERR_FILENO,	×
142	"Error: setuid(%d) failed.\n",
143	uid);
144	return -12;	×
145	}
146	return 0;
147	}
148
149	int
150	do_chroot(const char *path)	×
151	{
152	if (chroot(path) < 0) {	×
153	logprintf(STDERR_FILENO, "chroot failed: %s\n",	×
154	strerror(errno));	×
155	return -1;	×
156	}
157
158	if (chdir("/") < 0) {	×
159	logprintf(STDERR_FILENO, "chdir failed: %s\n",	×
160	strerror(errno));	×
161	return -1;	×
162	}
163	return 0;
164	}
165
166	void tpmlib_debug_libtpms_parameters(TPMLIB_TPMVersion tpmversion)	284✔
167	{
168	switch (tpmversion) {
169	case TPMLIB_TPM_VERSION_1_2:
170	TPM_DEBUG("TPM 1.2: Compiled for %u auth, %u transport, "
171	"and %u DAA session slots\n",
172	tpmlib_get_tpm_property(TPMPROP_TPM_MIN_AUTH_SESSIONS),
173	tpmlib_get_tpm_property(TPMPROP_TPM_MIN_TRANS_SESSIONS),
174	tpmlib_get_tpm_property(TPMPROP_TPM_MIN_DAA_SESSIONS));
175	TPM_DEBUG("TPM 1.2: Compiled for %u key slots, %u owner evict slots\n",
176	tpmlib_get_tpm_property(TPMPROP_TPM_KEY_HANDLES),
177	tpmlib_get_tpm_property(TPMPROP_TPM_OWNER_EVICT_KEY_HANDLES));
178	TPM_DEBUG("TPM 1.2: Compiled for %u counters, %u saved sessions\n",
179	tpmlib_get_tpm_property(TPMPROP_TPM_MIN_COUNTERS),
180	tpmlib_get_tpm_property(TPMPROP_TPM_MIN_SESSION_LIST));
181	TPM_DEBUG("TPM 1.2: Compiled for %u family, "
182	"%u delegate table entries\n",
183	tpmlib_get_tpm_property(TPMPROP_TPM_NUM_FAMILY_TABLE_ENTRY_MIN),
184	tpmlib_get_tpm_property(TPMPROP_TPM_NUM_DELEGATE_TABLE_ENTRY_MIN));
185	TPM_DEBUG("TPM 1.2: Compiled for %u total NV, %u savestate, "
186	"%u volatile space\n",
187	tpmlib_get_tpm_property(TPMPROP_TPM_MAX_NV_SPACE),
188	tpmlib_get_tpm_property(TPMPROP_TPM_MAX_SAVESTATE_SPACE),
189	tpmlib_get_tpm_property(TPMPROP_TPM_MAX_VOLATILESTATE_SPACE));
190	#if 0
191	TPM_DEBUG("TPM1.2: Compiled for %u NV defined space\n",
192	tpmlib_get_tpm_property(TPMPROP_TPM_MAX_NV_DEFINED_SIZE));
193	#endif
194	break;
195	case TPMLIB_TPM_VERSION_2:
196	break;
197	}
198	}	284✔
199
200	char *fd_to_filename(int fd)	1✔
201	{
202	#if defined __linux__
203
204	char buffer[64];
205	char *path;
206
207	snprintf(buffer, sizeof(buffer), "/proc/self/fd/%d", fd);	1✔
208
209	path = realpath(buffer, NULL);	1✔
210	if (!path) {	1✔
211	logprintf(STDERR_FILENO, "Could not read %s: %s\n",	×
212	buffer, strerror(errno));	×
213	return NULL;	×
214	}
215
216	return path;
217
218	#elif defined __APPLE__
219
220	char *path = malloc(MAXPATHLEN);
221	if (!path) {
222	logprintf(STDERR_FILENO, "Out of memory.\n");
223	return NULL;
224	}
225	if (fcntl(fd, F_GETPATH, path) < 0) {
226	logprintf(STDERR_FILENO, "fcntl for F_GETPATH failed: %\n",
227	strerror(errno));
228	free(path);
229	return NULL;
230	}
231	return path;
232
233	#else
234	(void)fd;
235	logprintf(STDERR_FILENO,
236	"Cannot convert file descriptor to filename on this platform.\n");
237	return NULL;
238
239	#endif
240	}
241
242	/*
243	* write_full: Write all bytes of a buffer into the file descriptor
244	* and handle partial writes on the way.
245	*
246	* @fd: file descriptor to write to
247	* @buffer: buffer
248	* @buflen: length of buffer
249	*
250	* Returns -1 in case not all bytes could be transferred, number of
251	* bytes written otherwise (must be equal to buflen).
252	*/
253	ssize_t write_full(int fd, const void *buffer, size_t buflen)	78,314✔
254	{
255	size_t written = 0;	78,314✔
256	ssize_t n;
257
258	while (written < buflen) {	234,942✔
259	n = write(fd, buffer, buflen - written);	78,314✔
260	if (n == 0)	78,314✔
261	return -1;
262	if (n < 0) {	78,314✔
263	if (errno == EINTR)	×
264	continue;	×
265	return -1;
266	}
267	written += n;	78,314✔
268	buffer += n;	78,314✔
269	}
270	return written;	78,314✔
271	}
272
273	/*
274	* writev_full: Write all bytes of an iovec into the file descriptor
275	* and handle partial writes on the way.
276	* @fd: file descriptor to write to
277	* @iov: pointer to iov
278	* @iovcnt: length of iov array
279	*
280	* Returns -1 in case not all bytes could be transferred, number of
281	* bytes written otherwise (must be equal to buflen).
282	*/
283	ssize_t writev_full(int fd, const struct iovec *iov, int iovcnt)	20,790✔
284	{
285	int i;
286	size_t off;
287	unsigned char *buf;
288	ssize_t n;
289	size_t bytecount = 0;	20,790✔
290	size_t numbufs = 0;	20,790✔
291	size_t lastidx = -1;	20,790✔
292
293	for (i = 0; i < iovcnt; i++) {	83,112✔
294	if (iov[i].iov_len) {	62,322✔
295	bytecount += iov[i].iov_len;	31,594✔
296	numbufs++;	31,594✔
297	lastidx = i;	31,594✔
298	}
299	}
300
301	if (numbufs == 1)	20,790✔
302	return write_full(fd, iov[lastidx].iov_base, iov[lastidx].iov_len);	15,364✔
303
304	buf = malloc(bytecount);	5,426✔
305	if (!buf) {	5,426✔
306	errno = ENOMEM;	×
307	return -1;	×
308	}
309
310	off = 0;
311	for (i = 0; i < iovcnt; i++) {	16,230✔
312	if (!iov[i].iov_len)	16,230✔
313	continue;	×
314	memcpy(&buf[off], iov[i].iov_base, iov[i].iov_len);	32,460✔
315	off += iov[i].iov_len;	16,230✔
316	}
317
318	n = write_full(fd, buf, off);	5,426✔
319
320	free(buf);	5,426✔
321
322	return n;	5,426✔
323	}
324
325	/*
326	* read_einter: Read bytes from a file descriptor into a buffer
327	* and handle EINTR. Perform one read().
328	*
329	* @fd: file descriptor to read from
330	* @buffer: buffer
331	* @buflen: length of buffer
332	*
333	* Returns -1 in case an error occurred, number of bytes read otherwise.
334	*/
335	ssize_t read_eintr(int fd, void *buffer, size_t buflen)	235✔
336	{
337	ssize_t n;
338
339	while (true) {
340	n = read(fd, buffer, buflen);	235✔
341	if (n < 0) {	235✔
342	if (errno == EINTR)	×
343	continue;	×
344	return -1;
345	}
346	return n;
347	}
348	}

stefanberger / swtpm / 4035

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous