mirror of
https://github.com/chrislusf/seaweedfs
synced 2025-06-30 16:52:46 +02:00
Compare commits
No commits in common. "12631a3f5b85e438b312b02bac044617fa106f45" and "00c4e06caad6f5960c3acfdd07106e2d8e3577c5" have entirely different histories.
12631a3f5b
...
00c4e06caa
36 changed files with 221 additions and 43 deletions
8
.github/workflows/release.yml
vendored
8
.github/workflows/release.yml
vendored
|
@ -11,15 +11,11 @@ jobs:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
goos: [linux, windows, darwin, freebsd, netbsd, openbsd ]
|
goos: [linux, windows, darwin, freebsd ]
|
||||||
goarch: [amd64, arm, arm64, 386]
|
goarch: [amd64, arm]
|
||||||
exclude:
|
exclude:
|
||||||
- goarch: arm
|
- goarch: arm
|
||||||
goos: darwin
|
goos: darwin
|
||||||
- goarch: 386
|
|
||||||
goos: darwin
|
|
||||||
- goarch: arm64
|
|
||||||
goos: windows
|
|
||||||
- goarch: arm
|
- goarch: arm
|
||||||
goos: windows
|
goos: windows
|
||||||
|
|
||||||
|
|
46
.travis.yml.disabled
Normal file
46
.travis.yml.disabled
Normal file
|
@ -0,0 +1,46 @@
|
||||||
|
sudo: false
|
||||||
|
language: go
|
||||||
|
go:
|
||||||
|
- 1.17.x
|
||||||
|
|
||||||
|
before_install:
|
||||||
|
- export PATH=/home/travis/gopath/bin:$PATH
|
||||||
|
|
||||||
|
install:
|
||||||
|
- export CGO_ENABLED="0"
|
||||||
|
- go env
|
||||||
|
|
||||||
|
script:
|
||||||
|
- env GO111MODULE=on go test ./weed/...
|
||||||
|
|
||||||
|
before_deploy:
|
||||||
|
- make release
|
||||||
|
deploy:
|
||||||
|
provider: releases
|
||||||
|
skip_cleanup: true
|
||||||
|
api_key:
|
||||||
|
secure: ERL986+ncQ8lwAJUYDrQ8s2/FxF/cyNIwJIFCqspnWxQgGNNyokET9HapmlPSxjpFRF0q6L2WCg9OY3mSVRq4oI6hg1igOQ12KlLyN71XSJ3c8w0Ay5ho48TQ9l3f3Iu97mntBCe9l0R9pnT8wj1VI8YJxloXwUMG2yeTjA9aBI=
|
||||||
|
file:
|
||||||
|
- build/linux_arm.tar.gz
|
||||||
|
- build/linux_arm64.tar.gz
|
||||||
|
- build/linux_386.tar.gz
|
||||||
|
- build/linux_amd64.tar.gz
|
||||||
|
- build/linux_amd64_large_disk.tar.gz
|
||||||
|
- build/darwin_amd64.tar.gz
|
||||||
|
- build/darwin_amd64_large_disk.tar.gz
|
||||||
|
- build/windows_386.zip
|
||||||
|
- build/windows_amd64.zip
|
||||||
|
- build/windows_amd64_large_disk.zip
|
||||||
|
- build/freebsd_arm.tar.gz
|
||||||
|
- build/freebsd_amd64.tar.gz
|
||||||
|
- build/freebsd_386.tar.gz
|
||||||
|
- build/netbsd_arm.tar.gz
|
||||||
|
- build/netbsd_amd64.tar.gz
|
||||||
|
- build/netbsd_386.tar.gz
|
||||||
|
- build/openbsd_arm.tar.gz
|
||||||
|
- build/openbsd_amd64.tar.gz
|
||||||
|
- build/openbsd_386.tar.gz
|
||||||
|
on:
|
||||||
|
tags: true
|
||||||
|
repo: chrislusf/seaweedfs
|
||||||
|
go: 1.17.x
|
147
Makefile
Normal file
147
Makefile
Normal file
|
@ -0,0 +1,147 @@
|
||||||
|
BINARY = weed/weed
|
||||||
|
package = github.com/chrislusf/seaweedfs/weed
|
||||||
|
|
||||||
|
GO_FLAGS = #-v
|
||||||
|
SOURCE_DIR = ./weed/
|
||||||
|
|
||||||
|
appname := weed
|
||||||
|
|
||||||
|
sources := $(wildcard *.go)
|
||||||
|
|
||||||
|
COMMIT ?= $(shell git rev-parse --short HEAD)
|
||||||
|
LDFLAGS ?= -X github.com/chrislusf/seaweedfs/weed/util.COMMIT=${COMMIT}
|
||||||
|
|
||||||
|
build = CGO_ENABLED=0 GOOS=$(1) GOARCH=$(2) go build -ldflags "-extldflags -static $(LDFLAGS)" -o build/$(appname)$(3) $(SOURCE_DIR)
|
||||||
|
tar = cd build && tar -cvzf $(1)_$(2).tar.gz $(appname)$(3) && rm $(appname)$(3)
|
||||||
|
zip = cd build && zip $(1)_$(2).zip $(appname)$(3) && rm $(appname)$(3)
|
||||||
|
|
||||||
|
build_large = CGO_ENABLED=0 GOOS=$(1) GOARCH=$(2) go build -tags 5BytesOffset -ldflags "-extldflags -static $(LDFLAGS)" -o build/$(appname)$(3) $(SOURCE_DIR)
|
||||||
|
tar_large = cd build && tar -cvzf $(1)_$(2)_large_disk.tar.gz $(appname)$(3) && rm $(appname)$(3)
|
||||||
|
zip_large = cd build && zip $(1)_$(2)_large_disk.zip $(appname)$(3) && rm $(appname)$(3)
|
||||||
|
|
||||||
|
all: build
|
||||||
|
|
||||||
|
.PHONY : clean deps build linux release windows_build darwin_build linux_build bsd_build clean
|
||||||
|
|
||||||
|
clean:
|
||||||
|
go clean -i $(GO_FLAGS) $(SOURCE_DIR)
|
||||||
|
rm -f $(BINARY)
|
||||||
|
rm -rf build/
|
||||||
|
|
||||||
|
deps:
|
||||||
|
go get $(GO_FLAGS) -d $(SOURCE_DIR)
|
||||||
|
rm -rf /home/travis/gopath/src/github.com/coreos/etcd/vendor/golang.org/x/net/trace
|
||||||
|
rm -rf /home/travis/gopath/src/go.etcd.io/etcd/vendor/golang.org/x/net/trace
|
||||||
|
|
||||||
|
build: deps
|
||||||
|
go build $(GO_FLAGS) -ldflags "$(LDFLAGS)" -o $(BINARY) $(SOURCE_DIR)
|
||||||
|
|
||||||
|
gccgo_build: deps
|
||||||
|
go build $(GO_FLAGS) -ldflags "$(LDFLAGS)" -compiler=gccgo -tags gccgo,noasm -o $(BINARY) $(SOURCE_DIR)
|
||||||
|
|
||||||
|
install: deps
|
||||||
|
go install $(GO_FLAGS) -ldflags "$(LDFLAGS)" $(SOURCE_DIR)
|
||||||
|
|
||||||
|
linux: deps
|
||||||
|
mkdir -p linux
|
||||||
|
GOOS=linux GOARCH=amd64 go build $(GO_FLAGS) -ldflags "$(LDFLAGS)" -o linux/$(BINARY) $(SOURCE_DIR)
|
||||||
|
|
||||||
|
release: deps windows_build darwin_build linux_build bsd_build 5_byte_linux_build 5_byte_arm64_build 5_byte_darwin_build 5_byte_windows_build
|
||||||
|
|
||||||
|
##### LINUX BUILDS #####
|
||||||
|
5_byte_linux_build:
|
||||||
|
$(call build_large,linux,amd64,)
|
||||||
|
$(call tar_large,linux,amd64)
|
||||||
|
|
||||||
|
5_byte_darwin_build:
|
||||||
|
$(call build_large,darwin,amd64,)
|
||||||
|
$(call tar_large,darwin,amd64)
|
||||||
|
|
||||||
|
5_byte_windows_build:
|
||||||
|
$(call build_large,windows,amd64,.exe)
|
||||||
|
$(call zip_large,windows,amd64,.exe)
|
||||||
|
|
||||||
|
5_byte_arm_build: $(sources)
|
||||||
|
$(call build_large,linux,arm,)
|
||||||
|
$(call tar_large,linux,arm)
|
||||||
|
|
||||||
|
5_byte_arm64_build: $(sources)
|
||||||
|
$(call build_large,linux,arm64,)
|
||||||
|
$(call tar_large,linux,arm64)
|
||||||
|
|
||||||
|
linux_build: build/linux_arm.tar.gz build/linux_arm64.tar.gz build/linux_386.tar.gz build/linux_amd64.tar.gz
|
||||||
|
|
||||||
|
build/linux_386.tar.gz: $(sources)
|
||||||
|
$(call build,linux,386,)
|
||||||
|
$(call tar,linux,386)
|
||||||
|
|
||||||
|
build/linux_amd64.tar.gz: $(sources)
|
||||||
|
$(call build,linux,amd64,)
|
||||||
|
$(call tar,linux,amd64)
|
||||||
|
|
||||||
|
build/linux_arm.tar.gz: $(sources)
|
||||||
|
$(call build,linux,arm,)
|
||||||
|
$(call tar,linux,arm)
|
||||||
|
|
||||||
|
build/linux_arm64.tar.gz: $(sources)
|
||||||
|
$(call build,linux,arm64,)
|
||||||
|
$(call tar,linux,arm64)
|
||||||
|
|
||||||
|
##### DARWIN (MAC) BUILDS #####
|
||||||
|
darwin_build: build/darwin_amd64.tar.gz
|
||||||
|
|
||||||
|
build/darwin_amd64.tar.gz: $(sources)
|
||||||
|
$(call build,darwin,amd64,)
|
||||||
|
$(call tar,darwin,amd64)
|
||||||
|
|
||||||
|
##### WINDOWS BUILDS #####
|
||||||
|
windows_build: build/windows_386.zip build/windows_amd64.zip
|
||||||
|
|
||||||
|
build/windows_386.zip: $(sources)
|
||||||
|
$(call build,windows,386,.exe)
|
||||||
|
$(call zip,windows,386,.exe)
|
||||||
|
|
||||||
|
build/windows_amd64.zip: $(sources)
|
||||||
|
$(call build,windows,amd64,.exe)
|
||||||
|
$(call zip,windows,amd64,.exe)
|
||||||
|
|
||||||
|
##### BSD BUILDS #####
|
||||||
|
bsd_build: build/freebsd_arm.tar.gz build/freebsd_386.tar.gz build/freebsd_amd64.tar.gz \
|
||||||
|
build/netbsd_arm.tar.gz build/netbsd_386.tar.gz build/netbsd_amd64.tar.gz \
|
||||||
|
build/openbsd_arm.tar.gz build/openbsd_386.tar.gz build/openbsd_amd64.tar.gz
|
||||||
|
|
||||||
|
build/freebsd_386.tar.gz: $(sources)
|
||||||
|
$(call build,freebsd,386,)
|
||||||
|
$(call tar,freebsd,386)
|
||||||
|
|
||||||
|
build/freebsd_amd64.tar.gz: $(sources)
|
||||||
|
$(call build,freebsd,amd64,)
|
||||||
|
$(call tar,freebsd,amd64)
|
||||||
|
|
||||||
|
build/freebsd_arm.tar.gz: $(sources)
|
||||||
|
$(call build,freebsd,arm,)
|
||||||
|
$(call tar,freebsd,arm)
|
||||||
|
|
||||||
|
build/netbsd_386.tar.gz: $(sources)
|
||||||
|
$(call build,netbsd,386,)
|
||||||
|
$(call tar,netbsd,386)
|
||||||
|
|
||||||
|
build/netbsd_amd64.tar.gz: $(sources)
|
||||||
|
$(call build,netbsd,amd64,)
|
||||||
|
$(call tar,netbsd,amd64)
|
||||||
|
|
||||||
|
build/netbsd_arm.tar.gz: $(sources)
|
||||||
|
$(call build,netbsd,arm,)
|
||||||
|
$(call tar,netbsd,arm)
|
||||||
|
|
||||||
|
build/openbsd_386.tar.gz: $(sources)
|
||||||
|
$(call build,openbsd,386,)
|
||||||
|
$(call tar,openbsd,386)
|
||||||
|
|
||||||
|
build/openbsd_amd64.tar.gz: $(sources)
|
||||||
|
$(call build,openbsd,amd64,)
|
||||||
|
$(call tar,openbsd,amd64)
|
||||||
|
|
||||||
|
build/openbsd_arm.tar.gz: $(sources)
|
||||||
|
$(call build,openbsd,arm,)
|
||||||
|
$(call tar,openbsd,arm)
|
|
@ -59,28 +59,15 @@ public class FilerClient extends FilerGrpcClient {
|
||||||
|
|
||||||
public static FilerProto.Entry afterEntryDeserialization(FilerProto.Entry entry) {
|
public static FilerProto.Entry afterEntryDeserialization(FilerProto.Entry entry) {
|
||||||
if (entry.getChunksList().size() <= 0) {
|
if (entry.getChunksList().size() <= 0) {
|
||||||
if (entry.getContent().isEmpty()) {
|
|
||||||
return entry;
|
return entry;
|
||||||
} else {
|
|
||||||
if (entry.getAttributes().getFileSize() <= 0) {
|
|
||||||
FilerProto.Entry.Builder entryBuilder = entry.toBuilder();
|
|
||||||
FilerProto.FuseAttributes.Builder attrBuilder = entry.getAttributes().toBuilder();
|
|
||||||
attrBuilder.setFileSize(entry.getContent().size());
|
|
||||||
entryBuilder.setAttributes(attrBuilder);
|
|
||||||
return entryBuilder.build();
|
|
||||||
}
|
}
|
||||||
}
|
|
||||||
return entry;
|
|
||||||
} else {
|
|
||||||
String fileId = entry.getChunks(0).getFileId();
|
String fileId = entry.getChunks(0).getFileId();
|
||||||
if (fileId != null && fileId.length() != 0) {
|
if (fileId != null && fileId.length() != 0) {
|
||||||
return entry;
|
return entry;
|
||||||
}
|
}
|
||||||
FilerProto.Entry.Builder entryBuilder = entry.toBuilder();
|
FilerProto.Entry.Builder entryBuilder = entry.toBuilder();
|
||||||
entryBuilder.clearChunks();
|
entryBuilder.clearChunks();
|
||||||
long fileSize = 0;
|
|
||||||
for (FilerProto.FileChunk chunk : entry.getChunksList()) {
|
for (FilerProto.FileChunk chunk : entry.getChunksList()) {
|
||||||
fileSize = Math.max(fileSize, chunk.getOffset()+chunk.getSize());
|
|
||||||
FilerProto.FileChunk.Builder chunkBuilder = chunk.toBuilder();
|
FilerProto.FileChunk.Builder chunkBuilder = chunk.toBuilder();
|
||||||
chunkBuilder.setFileId(toFileId(chunk.getFid()));
|
chunkBuilder.setFileId(toFileId(chunk.getFid()));
|
||||||
String sourceFileId = toFileId(chunk.getSourceFid());
|
String sourceFileId = toFileId(chunk.getSourceFid());
|
||||||
|
@ -89,14 +76,8 @@ public class FilerClient extends FilerGrpcClient {
|
||||||
}
|
}
|
||||||
entryBuilder.addChunks(chunkBuilder);
|
entryBuilder.addChunks(chunkBuilder);
|
||||||
}
|
}
|
||||||
if (entry.getAttributes().getFileSize() <= 0) {
|
|
||||||
FilerProto.FuseAttributes.Builder attrBuilder = entry.getAttributes().toBuilder();
|
|
||||||
attrBuilder.setFileSize(fileSize);
|
|
||||||
entryBuilder.setAttributes(attrBuilder);
|
|
||||||
}
|
|
||||||
return entryBuilder.build();
|
return entryBuilder.build();
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
public boolean mkdirs(String path, int mode) {
|
public boolean mkdirs(String path, int mode) {
|
||||||
String currentUser = System.getProperty("user.name");
|
String currentUser = System.getProperty("user.name");
|
||||||
|
|
|
@ -110,16 +110,24 @@ func (gcs *gcsRemoteStorageClient) WriteFile(loc *filer_pb.RemoteStorageLocation
|
||||||
|
|
||||||
key := loc.Path[1:]
|
key := loc.Path[1:]
|
||||||
|
|
||||||
metadata := toMetadata(entry.Extended)
|
|
||||||
wc := gcs.client.Bucket(loc.Bucket).Object(key).NewWriter(context.Background())
|
wc := gcs.client.Bucket(loc.Bucket).Object(key).NewWriter(context.Background())
|
||||||
wc.Metadata = metadata
|
|
||||||
if _, err = io.Copy(wc, reader); err != nil {
|
if _, err = io.Copy(wc, reader); err != nil {
|
||||||
|
wc.Close()
|
||||||
return nil, fmt.Errorf("upload to gcs %s/%s%s: %v", loc.Name, loc.Bucket, loc.Path, err)
|
return nil, fmt.Errorf("upload to gcs %s/%s%s: %v", loc.Name, loc.Bucket, loc.Path, err)
|
||||||
}
|
}
|
||||||
if err = wc.Close(); err != nil {
|
if err = wc.Close(); err != nil {
|
||||||
return nil, fmt.Errorf("close gcs %s/%s%s: %v", loc.Name, loc.Bucket, loc.Path, err)
|
return nil, fmt.Errorf("close gcs %s/%s%s: %v", loc.Name, loc.Bucket, loc.Path, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
metadata := toMetadata(entry.Extended)
|
||||||
|
if len(metadata) > 0 {
|
||||||
|
if _, err = gcs.client.Bucket(loc.Bucket).Object(key).Update(context.Background(), storage.ObjectAttrsToUpdate{
|
||||||
|
Metadata: metadata,
|
||||||
|
}); err != nil {
|
||||||
|
return nil, fmt.Errorf("update metadata gcs %s/%s%s: %v", loc.Name, loc.Bucket, loc.Path, err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// read back the remote entry
|
// read back the remote entry
|
||||||
return gcs.readFileRemoteEntry(loc)
|
return gcs.readFileRemoteEntry(loc)
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue