Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 453 for ctx_ (0.04 sec)

  1. cmd/server-main_test.go

    func TestNewObjectLayer(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	// Tests for ErasureSD object layer.
    	nDisks := 1
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal("Failed to create drives for the backend")
    	}
    	defer removeRoots(disks)
    
    	obj, err := newObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Dec 07 09:33:56 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  2. cmd/server-rlimit.go

    		logger.Info("WARNING: maximum virtual memory limit (%s) is too small for 'go runtime', please consider setting `ulimit -v` to unlimited",
    			humanize.IBytes(vssLimit))
    	}
    
    	if ctx.MemLimit > 0 {
    		debug.SetMemoryLimit(int64(ctx.MemLimit))
    	}
    
    	// Do not use RLIMIT_AS as that is not useful and at times on systems < 4Gi
    	// this can crash the Go runtime if the value is smaller refer
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:09:36 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. cmd/prepare-storage.go

    		reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String())
    		ctx := logger.SetReqInfo(GlobalContext, reqInfo)
    		mutex.Lock()
    		defer mutex.Unlock()
    
    		m, ok := printOnce[endpoint]
    		if !ok {
    			m = make(map[string]int)
    			printOnce[endpoint] = m
    			if once {
    				m[err.Error()]++
    				peersLogAlwaysIf(ctx, err)
    				return
    			}
    		}
    		// Once is set and we are here means error was already
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  4. src/main/java/jcifs/smb/SmbTreeConnectionTrace.java

     */
    package jcifs.smb;
    
    
    import jcifs.CIFSContext;
    
    
    /**
     * @author mbechler
     *
     */
    class SmbTreeConnectionTrace extends SmbTreeConnection {
    
        SmbTreeConnectionTrace ( CIFSContext ctx ) {
            super(ctx);
        }
    
    
        SmbTreeConnectionTrace ( SmbTreeConnection conn ) {
            super(conn);
        }
    
    
        @Override
        protected void finalize () throws Throwable {
            checkRelease();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Jul 20 08:41:19 UTC 2019
    - 1.1K bytes
    - Viewed (0)
  5. internal/hash/reader.go

    // does not send more content than specified size.
    func NewReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64) (*Reader, error) {
    	return newReader(ctx, src, size, md5Hex, sha256Hex, actualSize, false, nil)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  6. internal/event/target/webhook.go

    		return store.ErrNotConnected
    	}
    
    	return nil
    }
    
    // NewWebhookTarget - creates new Webhook target.
    func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, transport *http.Transport) (*WebhookTarget, error) {
    	ctx, cancel := context.WithCancel(ctx)
    
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-webhook-"+id)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  7. internal/http/dial_linux.go

    }
    
    // DialContext is a function to make custom Dial for internode communications
    type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
    
    // NewInternodeDialContext setups a custom dialer for internode communication
    func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext {
    	return func(ctx context.Context, network, addr string) (net.Conn, error) {
    		dialer := &net.Dialer{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. istioctl/pkg/proxystatus/proxystatus_test.go

    	})
    
    	for i, c := range cases {
    		t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.args, " ")), func(t *testing.T) {
    			ctx := cli.NewFakeContext(&cli.NewFakeContextOption{
    				IstioNamespace: "istio-system",
    			})
    			if !c.noIstiod {
    				client, err := ctx.CLIClientWithRevision(c.revision)
    				assert.NoError(t, err)
    				_, err = client.Kube().CoreV1().Pods("istio-system").Create(context.TODO(), &corev1.Pod{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Mar 15 08:28:50 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. cni/cmd/install-cni/main.go

    package main
    
    import (
    	"context"
    	"os"
    	"os/signal"
    	"syscall"
    
    	"istio.io/istio/cni/pkg/cmd"
    	"istio.io/istio/pkg/log"
    )
    
    func main() {
    	// Create context that cancels on termination signal
    	ctx, cancel := context.WithCancel(context.Background())
    	sigChan := make(chan os.Signal, 1)
    	signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM)
    	go func(sigChan chan os.Signal, cancel context.CancelFunc) {
    		sig := <-sigChan
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  10. cmd/server-startup-msg_test.go

    		t.Fatalf("Expected %#v, got %#v", apiEndpoints, newAPIEndpoints)
    	}
    }
    
    // Test printing server common message.
    func TestPrintServerCommonMessage(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatal(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3K bytes
    - Viewed (0)
Back to top