Examples of GcsFileMetadata

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

69
70
71
72
73
74
75
76
77
78
79
      out.endShard();
    }
    GoogleCloudStorageFileSet files = creator.finish(writers);
    assertEquals(NUM_SHARDS, files.getNumFiles());
    for (int i = 0; i < NUM_SHARDS; i++) {
      GcsFileMetadata metadata = gcsService.getMetadata(files.getFile(i));
      assertNotNull(metadata);
      assertEquals(SMALL_CONTENT.length, metadata.getLength());
      assertEquals(MIME_TYPE, metadata.getOptions().getMimeType());
    }
  }
View Full Code Here

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

115
116
117
118
119
120
121
122
123
124
125
126
127
128
    expectedContent.put(content);
    expectedContent.put(content);
    for (int i = 0; i < NUM_SHARDS; i++) {
      expectedContent.rewind();
      ByteBuffer actualContent = ByteBuffer.allocate(content.length * 2 + 1);
      GcsFileMetadata metadata = gcsService.getMetadata(files.getFile(i));
      assertNotNull(metadata);
      assertEquals(expectedContent.capacity(), metadata.getLength());
      assertEquals(MIME_TYPE, metadata.getOptions().getMimeType());
      try (ReadableByteChannel readChannel = gcsService.openReadChannel(files.getFile(i), 0)) {
        int read = readChannel.read(actualContent);
        assertEquals(read, content.length * 2);
        actualContent.limit(actualContent.position());
        actualContent.rewind();
View Full Code Here

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

65
66
67
68
69
70
71
72
73
74
      finished.add(w);
    }
    GoogleCloudStorageFileSet filesWritten = segmenter.finish(finished);
    assertEquals(15, filesWritten.getNumFiles());
    for (int i = 0; i < filesWritten.getNumFiles(); i++) {
      GcsFileMetadata metadata = gcsService.getMetadata(filesWritten.getFile(i));
      assertNotNull(metadata);
      assertEquals(MIME_TYPE, metadata.getOptions().getMimeType());
    }
  }
View Full Code Here

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

85
86
87
88
89
90
91
92
93
94
      countFiles += 3;
    }
    GoogleCloudStorageFileSet filesWritten = segmenter.finish(writers);
    assertEquals(countFiles, filesWritten.getNumFiles());
    for (int i = 0; i < filesWritten.getNumFiles(); i++) {
      GcsFileMetadata metadata = gcsService.getMetadata(filesWritten.getFile(i));
      assertNotNull(metadata);
      assertEquals(MIME_TYPE, metadata.getOptions().getMimeType());
    }
  }
View Full Code Here

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

363
364
365
366
367
368
369
370
371
372
373
    }
    ByteBuffer chunk = ByteBuffer.allocate(1024);
    Token token = beginObjectCreation(dest, GcsFileOptions.getDefaultInstance(), timeoutMillis);
    for (String filename : source) {
      GcsFilename sourceFileName = new GcsFilename(dest.getBucketName(), filename);
      GcsFileMetadata meta = getObjectMetadata(sourceFileName, timeoutMillis);
      if (meta == null) {
        throw new FileNotFoundException(this + ": No such file: " + filename);
      }
      AppEngineFile file = nameToAppEngineFile(sourceFileName);
      try (FileReadChannel readChannel = FILES.openReadChannel(file, false)) {
View Full Code Here

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

383
384
385
386
387
388
389
390
391
392
393
  }

  @Override
  public void copyObject(GcsFilename source, GcsFilename dest, long timeoutMillis)
      throws IOException {
    GcsFileMetadata meta = getObjectMetadata(source, timeoutMillis);
    if (meta == null) {
      throw new FileNotFoundException(this + ": No such file: " + source);
    }
    ByteBuffer chunk = ByteBuffer.allocate(1024);
    Token token = beginObjectCreation(dest, GcsFileOptions.getDefaultInstance(), timeoutMillis);
View Full Code Here

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
          }
          continue;
        }
      }
      GcsFilename filename = new GcsFilename(bucket, name);
      GcsFileMetadata metadata = createGcsFileMetadata(entity, filename);
      ListItem listItem = new ListItem.Builder()
          .setName(name)
          .setLength(metadata.getLength())
          .setLastModified(metadata.getLastModified())
          .build();
      items.add(listItem);
    }
    Cursor cursor = dsResults.getCursor();
    String nextMarker = null;
View Full Code Here

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

291
292
293
294
295
296
297
      length = (Long) entity.getProperty(FILE_LENGTH_PROP);
    } else {
      AppEngineFile file = nameToAppEngineFile(filename);
      length = FILES.stat(file).getLength();
    }
    return new GcsFileMetadata(filename, options, null, length, creationTime);
  }
View Full Code Here

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
  @Override
  public Future<GcsFileMetadata> readObjectAsync(
      ByteBuffer dst, GcsFilename filename, long offset, long timeoutMillis) {
    Preconditions.checkArgument(offset >= 0, "%s: offset must be non-negative: %s", this, offset);
    try {
      GcsFileMetadata meta = getObjectMetadata(filename, timeoutMillis);
      if (meta == null) {
        return Futures.immediateFailedFuture(
            new FileNotFoundException(this + ": No such file: " + filename));
      }
      if (offset >= meta.getLength()) {
        return Futures.immediateFailedFuture(new BadRangeException(
            "The requested range cannot be satisfied. bytes=" + Long.toString(offset) + "-"
            + Long.toString(offset + dst.remaining()) + " the file is only " + meta.getLength()));
      }
      AppEngineFile file = nameToAppEngineFile(filename);
      try (FileReadChannel readChannel = FILES.openReadChannel(file, false)) {
        readChannel.position(offset);
        int read = 0;
View Full Code Here

Examples of com.google.appengine.tools.cloudstorage.GcsFileMetadata

563
564
565
566
567
568
569
          default:
        }
      }
    }
    GcsFileOptions options = optionsBuilder.build();
    return new GcsFileMetadata(filename, options, etag, length, lastModified);
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.