Searched refs:iov (Results 1 - 25 of 44) sorted by relevance

12

/dovecot/src/lib/
H A Dostream-rawlog.c25 const struct const_iovec *iov, unsigned int iov_count)
31 if ((ret = o_stream_sendv(stream->parent, iov, iov_count)) < 0) {
37 if (iov[i].iov_len < (size_t)bytes) {
39 iov[i].iov_base, iov[i].iov_len);
40 bytes -= iov[i].iov_len;
43 iov[i].iov_base, bytes);
24 o_stream_rawlog_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
H A Dostream-unix.c23 const struct const_iovec *iov,
32 return o_stream_file_writev(fstream, iov, iov_count);
38 i_assert(iov[0].iov_len > 0);
40 iov[0].iov_base, iov[0].iov_len);
50 if (sent < iov[0].iov_len || iov_count == 1) {
56 ret = o_stream_file_writev(fstream, &iov[1], iov_count-1);
22 o_stream_unix_writev(struct file_ostream *fstream, const struct const_iovec *iov, unsigned int iov_count) argument
H A Dostream-hash.c16 const struct const_iovec *iov, unsigned int iov_count)
23 if ((ret = o_stream_sendv(stream->parent, iov, iov_count)) < 0) {
30 block_len = iov[i].iov_len <= bytes_left ?
31 iov[i].iov_len : bytes_left;
33 iov[i].iov_base, block_len);
15 o_stream_hash_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
H A Dostream-file-private.h10 const struct const_iovec *iov,
35 const struct const_iovec *iov,
38 const struct const_iovec *iov,
H A Dtest-ostream-escaped.c13 struct const_iovec iov[2]; local
21 iov[0].iov_base = "hello";
22 iov[0].iov_len = 5;
23 iov[1].iov_base = ", world";
24 iov[1].iov_len = 7;
25 test_assert(o_stream_sendv(os_encode, iov, 2) == 12);
H A Dostream-null.c9 const struct const_iovec *iov, unsigned int iov_count)
15 ret += iov[i].iov_len;
8 o_stream_null_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
H A Dfdpass.c107 struct const_iovec iov; local
116 iov.iov_base = data;
117 iov.iov_len = size;
119 msg.msg_iov = (void *)&iov;
157 struct iovec iov; local
166 iov.iov_base = data;
167 iov.iov_len = size;
169 msg.msg_iov = &iov;
H A Dostream-buffer.c34 const struct const_iovec *iov, unsigned int iov_count)
46 n = I_MIN(left, iov[i].iov_len);
47 buffer_write(bstream->buf, offset, iov[i].iov_base, n);
50 if (n != iov[i].iov_len)
33 o_stream_buffer_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
H A Dostream-file.c150 const struct const_iovec *iov,
158 i_assert(iov->iov_len > 0);
162 ret = write(fstream->fd, iov->iov_base, iov->iov_len);
166 ret = pwrite(fstream->fd, iov->iov_base, iov->iov_len,
177 size += iov[i].iov_len;
179 ret = writev(fstream->fd, (const struct iovec *)iov,
188 iov += IOV_MAX;
195 size += iov[
149 o_stream_file_writev(struct file_ostream *fstream, const struct const_iovec *iov, unsigned int iov_count) argument
212 o_stream_file_writev_full(struct file_ostream *fstream, const struct const_iovec *iov, unsigned int iov_count) argument
292 o_stream_fill_iovec(struct file_ostream *fstream, struct const_iovec iov[2]) argument
317 struct const_iovec iov[2]; local
548 o_stream_file_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
[all...]
H A Diostream-temp.c112 const struct const_iovec *iov, unsigned int iov_count)
118 if (write_full(tstream->fd, iov[i].iov_base, iov[i].iov_len) < 0) {
125 buffer_append(tstream->buf, iov[i].iov_base, iov[i].iov_len);
126 bytes += iov[i].iov_len;
127 tstream->ostream.ostream.offset += iov[i].iov_len;
132 bytes += iov[i].iov_len;
133 tstream->ostream.ostream.offset += iov[i].iov_len;
141 const struct const_iovec *iov, unsigne
111 o_stream_temp_fd_sendv(struct temp_ostream *tstream, const struct const_iovec *iov, unsigned int iov_count) argument
140 o_stream_temp_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
[all...]
H A Dostream-escaped.c72 const struct const_iovec *iov, unsigned int iov_count)
80 iov[iov_cur].iov_base, iov[iov_cur].iov_len);
84 if ((size_t)ret != iov[iov_cur].iov_len)
71 o_stream_escaped_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
H A Dostream-failure-at.c26 const struct const_iovec *iov, unsigned int iov_count)
41 blocking_bytes_count += iov[i].iov_len;
61 iov_dup[i] = iov[i];
25 o_stream_failure_at_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
H A Dostream.c251 struct const_iovec iov; local
253 i_zero(&iov);
254 iov.iov_base = data;
255 iov.iov_len = size;
257 return o_stream_sendv(stream, &iov, 1);
261 o_stream_sendv_int(struct ostream *stream, const struct const_iovec *iov, argument
272 total_size += iov[i].iov_len;
277 ret = _stream->sendv(_stream, iov, iov_count);
293 ssize_t o_stream_sendv(struct ostream *stream, const struct const_iovec *iov, argument
302 return o_stream_sendv_int(stream, iov, iov_coun
312 struct const_iovec iov; local
321 o_stream_nsendv(struct ostream *stream, const struct const_iovec *iov, unsigned int iov_count) argument
482 struct const_iovec iov; local
648 o_stream_default_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
[all...]
H A Dcompat.c85 ssize_t i_my_writev(int fd, const struct iovec *iov, int iov_len) argument
92 for (i = 0; i < iov_len; i++, iov++) {
93 ret = write(fd, iov->iov_base, iov->iov_len);
98 if ((size_t)ret != iov->iov_len)
/dovecot/src/lib-fs/
H A Dostream-cmp.c48 const struct const_iovec *iov, unsigned int iov_count)
56 if (!stream_cmp_block(cstream->input, iov[i].iov_base,
57 iov[i].iov_len)) {
64 if ((ret = o_stream_sendv(stream->parent, iov, iov_count)) < 0) {
47 o_stream_cmp_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
H A Dostream-metawrap.c28 const struct const_iovec *iov, unsigned int iov_count)
34 if ((ret = o_stream_sendv(stream->parent, iov, iov_count)) < 0)
27 o_stream_metawrap_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
/dovecot/src/lib-ssl-iostream/
H A Dostream-openssl.c33 o_stream_ssl_buffer(struct ssl_ostream *sstream, const struct const_iovec *iov, argument
44 if (skip_left < iov[i].iov_len)
46 skip_left -= iov[i].iov_len;
58 size = I_MIN(iov[i].iov_len - skip_left, avail);
60 CONST_PTR_OFFSET(iov[i].iov_base, skip_left),
64 if (size != iov[i].iov_len)
71 size = I_MIN(iov[i].iov_len, avail);
72 buffer_append(sstream->buffer, iov[i].iov_base, size);
76 if (size != iov[i].iov_len)
152 const struct const_iovec *iov, unsigne
151 o_stream_ssl_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
[all...]
/dovecot/src/lib-master/
H A Dipc-client.c149 struct const_iovec iov[2]; local
157 iov[0].iov_base = cmd;
158 iov[0].iov_len = strlen(cmd);
159 iov[1].iov_base = "\n";
160 iov[1].iov_len = 1;
161 o_stream_nsendv(client->output, iov, N_ELEMENTS(iov));
H A Danvil-client.c203 struct const_iovec iov[2]; local
210 iov[0].iov_base = cmd;
211 iov[0].iov_len = strlen(cmd);
212 iov[1].iov_base = "\n";
213 iov[1].iov_len = 1;
214 if (o_stream_sendv(client->output, iov, 2) < 0) {
/dovecot/src/lib-http/
H A Dhttp-server-response.c14 struct const_iovec *iov; member in struct:http_server_response_payload
276 struct const_iovec *iov; local
284 iov = &rpay->iov[rpay->iov_idx];
287 if ((ret=o_stream_sendv(output, iov, iov_count)) < 0) {
294 block_len = iov[i].iov_len <= bytes_left ?
295 iov[i].iov_len : bytes_left;
300 i_assert(iov[i].iov_len > bytes_left);
301 iov[i].iov_base = PTR_OFFSET
302 (iov[
314 http_server_response_output_payload( struct http_server_response **_resp, const struct const_iovec *iov, unsigned int iov_count) argument
431 struct const_iovec iov; local
564 struct const_iovec iov[3]; local
717 http_server_ostream_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
[all...]
/dovecot/src/lib-auth/
H A Dauth-client-request.c152 struct const_iovec iov[3]; local
157 iov[0].iov_base = prefix;
158 iov[0].iov_len = strlen(prefix);
159 iov[1].iov_base = data_base64;
160 iov[1].iov_len = strlen(data_base64);
161 iov[2].iov_base = "\n";
162 iov[2].iov_len = 1;
164 if (o_stream_sendv(request->conn->output, iov, 3) < 0)
/dovecot/src/lib-test/
H A Dtest-ostream.c43 const struct const_iovec *iov, unsigned int iov_count)
60 n = I_MIN(left, iov[i].iov_len);
61 buffer_append(tstream->output_buf, iov[i].iov_base, n);
64 if (n != iov[i].iov_len) {
65 cur_iov.iov_base = CONST_PTR_OFFSET(iov[i].iov_base, n);
66 cur_iov.iov_len = iov[i].iov_len - n;
84 cur_iov = iov[i];
42 o_stream_test_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
/dovecot/src/lib-compression/
H A Dostream-bzlib.c157 const struct const_iovec *iov, unsigned int iov_count)
170 ret = o_stream_bzlib_send_chunk(zstream, iov[i].iov_base,
171 iov[i].iov_len);
175 if ((size_t)ret != iov[i].iov_len)
156 o_stream_bzlib_sendv(struct ostream_private *stream, const struct const_iovec *iov, unsigned int iov_count) argument
/dovecot/src/director/
H A Dlogin-connection.c113 struct const_iovec iov[2]; local
118 iov[0].iov_base = line;
119 iov[0].iov_len = strlen(line);
120 iov[1].iov_base = "\n";
121 iov[1].iov_len = 1;
122 o_stream_nsendv(conn->output, iov, N_ELEMENTS(iov));
/dovecot/src/auth/
H A Dauth-worker-server.c91 struct const_iovec iov[3]; local
117 iov[0].iov_base = t_strdup_printf("%d\t", request->id);
118 iov[0].iov_len = strlen(iov[0].iov_base);
119 iov[1].iov_base = request->data;
120 iov[1].iov_len = strlen(request->data);
121 iov[2].iov_base = "\n";
122 iov[2].iov_len = 1;
124 o_stream_nsendv(conn->output, iov, 3);

Completed in 1790 milliseconds

12