1 files changed, 122 insertions, 0 deletions
diff --git a/subversion/libsvn_ra_serf/eagain_bucket.c b/subversion/libsvn_ra_serf/eagain_bucket.c
new file mode 100644
index 0000000..16387be
--- /dev/null
+++ b/subversion/libsvn_ra_serf/eagain_bucket.c
@@ -0,0 +1,122 @@
+/*
+ * eagain_bucket.c :  a serf bucket that handles slowing down data
+ *                   for specific readers that would have unwanted
+ *                   behavior if they read everything too fast
+ * ====================================================================
+ *    Licensed to the Apache Software Foundation (ASF) under one
+ *    or more contributor license agreements.  See the NOTICE file
+ *    distributed with this work for additional information
+ *    regarding copyright ownership.  The ASF licenses this file
+ *    to you under the Apache License, Version 2.0 (the
+ *    "License"); you may not use this file except in compliance
+ *    with the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *    Unless required by applicable law or agreed to in writing,
+ *    software distributed under the License is distributed on an
+ *    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *    KIND, either express or implied.  See the License for the
+ *    specific language governing permissions and limitations
+ *    under the License.
+ * ====================================================================
+ */
+
+#include <serf.h>
+#include <serf_bucket_util.h>
+
+#include "svn_private_config.h"
+
+#include "ra_serf.h"
+
+typedef struct eagain_baton_t
+{
+  const char *data;
+  apr_size_t remaining;
+} eagain_baton_t;
+
+static apr_status_t
+eagain_bucket_read(serf_bucket_t *bucket,
+                   apr_size_t requested,
+                   const char **data,
+                   apr_size_t *len)
+{
+  eagain_baton_t *eab = bucket->data;
+
+  if (eab->remaining > 0)
+    {
+      *data = eab->data;
+      if (requested > eab->remaining || requested == SERF_READ_ALL_AVAIL)
+        {
+          *len = eab->remaining;
+          eab->data = NULL;
+          eab->remaining = 0;
+        }
+      else
+        {
+          *len = requested;
+          eab->data += requested;
+          eab->remaining -= requested;
+        }
+
+      if (eab->remaining)
+        return APR_SUCCESS;
+    }
+
+  return APR_EAGAIN;
+}
+
+
+static apr_status_t
+eagain_bucket_readline(serf_bucket_t *bucket,
+                       int acceptable,
+                       int *found,
+                       const char **data,
+                       apr_size_t *len)
+{
+  /* ### for now, we know callers won't use this function.  */
+  svn_error_clear(svn_error__malfunction(TRUE, __FILE__, __LINE__,
+                                         "Not implemented."));
+  return APR_ENOTIMPL;
+}
+
+
+static apr_status_t
+eagain_bucket_peek(serf_bucket_t *bucket,
+                   const char **data,
+                   apr_size_t *len)
+{
+  const eagain_baton_t *eab = bucket->data;
+
+  *data = eab->data ? eab->data : "";
+  *len = eab->remaining;
+
+  return APR_SUCCESS;
+}
+
+
+static const serf_bucket_type_t delay_bucket_vtable = {
+    "BUF-EAGAIN",
+    eagain_bucket_read,
+    eagain_bucket_readline,
+    serf_default_read_iovec,
+    serf_default_read_for_sendfile,
+    serf_default_read_bucket,
+    eagain_bucket_peek,
+    serf_default_destroy_and_data,
+};
+
+
+serf_bucket_t *
+svn_ra_serf__create_bucket_with_eagain(const char *data,
+                                       apr_size_t len,
+                                       serf_bucket_alloc_t *allocator)
+{
+  eagain_baton_t *eab;
+
+  eab = serf_bucket_mem_alloc(allocator, sizeof(*eab));
+  eab->data = data;
+  eab->remaining = len;
+
+  return serf_bucket_create(&delay_bucket_vtable, allocator, eab);
+}