You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@subversion.apache.org by st...@apache.org on 2013/03/30 19:39:23 UTC
svn commit: r1462837 - in /subversion/branches/fsfs-format7/subversion:
include/private/svn_packed_data.h libsvn_fs_fs/changes.c
libsvn_fs_fs/string_table.c libsvn_subr/packed_data.c
Author: stefan2
Date: Sat Mar 30 18:39:23 2013
New Revision: 1462837
URL: http://svn.apache.org/r1462837
Log:
On the fsfs-format7 branch: rename svn__packed_* to svn_packed__*.
* subversion/include/private/svn_packed_data.h
(svn__packed_data_root_t,
svn__packed_byte_stream_t,
svn__packed_int_stream_t,
svn__packed_data_create_root,
svn__packed_create_int_stream,
svn__packed_create_int_substream,
svn__packed_create_bytes_stream,
svn__packed_create_bytes_substream,
svn__packed_data_write,
svn__packed_first_int_stream,
svn__packed_first_byte_stream,
svn__packed_next_int_stream,
svn__packed_next_byte_stream,
svn__packed_first_int_substream): rename to svn_packed__*
* subversion/libsvn_subr/packed_data.c
(svn__packed_byte_stream_t,
svn__packed_data_root_t,
svn__packed_data_create_root,
svn__packed_create_int_stream,
svn__packed_create_int_substream,
svn__packed_create_bytes_stream,
svn__packed_create_bytes_substream,
svn__packed_add_uint,
svn__packed_add_int,
svn__packed_add_bytes,
svn__packed_data_flush_buffer,
svn__packed_data_write,
svn__packed_first_int_stream,
svn__packed_first_byte_stream,
svn__packed_next_int_stream,
svn__packed_next_byte_stream,
svn__packed_first_int_substream,
svn__packed_get_uint,
svn__packed_get_int,
svn__packed_get_bytes,
svn__packed_data_fill_buffer,
svn__packed_data_read): rename to svn_packed__*
(packed_int_private_t,
create_bytes_stream_body,
packed_data_create_bytes_substream_body,
write_int_stream_structure,
write_byte_stream_structure,
read_int_stream_structure,
read_byte_stream_structure): update references
* subversion/libsvn_fs_fs/changes.c
(svn_fs_fs__write_changes_container,
svn_fs_fs__read_changes_container): update callers
* subversion/libsvn_fs_fs/string_table.c
(svn_fs_fs__write_string_table,
svn_fs_fs__read_string_table): update callers
Suggested by: danielsh
Modified:
subversion/branches/fsfs-format7/subversion/include/private/svn_packed_data.h
subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/changes.c
subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/string_table.c
subversion/branches/fsfs-format7/subversion/libsvn_subr/packed_data.c
Modified: subversion/branches/fsfs-format7/subversion/include/private/svn_packed_data.h
URL: http://svn.apache.org/viewvc/subversion/branches/fsfs-format7/subversion/include/private/svn_packed_data.h?rev=1462837&r1=1462836&r2=1462837&view=diff
==============================================================================
--- subversion/branches/fsfs-format7/subversion/include/private/svn_packed_data.h (original)
+++ subversion/branches/fsfs-format7/subversion/include/private/svn_packed_data.h Sat Mar 30 18:39:23 2013
@@ -84,16 +84,16 @@
/* Opaque type for the root object.
*/
-typedef struct svn__packed_data_root_t svn__packed_data_root_t;
+typedef struct svn_packed__data_root_t svn_packed__data_root_t;
/* Opaque type for byte streams.
*/
-typedef struct svn__packed_byte_stream_t svn__packed_byte_stream_t;
+typedef struct svn_packed__byte_stream_t svn_packed__byte_stream_t;
/* Semi-opaque type for integer streams. We expose the unpacked buffer
- * to allow for replacing svn__packed_add_uint and friends by macros.
+ * to allow for replacing svn_packed__add_uint and friends by macros.
*/
-typedef struct svn__packed_int_stream_t
+typedef struct svn_packed__int_stream_t
{
/* pointer to the remainder of the data structure */
void *private_data;
@@ -104,15 +104,15 @@ typedef struct svn__packed_int_stream_t
/* unpacked integers (either yet to be packed or pre-fetched from the
* packed buffers). Only the first BUFFER_USED entries are valid. */
apr_uint64_t buffer[SVN__PACKED_DATA_BUFFER_SIZE];
-} svn__packed_int_stream_t;
+} svn_packed__int_stream_t;
/* Writing data. */
/* Return a new serialization root object, allocated in POOL.
*/
-svn__packed_data_root_t *
-svn__packed_data_create_root(apr_pool_t *pool);
+svn_packed__data_root_t *
+svn_packed__data_create_root(apr_pool_t *pool);
/* Create and return a new top-level integer stream in ROOT. If signed,
* negative numbers will be put into that stream, SIGNED_INTS should be
@@ -120,8 +120,8 @@ svn__packed_data_create_root(apr_pool_t
* DIFF to TRUE if you expect the difference between consecutive numbers
* to be much smaller (~100 times) than the actual numbers.
*/
-svn__packed_int_stream_t *
-svn__packed_create_int_stream(svn__packed_data_root_t *root,
+svn_packed__int_stream_t *
+svn_packed__create_int_stream(svn_packed__data_root_t *root,
svn_boolean_t diff,
svn_boolean_t signed_ints);
@@ -131,47 +131,47 @@ svn__packed_create_int_stream(svn__packe
* Set DIFF to TRUE if you expect the difference between consecutive numbers
* to be much smaller (~100 times) than the actual numbers.
*/
-svn__packed_int_stream_t *
-svn__packed_create_int_substream(svn__packed_int_stream_t *parent,
+svn_packed__int_stream_t *
+svn_packed__create_int_substream(svn_packed__int_stream_t *parent,
svn_boolean_t diff,
svn_boolean_t signed_ints);
/* Create and return a new top-level byte sequence stream in ROOT.
*/
-svn__packed_byte_stream_t *
-svn__packed_create_bytes_stream(svn__packed_data_root_t *root);
+svn_packed__byte_stream_t *
+svn_packed__create_bytes_stream(svn_packed__data_root_t *root);
/* Create and return a new sub-stream to the existing byte sequence stream
* PARENT.
*/
-svn__packed_byte_stream_t *
-svn__packed_create_bytes_substream(svn__packed_byte_stream_t *parent);
+svn_packed__byte_stream_t *
+svn_packed__create_bytes_substream(svn_packed__byte_stream_t *parent);
/* Empty the unprocessed integer buffer in STREAM by either pushing the
* data to the sub-streams or writing to the packed data (in case there
* are no sub-streams). Users don't need to call this explicitly as it
- * will be called by svn__packed_add_uint, svn__packed_add_int and
- * svn__packed_data_write as necessary.
+ * will be called by svn_packed__add_uint, svn_packed__add_int and
+ * svn_packed__data_write as necessary.
*/
void
-svn__packed_data_flush_buffer(svn__packed_int_stream_t *stream);
+svn_packed__data_flush_buffer(svn_packed__int_stream_t *stream);
/* Write the unsigned integer VALUE to STEAM.
*/
void
-svn__packed_add_uint(svn__packed_int_stream_t *stream,
+svn_packed__add_uint(svn_packed__int_stream_t *stream,
apr_uint64_t value);
/* Write the signed integer VALUE to STEAM.
*/
void
-svn__packed_add_int(svn__packed_int_stream_t *stream,
+svn_packed__add_int(svn_packed__int_stream_t *stream,
apr_int64_t value);
/* Write the sequence stating at DATA containing LEN bytes to STEAM.
*/
void
-svn__packed_add_bytes(svn__packed_byte_stream_t *stream,
+svn_packed__add_bytes(svn_packed__byte_stream_t *stream,
const char *data,
apr_size_t len);
@@ -179,8 +179,8 @@ svn__packed_add_bytes(svn__packed_byte_s
* Use SCRATCH_POOL for temporary allocations.
*/
svn_error_t *
-svn__packed_data_write(svn_stream_t *stream,
- svn__packed_data_root_t *root,
+svn_packed__data_write(svn_stream_t *stream,
+ svn_packed__data_root_t *root,
apr_pool_t *scratch_pool);
@@ -189,65 +189,65 @@ svn__packed_data_write(svn_stream_t *str
/* Return the first integer stream in ROOT. Returns NULL in case there
* aren't any.
*/
-svn__packed_int_stream_t *
-svn__packed_first_int_stream(svn__packed_data_root_t *root);
+svn_packed__int_stream_t *
+svn_packed__first_int_stream(svn_packed__data_root_t *root);
/* Return the first byte sequence stream in ROOT. Returns NULL in case
* there aren't any.
*/
-svn__packed_byte_stream_t *
-svn__packed_first_byte_stream(svn__packed_data_root_t *root);
+svn_packed__byte_stream_t *
+svn_packed__first_byte_stream(svn_packed__data_root_t *root);
/* Return the next (sibling) integer stream to STREAM. Returns NULL in
* case there isn't any.
*/
-svn__packed_int_stream_t *
-svn__packed_next_int_stream(svn__packed_int_stream_t *stream);
+svn_packed__int_stream_t *
+svn_packed__next_int_stream(svn_packed__int_stream_t *stream);
/* Return the next (sibling) byte sequence stream to STREAM. Returns NULL
* in case there isn't any.
*/
-svn__packed_byte_stream_t *
-svn__packed_next_byte_stream(svn__packed_byte_stream_t *stream);
+svn_packed__byte_stream_t *
+svn_packed__next_byte_stream(svn_packed__byte_stream_t *stream);
/* Return the first sub-stream of STREAM. Returns NULL in case there
* isn't any.
*/
-svn__packed_int_stream_t *
-svn__packed_first_int_substream(svn__packed_int_stream_t *stream);
+svn_packed__int_stream_t *
+svn_packed__first_int_substream(svn_packed__int_stream_t *stream);
/* Return the first sub-stream of STREAM. Returns NULL in case there
* isn't any.
*/
-svn__packed_byte_stream_t *
-svn__packed_first_byte_substream(svn__packed_byte_stream_t *stream);
+svn_packed__byte_stream_t *
+svn_packed__first_byte_substream(svn_packed__byte_stream_t *stream);
/* Return the number of integers left to read from STREAM.
*/
apr_size_t
-svn__packed_int_count(svn__packed_int_stream_t *stream);
+svn_packed__int_count(svn_packed__int_stream_t *stream);
/* Return the number of bytes left to read from STREAM.
*/
apr_size_t
-svn__packed_byte_count(svn__packed_byte_stream_t *stream);
+svn_packed__byte_count(svn_packed__byte_stream_t *stream);
/* Return the number of bytes left to read from STREAM.
*/
void
-svn__packed_data_fill_buffer(svn__packed_int_stream_t *stream);
+svn_packed__data_fill_buffer(svn_packed__int_stream_t *stream);
/* Return the next number from STREAM as unsigned integer. Returns 0 when
* reading beyond the end of the stream.
*/
apr_uint64_t
-svn__packed_get_uint(svn__packed_int_stream_t *stream);
+svn_packed__get_uint(svn_packed__int_stream_t *stream);
/* Return the next number from STREAM as signed integer. Returns 0 when
* reading beyond the end of the stream.
*/
apr_int64_t
-svn__packed_get_int(svn__packed_int_stream_t *stream,
+svn_packed__get_int(svn_packed__int_stream_t *stream,
apr_int64_t value);
/* Return the next byte sequence from STREAM and set *LEN to the length
@@ -255,7 +255,7 @@ svn__packed_get_int(svn__packed_int_stre
* stream.
*/
const char *
-svn__packed_get_bytes(svn__packed_byte_stream_t *stream,
+svn_packed__get_bytes(svn_packed__byte_stream_t *stream,
apr_size_t *len);
/* Allocate a new packed data root in RESULT_POOL, read its structure and
@@ -263,7 +263,7 @@ svn__packed_get_bytes(svn__packed_byte_s
* for temporary allocations.
*/
svn_error_t *
-svn__packed_data_read(svn__packed_data_root_t **root_p,
+svn_packed__data_read(svn_packed__data_root_t **root_p,
svn_stream_t *stream,
apr_pool_t *result_pool,
apr_pool_t *scratch_pool);
Modified: subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/changes.c
URL: http://svn.apache.org/viewvc/subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/changes.c?rev=1462837&r1=1462836&r2=1462837&view=diff
==============================================================================
--- subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/changes.c (original)
+++ subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/changes.c Sat Mar 30 18:39:23 2013
@@ -335,26 +335,26 @@ svn_fs_fs__write_changes_container(svn_s
{
int i;
- svn__packed_data_root_t *root = svn__packed_data_create_root(pool);
+ svn_packed__data_root_t *root = svn_packed__data_create_root(pool);
/* one top-level stream for each array */
- svn__packed_int_stream_t *offsets_stream
- = svn__packed_create_int_stream(root, TRUE, FALSE);
- svn__packed_int_stream_t *changes_stream
- = svn__packed_create_int_stream(root, FALSE, FALSE);
+ svn_packed__int_stream_t *offsets_stream
+ = svn_packed__create_int_stream(root, TRUE, FALSE);
+ svn_packed__int_stream_t *changes_stream
+ = svn_packed__create_int_stream(root, FALSE, FALSE);
/* structure the CHANGES_STREAM such we can extract much of the redundancy
* from the binary_change_t structs */
- svn__packed_create_int_substream(changes_stream, TRUE, FALSE);
- svn__packed_create_int_substream(changes_stream, TRUE, FALSE);
- svn__packed_create_int_substream(changes_stream, TRUE, TRUE);
- svn__packed_create_int_substream(changes_stream, TRUE, FALSE);
- svn__packed_create_int_substream(changes_stream, TRUE, TRUE);
- svn__packed_create_int_substream(changes_stream, TRUE, FALSE);
- svn__packed_create_int_substream(changes_stream, TRUE, TRUE);
- svn__packed_create_int_substream(changes_stream, TRUE, FALSE);
- svn__packed_create_int_substream(changes_stream, TRUE, TRUE);
- svn__packed_create_int_substream(changes_stream, TRUE, FALSE);
+ svn_packed__create_int_substream(changes_stream, TRUE, FALSE);
+ svn_packed__create_int_substream(changes_stream, TRUE, FALSE);
+ svn_packed__create_int_substream(changes_stream, TRUE, TRUE);
+ svn_packed__create_int_substream(changes_stream, TRUE, FALSE);
+ svn_packed__create_int_substream(changes_stream, TRUE, TRUE);
+ svn_packed__create_int_substream(changes_stream, TRUE, FALSE);
+ svn_packed__create_int_substream(changes_stream, TRUE, TRUE);
+ svn_packed__create_int_substream(changes_stream, TRUE, FALSE);
+ svn_packed__create_int_substream(changes_stream, TRUE, TRUE);
+ svn_packed__create_int_substream(changes_stream, TRUE, FALSE);
/* CHANGES must be in 'finalized' mode */
SVN_ERR_ASSERT(changes->builder == NULL);
@@ -362,7 +362,7 @@ svn_fs_fs__write_changes_container(svn_s
/* serialize offsets array */
for (i = 0; i < changes->offsets->nelts; ++i)
- svn__packed_add_uint(offsets_stream,
+ svn_packed__add_uint(offsets_stream,
APR_ARRAY_IDX(changes->offsets, i, int));
/* serialize changes array */
@@ -371,23 +371,23 @@ svn_fs_fs__write_changes_container(svn_s
const binary_change_t *change
= &APR_ARRAY_IDX(changes->changes, i, binary_change_t);
- svn__packed_add_uint(changes_stream, change->flags);
- svn__packed_add_uint(changes_stream, change->path);
+ svn_packed__add_uint(changes_stream, change->flags);
+ svn_packed__add_uint(changes_stream, change->path);
- svn__packed_add_uint(changes_stream, change->copyfrom_rev);
- svn__packed_add_uint(changes_stream, change->copyfrom_path);
+ svn_packed__add_uint(changes_stream, change->copyfrom_rev);
+ svn_packed__add_uint(changes_stream, change->copyfrom_path);
- svn__packed_add_uint(changes_stream, change->node_id.revision);
- svn__packed_add_uint(changes_stream, change->node_id.number);
- svn__packed_add_uint(changes_stream, change->copy_id.revision);
- svn__packed_add_uint(changes_stream, change->copy_id.number);
- svn__packed_add_uint(changes_stream, change->rev_id.revision);
- svn__packed_add_uint(changes_stream, change->rev_id.number);
+ svn_packed__add_uint(changes_stream, change->node_id.revision);
+ svn_packed__add_uint(changes_stream, change->node_id.number);
+ svn_packed__add_uint(changes_stream, change->copy_id.revision);
+ svn_packed__add_uint(changes_stream, change->copy_id.number);
+ svn_packed__add_uint(changes_stream, change->rev_id.revision);
+ svn_packed__add_uint(changes_stream, change->rev_id.number);
}
/* write to disk */
SVN_ERR(svn_fs_fs__write_string_table(stream, changes->paths, pool));
- SVN_ERR(svn__packed_data_write(stream, root, pool));
+ SVN_ERR(svn_packed__data_write(stream, root, pool));
return SVN_NO_ERROR;
}
@@ -403,46 +403,46 @@ svn_fs_fs__read_changes_container(svn_fs
svn_fs_fs__changes_t *changes = apr_pcalloc(result_pool, sizeof(*changes));
- svn__packed_data_root_t *root;
- svn__packed_int_stream_t *offsets_stream;
- svn__packed_int_stream_t *changes_stream;
+ svn_packed__data_root_t *root;
+ svn_packed__int_stream_t *offsets_stream;
+ svn_packed__int_stream_t *changes_stream;
/* write from disk */
SVN_ERR(svn_fs_fs__read_string_table(&changes->paths, stream,
result_pool, scratch_pool));
- SVN_ERR(svn__packed_data_read(&root, stream, result_pool, scratch_pool));
- offsets_stream = svn__packed_first_int_stream(root);
- changes_stream = svn__packed_next_int_stream(offsets_stream);
+ SVN_ERR(svn_packed__data_read(&root, stream, result_pool, scratch_pool));
+ offsets_stream = svn_packed__first_int_stream(root);
+ changes_stream = svn_packed__next_int_stream(offsets_stream);
/* read offsets array */
- count = svn__packed_int_count(offsets_stream);
+ count = svn_packed__int_count(offsets_stream);
changes->offsets = apr_array_make(result_pool, count, sizeof(int));
for (i = 0; i < count; ++i)
APR_ARRAY_PUSH(changes->offsets, int)
- = (int)svn__packed_get_uint(offsets_stream);
+ = (int)svn_packed__get_uint(offsets_stream);
/* read changes array */
count
- = svn__packed_int_count(svn__packed_first_int_substream(changes_stream));
+ = svn_packed__int_count(svn_packed__first_int_substream(changes_stream));
changes->changes
= apr_array_make(result_pool, count, sizeof(binary_change_t));
for (i = 0; i < count; ++i)
{
binary_change_t change;
- change.flags = svn__packed_get_uint(changes_stream);
- change.path = svn__packed_get_uint(changes_stream);
+ change.flags = svn_packed__get_uint(changes_stream);
+ change.path = svn_packed__get_uint(changes_stream);
- change.copyfrom_rev = svn__packed_get_uint(changes_stream);
- change.copyfrom_path = svn__packed_get_uint(changes_stream);
+ change.copyfrom_rev = svn_packed__get_uint(changes_stream);
+ change.copyfrom_path = svn_packed__get_uint(changes_stream);
- change.node_id.revision = svn__packed_get_uint(changes_stream);
- change.node_id.number = svn__packed_get_uint(changes_stream);
- change.copy_id.revision = svn__packed_get_uint(changes_stream);
- change.copy_id.number = svn__packed_get_uint(changes_stream);
- change.rev_id.revision = svn__packed_get_uint(changes_stream);
- change.rev_id.number = svn__packed_get_uint(changes_stream);
+ change.node_id.revision = svn_packed__get_uint(changes_stream);
+ change.node_id.number = svn_packed__get_uint(changes_stream);
+ change.copy_id.revision = svn_packed__get_uint(changes_stream);
+ change.copy_id.number = svn_packed__get_uint(changes_stream);
+ change.rev_id.revision = svn_packed__get_uint(changes_stream);
+ change.rev_id.number = svn_packed__get_uint(changes_stream);
APR_ARRAY_PUSH(changes->changes, binary_change_t) = change;
}
Modified: subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/string_table.c
URL: http://svn.apache.org/viewvc/subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/string_table.c?rev=1462837&r1=1462836&r2=1462837&view=diff
==============================================================================
--- subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/string_table.c (original)
+++ subversion/branches/fsfs-format7/subversion/libsvn_fs_fs/string_table.c Sat Mar 30 18:39:23 2013
@@ -560,34 +560,34 @@ svn_fs_fs__write_string_table(svn_stream
{
apr_size_t i, k;
- svn__packed_data_root_t *root = svn__packed_data_create_root(pool);
+ svn_packed__data_root_t *root = svn_packed__data_create_root(pool);
- svn__packed_int_stream_t *table_sizes
- = svn__packed_create_int_stream(root, FALSE, FALSE);
- svn__packed_int_stream_t *small_strings_headers
- = svn__packed_create_int_stream(root, FALSE, FALSE);
- svn__packed_byte_stream_t *large_strings
- = svn__packed_create_bytes_stream(root);
- svn__packed_byte_stream_t *small_strings_data
- = svn__packed_create_bytes_stream(root);
-
- svn__packed_create_int_substream(small_strings_headers, TRUE, FALSE);
- svn__packed_create_int_substream(small_strings_headers, FALSE, FALSE);
- svn__packed_create_int_substream(small_strings_headers, TRUE, FALSE);
- svn__packed_create_int_substream(small_strings_headers, FALSE, FALSE);
+ svn_packed__int_stream_t *table_sizes
+ = svn_packed__create_int_stream(root, FALSE, FALSE);
+ svn_packed__int_stream_t *small_strings_headers
+ = svn_packed__create_int_stream(root, FALSE, FALSE);
+ svn_packed__byte_stream_t *large_strings
+ = svn_packed__create_bytes_stream(root);
+ svn_packed__byte_stream_t *small_strings_data
+ = svn_packed__create_bytes_stream(root);
+
+ svn_packed__create_int_substream(small_strings_headers, TRUE, FALSE);
+ svn_packed__create_int_substream(small_strings_headers, FALSE, FALSE);
+ svn_packed__create_int_substream(small_strings_headers, TRUE, FALSE);
+ svn_packed__create_int_substream(small_strings_headers, FALSE, FALSE);
/* number of sub-tables */
- svn__packed_add_uint(table_sizes, table->size);
+ svn_packed__add_uint(table_sizes, table->size);
/* all short-string char data sizes */
for (i = 0; i < table->size; ++i)
- svn__packed_add_uint(table_sizes,
+ svn_packed__add_uint(table_sizes,
table->sub_tables[i].short_string_count);
for (i = 0; i < table->size; ++i)
- svn__packed_add_uint(table_sizes,
+ svn_packed__add_uint(table_sizes,
table->sub_tables[i].long_string_count);
/* all strings */
@@ -595,7 +595,7 @@ svn_fs_fs__write_string_table(svn_stream
for (i = 0; i < table->size; ++i)
{
string_sub_table_t *sub_table = &table->sub_tables[i];
- svn__packed_add_bytes(small_strings_data,
+ svn_packed__add_bytes(small_strings_data,
sub_table->data,
sub_table->data_size);
@@ -603,21 +603,21 @@ svn_fs_fs__write_string_table(svn_stream
{
string_header_t *string = &sub_table->short_strings[k];
- svn__packed_add_uint(small_strings_headers, string->head_string);
- svn__packed_add_uint(small_strings_headers, string->head_length);
- svn__packed_add_uint(small_strings_headers, string->tail_start);
- svn__packed_add_uint(small_strings_headers, string->tail_length);
+ svn_packed__add_uint(small_strings_headers, string->head_string);
+ svn_packed__add_uint(small_strings_headers, string->head_length);
+ svn_packed__add_uint(small_strings_headers, string->tail_start);
+ svn_packed__add_uint(small_strings_headers, string->tail_length);
}
for (k = 0; k < sub_table->long_string_count; ++k)
- svn__packed_add_bytes(large_strings,
+ svn_packed__add_bytes(large_strings,
sub_table->long_strings[k].data,
sub_table->long_strings[k].len + 1);
}
/* write to target stream */
- SVN_ERR(svn__packed_data_write(stream, root, pool));
+ SVN_ERR(svn_packed__data_write(stream, root, pool));
return SVN_NO_ERROR;
}
@@ -632,21 +632,21 @@ svn_fs_fs__read_string_table(string_tabl
string_table_t *table = apr_palloc(result_pool, sizeof(*table));
- svn__packed_data_root_t *root;
- svn__packed_int_stream_t *table_sizes;
- svn__packed_byte_stream_t *large_strings;
- svn__packed_byte_stream_t *small_strings_data;
- svn__packed_int_stream_t *headers;
-
- SVN_ERR(svn__packed_data_read(&root, stream, result_pool, scratch_pool));
- table_sizes = svn__packed_first_int_stream(root);
- headers = svn__packed_next_int_stream(table_sizes);
- large_strings = svn__packed_first_byte_stream(root);
- small_strings_data = svn__packed_next_byte_stream(large_strings);
+ svn_packed__data_root_t *root;
+ svn_packed__int_stream_t *table_sizes;
+ svn_packed__byte_stream_t *large_strings;
+ svn_packed__byte_stream_t *small_strings_data;
+ svn_packed__int_stream_t *headers;
+
+ SVN_ERR(svn_packed__data_read(&root, stream, result_pool, scratch_pool));
+ table_sizes = svn_packed__first_int_stream(root);
+ headers = svn_packed__next_int_stream(table_sizes);
+ large_strings = svn_packed__first_byte_stream(root);
+ small_strings_data = svn_packed__next_byte_stream(large_strings);
/* create sub-tables */
- table->size = svn__packed_get_uint(table_sizes);
+ table->size = svn_packed__get_uint(table_sizes);
table->sub_tables = apr_pcalloc(result_pool,
table->size * sizeof(*table->sub_tables));
@@ -656,7 +656,7 @@ svn_fs_fs__read_string_table(string_tabl
{
string_sub_table_t *sub_table = &table->sub_tables[i];
- sub_table->short_string_count = svn__packed_get_uint(table_sizes);
+ sub_table->short_string_count = svn_packed__get_uint(table_sizes);
if (sub_table->short_string_count)
{
sub_table->short_strings
@@ -669,14 +669,14 @@ svn_fs_fs__read_string_table(string_tabl
{
string_header_t *string = &sub_table->short_strings[k];
- string->head_string = svn__packed_get_uint(headers);
- string->head_length = svn__packed_get_uint(headers);
- string->tail_start = svn__packed_get_uint(headers);
- string->tail_length = svn__packed_get_uint(headers);
+ string->head_string = svn_packed__get_uint(headers);
+ string->head_length = svn_packed__get_uint(headers);
+ string->tail_start = svn_packed__get_uint(headers);
+ string->tail_length = svn_packed__get_uint(headers);
}
}
- sub_table->data = svn__packed_get_bytes(small_strings_data,
+ sub_table->data = svn_packed__get_bytes(small_strings_data,
&sub_table->data_size);
}
@@ -687,7 +687,7 @@ svn_fs_fs__read_string_table(string_tabl
/* initialize long string table */
string_sub_table_t *sub_table = &table->sub_tables[i];
- sub_table->long_string_count = svn__packed_get_uint(table_sizes);
+ sub_table->long_string_count = svn_packed__get_uint(table_sizes);
if (sub_table->long_string_count)
{
sub_table->long_strings
@@ -699,7 +699,7 @@ svn_fs_fs__read_string_table(string_tabl
for (k = 0; k < sub_table->long_string_count; ++k)
{
svn_string_t *string = &sub_table->long_strings[k];
- string->data = svn__packed_get_bytes(large_strings,
+ string->data = svn_packed__get_bytes(large_strings,
&string->len);
string->len--;
}
Modified: subversion/branches/fsfs-format7/subversion/libsvn_subr/packed_data.c
URL: http://svn.apache.org/viewvc/subversion/branches/fsfs-format7/subversion/libsvn_subr/packed_data.c?rev=1462837&r1=1462836&r2=1462837&view=diff
==============================================================================
--- subversion/branches/fsfs-format7/subversion/libsvn_subr/packed_data.c (original)
+++ subversion/branches/fsfs-format7/subversion/libsvn_subr/packed_data.c Sat Mar 30 18:39:23 2013
@@ -33,27 +33,27 @@
-/* Private int stream data referenced by svn__packed_int_stream_t.
+/* Private int stream data referenced by svn_packed__int_stream_t.
*/
typedef struct packed_int_private_t
{
/* First sub-stream, if any. NULL otherwise. */
- svn__packed_int_stream_t *first_substream;
+ svn_packed__int_stream_t *first_substream;
/* Last sub-stream, if any. NULL otherwise. */
- svn__packed_int_stream_t *last_substream;
+ svn_packed__int_stream_t *last_substream;
/* Current sub-stream to read from / write to, if any. NULL otherwise.
This will be initialized to FIRST_SUBSTREAM and then advanced in a
round-robin scheme after each number being read. */
- svn__packed_int_stream_t *current_substream;
+ svn_packed__int_stream_t *current_substream;
/* Number of sub-streams. */
apr_size_t substream_count;
/* Next (sibling) integer stream. If this is the last one, points to
the first in the list (i.e. this forms a ring list). Never NULL. */
- svn__packed_int_stream_t *next;
+ svn_packed__int_stream_t *next;
/* 7b/8b encoded integer values (previously diff'ed and sign-handled,
if indicated by the flags below). The contents are disjoint from
@@ -84,22 +84,22 @@ typedef struct packed_int_private_t
/* A byte sequence stream. Please note that NEXT is defined different
* from the NEXT member in integer streams.
*/
-struct svn__packed_byte_stream_t
+struct svn_packed__byte_stream_t
{
/* First sub-stream, if any. NULL otherwise. */
- svn__packed_byte_stream_t *first_substream;
+ svn_packed__byte_stream_t *first_substream;
/* Last sub-stream, if any. NULL otherwise. */
- svn__packed_byte_stream_t *last_substream;
+ svn_packed__byte_stream_t *last_substream;
/* Number of sub-streams. */
apr_size_t substream_count;
/* Next (sibling) byte sequence stream, if any. NULL otherwise. */
- svn__packed_byte_stream_t *next;
+ svn_packed__byte_stream_t *next;
/* Stream to store the sequence lengths. */
- svn__packed_int_stream_t *lengths_stream;
+ svn_packed__int_stream_t *lengths_stream;
/* It's index (relative to its parent). */
apr_size_t lengths_stream_index;
@@ -113,22 +113,22 @@ struct svn__packed_byte_stream_t
/* The serialization root object. It references the top-level streams.
*/
-struct svn__packed_data_root_t
+struct svn_packed__data_root_t
{
/* First top-level integer stream, if any. NULL otherwise. */
- svn__packed_int_stream_t *first_int_stream;
+ svn_packed__int_stream_t *first_int_stream;
/* Last top-level integer stream, if any. NULL otherwise. */
- svn__packed_int_stream_t *last_int_stream;
+ svn_packed__int_stream_t *last_int_stream;
/* Number of top-level integer streams. */
apr_size_t int_stream_count;
/* First top-level byte sequence stream, if any. NULL otherwise. */
- svn__packed_byte_stream_t *first_byte_stream;
+ svn_packed__byte_stream_t *first_byte_stream;
/* Last top-level byte sequence stream, if any. NULL otherwise. */
- svn__packed_byte_stream_t *last_byte_stream;
+ svn_packed__byte_stream_t *last_byte_stream;
/* Number of top-level byte sequence streams. */
apr_size_t byte_stream_count;
@@ -139,24 +139,24 @@ struct svn__packed_data_root_t
/* Write access. */
-svn__packed_data_root_t *
-svn__packed_data_create_root(apr_pool_t *pool)
+svn_packed__data_root_t *
+svn_packed__data_create_root(apr_pool_t *pool)
{
- svn__packed_data_root_t *root = apr_pcalloc(pool, sizeof(*root));
+ svn_packed__data_root_t *root = apr_pcalloc(pool, sizeof(*root));
root->pool = pool;
return root;
}
-svn__packed_int_stream_t *
-svn__packed_create_int_stream(svn__packed_data_root_t *root,
+svn_packed__int_stream_t *
+svn_packed__create_int_stream(svn_packed__data_root_t *root,
svn_boolean_t diff,
svn_boolean_t signed_ints)
{
/* allocate and initialize the stream node */
packed_int_private_t *private_data
= apr_pcalloc(root->pool, sizeof(*private_data));
- svn__packed_int_stream_t *stream
+ svn_packed__int_stream_t *stream
= apr_palloc(root->pool, sizeof(*stream));
private_data->diff = diff;
@@ -186,8 +186,8 @@ svn__packed_create_int_stream(svn__packe
return stream;
}
-svn__packed_int_stream_t *
-svn__packed_create_int_substream(svn__packed_int_stream_t *parent,
+svn_packed__int_stream_t *
+svn_packed__create_int_substream(svn_packed__int_stream_t *parent,
svn_boolean_t diff,
svn_boolean_t signed_ints)
{
@@ -196,7 +196,7 @@ svn__packed_create_int_substream(svn__pa
/* allocate and initialize the stream node */
packed_int_private_t *private_data
= apr_pcalloc(parent_private->pool, sizeof(*private_data));
- svn__packed_int_stream_t *stream
+ svn_packed__int_stream_t *stream
= apr_palloc(parent_private->pool, sizeof(*stream));
private_data->diff = diff;
@@ -231,10 +231,10 @@ svn__packed_create_int_substream(svn__pa
/* Returns a new top-level byte sequence stream for ROOT but does not
* initialize the LENGTH_STREAM member.
*/
-static svn__packed_byte_stream_t *
-create_bytes_stream_body(svn__packed_data_root_t *root)
+static svn_packed__byte_stream_t *
+create_bytes_stream_body(svn_packed__data_root_t *root)
{
- svn__packed_byte_stream_t *stream
+ svn_packed__byte_stream_t *stream
= apr_pcalloc(root->pool, sizeof(*stream));
stream->packed = svn_stringbuf_create_empty(root->pool);
@@ -250,14 +250,14 @@ create_bytes_stream_body(svn__packed_dat
return stream;
}
-svn__packed_byte_stream_t *
-svn__packed_create_bytes_stream(svn__packed_data_root_t *root)
+svn_packed__byte_stream_t *
+svn_packed__create_bytes_stream(svn_packed__data_root_t *root)
{
- svn__packed_byte_stream_t *stream
+ svn_packed__byte_stream_t *stream
= create_bytes_stream_body(root);
stream->lengths_stream_index = root->int_stream_count;
- stream->lengths_stream = svn__packed_create_int_stream(root, FALSE, FALSE);
+ stream->lengths_stream = svn_packed__create_int_stream(root, FALSE, FALSE);
return stream;
}
@@ -265,10 +265,10 @@ svn__packed_create_bytes_stream(svn__pac
/* Returns a new sub-stream for PARENT but does not initialize the
* LENGTH_STREAM member.
*/
-static svn__packed_byte_stream_t *
-packed_data_create_bytes_substream_body(svn__packed_byte_stream_t *parent)
+static svn_packed__byte_stream_t *
+packed_data_create_bytes_substream_body(svn_packed__byte_stream_t *parent)
{
- svn__packed_byte_stream_t *stream
+ svn_packed__byte_stream_t *stream
= apr_pcalloc(parent->pool, sizeof(*stream));
stream->packed = svn_stringbuf_create_empty(parent->pool);
@@ -284,44 +284,44 @@ packed_data_create_bytes_substream_body(
return stream;
}
-svn__packed_byte_stream_t *
-svn__packed_create_bytes_substream(svn__packed_byte_stream_t *parent)
+svn_packed__byte_stream_t *
+svn_packed__create_bytes_substream(svn_packed__byte_stream_t *parent)
{
packed_int_private_t *parent_length_private
= parent->lengths_stream->private_data;
- svn__packed_byte_stream_t *stream
+ svn_packed__byte_stream_t *stream
= packed_data_create_bytes_substream_body(parent);
stream->lengths_stream_index = parent_length_private->substream_count;
stream->lengths_stream
- = svn__packed_create_int_substream(parent->lengths_stream,
+ = svn_packed__create_int_substream(parent->lengths_stream,
FALSE, FALSE);
return stream;
}
void
-svn__packed_add_uint(svn__packed_int_stream_t *stream,
+svn_packed__add_uint(svn_packed__int_stream_t *stream,
apr_uint64_t value)
{
stream->buffer[stream->buffer_used] = value;
if (++stream->buffer_used == SVN__PACKED_DATA_BUFFER_SIZE)
- svn__packed_data_flush_buffer(stream);
+ svn_packed__data_flush_buffer(stream);
}
void
-svn__packed_add_int(svn__packed_int_stream_t *stream,
+svn_packed__add_int(svn_packed__int_stream_t *stream,
apr_int64_t value)
{
- svn__packed_add_uint(stream, (apr_uint64_t)value);
+ svn_packed__add_uint(stream, (apr_uint64_t)value);
}
void
-svn__packed_add_bytes(svn__packed_byte_stream_t *stream,
+svn_packed__add_bytes(svn_packed__byte_stream_t *stream,
const char *data,
apr_size_t len)
{
- svn__packed_add_uint(stream->lengths_stream, len);
+ svn_packed__add_uint(stream->lengths_stream, len);
svn_stringbuf_appendbytes(stream->packed, data, len);
}
@@ -343,7 +343,7 @@ write_packed_uint_body(unsigned char *bu
}
void
-svn__packed_data_flush_buffer(svn__packed_int_stream_t *stream)
+svn_packed__data_flush_buffer(svn_packed__int_stream_t *stream)
{
packed_int_private_t *private_data = stream->private_data;
apr_size_t i;
@@ -355,7 +355,7 @@ svn__packed_data_flush_buffer(svn__packe
packed_int_private_t *current_private_data
= private_data->current_substream->private_data;
- svn__packed_add_uint(private_data->current_substream,
+ svn_packed__add_uint(private_data->current_substream,
stream->buffer[i]);
private_data->current_substream = current_private_data->next;
}
@@ -437,7 +437,7 @@ write_packed_uint(svn_stringbuf_t* packe
*/
static void
write_int_stream_structure(svn_stringbuf_t* tree_struct,
- svn__packed_int_stream_t* stream)
+ svn_packed__int_stream_t* stream)
{
while (stream)
{
@@ -448,7 +448,7 @@ write_int_stream_structure(svn_stringbuf
+ (private_data->is_signed ? 2 : 0));
/* store item count and length their of packed representation */
- svn__packed_data_flush_buffer(stream);
+ svn_packed__data_flush_buffer(stream);
write_packed_uint(tree_struct, private_data->item_count);
write_packed_uint(tree_struct, private_data->packed
@@ -468,7 +468,7 @@ write_int_stream_structure(svn_stringbuf
*/
static void
write_byte_stream_structure(svn_stringbuf_t* tree_struct,
- svn__packed_byte_stream_t* stream)
+ svn_packed__byte_stream_t* stream)
{
/* for this and all siblings */
for (; stream; stream = stream->next)
@@ -502,7 +502,7 @@ write_stream_uint(svn_stream_t *stream,
* calling this function.
*/
static apr_size_t
-packed_int_stream_length(svn__packed_int_stream_t *stream)
+packed_int_stream_length(svn_packed__int_stream_t *stream)
{
packed_int_private_t *private_data = stream->private_data;
apr_size_t result = private_data->packed ? private_data->packed->len : 0;
@@ -522,7 +522,7 @@ packed_int_stream_length(svn__packed_int
* and all sub-streams.
*/
static apr_size_t
-packed_byte_stream_length(svn__packed_byte_stream_t *stream)
+packed_byte_stream_length(svn_packed__byte_stream_t *stream)
{
apr_size_t result = stream->packed->len;
@@ -536,7 +536,7 @@ packed_byte_stream_length(svn__packed_by
* COMBINED.
*/
static void
-append_int_stream(svn__packed_int_stream_t *stream,
+append_int_stream(svn_packed__int_stream_t *stream,
svn_stringbuf_t *combined)
{
packed_int_private_t *private_data = stream->private_data;
@@ -556,7 +556,7 @@ append_int_stream(svn__packed_int_stream
* to COMBINED.
*/
static void
-append_byte_stream(svn__packed_byte_stream_t *stream,
+append_byte_stream(svn_packed__byte_stream_t *stream,
svn_stringbuf_t *combined)
{
svn_stringbuf_appendstr(combined, stream->packed);
@@ -588,12 +588,12 @@ write_stream_data(svn_stream_t *stream,
}
svn_error_t *
-svn__packed_data_write(svn_stream_t *stream,
- svn__packed_data_root_t *root,
+svn_packed__data_write(svn_stream_t *stream,
+ svn_packed__data_root_t *root,
apr_pool_t *scratch_pool)
{
- svn__packed_int_stream_t *int_stream;
- svn__packed_byte_stream_t *byte_stream;
+ svn_packed__int_stream_t *int_stream;
+ svn_packed__byte_stream_t *byte_stream;
/* re-usable data buffers */
svn_stringbuf_t *compressed
@@ -644,79 +644,79 @@ svn__packed_data_write(svn_stream_t *str
/* Read access. */
-svn__packed_int_stream_t *
-svn__packed_first_int_stream(svn__packed_data_root_t *root)
+svn_packed__int_stream_t *
+svn_packed__first_int_stream(svn_packed__data_root_t *root)
{
return root->first_int_stream;
}
-svn__packed_byte_stream_t *
-svn__packed_first_byte_stream(svn__packed_data_root_t *root)
+svn_packed__byte_stream_t *
+svn_packed__first_byte_stream(svn_packed__data_root_t *root)
{
return root->first_byte_stream;
}
-svn__packed_int_stream_t *
-svn__packed_next_int_stream(svn__packed_int_stream_t *stream)
+svn_packed__int_stream_t *
+svn_packed__next_int_stream(svn_packed__int_stream_t *stream)
{
packed_int_private_t *private_data = stream->private_data;
return private_data->is_last ? NULL : private_data->next;
}
-svn__packed_byte_stream_t *
-svn__packed_next_byte_stream(svn__packed_byte_stream_t *stream)
+svn_packed__byte_stream_t *
+svn_packed__next_byte_stream(svn_packed__byte_stream_t *stream)
{
return stream->next;
}
-svn__packed_int_stream_t *
-svn__packed_first_int_substream(svn__packed_int_stream_t *stream)
+svn_packed__int_stream_t *
+svn_packed__first_int_substream(svn_packed__int_stream_t *stream)
{
packed_int_private_t *private_data = stream->private_data;
return private_data->first_substream;
}
-svn__packed_byte_stream_t *
-svn__packed_first_byte_substream(svn__packed_byte_stream_t *stream)
+svn_packed__byte_stream_t *
+svn_packed__first_byte_substream(svn_packed__byte_stream_t *stream)
{
return stream->first_substream;
}
apr_size_t
-svn__packed_int_count(svn__packed_int_stream_t *stream)
+svn_packed__int_count(svn_packed__int_stream_t *stream)
{
packed_int_private_t *private_data = stream->private_data;
return private_data->item_count + stream->buffer_used;
}
apr_size_t
-svn__packed_byte_count(svn__packed_byte_stream_t *stream)
+svn_packed__byte_count(svn_packed__byte_stream_t *stream)
{
return stream->packed->len;
}
apr_uint64_t
-svn__packed_get_uint(svn__packed_int_stream_t *stream)
+svn_packed__get_uint(svn_packed__int_stream_t *stream)
{
if (stream->buffer_used == 0)
- svn__packed_data_fill_buffer(stream);
+ svn_packed__data_fill_buffer(stream);
return stream->buffer_used ? stream->buffer[--stream->buffer_used] : 0;
}
apr_int64_t
-svn__packed_get_int(svn__packed_int_stream_t *stream,
+svn_packed__get_int(svn_packed__int_stream_t *stream,
apr_int64_t value)
{
- return (apr_int64_t)svn__packed_get_uint(stream);
+ return (apr_int64_t)svn_packed__get_uint(stream);
}
const char *
-svn__packed_get_bytes(svn__packed_byte_stream_t *stream,
+svn_packed__get_bytes(svn_packed__byte_stream_t *stream,
apr_size_t *len)
{
const char *result = stream->packed->data;
- apr_size_t count = svn__packed_get_uint(stream->lengths_stream);
+ apr_size_t count = svn_packed__get_uint(stream->lengths_stream);
if (count > stream->packed->len)
count = stream->packed->len;
@@ -802,7 +802,7 @@ read_stream_uint(svn_stream_t *stream, a
}
void
-svn__packed_data_fill_buffer(svn__packed_int_stream_t *stream)
+svn_packed__data_fill_buffer(svn_packed__int_stream_t *stream)
{
packed_int_private_t *private_data = stream->private_data;
apr_size_t i;
@@ -821,7 +821,7 @@ svn__packed_data_fill_buffer(svn__packed
packed_int_private_t *current_private_data
= private_data->current_substream->private_data;
stream->buffer[i-1]
- = svn__packed_get_uint(private_data->current_substream);
+ = svn_packed__get_uint(private_data->current_substream);
private_data->current_substream = current_private_data->next;
}
else
@@ -910,7 +910,7 @@ read_packed_uint(svn_stringbuf_t *packed
*/
static void
read_int_stream_structure(svn_stringbuf_t *tree_struct,
- svn__packed_int_stream_t *stream)
+ svn_packed__int_stream_t *stream)
{
packed_int_private_t *private_data = stream->private_data;
apr_uint64_t value = read_packed_uint(tree_struct);
@@ -935,7 +935,7 @@ read_int_stream_structure(svn_stringbuf_
/* add sub-streams and read their config, too */
for (i = 0; i < substream_count; ++i)
read_int_stream_structure(tree_struct,
- svn__packed_create_int_substream(stream,
+ svn_packed__create_int_substream(stream,
FALSE,
FALSE));
}
@@ -946,8 +946,8 @@ read_int_stream_structure(svn_stringbuf_
*/
static void
read_byte_stream_structure(svn_stringbuf_t *tree_struct,
- svn__packed_byte_stream_t *stream,
- svn__packed_int_stream_t *first_int_stream)
+ svn_packed__byte_stream_t *stream,
+ svn_packed__int_stream_t *first_int_stream)
{
/* read parameters from the TREE_STRUCT buffer */
apr_size_t substream_count = (apr_size_t)read_packed_uint(tree_struct);
@@ -972,7 +972,7 @@ read_byte_stream_structure(svn_stringbuf
/* reconstruct sub-streams */
for (i = 0; i < substream_count; ++i)
{
- svn__packed_byte_stream_t *substream
+ svn_packed__byte_stream_t *substream
= packed_data_create_bytes_substream_body(stream);
packed_int_private_t *length_private
= stream->lengths_stream->private_data;
@@ -1013,7 +1013,7 @@ read_stream_data(svn_stream_t *stream,
* continue with the sub-streams.
*/
static void
-unflatten_int_stream(svn__packed_int_stream_t *stream,
+unflatten_int_stream(svn_packed__int_stream_t *stream,
svn_stringbuf_t *combined,
apr_size_t *offset)
{
@@ -1042,7 +1042,7 @@ unflatten_int_stream(svn__packed_int_str
* continue with the sub-streams.
*/
static void
-unflatten_byte_stream(svn__packed_byte_stream_t *stream,
+unflatten_byte_stream(svn_packed__byte_stream_t *stream,
svn_stringbuf_t *combined,
apr_size_t *offset)
{
@@ -1057,7 +1057,7 @@ unflatten_byte_stream(svn__packed_byte_s
}
svn_error_t *
-svn__packed_data_read(svn__packed_data_root_t **root_p,
+svn_packed__data_read(svn_packed__data_root_t **root_p,
svn_stream_t *stream,
apr_pool_t *result_pool,
apr_pool_t *scratch_pool)
@@ -1065,9 +1065,9 @@ svn__packed_data_read(svn__packed_data_r
apr_size_t i;
apr_size_t count;
- svn__packed_int_stream_t *int_stream;
- svn__packed_byte_stream_t *byte_stream;
- svn__packed_data_root_t *root = svn__packed_data_create_root(result_pool);
+ svn_packed__int_stream_t *int_stream;
+ svn_packed__byte_stream_t *byte_stream;
+ svn_packed__data_root_t *root = svn_packed__data_create_root(result_pool);
svn_stringbuf_t *compressed
= svn_stringbuf_create_ensure(1024, scratch_pool);
@@ -1092,7 +1092,7 @@ svn__packed_data_read(svn__packed_data_r
count = read_packed_uint(tree_struct);
for (i = 0; i < count; ++i)
read_int_stream_structure(tree_struct,
- svn__packed_create_int_stream(root, FALSE,
+ svn_packed__create_int_stream(root, FALSE,
FALSE));
count = read_packed_uint(tree_struct);