1/*
2 * Copyright (c) 2005 Anil Madhavapeddy. All rights reserved.
3 * Copyright (c) 1995,1999 Theo de Raadt. All rights reserved.
4 * All rights reserved.
5 *
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
8 * are met:
9 * 1. Redistributions of source code must retain the above copyright

--- 10 unchanged lines hidden (view full) ---

20 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
21 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
22 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
23 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
24 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
25 */
26
27#include "includes.h"
28RCSID("$OpenBSD: atomicio.c,v 1.13 2005/05/24 17:32:43 avsm Exp $");
29
30#include "atomicio.h"
31
32/*
33 * ensure all of data on socket comes through. f==read || f==vwrite
34 */
35size_t
36atomicio(f, fd, _s, n)
37 ssize_t (*f) (int, void *, size_t);
38 int fd;
39 void *_s;
40 size_t n;
41{
42 char *s = _s;
43 size_t pos = 0;
44 ssize_t res;
45
46 while (n > pos) {
47 res = (f) (fd, s + pos, n - pos);
48 switch (res) {

--- 4 unchanged lines hidden (view full) ---

53 if (errno == EINTR || errno == EAGAIN)
54#endif
55 continue;
56 return 0;
57 case 0:
58 errno = EPIPE;
59 return pos;
60 default:
61 pos += (u_int)res;
62 }
63 }
64 return (pos);
65}