git@vger.kernel.org list mirror (unofficial, one of many)
 help / color / mirror / code / Atom feed
91eb0b495f596f96bd269f31cdf94f8a3c3635e2 blob 3098 bytes (raw)

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
 
/*
Copyright 2020 Google LLC

Use of this source code is governed by a BSD-style
license that can be found in the LICENSE file or at
https://developers.google.com/open-source/licenses/bsd
*/

#include "system.h"

#include "basics.h"
#include "blocksource.h"
#include "reftable-blocksource.h"
#include "reftable-error.h"

static void strbuf_return_block(void *b, struct reftable_block *dest)
{
	memset(dest->data, 0xff, dest->len);
	reftable_free(dest->data);
}

static void strbuf_close(void *b)
{
}

static int strbuf_read_block(void *v, struct reftable_block *dest, uint64_t off,
			     uint32_t size)
{
	struct strbuf *b = v;
	assert(off + size <= b->len);
	dest->data = reftable_calloc(size);
	memcpy(dest->data, b->buf + off, size);
	dest->len = size;
	return size;
}

static uint64_t strbuf_size(void *b)
{
	struct strbuf *buf = b;
	return buf->len;
}

static struct reftable_block_source_vtable strbuf_vtable = {
	.size = &strbuf_size,
	.read_block = &strbuf_read_block,
	.return_block = &strbuf_return_block,
	.close = &strbuf_close,
};

void block_source_from_strbuf(struct reftable_block_source *bs,
			      struct strbuf *buf)
{
	assert(bs->ops == NULL);
	bs->ops = &strbuf_vtable;
	bs->arg = buf;
}

static void malloc_return_block(void *b, struct reftable_block *dest)
{
	memset(dest->data, 0xff, dest->len);
	reftable_free(dest->data);
}

static struct reftable_block_source_vtable malloc_vtable = {
	.return_block = &malloc_return_block,
};

static struct reftable_block_source malloc_block_source_instance = {
	.ops = &malloc_vtable,
};

struct reftable_block_source malloc_block_source(void)
{
	return malloc_block_source_instance;
}

struct file_block_source {
	int fd;
	uint64_t size;
};

static uint64_t file_size(void *b)
{
	return ((struct file_block_source *)b)->size;
}

static void file_return_block(void *b, struct reftable_block *dest)
{
	memset(dest->data, 0xff, dest->len);
	reftable_free(dest->data);
}

static void file_close(void *b)
{
	struct file_block_source *bs =  b;
	int fd = bs->fd;
	if (fd > 0) {
		close(fd);
		bs->fd = 0;
	}

	reftable_free(b);
}

static int file_read_block(void *v, struct reftable_block *dest, uint64_t off,
			   uint32_t size)
{
	struct file_block_source *b = v;
	assert(off + size <= b->size);
	dest->data = reftable_malloc(size);
	if (pread(b->fd, dest->data, size, off) != size)
		return -1;
	dest->len = size;
	return size;
}

static struct reftable_block_source_vtable file_vtable = {
	.size = &file_size,
	.read_block = &file_read_block,
	.return_block = &file_return_block,
	.close = &file_close,
};

int reftable_block_source_from_file(struct reftable_block_source *bs,
				    const char *name)
{
	struct stat st = { 0 };
	int err = 0;
	int fd = open(name, O_RDONLY);
	struct file_block_source *p = NULL;
	if (fd < 0) {
		if (errno == ENOENT) {
			return REFTABLE_NOT_EXIST_ERROR;
		}
		return -1;
	}

	err = fstat(fd, &st);
	if (err < 0)
		return -1;

	p = reftable_calloc(sizeof(struct file_block_source));
	p->size = st.st_size;
	p->fd = fd;

	assert(bs->ops == NULL);
	bs->ops = &file_vtable;
	bs->arg = p;
	return 0;
}
debug log:

solving 91eb0b495f5 ...
found 91eb0b495f5 in https://public-inbox.org/git/87tuoa2vhz.fsf@evledraar.gmail.com/
found 25d4d95b52b in https://public-inbox.org/git/aaa817f8598bd5eee3b3f0fa35d613a8687cdd01.1607522429.git.gitgitgadget@gmail.com/ ||
	https://public-inbox.org/git/e41fa780882d229995fb69dcc807420a5468ffdb.1615580397.git.gitgitgadget@gmail.com/ ||
	https://public-inbox.org/git/6807af53e9a039850364bc7f6b8579322b9a8884.1618255552.git.gitgitgadget@gmail.com/

applying [1/4] https://public-inbox.org/git/aaa817f8598bd5eee3b3f0fa35d613a8687cdd01.1607522429.git.gitgitgadget@gmail.com/
diff --git a/reftable/blocksource.c b/reftable/blocksource.c
new file mode 100644
index 00000000000..25d4d95b52b

Checking patch reftable/blocksource.c...
Applied patch reftable/blocksource.c cleanly.

skipping https://public-inbox.org/git/e41fa780882d229995fb69dcc807420a5468ffdb.1615580397.git.gitgitgadget@gmail.com/ for 25d4d95b52b
skipping https://public-inbox.org/git/6807af53e9a039850364bc7f6b8579322b9a8884.1618255552.git.gitgitgadget@gmail.com/ for 25d4d95b52b
index at:
100644 25d4d95b52b87ed5307594713a6fe3660e8e918a	reftable/blocksource.c

applying [2/4] https://public-inbox.org/git/87tuoa2vhz.fsf@evledraar.gmail.com/
diff --git a/reftable/blocksource.c b/reftable/blocksource.c
index 25d4d95b52b..91eb0b495f5 100644

Checking patch reftable/blocksource.c...
Applied patch reftable/blocksource.c cleanly.

index at:
100644 91eb0b495f596f96bd269f31cdf94f8a3c3635e2	reftable/blocksource.c

Code repositories for project(s) associated with this inbox:

	https://80x24.org/mirrors/git.git

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for read-only IMAP folder(s) and NNTP newsgroup(s).