2 * Copyright (c) 2022 Cisco and/or its affiliates.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at:
7 * http://www.apache.org/licenses/LICENSE-2.0
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
16 #include <http/http_buffer.h>
17 #include <http/http.h>
19 static http_buffer_vft_t buf_vfts[HTTP_BUFFER_PTR + 1];
21 #define HTTP_BUFFER_REGISTER_VFT(type, vft) \
22 static void __attribute__ ((constructor)) http_buf_init_##type (void) \
24 buf_vfts[type] = vft; \
27 typedef struct http_buffer_fifo_
35 STATIC_ASSERT (sizeof (http_buffer_fifo_t) <= HTTP_BUFFER_DATA_SZ, "buf data");
38 buf_fifo_init (http_buffer_t *hb, void *data, u64 len)
40 svm_fifo_t *f = (svm_fifo_t *) data;
41 http_buffer_fifo_t *bf;
43 bf = (http_buffer_fifo_t *) &hb->data;
52 buf_fifo_free (http_buffer_t *hb)
54 http_buffer_fifo_t *bf = (http_buffer_fifo_t *) &hb->data;
60 static svm_fifo_seg_t *
61 buf_fifo_get_segs (http_buffer_t *hb, u32 max_len, u32 *n_segs)
63 http_buffer_fifo_t *bf = (http_buffer_fifo_t *) &hb->data;
68 max_len = clib_min (bf->len - bf->offset, (u64) max_len);
70 vec_validate (bf->segs, _n_segs);
72 len = svm_fifo_segments (bf->src, 0, bf->segs, &_n_segs, max_len);
78 HTTP_DBG (1, "available to send %u n_segs %u", len, *n_segs);
84 buf_fifo_drain (http_buffer_t *hb, u32 len)
86 http_buffer_fifo_t *bf = (http_buffer_fifo_t *) &hb->data;
89 svm_fifo_dequeue_drop (bf->src, len);
90 HTTP_DBG (1, "drained %u len %u offset %u", len, bf->len, bf->offset);
96 buf_fifo_is_drained (http_buffer_t *hb)
98 http_buffer_fifo_t *bf = (http_buffer_fifo_t *) &hb->data;
100 ASSERT (bf->offset <= bf->len);
101 return (bf->offset == bf->len);
104 const static http_buffer_vft_t buf_fifo_vft = {
105 .init = buf_fifo_init,
106 .free = buf_fifo_free,
107 .get_segs = buf_fifo_get_segs,
108 .drain = buf_fifo_drain,
109 .is_drained = buf_fifo_is_drained,
112 HTTP_BUFFER_REGISTER_VFT (HTTP_BUFFER_FIFO, buf_fifo_vft);
114 typedef struct http_buffer_ptr_
116 svm_fifo_seg_t *segs;
120 STATIC_ASSERT (sizeof (http_buffer_ptr_t) <= HTTP_BUFFER_DATA_SZ, "buf data");
123 buf_ptr_init (http_buffer_t *hb, void *data, u64 len)
125 svm_fifo_t *f = (svm_fifo_t *) data;
126 http_buffer_ptr_t *bf;
130 bf = (http_buffer_ptr_t *) &hb->data;
132 /* Peek the pointer, do not drain the fifo until done with transfer */
133 rv = svm_fifo_peek (f, 0, sizeof (ptr), (u8 *) &ptr);
134 ASSERT (rv == sizeof (ptr));
138 vec_validate (bf->segs, 1);
140 bf->segs[0].data = uword_to_pointer (ptr, u8 *);
141 bf->segs[0].len = len;
143 bf->segs[1] = bf->segs[0];
147 buf_ptr_free (http_buffer_t *hb)
149 http_buffer_ptr_t *bf = (http_buffer_ptr_t *) &hb->data;
155 static svm_fifo_seg_t *
156 buf_ptr_get_segs (http_buffer_t *hb, u32 max_len, u32 *n_segs)
158 http_buffer_ptr_t *bf = (http_buffer_ptr_t *) &hb->data;
161 bf->segs[1].len = clib_min (bf->segs[0].len, max_len);
167 buf_ptr_drain (http_buffer_t *hb, u32 len)
169 http_buffer_ptr_t *bf = (http_buffer_ptr_t *) &hb->data;
171 ASSERT (bf->segs[0].len >= len);
173 bf->segs[1].data += len;
174 bf->segs[0].len -= len;
176 HTTP_DBG (1, "drained %u left %u", len, bf->segs[1].len);
178 if (!bf->segs[0].len)
180 svm_fifo_dequeue_drop (bf->f, sizeof (uword));
181 return sizeof (uword);
188 buf_ptr_is_drained (http_buffer_t *hb)
190 http_buffer_ptr_t *bf = (http_buffer_ptr_t *) &hb->data;
192 return (bf->segs[0].len == 0);
195 const static http_buffer_vft_t buf_ptr_vft = {
196 .init = buf_ptr_init,
197 .free = buf_ptr_free,
198 .get_segs = buf_ptr_get_segs,
199 .drain = buf_ptr_drain,
200 .is_drained = buf_ptr_is_drained,
203 HTTP_BUFFER_REGISTER_VFT (HTTP_BUFFER_PTR, buf_ptr_vft);
206 http_buffer_init (http_buffer_t *hb, http_buffer_type_t type, svm_fifo_t *f,
209 hb->vft = &buf_vfts[type];
210 hb->vft->init (hb, f, data_len);
214 * fd.io coding-style-patch-verification: ON
217 * eval: (c-set-style "gnu")