Nevar pievienot vairāk kā 25 tēmas Tēmai ir jāsākas ar burtu vai ciparu, tā var saturēt domu zīmes ('-') un var būt līdz 35 simboliem gara.

UploadTest.java 3.8KB

Support LFS protocol and a file system based LFS storage Implement LfsProtocolServlet handling the "Git LFS v1 Batch API" protocol [1]. Add a simple file system based LFS content store and the debug-lfs-store command to simplify testing. Introduce a LargeFileRepository interface to enable additional storage implementation while reusing the same protocol implementation. At the client side we have to configure the lfs.url, specify that we use the batch API and we don't use authentication: [lfs] url = http://host:port/lfs batch = true [lfs "http://host:port/lfs"] access = none the git-lfs client appends the "objects/batch" to the lfs.url. Hard code an Authorization header in the FileLfsRepository.getAction because then git-lfs client will skip asking for credentials. It will just forward the Authorization header from the response to the download/upload request. The FileLfsServlet supports file content storage for "Large File Storage" (LFS) server as defined by the Github LFS API [2]. - upload and download of large files is probably network bound hence use an asynchronous servlet for good scalability - simple object storage in file system with 2 level fan-out - use LockFile to protect writing large objects against multiple concurrent uploads of the same object - to prevent corrupt uploads the uploaded file is rejected if its hash doesn't match id given in URL The debug-lfs-store command is used to run the LfsProtocolServlet and, optionally, the FileLfsServlet which makes it easier to setup a local test server. [1] https://github.com/github/git-lfs/blob/master/docs/api/http-v1-batch.md [2] https://github.com/github/git-lfs/tree/master/docs/api Bug: 472961 Change-Id: I7378da5575159d2195138d799704880c5c82d5f3 Signed-off-by: Matthias Sohn <matthias.sohn@sap.com> Signed-off-by: Sasa Zivkov <sasa.zivkov@sap.com>
pirms 8 gadiem
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101
  1. /*
  2. * Copyright (C) 2015, Matthias Sohn <matthias.sohnk@sap.com>
  3. * and other copyright owners as documented in the project's IP log.
  4. *
  5. * This program and the accompanying materials are made available
  6. * under the terms of the Eclipse Distribution License v1.0 which
  7. * accompanies this distribution, is reproduced below, and is
  8. * available at http://www.eclipse.org/org/documents/edl-v10.php
  9. *
  10. * All rights reserved.
  11. *
  12. * Redistribution and use in source and binary forms, with or
  13. * without modification, are permitted provided that the following
  14. * conditions are met:
  15. *
  16. * - Redistributions of source code must retain the above copyright
  17. * notice, this list of conditions and the following disclaimer.
  18. *
  19. * - Redistributions in binary form must reproduce the above
  20. * copyright notice, this list of conditions and the following
  21. * disclaimer in the documentation and/or other materials provided
  22. * with the distribution.
  23. *
  24. * - Neither the name of the Eclipse Foundation, Inc. nor the
  25. * names of its contributors may be used to endorse or promote
  26. * products derived from this software without specific prior
  27. * written permission.
  28. *
  29. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
  30. * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
  31. * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  32. * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  33. * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
  34. * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  35. * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
  36. * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  37. * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
  38. * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
  39. * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  40. * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
  41. * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  42. */
  43. package org.eclipse.jgit.lfs.server.fs;
  44. import static org.junit.Assert.assertEquals;
  45. import static org.junit.Assert.assertFalse;
  46. import static org.junit.Assert.assertTrue;
  47. import static org.junit.Assert.fail;
  48. import java.nio.file.Files;
  49. import java.nio.file.Path;
  50. import java.nio.file.Paths;
  51. import java.text.MessageFormat;
  52. import org.eclipse.jgit.lfs.lib.AnyLongObjectId;
  53. import org.eclipse.jgit.lfs.lib.LongObjectId;
  54. import org.eclipse.jgit.lfs.test.LongObjectIdTestUtils;
  55. import org.junit.Test;
  56. public class UploadTest extends LfsServerTest {
  57. @Test
  58. public void testUpload() throws Exception {
  59. String TEXT = "test";
  60. AnyLongObjectId id = putContent(TEXT);
  61. assertTrue("expect object " + id.name() + " to exist",
  62. repository.getSize(id) >= 0);
  63. assertEquals("expected object length " + TEXT.length(), TEXT.length(),
  64. repository.getSize(id));
  65. }
  66. @Test
  67. public void testCorruptUpload() throws Exception {
  68. String TEXT = "test";
  69. AnyLongObjectId id = LongObjectIdTestUtils.hash("wrongHash");
  70. try {
  71. putContent(id, TEXT);
  72. fail("expected RuntimeException(\"Status 400\")");
  73. } catch (RuntimeException e) {
  74. assertEquals("Status: 400. Bad Request", e.getMessage());
  75. }
  76. assertFalse("expect object " + id.name() + " not to exist",
  77. repository.getSize(id) >= 0);
  78. }
  79. @SuppressWarnings("boxing")
  80. @Test
  81. public void testLargeFileUpload() throws Exception {
  82. Path f = Paths.get(getTempDirectory().toString(), "largeRandomFile");
  83. createPseudoRandomContentFile(f, 5 * MiB);
  84. long start = System.nanoTime();
  85. LongObjectId id = putContent(f);
  86. System.out.println(
  87. MessageFormat.format("uploaded 10 MiB random data in {0}ms",
  88. (System.nanoTime() - start) / 1e6));
  89. assertTrue("expect object " + id.name() + " to exist",
  90. repository.getSize(id) >= 0);
  91. assertEquals("expected object length " + Files.size(f), Files.size(f),
  92. repository.getSize(id));
  93. }
  94. }