Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 129 for Handle (0.21 sec)

  1. internal/grid/handlers.go

    	HandlerRenameData2
    
    	// Add more above here ^^^
    	// If all handlers are used, the type of Handler can be changed.
    	// Handlers have no versioning, so non-compatible handler changes must result in new IDs.
    	handlerTest
    	handlerTest2
    	handlerLast
    )
    
    // handlerPrefixes are prefixes for handler IDs used for tracing.
    // If a handler is not listed here, it will be traced with "grid" prefix.
    var handlerPrefixes = [handlerLast]string{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
  2. cmd/signature-v4-utils.go

    	if confRegion == "" {
    		return true
    	}
    	if confRegion == "US" {
    		confRegion = globalMinioDefaultRegion
    	}
    	// Some older s3 clients set region as "US" instead of
    	// globalMinioDefaultRegion, handle it.
    	if reqRegion == "US" {
    		reqRegion = globalMinioDefaultRegion
    	}
    	return reqRegion == confRegion
    }
    
    // check if the access key is valid and recognized, additionally
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 18:56:45 GMT 2024
    - 9K bytes
    - Viewed (0)
  3. cmd/os-reliable.go

    			// the parents is a file.
    			return errFileAccessDenied
    		case isSysErrPathNotFound(err):
    			// This is a special case should be handled only for
    			// windows, because windows API does not return "not a
    			// directory" error message. Handle this specifically
    			// here.
    			return errFileAccessDenied
    		}
    	}
    	return err
    }
    
    // Reliably retries os.RemoveAll if for some reason os.RemoveAll returns
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  4. internal/http/server.go

    			return
    		}
    
    		atomic.AddInt32(&srv.requestCount, 1)
    		defer atomic.AddInt32(&srv.requestCount, -1)
    
    		// Handle request using passed handler.
    		handler.ServeHTTP(w, r)
    	})
    
    	srv.listenerMutex.Lock()
    	srv.Handler = wrappedHandler
    	srv.listener = listener
    	srv.listenerMutex.Unlock()
    
    	var l net.Listener = listener
    	if tlsConfig != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  5. cmd/metrics-v3-handler.go

    		for _, metric := range metrics {
    			b.WriteString(metric.TableRow())
    		}
    		w.Write([]byte(b.String()))
    	})
    }
    
    func (h *metricsV3Server) handle(path string, isListingRequest bool, buckets []string) http.Handler {
    	var notFoundHandler http.Handler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		http.Error(w, "Metrics Resource Not found", http.StatusNotFound)
    	})
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  6. internal/grid/grid_test.go

    	}
    
    	// We fake a local and remote server.
    	remoteHost := remote.HostName()
    	handler := NewStream[*testRequest, *testRequest, *testResponse](handlerTest, newTestRequest, newTestRequest, newTestResponse)
    	handler.InCapacity = 1
    	handler.OutCapacity = 1
    	const payloads = 10
    
    	// 1: Echo
    	register := func(manager *Manager) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  7. cmd/storage-errors.go

    	}
    	if isSysErrIO(err) {
    		return errFaultyDisk
    	}
    	if isSysErrInvalidArg(err) {
    		storageLogIf(context.Background(), err)
    		// For some odd calls with O_DIRECT reads
    		// filesystems can return EINVAL, handle
    		// these as FileNotFound instead.
    		return errFileNotFound
    	}
    	if isSysErrNoSpace(err) {
    		return errDiskFull
    	}
    	return err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  8. cmd/crossdomain-xml-handler.go

    // When clients request content hosted on a particular source domain and that content make requests
    // directed towards a domain other than its own, the remote domain needs to host a cross-domain
    // policy file that grants access to the source domain, allowing the client to continue the transaction.
    func setCrossDomainPolicyMiddleware(h http.Handler) http.Handler {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 18 06:42:40 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  9. cmd/xl-storage-errors.go

    			return errno == 0x03
    		}
    	}
    	return false
    }
    
    // Check if the given error corresponds to the specific ERROR_INVALID_HANDLE for windows
    func isSysErrHandleInvalid(err error) bool {
    	if runtime.GOOS != globalWindowsOSName {
    		return false
    	}
    	// Check if err contains ERROR_INVALID_HANDLE errno
    	var pathErr *os.PathError
    	if errors.As(err, &pathErr) {
    		var errno syscall.Errno
    		if errors.As(pathErr.Err, &errno) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 06 16:56:29 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  10. internal/http/listener.go

    		case <-listener.ctx.Done():
    			return false
    		}
    	}
    
    	// Closure to handle TCPListener until done channel is closed.
    	handleListener := func(idx int, listener net.Listener) {
    		for {
    			conn, err := listener.Accept()
    			send(acceptResult{conn, err, idx})
    		}
    	}
    
    	// Start separate goroutine for each TCP listener to handle connection.
    	for idx, tcpListener := range listener.listeners {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
Back to top