Search Options

Results per page
Sort
Preferred Languages
Advance

Results 801 - 810 of 1,423 for Func (0.04 sec)

  1. internal/disk/fdatasync_unix.go

    package disk
    
    import (
    	"os"
    	"syscall"
    )
    
    // Fdatasync is fsync on freebsd/darwin
    func Fdatasync(f *os.File) error {
    	return syscall.Fsync(int(f.Fd()))
    }
    
    // FadviseDontNeed is a no-op
    func FadviseDontNeed(f *os.File) error {
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 29 23:40:28 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  2. internal/disk/fdatasync_unsupported.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package disk
    
    import (
    	"os"
    )
    
    // Fdatasync is a no-op
    func Fdatasync(f *os.File) error {
    	return nil
    }
    
    // FadviseDontNeed is a no-op
    func FadviseDontNeed(f *os.File) error {
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 29 23:40:28 UTC 2021
    - 1K bytes
    - Viewed (0)
  3. internal/once/singleton.go

    	set chan struct{}
    }
    
    // NewSingleton creates a new unset singleton.
    func NewSingleton[T any]() *Singleton[T] {
    	return &Singleton[T]{set: make(chan struct{}), v: nil}
    }
    
    // Get will return the singleton value.
    func (s *Singleton[T]) Get() *T {
    	<-s.set
    	return s.v
    }
    
    // GetNonBlocking will return the singleton value or nil if not set yet.
    func (s *Singleton[T]) GetNonBlocking() *T {
    	select {
    	case <-s.set:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 952 bytes
    - Viewed (0)
  4. clause/set.go

    package clause
    
    import "sort"
    
    type Set []Assignment
    
    type Assignment struct {
    	Column Column
    	Value  interface{}
    }
    
    func (set Set) Name() string {
    	return "SET"
    }
    
    func (set Set) Build(builder Builder) {
    	if len(set) > 0 {
    		for idx, assignment := range set {
    			if idx > 0 {
    				builder.WriteByte(',')
    			}
    			builder.WriteQuoted(assignment.Column)
    			builder.WriteByte('=')
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Nov 29 03:02:44 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  5. docs/auditlog/auditlog-echo.go

    package main
    
    import (
    	"bytes"
    	"encoding/json"
    	"flag"
    	"fmt"
    	"io"
    	"log"
    	"net/http"
    )
    
    var port int
    
    func init() {
    	flag.IntVar(&port, "port", 8080, "Port to listen on")
    }
    
    func mainHandler(w http.ResponseWriter, r *http.Request) {
    	body, err := io.ReadAll(r.Body)
    	defer r.Body.Close()
    	if err != nil {
    		log.Printf("Error reading request body: %v", err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 21:31:13 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-utils.go

    //
    // Note: Only the scanner requires fivs.Versions to have exclusively non-free versions. This is used while enforcing NewerNoncurrentVersions lifecycle element.
    func getFileInfoVersions(xlMetaBuf []byte, volume, path string, inclFreeVersions bool) (FileInfoVersions, error) {
    	fivs, err := getAllFileInfoVersions(xlMetaBuf, volume, path, true)
    	if err != nil {
    		return fivs, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. internal/event/rulesmap_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package event
    
    import (
    	"reflect"
    	"testing"
    )
    
    func TestRulesMapClone(t *testing.T) {
    	rulesMapCase1 := make(RulesMap)
    	rulesMapToAddCase1 := NewRulesMap([]Name{ObjectCreatedAll}, "*", TargetID{"1", "webhook"})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  8. cmd/peer-s3-server.go

    				Deleted: v.Created,
    			})
    		}
    	}
    
    	return buckets, nil
    }
    
    func cloneDrives(drives map[string]StorageAPI) []StorageAPI {
    	copyDrives := make([]StorageAPI, 0, len(drives))
    	for _, drive := range drives {
    		copyDrives = append(copyDrives, drive)
    	}
    	return copyDrives
    }
    
    func getBucketInfoLocal(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/arch/arm.go

    	"BGE":  true,
    	"BLT":  true,
    	"BGT":  true,
    	"BLE":  true,
    	"CALL": true,
    	"JMP":  true,
    }
    
    func jumpArm(word string) bool {
    	return armJump[word]
    }
    
    // IsARMCMP reports whether the op (as defined by an arm.A* constant) is
    // one of the comparison instructions that require special handling.
    func IsARMCMP(op obj.As) bool {
    	switch op {
    	case arm.ACMN, arm.ACMP, arm.ATEQ, arm.ATST:
    		return true
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 23 15:18:14 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. internal/s3select/csv/record.go

    func (r *Record) Raw() (sql.SelectObjectFormat, interface{}) {
    	return sql.SelectFmtCSV, r
    }
    
    // Replace - is not supported for CSV
    func (r *Record) Replace(_ interface{}) error {
    	return errors.New("Replace is not supported for CSV")
    }
    
    // NewRecord - creates new CSV record.
    func NewRecord() *Record {
    	return &Record{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
Back to top