From: Junio C Hamano <gitster@pobox.com>
Date: Wed, 25 Feb 2009 22:48:30 +0000 (-0800)
Subject: Merge branch 'jc/maint-1.6.0-pack-directory'
X-Git-Tag: v1.6.2-rc2~1
X-Git-Url: https://git.tokkee.org/?a=commitdiff_plain;h=bb0cebd7d0ac9bf2ddf94fe5579603819c4a1fc7;p=git.git

Merge branch 'jc/maint-1.6.0-pack-directory'

* jc/maint-1.6.0-pack-directory:
  Make sure objects/pack exists before creating a new pack
---

bb0cebd7d0ac9bf2ddf94fe5579603819c4a1fc7
diff --cc fast-import.c
index 3ef3413e6,f0114948e..3748ddf48
--- a/fast-import.c
+++ b/fast-import.c
@@@ -879,12 -876,11 +878,11 @@@ static char *create_index(void
  		c = next;
  	}
  
- 	snprintf(tmpfile, sizeof(tmpfile),
- 		"%s/pack/tmp_idx_XXXXXX", get_object_directory());
- 	idx_fd = xmkstemp(tmpfile);
+ 	idx_fd = odb_mkstemp(tmpfile, sizeof(tmpfile),
+ 			     "pack/tmp_idx_XXXXXX");
  	f = sha1fd(idx_fd, tmpfile);
  	sha1write(f, array, 256 * sizeof(int));
 -	SHA1_Init(&ctx);
 +	git_SHA1_Init(&ctx);
  	for (c = idx; c != last; c++) {
  		uint32_t offset = htonl((*c)->offset);
  		sha1write(f, &offset, 4);
diff --cc wrapper.c
index c85ca52ec,231a58f1a..b07cdf299
--- a/wrapper.c
+++ b/wrapper.c
@@@ -197,62 -197,34 +197,94 @@@ int xmkstemp(char *template
  	return fd;
  }
  
 +/*
 + * zlib wrappers to make sure we don't silently miss errors
 + * at init time.
 + */
 +void git_inflate_init(z_streamp strm)
 +{
 +	const char *err;
 +
 +	switch (inflateInit(strm)) {
 +	case Z_OK:
 +		return;
 +
 +	case Z_MEM_ERROR:
 +		err = "out of memory";
 +		break;
 +	case Z_VERSION_ERROR:
 +		err = "wrong version";
 +		break;
 +	default:
 +		err = "error";
 +	}
 +	die("inflateInit: %s (%s)", err, strm->msg ? strm->msg : "no message");
 +}
 +
 +void git_inflate_end(z_streamp strm)
 +{
 +	if (inflateEnd(strm) != Z_OK)
 +		error("inflateEnd: %s", strm->msg ? strm->msg : "failed");
 +}
 +
 +int git_inflate(z_streamp strm, int flush)
 +{
 +	int ret = inflate(strm, flush);
 +	const char *err;
 +
 +	switch (ret) {
 +	/* Out of memory is fatal. */
 +	case Z_MEM_ERROR:
 +		die("inflate: out of memory");
 +
 +	/* Data corruption errors: we may want to recover from them (fsck) */
 +	case Z_NEED_DICT:
 +		err = "needs dictionary"; break;
 +	case Z_DATA_ERROR:
 +		err = "data stream error"; break;
 +	case Z_STREAM_ERROR:
 +		err = "stream consistency error"; break;
 +	default:
 +		err = "unknown error"; break;
 +
 +	/* Z_BUF_ERROR: normal, needs more space in the output buffer */
 +	case Z_BUF_ERROR:
 +	case Z_OK:
 +	case Z_STREAM_END:
 +		return ret;
 +	}
 +	error("inflate: %s (%s)", err, strm->msg ? strm->msg : "no message");
 +	return ret;
 +}
++
+ int odb_mkstemp(char *template, size_t limit, const char *pattern)
+ {
+ 	int fd;
+ 
+ 	snprintf(template, limit, "%s/%s",
+ 		 get_object_directory(), pattern);
+ 	fd = mkstemp(template);
+ 	if (0 <= fd)
+ 		return fd;
+ 
+ 	/* slow path */
+ 	safe_create_leading_directories(template);
+ 	snprintf(template, limit, "%s/%s",
+ 		 get_object_directory(), pattern);
+ 	return xmkstemp(template);
+ }
+ 
+ int odb_pack_keep(char *name, size_t namesz, unsigned char *sha1)
+ {
+ 	int fd;
+ 
+ 	snprintf(name, namesz, "%s/pack/pack-%s.keep",
+ 		 get_object_directory(), sha1_to_hex(sha1));
+ 	fd = open(name, O_RDWR|O_CREAT|O_EXCL, 0600);
+ 	if (0 <= fd)
+ 		return fd;
+ 
+ 	/* slow path */
+ 	safe_create_leading_directories(name);
+ 	return open(name, O_RDWR|O_CREAT|O_EXCL, 0600);
+ }