// Copyright 2017 The go-ethereum Authors // This file is part of the go-ethereum library. // // The go-ethereum library is free software: you can redistribute it and/or modify // it under the terms of the GNU Lesser General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // The go-ethereum library is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Lesser General Public License for more details. // // You should have received a copy of the GNU Lesser General Public License // along with the go-ethereum library. If not, see . // +build linux darwin freebsd package fuse import ( "errors" "io" "os" "sync" "bazil.org/fuse" "bazil.org/fuse/fs" "github.com/ethereum/go-ethereum/log" "github.com/ethereum/go-ethereum/swarm/storage" "golang.org/x/net/context" ) const ( MaxAppendFileSize = 10485760 // 10Mb ) var ( errInvalidOffset = errors.New("Invalid offset during write") errFileSizeMaxLimixReached = errors.New("File size exceeded max limit") ) var ( _ fs.Node = (*SwarmFile)(nil) _ fs.HandleReader = (*SwarmFile)(nil) _ fs.HandleWriter = (*SwarmFile)(nil) ) type SwarmFile struct { inode uint64 name string path string key storage.Key fileSize int64 reader storage.LazySectionReader mountInfo *MountInfo lock *sync.RWMutex } func NewSwarmFile(path, fname string, minfo *MountInfo) *SwarmFile { newFile := &SwarmFile{ inode: NewInode(), name: fname, path: path, key: nil, fileSize: -1, // -1 means , file already exists in swarm and you need to just get the size from swarm reader: nil, mountInfo: minfo, lock: &sync.RWMutex{}, } return newFile } func (file *SwarmFile) Attr(ctx context.Context, a *fuse.Attr) error { a.Inode = file.inode //TODO: need to get permission as argument a.Mode = 0700 a.Uid = uint32(os.Getuid()) a.Gid = uint32(os.Getegid()) if file.fileSize == -1 { reader := file.mountInfo.swarmApi.Retrieve(file.key) quitC := make(chan bool) size, err := reader.Size(quitC) if err != nil { log.Warn("Couldnt get size of file %s : %v", file.path, err) } file.fileSize = size } a.Size = uint64(file.fileSize) return nil } func (sf *SwarmFile) Read(ctx context.Context, req *fuse.ReadRequest, resp *fuse.ReadResponse) error { sf.lock.RLock() defer sf.lock.RUnlock() if sf.reader == nil { sf.reader = sf.mountInfo.swarmApi.Retrieve(sf.key) } buf := make([]byte, req.Size) n, err := sf.reader.ReadAt(buf, req.Offset) if err == io.ErrUnexpectedEOF || err == io.EOF { err = nil } resp.Data = buf[:n] sf.reader = nil return err } func (sf *SwarmFile) Write(ctx context.Context, req *fuse.WriteRequest, resp *fuse.WriteResponse) error { if sf.fileSize == 0 && req.Offset == 0 { // A new file is created err := addFileToSwarm(sf, req.Data, len(req.Data)) if err != nil { return err } resp.Size = len(req.Data) } else if req.Offset <= sf.fileSize { totalSize := sf.fileSize + int64(len(req.Data)) if totalSize > MaxAppendFileSize { log.Warn("Append file size reached (%v) : (%v)", sf.fileSize, len(req.Data)) return errFileSizeMaxLimixReached } err := appendToExistingFileInSwarm(sf, req.Data, req.Offset, int64(len(req.Data))) if err != nil { return err } resp.Size = len(req.Data) } else { log.Warn("Invalid write request size(%v) : off(%v)", sf.fileSize, req.Offset) return errInvalidOffset } return nil } phics/goocanvas/Makefile
diff options
context:
space:
mode:
authorehaupt <ehaupt@FreeBSD.org>2014-02-10 21:54:26 +0800
committerehaupt <ehaupt@FreeBSD.org>2014-02-10 21:54:26 +0800
commit591689f7f7301da41e08d95976e1318322254d75 (patch)
tree3a1e73b4128190b7ed7020b2113a1d94d76b0e93 /graphics/goocanvas/Makefile
parent241bc346167b5bfc4beac8d3b3044454cf6b0f87 (diff)
downloadfreebsd-ports-graphics-591689f7f7301da41e08d95976e1318322254d75.tar.gz
freebsd-ports-graphics-591689f7f7301da41e08d95976e1318322254d75.tar.zst
freebsd-ports-graphics-591689f7f7301da41e08d95976e1318322254d75.zip
According to the Porter's Handbook (5.12.2.3.) default options must be added to
OPTIONS_DEFINE. This policy has been implemented only recently that's why we have many ports violating this policy. This patch adds the default options specified in the Porter's Handbook to OPTIONS_DEFINE where they are being used. Ports maintained by gnome@FreeBSD.org, kde@FreeBSD.org and x11@FreeBSD.org have been excluded. Approved by: portmgr (bapt)
Diffstat (limited to 'graphics/goocanvas/Makefile')