@ -11,8 +11,8 @@
@@ -11,8 +11,8 @@
#include "repo_tree.h"
#include "fast_export.h"
#include "line_buffer.h"
#include "obj_pool.h"
#include "string_pool.h"
#include "strbuf.h"
#define REPORT_FILENO 3
@ -37,22 +37,8 @@
@@ -37,22 +37,8 @@
#define LENGTH_UNKNOWN (~0)
#define DATE_RFC2822_LEN 31
/* Create memory pool for log messages */
obj_pool_gen(log, char, 4096)
static struct line_buffer input = LINE_BUFFER_INIT;
#define REPORT_FILENO 3
static char *log_copy(uint32_t length, const char *log)
{
char *buffer;
log_free(log_pool.size);
buffer = log_pointer(log_alloc(length));
strncpy(buffer, log, length);
return buffer;
}
static struct {
uint32_t action, propLength, textLength, srcRev, type;
uint32_t src[REPO_MAX_PATH_DEPTH], dst[REPO_MAX_PATH_DEPTH];
@ -60,13 +46,14 @@ static struct {
@@ -60,13 +46,14 @@ static struct {
} node_ctx;
static struct {
uint32_t revision, author;
uint32_t revision;
unsigned long timestamp;
char *log;
struct strbuf log, author;
} rev_ctx;
static struct {
uint32_t version, uuid, url;
uint32_t version;
struct strbuf uuid, url;
} dump_ctx;
static void reset_node_ctx(char *fname)
@ -86,15 +73,17 @@ static void reset_rev_ctx(uint32_t revision)
@@ -86,15 +73,17 @@ static void reset_rev_ctx(uint32_t revision)
{
rev_ctx.revision = revision;
rev_ctx.timestamp = 0;
rev_ctx.log = NULL;
rev_ctx.author = ~0;
strbuf_reset(&rev_ctx.log);
strbuf_reset(&rev_ctx.author);
}
static void reset_dump_ctx(uint32_t url)
static void reset_dump_ctx(const char *url)
{
dump_ctx.url = url;
strbuf_reset(&dump_ctx.url);
if (url)
strbuf_addstr(&dump_ctx.url, url);
dump_ctx.version = 1;
dump_ctx.uuid = ~0;
strbuf_reset(&dump_ctx.uuid);
}
static void handle_property(const struct strbuf *key_buf,
@ -110,13 +99,15 @@ static void handle_property(const struct strbuf *key_buf,
@@ -110,13 +99,15 @@ static void handle_property(const struct strbuf *key_buf,
break;
if (!val)
die("invalid dump: unsets svn:log");
/* Value length excludes terminating nul. */
rev_ctx.log = log_copy(len + 1, val);
strbuf_reset(&rev_ctx.log);
strbuf_add(&rev_ctx.log, val, len);
break;
case sizeof("svn:author"):
if (constcmp(key, "svn:author"))
break;
rev_ctx.author = pool_intern(val);
strbuf_reset(&rev_ctx.author);
if (val)
strbuf_add(&rev_ctx.author, val, len);
break;
case sizeof("svn:date"):
if (constcmp(key, "svn:date"))
@ -311,8 +302,9 @@ static void begin_revision(void)
@@ -311,8 +302,9 @@ static void begin_revision(void)
{
if (!rev_ctx.revision) /* revision 0 gets no git commit. */
return;
fast_export_begin_commit(rev_ctx.revision, rev_ctx.author, rev_ctx.log,
dump_ctx.uuid, dump_ctx.url, rev_ctx.timestamp);
fast_export_begin_commit(rev_ctx.revision, rev_ctx.author.buf,
rev_ctx.log.buf, dump_ctx.uuid.buf, dump_ctx.url.buf,
rev_ctx.timestamp);
}
static void end_revision(void)
@ -328,7 +320,7 @@ void svndump_read(const char *url)
@@ -328,7 +320,7 @@ void svndump_read(const char *url)
uint32_t active_ctx = DUMP_CTX;
uint32_t len;
reset_dump_ctx(pool_intern(url));
reset_dump_ctx(url);
while ((t = buffer_read_line(&input))) {
val = strstr(t, ": ");
if (!val)
@ -348,7 +340,8 @@ void svndump_read(const char *url)
@@ -348,7 +340,8 @@ void svndump_read(const char *url)
case sizeof("UUID"):
if (constcmp(t, "UUID"))
continue;
dump_ctx.uuid = pool_intern(val);
strbuf_reset(&dump_ctx.uuid);
strbuf_addstr(&dump_ctx.uuid, val);
break;
case sizeof("Revision-number"):
if (constcmp(t, "Revision-number"))
@ -463,7 +456,11 @@ int svndump_init(const char *filename)
@@ -463,7 +456,11 @@ int svndump_init(const char *filename)
if (buffer_init(&input, filename))
return error("cannot open %s: %s", filename, strerror(errno));
fast_export_init(REPORT_FILENO);
reset_dump_ctx(~0);
strbuf_init(&dump_ctx.uuid, 4096);
strbuf_init(&dump_ctx.url, 4096);
strbuf_init(&rev_ctx.log, 4096);
strbuf_init(&rev_ctx.author, 4096);
reset_dump_ctx(NULL);
reset_rev_ctx(0);
reset_node_ctx(NULL);
return 0;
@ -471,11 +468,11 @@ int svndump_init(const char *filename)
@@ -471,11 +468,11 @@ int svndump_init(const char *filename)
void svndump_deinit(void)
{
log_reset();
fast_export_deinit();
reset_dump_ctx(~0);
reset_dump_ctx(NULL);
reset_rev_ctx(0);
reset_node_ctx(NULL);
strbuf_release(&rev_ctx.log);
if (buffer_deinit(&input))
fprintf(stderr, "Input error\n");
if (ferror(stdout))
@ -484,10 +481,10 @@ void svndump_deinit(void)
@@ -484,10 +481,10 @@ void svndump_deinit(void)
void svndump_reset(void)
{
log_reset();
fast_export_reset();
buffer_reset(&input);
reset_dump_ctx(~0);
reset_rev_ctx(0);
reset_node_ctx(NULL);
strbuf_release(&dump_ctx.uuid);
strbuf_release(&dump_ctx.url);
strbuf_release(&rev_ctx.log);
strbuf_release(&rev_ctx.author);
}