Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for freezeServices (0.3 sec)

  1. cmd/service.go

    	// Re-uses the same pid. This preserves the pid over multiple server-respawns.
    	return syscall.Exec(argv0, os.Args, os.Environ())
    }
    
    // freezeServices will freeze all incoming S3 API calls.
    // For each call, unfreezeServices must be called once.
    func freezeServices() {
    	// Use atomics for globalServiceFreeze, so we can read without locking.
    	// We need a lock since we are need the 2 atomic values to remain in sync.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Feb 28 07:02:14 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  2. cmd/server-main.go

    			}
    		})
    	}
    
    	if !globalDisableFreezeOnBoot {
    		// Freeze the services until the bucket notification subsystem gets initialized.
    		bootstrapTrace("freezeServices", freezeServices)
    	}
    
    	var newObject ObjectLayer
    	bootstrapTrace("newObjectLayer", func() {
    		var err error
    		newObject, err = newObjectLayer(GlobalContext, globalEndpoints)
    		if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 32.7K bytes
    - Viewed (1)
  3. cmd/notification.go

    			continue
    		}
    		client := client
    		ng.Go(GlobalContext, func() error {
    			return client.SignalService(serviceSig, "", false)
    		}, idx, *client.host)
    	}
    	nerrs := ng.Wait()
    	if freeze {
    		freezeServices()
    	} else {
    		unfreezeServices()
    	}
    	return nerrs
    }
    
    // Netperf - perform mesh style network throughput test
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    			adminLogIf(ctx, nerr.Err)
    		}
    	}
    
    	// Reply to the client before restarting, stopping MinIO server.
    	writeSuccessResponseHeadersOnly(w)
    
    	switch serviceSig {
    	case serviceFreeze:
    		freezeServices()
    	case serviceUnFreeze:
    		unfreezeServices()
    	case serviceRestart, serviceStop:
    		globalServiceSignalCh <- serviceSig
    	}
    }
    
    type servicePeerResult struct {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  5. cmd/peer-rest-server.go

    			if err != nil {
    				return np, grid.NewRemoteErr(err)
    			}
    			return np, grid.NewRemoteErrString(string(buf))
    		}
    		if !dryRun {
    			globalServiceSignalCh <- signal
    		}
    	case serviceFreeze:
    		freezeServices()
    	case serviceUnFreeze:
    		unfreezeServices()
    	case serviceReloadDynamic:
    		objAPI := newObjectLayerFn()
    		if objAPI == nil {
    			return np, grid.NewRemoteErr(errServerNotInitialized)
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
Back to top