comparison: ucx/streams.c
ucx/streams.c
- changeset 1016
- ccde46662db7
- parent 629
- 0385a450c2a6
equal
deleted
inserted
replaced
| 1015:b459361d98ad | 1016:ccde46662db7 |
|---|---|
| 27 */ | 27 */ |
| 28 | 28 |
| 29 #include "cx/streams.h" | 29 #include "cx/streams.h" |
| 30 #include "cx/allocator.h" | 30 #include "cx/allocator.h" |
| 31 | 31 |
| 32 #ifndef CX_STREAM_BCOPY_BUF_SIZE | 32 #ifndef cx_strEAM_BCOPY_BUF_SIZE |
| 33 #define CX_STREAM_BCOPY_BUF_SIZE 8192 | 33 #define cx_strEAM_BCOPY_BUF_SIZE 8192 |
| 34 #endif | 34 #endif |
| 35 | 35 |
| 36 #ifndef CX_STREAM_COPY_BUF_SIZE | 36 #ifndef cx_strEAM_COPY_BUF_SIZE |
| 37 #define CX_STREAM_COPY_BUF_SIZE 1024 | 37 #define cx_strEAM_COPY_BUF_SIZE 1024 |
| 38 #endif | 38 #endif |
| 39 | 39 |
| 40 size_t cx_stream_bncopy( | 40 size_t cx_stream_bncopy( |
| 41 void *src, | 41 void *src, |
| 42 void *dest, | 42 void *dest, |
| 55 | 55 |
| 56 if (buf) { | 56 if (buf) { |
| 57 if (bufsize == 0) return 0; | 57 if (bufsize == 0) return 0; |
| 58 lbuf = buf; | 58 lbuf = buf; |
| 59 } else { | 59 } else { |
| 60 if (bufsize == 0) bufsize = CX_STREAM_BCOPY_BUF_SIZE; | 60 if (bufsize == 0) bufsize = cx_strEAM_BCOPY_BUF_SIZE; |
| 61 lbuf = cxMallocDefault(bufsize); | 61 lbuf = cxMallocDefault(bufsize); |
| 62 if (lbuf == NULL) return 0; | 62 if (lbuf == NULL) return 0; |
| 63 } | 63 } |
| 64 | 64 |
| 65 size_t r; | 65 size_t r; |
| 86 void *dest, | 86 void *dest, |
| 87 cx_read_func rfnc, | 87 cx_read_func rfnc, |
| 88 cx_write_func wfnc, | 88 cx_write_func wfnc, |
| 89 size_t n | 89 size_t n |
| 90 ) { | 90 ) { |
| 91 char buf[CX_STREAM_COPY_BUF_SIZE]; | 91 char buf[cx_strEAM_COPY_BUF_SIZE]; |
| 92 return cx_stream_bncopy(src, dest, rfnc, wfnc, | 92 return cx_stream_bncopy(src, dest, rfnc, wfnc, |
| 93 buf, CX_STREAM_COPY_BUF_SIZE, n); | 93 buf, cx_strEAM_COPY_BUF_SIZE, n); |
| 94 } | 94 } |
