Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 221 for fatalIf (0.04 seconds)

  1. cmd/peer-rest-server.go

    	logger.FatalIf(getBucketStatsRPC.Register(gm, server.GetBucketStatsHandler), "unable to register handler")
    	logger.FatalIf(getCPUsHandler.Register(gm, server.GetCPUsHandler), "unable to register handler")
    	logger.FatalIf(getLastDayTierStatsRPC.Register(gm, server.GetLastDayTierStatsHandler), "unable to register handler")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  2. cmd/storage-rest-server.go

    			logger.FatalIf(storageListDirRPC.RegisterNoInput(gm, server.ListDirHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(storageReadAllRPC.Register(gm, server.ReadAllHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(storageWriteAllRPC.Register(gm, server.WriteAllHandler, endpoint.Path), "unable to register handler")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  3. cmd/server-main.go

    	v, _, _, err := env.LookupEnv(config.EnvArgs)
    	if err != nil {
    		logger.FatalIf(err, "Unable to validate passed arguments in %s:%s",
    			config.EnvArgs, os.Getenv(config.EnvArgs))
    	}
    	if v == "" {
    		v, _, _, err = env.LookupEnv(config.EnvVolumes)
    		if err != nil {
    			logger.FatalIf(err, "Unable to validate passed arguments in %s:%s",
    				config.EnvVolumes, os.Getenv(config.EnvVolumes))
    		}
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  4. cmd/common-main.go

    			if err != nil {
    				logger.FatalIf(err, "Unable to get free port for Console UI on the host")
    			}
    			// hold the port
    			l, err := net.Listen("TCP", fmt.Sprintf(":%s", p.String()))
    			if err == nil {
    				defer l.Close()
    			}
    			consoleAddr = net.JoinHostPort("", p.String())
    		}
    
    		if _, _, err := net.SplitHostPort(consoleAddr); err != nil {
    			logger.FatalIf(err, "Unable to start listening on console port")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
  5. cmd/net.go

    	localLoopbacks = mustGetLocalLoopbacks()
    )
    
    // mustSplitHostPort is a wrapper to net.SplitHostPort() where error is assumed to be a fatal.
    func mustSplitHostPort(hostPort string) (host, port string) {
    	xh, err := xnet.ParseHost(hostPort)
    	if err != nil {
    		logger.FatalIf(err, "Unable to split host port %s", hostPort)
    	}
    	return xh.Name, xh.Port.String()
    }
    
    // mustGetLocalIPs returns IPs of local interface
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.6K bytes
    - Click Count (1)
  6. internal/logger/logger.go

    	if err != nil {
    		LogIf(ctx, "", err, errKind...)
    		panic(ErrCritical)
    	}
    }
    
    // FatalIf is similar to Fatal() but it ignores passed nil error
    func FatalIf(err error, msg string, data ...any) {
    	if err == nil {
    		return
    	}
    	fatal(err, msg, data...)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  7. cmd/consolelogger.go

    func (sys *HTTPConsoleLoggerSys) SetNodeName(nodeName string) {
    	if !globalIsDistErasure {
    		sys.nodeName = ""
    		return
    	}
    
    	host, err := xnet.ParseHost(globalLocalNodeName)
    	if err != nil {
    		logger.FatalIf(err, "Unable to start console logging subsystem")
    	}
    
    	sys.nodeName = host.Name
    }
    
    // HasLogListeners returns true if console log listeners are registered
    // for this node or peers
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  8. internal/store/queuestore_test.go

    		t.Fatalf("expected itemcount=10 but found %v", key.ItemCount)
    	}
    
    	raw, err := store.GetRaw(key)
    	if err != nil {
    		t.Fatalf("unable to get multiple items; %v", err)
    	}
    
    	if !bytes.Equal(buf.Bytes(), raw) {
    		t.Fatalf("expected bytes: %d vs read bytes is wrong %d", len(buf.Bytes()), len(raw))
    	}
    
    	if err := store.Del(key); err != nil {
    		t.Fatalf("unable to Del; %v", err)
    	}
    
    	// Re-list
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  9. cmd/local-locker_test.go

    		ok, err := l.RLock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get read lock")
    		}
    		// RLock twice
    		ok, err = l.RLock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get write lock")
    		}
    
    		rResources[i] = arg.Resources[0]
    	}
    	if len(l.lockMap) != len(rResources)+len(wResources) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  10. cmd/format-erasure_test.go

    		t.Fatal(err)
    	}
    	if formatV3.Erasure.This != m.Erasure.Disk {
    		t.Fatalf("expected drive uuid: %s, got: %s", m.Erasure.Disk, formatV3.Erasure.This)
    	}
    	if len(formatV3.Erasure.Sets) != 1 {
    		t.Fatalf("expected single set after migrating from v1 to v3, but found %d", len(formatV3.Erasure.Sets))
    	}
    	if !reflect.DeepEqual(formatV3.Erasure.Sets[0], m.Erasure.JBOD) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.7K bytes
    - Click Count (0)
Back to Top