Search Options

Results per page
Sort
Preferred Languages
Advance

Results 651 - 660 of 1,423 for Func (0.02 sec)

  1. prepare_stmt.go

    	return nil, ErrInvalidDB
    }
    
    func (db *PreparedStmtDB) Close() {
    	db.Mux.Lock()
    	defer db.Mux.Unlock()
    
    	for _, stmt := range db.Stmts {
    		go func(s *Stmt) {
    			// make sure the stmt must finish preparation first
    			<-s.prepared
    			if s.Stmt != nil {
    				_ = s.Close()
    			}
    		}(stmt)
    	}
    	// setting db.Stmts to nil to avoid further using
    	db.Stmts = nil
    }
    
    func (sdb *PreparedStmtDB) Reset() {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. cmd/tier-handlers.go

    	errTierReservedName = AdminError{
    		Code:       "XMinioAdminTierReserved",
    		Message:    "Cannot use reserved tier name",
    		StatusCode: http.StatusBadRequest,
    	}
    )
    
    func (api adminAPIHandlers) AddTierHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objAPI, cred := validateAdminReq(ctx, w, r, policy.SetTierAction)
    	if objAPI == nil {
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. istioctl/pkg/cli/mock_client.go

    	"istio.io/istio/pkg/kube"
    )
    
    type MockPortForwarder struct{}
    
    func (m MockPortForwarder) Start() error {
    	return nil
    }
    
    func (m MockPortForwarder) Address() string {
    	return "localhost:3456"
    }
    
    func (m MockPortForwarder) Close() {
    }
    
    func (m MockPortForwarder) ErrChan() <-chan error {
    	return make(chan error)
    }
    
    func (m MockPortForwarder) WaitForStop() {
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Mar 08 08:38:19 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  4. utils/tests/dummy_dialecter.go

    	})
    
    	return nil
    }
    
    func (DummyDialector) DefaultValueOf(field *schema.Field) clause.Expression {
    	return clause.Expr{SQL: "DEFAULT"}
    }
    
    func (DummyDialector) Migrator(*gorm.DB) gorm.Migrator {
    	return nil
    }
    
    func (DummyDialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{}) {
    	writer.WriteByte('?')
    }
    
    func (DummyDialector) QuoteTo(writer clause.Writer, str string) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 06 06:03:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/cni-watcher_test.go

    	t.Run("found pod", func(t *testing.T) {
    		p, err := pluginServer.getPodWithRetry(log, pod.Name, pod.Namespace)
    		assert.NoError(t, err)
    		assert.Equal(t, p, pod)
    	})
    	t.Run("no pod", func(t *testing.T) {
    		p, err := pluginServer.getPodWithRetry(log, "fake", pod.Namespace)
    		assert.Error(t, err)
    		assert.Equal(t, p, nil)
    	})
    	t.Run("pod out of ambient", func(t *testing.T) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. src/archive/tar/stat_actime1.go

    // license that can be found in the LICENSE file.
    
    //go:build aix || linux || dragonfly || openbsd || solaris
    
    package tar
    
    import (
    	"syscall"
    	"time"
    )
    
    func statAtime(st *syscall.Stat_t) time.Time {
    	return time.Unix(st.Atim.Unix())
    }
    
    func statCtime(st *syscall.Stat_t) time.Time {
    	return time.Unix(st.Ctim.Unix())
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 431 bytes
    - Viewed (0)
  7. src/cmd/asm/internal/arch/mips.go

    	"cmd/internal/obj/mips"
    )
    
    func jumpMIPS(word string) bool {
    	switch word {
    	case "BEQ", "BFPF", "BFPT", "BGEZ", "BGEZAL", "BGTZ", "BLEZ", "BLTZ", "BLTZAL", "BNE", "JMP", "JAL", "CALL":
    		return true
    	}
    	return false
    }
    
    // IsMIPSCMP reports whether the op (as defined by an mips.A* constant) is
    // one of the CMP instructions that require special handling.
    func IsMIPSCMP(op obj.As) bool {
    	switch op {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Mar 04 19:06:44 UTC 2020
    - 1.7K bytes
    - Viewed (0)
  8. schema/relationship.go

    // 1. `POLYMORPHIC` tag
    // 2. `POLYMORPHICTYPE` and `POLYMORPHICID` tag
    func hasPolymorphicRelation(tagSettings map[string]string) bool {
    	if _, ok := tagSettings["POLYMORPHIC"]; ok {
    		return true
    	}
    
    	_, hasType := tagSettings["POLYMORPHICTYPE"]
    	_, hasId := tagSettings["POLYMORPHICID"]
    
    	return hasType && hasId
    }
    
    func (schema *Schema) setRelation(relation *Relationship) {
    	// set non-embedded relation
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 03:46:59 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    // Read(Closer). When err != nil, the returned reader is always nil.
    func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "GetObject", object, &er)
    	}
    
    	var unlockOnDefer bool
    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  10. internal/config/dns/etcd_dns.go

    // constructor initializes.
    func DomainNames(domainNames []string) EtcdOption {
    	return func(args *CoreDNS) {
    		args.domainNames = domainNames
    	}
    }
    
    // DomainIPs set a list of custom domain IPs, note this will
    // fail if set to empty when constructor initializes.
    func DomainIPs(domainIPs set.StringSet) EtcdOption {
    	return func(args *CoreDNS) {
    		args.domainIPs = domainIPs
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top