Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 172 for Handle (0.17 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. 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)
  4. 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)
  5. 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)
  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. operator/cmd/mesh/profile-dump.go

    	}
    	return out2, nil
    }
    
    // Convert the generated YAML to pretty JSON.
    func yamlToPrettyJSON(yml string) (string, error) {
    	// YAML objects are not completely compatible with JSON
    	// objects. Let yaml.YAMLToJSON handle the edge cases and
    	// we'll re-encode the result to pretty JSON.
    	uglyJSON, err := yaml.YAMLToJSON([]byte(yml))
    	if err != nil {
    		return "", err
    	}
    	var decoded any
    	if uglyJSON[0] == '[' {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 7.1K 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. istioctl/pkg/util/configdump/wrapper.go

    // Wrapper is a wrapper around the Envoy ConfigDump
    // It has extra helper functions for handling any/struct/marshal protobuf pain
    type Wrapper struct {
    	*admin.ConfigDump
    }
    
    // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
    func (w *Wrapper) UnmarshalJSON(b []byte) error {
    	cd := &admin.ConfigDump{}
    	err := protomarshal.UnmarshalAllowUnknownWithAnyResolver(nonStrictResolver, b, cd)
    	*w = Wrapper{cd}
    	return err
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 1.8K bytes
    - Viewed (0)
Back to top