003 File Manager
Current Path:
/usr/src/contrib/subversion/subversion/libsvn_ra_serf
usr
/
src
/
contrib
/
subversion
/
subversion
/
libsvn_ra_serf
/
📁
..
📄
blame.c
(12.16 KB)
📄
blncache.c
(5.44 KB)
📄
blncache.h
(3.44 KB)
📄
commit.c
(81.79 KB)
📄
eagain_bucket.c
(3.5 KB)
📄
get_deleted_rev.c
(5.66 KB)
📄
get_file.c
(12.05 KB)
📄
get_lock.c
(9.66 KB)
📄
getdate.c
(4.93 KB)
📄
getlocations.c
(5.98 KB)
📄
getlocationsegments.c
(6.46 KB)
📄
getlocks.c
(8.91 KB)
📄
inherited_props.c
(14.64 KB)
📄
libsvn_ra_serf.pc.in
(414 B)
📄
list.c
(9.19 KB)
📄
lock.c
(20.92 KB)
📄
log.c
(18.43 KB)
📄
merge.c
(14.29 KB)
📄
mergeinfo.c
(7.67 KB)
📄
multistatus.c
(23.68 KB)
📄
options.c
(28 KB)
📄
property.c
(29.11 KB)
📄
ra_serf.h
(60.75 KB)
📄
replay.c
(28.62 KB)
📄
request_body.c
(6.79 KB)
📄
sb_bucket.c
(5.08 KB)
📄
serf.c
(38.92 KB)
📄
stat.c
(17.59 KB)
📄
stream_bucket.c
(3.43 KB)
📄
update.c
(92.6 KB)
📄
util.c
(68.61 KB)
📄
util_error.c
(2.87 KB)
📄
xml.c
(29.94 KB)
Editing: eagain_bucket.c
/* * 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; } #if !SERF_VERSION_AT_LEAST(1, 4, 0) 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; } #endif 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, #if SERF_VERSION_AT_LEAST(1, 4, 0) serf_default_readline, #else eagain_bucket_readline, #endif 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); }
Upload File
Create Folder