Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 70 for Handle (0.16 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. cmd/auth-handler.go

    	_, ok := supportedS3AuthTypes[aType]
    	return ok
    }
    
    // setAuthMiddleware to validate authorization header for the incoming request.
    func setAuthMiddleware(h http.Handler) http.Handler {
    	// handler for validating incoming authorization headers.
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26K bytes
    - Viewed (0)
  8. 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)
  9. internal/grid/connection.go

    			return newMuxStateless(ctx, m, c, *handler)
    		})
    	} else {
    		// Stream:
    		var handler *StreamHandler
    		if subID == nil {
    			if !m.Handler.valid() {
    				gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Invalid Handler"}))
    				return
    			}
    			handler = c.handlers.streams[m.Handler]
    		} else {
    			handler = c.handlers.subStreams[*subID]
    		}
    		if handler == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  10. internal/grid/types.go

    	"strings"
    	"sync"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    // 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.
    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