Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 68 for HANDLE (0.17 sec)

  1. 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)
  2. internal/grid/handlers.go

    	// There is flow control in both directions.
    	StreamHandler struct {
    		// Handle an incoming request. Initial payload is sent.
    		// Additional input packets (if any) are streamed to request.
    		// Upstream will block when request channel is full.
    		// Response packets can be sent at any time.
    		// Any non-nil error sent as response means no more responses are sent.
    		Handle StreamHandlerFn
    
    		// Subroute for handler.
    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)
  3. 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)
  4. internal/http/server.go

    			w.WriteHeader(http.StatusServiceUnavailable)
    			w.Write([]byte(http.ErrServerClosed.Error()))
    			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()
    
    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/os-reliable.go

    			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
    // syscall.ENOTEMPTY (children has files).
    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)
  6. 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)
  7. 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)
  8. internal/grid/grid_test.go

    	}
    
    	// We fake a local and remote server.
    	remoteHost := remote.HostName()
    
    	// 1: Echo
    	register := func(manager *Manager) {
    		errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{
    			Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
    				for in := range request {
    					b := append([]byte{}, payload...)
    					b = append(b, in...)
    					resp <- b
    				}
    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)
  9. cmd/metrics-v3-handler.go

    		b.WriteString("| ---- | ---- | ---- | ------ |\n")
    		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)
  10. internal/grid/types.go

    )
    
    // Recycler will override the internal reuse in typed handlers.
    // When this is supported, the handler will not do internal pooling of objects,
    // call Recycle() when the object is no longer needed.
    // The recycler should handle nil pointers.
    type Recycler interface {
    	Recycle()
    }
    
    // MSS is a map[string]string that can be serialized.
    // It is not very efficient, but it is only used for easy parameter passing.
    type MSS map[string]string
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
Back to top