summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorCarlos Martín Nieto <cmn@dwim.me>2013-10-30 15:00:05 +0100
committerCarlos Martín Nieto <cmn@dwim.me>2013-10-30 15:00:05 +0100
commita6154f2183043626cdbe995b4795346610b5862e (patch)
treeda7018cc6cf06bf27cb11cef356d6b9fde31b9fd /src
parent5c50f22a93c78190fb7d81802199ff9defc8cf55 (diff)
downloadlibgit2-a6154f2183043626cdbe995b4795346610b5862e.tar.gz
indexer: remove the stream infix
It was there to keep it apart from the one which read in from a file on disk. This other indexer does not exist anymore, so there is no need for anything other than git_indexer to refer to it. While here, rename _add() function to _append() and _finalize() to _commit(). The former change is cosmetic, while the latter avoids talking about "finalizing", which OO languages use to mean something completely different.
Diffstat (limited to 'src')
-rw-r--r--src/indexer.c52
-rw-r--r--src/odb_pack.c14
-rw-r--r--src/pack-objects.c14
-rw-r--r--src/transports/local.c2
-rw-r--r--src/transports/smart_protocol.c4
5 files changed, 43 insertions, 43 deletions
diff --git a/src/indexer.c b/src/indexer.c
index 9f55c8b2c..07d0073c8 100644
--- a/src/indexer.c
+++ b/src/indexer.c
@@ -29,7 +29,7 @@ struct entry {
uint64_t offset_long;
};
-struct git_indexer_stream {
+struct git_indexer {
unsigned int parsed_header :1,
opened_pack :1,
have_stream :1,
@@ -63,7 +63,7 @@ struct delta_info {
git_off_t delta_off;
};
-const git_oid *git_indexer_stream_hash(const git_indexer_stream *idx)
+const git_oid *git_indexer_hash(const git_indexer *idx)
{
return &idx->hash;
}
@@ -116,19 +116,19 @@ static int objects_cmp(const void *a, const void *b)
return git_oid__cmp(&entrya->oid, &entryb->oid);
}
-int git_indexer_stream_new(
- git_indexer_stream **out,
+int git_indexer_new(
+ git_indexer **out,
const char *prefix,
git_odb *odb,
git_transfer_progress_callback progress_cb,
void *progress_payload)
{
- git_indexer_stream *idx;
+ git_indexer *idx;
git_buf path = GIT_BUF_INIT;
static const char suff[] = "/pack";
int error;
- idx = git__calloc(1, sizeof(git_indexer_stream));
+ idx = git__calloc(1, sizeof(git_indexer));
GITERR_CHECK_ALLOC(idx);
idx->odb = odb;
idx->progress_cb = progress_cb;
@@ -156,7 +156,7 @@ cleanup:
}
/* Try to store the delta so we can try to resolve it later */
-static int store_delta(git_indexer_stream *idx)
+static int store_delta(git_indexer *idx)
{
struct delta_info *delta;
@@ -179,7 +179,7 @@ static void hash_header(git_hash_ctx *ctx, git_off_t len, git_otype type)
git_hash_update(ctx, buffer, hdrlen);
}
-static int hash_object_stream(git_indexer_stream *idx, git_packfile_stream *stream)
+static int hash_object_stream(git_indexer*idx, git_packfile_stream *stream)
{
ssize_t read;
@@ -199,7 +199,7 @@ static int hash_object_stream(git_indexer_stream *idx, git_packfile_stream *stre
}
/* In order to create the packfile stream, we need to skip over the delta base description */
-static int advance_delta_offset(git_indexer_stream *idx, git_otype type)
+static int advance_delta_offset(git_indexer *idx, git_otype type)
{
git_mwindow *w = NULL;
@@ -218,7 +218,7 @@ static int advance_delta_offset(git_indexer_stream *idx, git_otype type)
}
/* Read from the stream and discard any output */
-static int read_object_stream(git_indexer_stream *idx, git_packfile_stream *stream)
+static int read_object_stream(git_indexer *idx, git_packfile_stream *stream)
{
ssize_t read;
@@ -258,7 +258,7 @@ static int crc_object(uint32_t *crc_out, git_mwindow_file *mwf, git_off_t start,
return 0;
}
-static int store_object(git_indexer_stream *idx)
+static int store_object(git_indexer *idx)
{
int i, error;
khiter_t k;
@@ -316,7 +316,7 @@ on_error:
return -1;
}
-static int save_entry(git_indexer_stream *idx, struct entry *entry, struct git_pack_entry *pentry, git_off_t entry_start)
+static int save_entry(git_indexer *idx, struct entry *entry, struct git_pack_entry *pentry, git_off_t entry_start)
{
int i, error;
khiter_t k;
@@ -346,7 +346,7 @@ static int save_entry(git_indexer_stream *idx, struct entry *entry, struct git_p
return 0;
}
-static int hash_and_save(git_indexer_stream *idx, git_rawobj *obj, git_off_t entry_start)
+static int hash_and_save(git_indexer *idx, git_rawobj *obj, git_off_t entry_start)
{
git_oid oid;
size_t entry_size;
@@ -380,14 +380,14 @@ on_error:
return -1;
}
-static int do_progress_callback(git_indexer_stream *idx, git_transfer_progress *stats)
+static int do_progress_callback(git_indexer *idx, git_transfer_progress *stats)
{
if (!idx->progress_cb) return 0;
return idx->progress_cb(stats, idx->progress_payload);
}
/* Hash everything but the last 20B of input */
-static void hash_partially(git_indexer_stream *idx, const uint8_t *data, size_t size)
+static void hash_partially(git_indexer *idx, const uint8_t *data, size_t size)
{
size_t to_expell, to_keep;
@@ -423,7 +423,7 @@ static void hash_partially(git_indexer_stream *idx, const uint8_t *data, size_t
idx->inbuf_len += size - to_expell;
}
-int git_indexer_stream_add(git_indexer_stream *idx, const void *data, size_t size, git_transfer_progress *stats)
+int git_indexer_append(git_indexer *idx, const void *data, size_t size, git_transfer_progress *stats)
{
int error = -1;
size_t processed;
@@ -583,7 +583,7 @@ on_error:
return error;
}
-static int index_path_stream(git_buf *path, git_indexer_stream *idx, const char *suffix)
+static int index_path(git_buf *path, git_indexer *idx, const char *suffix)
{
const char prefix[] = "pack-";
size_t slash = (size_t)path->size;
@@ -609,7 +609,7 @@ static int index_path_stream(git_buf *path, git_indexer_stream *idx, const char
* Rewind the packfile by the trailer, as we might need to fix the
* packfile by injecting objects at the tail and must overwrite it.
*/
-static git_off_t seek_back_trailer(git_indexer_stream *idx)
+static git_off_t seek_back_trailer(git_indexer *idx)
{
git_off_t off;
@@ -622,7 +622,7 @@ static git_off_t seek_back_trailer(git_indexer_stream *idx)
return off;
}
-static int inject_object(git_indexer_stream *idx, git_oid *id)
+static int inject_object(git_indexer *idx, git_oid *id)
{
git_odb_object *obj;
struct entry *entry;
@@ -684,7 +684,7 @@ cleanup:
return error;
}
-static int fix_thin_pack(git_indexer_stream *idx, git_transfer_progress *stats)
+static int fix_thin_pack(git_indexer *idx, git_transfer_progress *stats)
{
int error, found_ref_delta = 0;
unsigned int i;
@@ -741,7 +741,7 @@ static int fix_thin_pack(git_indexer_stream *idx, git_transfer_progress *stats)
return 0;
}
-static int resolve_deltas(git_indexer_stream *idx, git_transfer_progress *stats)
+static int resolve_deltas(git_indexer *idx, git_transfer_progress *stats)
{
unsigned int i;
struct delta_info *delta;
@@ -784,7 +784,7 @@ static int resolve_deltas(git_indexer_stream *idx, git_transfer_progress *stats)
return 0;
}
-static int update_header_and_rehash(git_indexer_stream *idx, git_transfer_progress *stats)
+static int update_header_and_rehash(git_indexer *idx, git_transfer_progress *stats)
{
void *ptr;
size_t chunk = 1024*1024;
@@ -833,7 +833,7 @@ static int update_header_and_rehash(git_indexer_stream *idx, git_transfer_progre
return 0;
}
-int git_indexer_stream_finalize(git_indexer_stream *idx, git_transfer_progress *stats)
+int git_indexer_commit(git_indexer *idx, git_transfer_progress *stats)
{
git_mwindow *w = NULL;
unsigned int i, long_offsets = 0, left;
@@ -965,7 +965,7 @@ int git_indexer_stream_finalize(git_indexer_stream *idx, git_transfer_progress *
git_filebuf_write(&index_file, &trailer_hash, sizeof(git_oid));
/* Figure out what the final name should be */
- if (index_path_stream(&filename, idx, ".idx") < 0)
+ if (index_path(&filename, idx, ".idx") < 0)
goto on_error;
/* Commit file */
@@ -977,7 +977,7 @@ int git_indexer_stream_finalize(git_indexer_stream *idx, git_transfer_progress *
p_close(idx->pack->mwf.fd);
idx->pack->mwf.fd = -1;
- if (index_path_stream(&filename, idx, ".pack") < 0)
+ if (index_path(&filename, idx, ".pack") < 0)
goto on_error;
/* And don't forget to rename the packfile to its new place. */
if (git_filebuf_commit_at(&idx->pack_file, filename.ptr, GIT_PACK_FILE_MODE) < 0)
@@ -994,7 +994,7 @@ on_error:
return -1;
}
-void git_indexer_stream_free(git_indexer_stream *idx)
+void git_indexer_free(git_indexer *idx)
{
khiter_t k;
unsigned int i;
diff --git a/src/odb_pack.c b/src/odb_pack.c
index 4c7c82253..12f4591ec 100644
--- a/src/odb_pack.c
+++ b/src/odb_pack.c
@@ -29,7 +29,7 @@ struct pack_backend {
struct pack_writepack {
struct git_odb_writepack parent;
- git_indexer_stream *indexer_stream;
+ git_indexer *indexer;
};
/**
@@ -511,13 +511,13 @@ static int pack_backend__foreach(git_odb_backend *_backend, git_odb_foreach_cb c
return 0;
}
-static int pack_backend__writepack_add(struct git_odb_writepack *_writepack, const void *data, size_t size, git_transfer_progress *stats)
+static int pack_backend__writepack_append(struct git_odb_writepack *_writepack, const void *data, size_t size, git_transfer_progress *stats)
{
struct pack_writepack *writepack = (struct pack_writepack *)_writepack;
assert(writepack);
- return git_indexer_stream_add(writepack->indexer_stream, data, size, stats);
+ return git_indexer_append(writepack->indexer, data, size, stats);
}
static int pack_backend__writepack_commit(struct git_odb_writepack *_writepack, git_transfer_progress *stats)
@@ -526,7 +526,7 @@ static int pack_backend__writepack_commit(struct git_odb_writepack *_writepack,
assert(writepack);
- return git_indexer_stream_finalize(writepack->indexer_stream, stats);
+ return git_indexer_commit(writepack->indexer, stats);
}
static void pack_backend__writepack_free(struct git_odb_writepack *_writepack)
@@ -535,7 +535,7 @@ static void pack_backend__writepack_free(struct git_odb_writepack *_writepack)
assert(writepack);
- git_indexer_stream_free(writepack->indexer_stream);
+ git_indexer_free(writepack->indexer);
git__free(writepack);
}
@@ -557,14 +557,14 @@ static int pack_backend__writepack(struct git_odb_writepack **out,
writepack = git__calloc(1, sizeof(struct pack_writepack));
GITERR_CHECK_ALLOC(writepack);
- if (git_indexer_stream_new(&writepack->indexer_stream,
+ if (git_indexer_new(&writepack->indexer,
backend->pack_folder, odb, progress_cb, progress_payload) < 0) {
git__free(writepack);
return -1;
}
writepack->parent.backend = _backend;
- writepack->parent.add = pack_backend__writepack_add;
+ writepack->parent.append = pack_backend__writepack_append;
writepack->parent.commit = pack_backend__writepack_commit;
writepack->parent.free = pack_backend__writepack_free;
diff --git a/src/pack-objects.c b/src/pack-objects.c
index 93541e974..938b28fde 100644
--- a/src/pack-objects.c
+++ b/src/pack-objects.c
@@ -35,7 +35,7 @@ struct tree_walk_context {
};
struct pack_write_context {
- git_indexer_stream *indexer;
+ git_indexer *indexer;
git_transfer_progress *stats;
};
@@ -1242,7 +1242,7 @@ int git_packbuilder_write_buf(git_buf *buf, git_packbuilder *pb)
static int write_cb(void *buf, size_t len, void *payload)
{
struct pack_write_context *ctx = payload;
- return git_indexer_stream_add(ctx->indexer, buf, len, ctx->stats);
+ return git_indexer_append(ctx->indexer, buf, len, ctx->stats);
}
int git_packbuilder_write(
@@ -1251,13 +1251,13 @@ int git_packbuilder_write(
git_transfer_progress_callback progress_cb,
void *progress_cb_payload)
{
- git_indexer_stream *indexer;
+ git_indexer *indexer;
git_transfer_progress stats;
struct pack_write_context ctx;
PREPARE_PACK;
- if (git_indexer_stream_new(
+ if (git_indexer_new(
&indexer, path, pb->odb, progress_cb, progress_cb_payload) < 0)
return -1;
@@ -1265,12 +1265,12 @@ int git_packbuilder_write(
ctx.stats = &stats;
if (git_packbuilder_foreach(pb, write_cb, &ctx) < 0 ||
- git_indexer_stream_finalize(indexer, &stats) < 0) {
- git_indexer_stream_free(indexer);
+ git_indexer_commit(indexer, &stats) < 0) {
+ git_indexer_free(indexer);
return -1;
}
- git_indexer_stream_free(indexer);
+ git_indexer_free(indexer);
return 0;
}
diff --git a/src/transports/local.c b/src/transports/local.c
index 3c1f98804..3163d2eac 100644
--- a/src/transports/local.c
+++ b/src/transports/local.c
@@ -459,7 +459,7 @@ static int foreach_cb(void *buf, size_t len, void *payload)
foreach_data *data = (foreach_data*)payload;
data->stats->received_bytes += len;
- return data->writepack->add(data->writepack, buf, len, data->stats);
+ return data->writepack->append(data->writepack, buf, len, data->stats);
}
static int local_download_pack(
diff --git a/src/transports/smart_protocol.c b/src/transports/smart_protocol.c
index af6e35fa1..8833b2816 100644
--- a/src/transports/smart_protocol.c
+++ b/src/transports/smart_protocol.c
@@ -408,7 +408,7 @@ static int no_sideband(transport_smart *t, struct git_odb_writepack *writepack,
return GIT_EUSER;
}
- if (writepack->add(writepack, buf->data, buf->offset, stats) < 0)
+ if (writepack->append(writepack, buf->data, buf->offset, stats) < 0)
return -1;
gitno_consume_n(buf, buf->offset);
@@ -523,7 +523,7 @@ int git_smart__download_pack(
git__free(pkt);
} else if (pkt->type == GIT_PKT_DATA) {
git_pkt_data *p = (git_pkt_data *) pkt;
- error = writepack->add(writepack, p->data, p->len, stats);
+ error = writepack->append(writepack, p->data, p->len, stats);
git__free(pkt);
if (error < 0)