Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 1,384 for funcs (0.03 sec)

  1. schema/pool.go

    package schema
    
    import (
    	"reflect"
    	"sync"
    )
    
    // sync pools
    var (
    	normalPool      sync.Map
    	poolInitializer = func(reflectType reflect.Type) FieldNewValuePool {
    		v, _ := normalPool.LoadOrStore(reflectType, &sync.Pool{
    			New: func() interface{} {
    				return reflect.New(reflectType).Interface()
    			},
    		})
    		return v.(FieldNewValuePool)
    	}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Apr 11 13:37:44 UTC 2022
    - 345 bytes
    - Viewed (0)
  2. istioctl/pkg/writer/ztunnel/configdump/policies.go

    // Verify returns true if the passed workload matches the filter fields
    func (wf *PolicyFilter) Verify(pol *ZtunnelPolicy) bool {
    	if wf.Namespace != "" {
    		if !strings.EqualFold(pol.Namespace, wf.Namespace) {
    			return false
    		}
    	}
    
    	return true
    }
    
    // PrintServiceSummary prints a summary of the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintPolicySummary(filter PolicyFilter) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 31 21:45:11 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  3. tensorflow/c/eager/c_api_distributed_test.cc

      ASSERT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
    
      TFE_Op* func = TFE_NewOp(ctx, "AddVariablesFunction", status);
      ASSERT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
      TFE_OpAddInput(func, packed_handle, status);
      ASSERT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
      if (remote) {
        TFE_OpSetDevice(func, task1_name, status);
        ASSERT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status);
      }
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  4. cmd/api-utils.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"net/http"
    	"reflect"
    	"runtime"
    	"strings"
    )
    
    func shouldEscape(c byte) bool {
    	if 'A' <= c && c <= 'Z' || 'a' <= c && c <= 'z' || '0' <= c && c <= '9' {
    		return false
    	}
    
    	switch c {
    	case '-', '_', '.', '/', '*':
    		return false
    	}
    	return true
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 04 18:05:56 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. internal/config/lambda/target/lazyinit.go

    // initialized when the provided function returns nil.
    
    type lazyInit struct {
    	done uint32
    	m    sync.Mutex
    }
    
    func (l *lazyInit) Do(f func() error) error {
    	if atomic.LoadUint32(&l.done) == 0 {
    		return l.doSlow(f)
    	}
    	return nil
    }
    
    func (l *lazyInit) doSlow(f func() error) error {
    	l.m.Lock()
    	defer l.m.Unlock()
    	if atomic.LoadUint32(&l.done) == 0 {
    		if err := f(); err != nil {
    			return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  6. cni/pkg/install/cniconfig.go

    	"sort"
    	"strings"
    
    	"github.com/containernetworking/cni/libcni"
    
    	"istio.io/istio/cni/pkg/config"
    	"istio.io/istio/cni/pkg/plugin"
    	"istio.io/istio/cni/pkg/util"
    	"istio.io/istio/pkg/file"
    )
    
    func createCNIConfigFile(ctx context.Context, cfg *config.InstallConfig) (string, error) {
    	pluginConfig := plugin.Config{
    		PluginLogLevel:    cfg.PluginLogLevel,
    		CNIAgentRunDir:    cfg.CNIAgentRunDir,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  7. internal/grid/debugmsg_string.go

    // Code generated by "stringer -type=debugMsg debug.go"; DO NOT EDIT.
    
    package grid
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[debugShutdown-0]
    	_ = x[debugKillInbound-1]
    	_ = x[debugKillOutbound-2]
    	_ = x[debugWaitForExit-3]
    	_ = x[debugSetConnPingDuration-4]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 1K bytes
    - Viewed (0)
  8. cmd/os_other.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"io"
    	"os"
    	"syscall"
    )
    
    func access(name string) error {
    	_, err := os.Lstat(name)
    	return err
    }
    
    func osMkdirAll(dirPath string, perm os.FileMode, _ string) error {
    	// baseDir is not honored in plan9 and solaris platforms.
    	return os.MkdirAll(dirPath, perm)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 13 15:14:36 UTC 2023
    - 4K bytes
    - Viewed (0)
  9. cmd/batch-replicate.go

    // Validate validates if the replicate resource type is recognized and supported
    func (t BatchJobReplicateResourceType) Validate() error {
    	switch t {
    	case BatchJobReplicateResourceMinIO:
    	case BatchJobReplicateResourceS3:
    	default:
    		return errInvalidArgument
    	}
    	return nil
    }
    
    func (t BatchJobReplicateResourceType) isMinio() bool {
    	return t == BatchJobReplicateResourceMinIO
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2_gen.go

    func (z ErasureAlgo) Msgsize() (s int) {
    	s = msgp.Uint8Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *VersionType) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = VersionType(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
Back to top