Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for Kistner (0.2 sec)

  1. cmd/metacache-set.go

    	// If false only main directory will be scanned.
    	// Should always be true if Separator is n SlashSeparator.
    	Recursive bool
    
    	// Separator to use.
    	Separator string
    
    	// Create indicates that the lister should not attempt to load an existing cache.
    	Create bool
    
    	// Include pure directories.
    	IncludeDirectories bool
    
    	// Transient is set if the cache is transient due to an error or being a reserved bucket.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  2. internal/http/listener.go

    		}
    	case <-listener.ctx.Done():
    	}
    	return nil, syscall.EINVAL
    }
    
    // Close - closes underneath all TCP listeners.
    func (listener *httpListener) Close() (err error) {
    	listener.ctxCanceler()
    
    	for i := range listener.tcpListeners {
    		listener.tcpListeners[i].Close()
    	}
    
    	return nil
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  3. internal/grid/debug.go

    		listeners = append(listeners, l)
    	}
    	return
    }
    
    func startHTTPServer(listener net.Listener, handler http.Handler) (server *httptest.Server) {
    	server = httptest.NewUnstartedServer(handler)
    	server.Config.Addr = listener.Addr().String()
    	server.Listener = listener
    	server.Start()
    	return server
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    	globalObjLayerMutex.Lock()
    	globalObjectAPI = objLayer
    	globalObjLayerMutex.Unlock()
    
    	// initialize peer rpc
    	host, port := mustSplitHostPort(testServer.Server.Listener.Addr().String())
    	globalMinioHost = host
    	globalMinioPort = port
    	globalMinioAddr = getEndpointsLocalAddr(testServer.Disks)
    
    	initAllSubsystems(ctx)
    
    	globalEtcdClient = nil
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 75.7K bytes
    - Viewed (0)
  5. internal/http/server.go

    		// 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 {
    		l = tls.NewListener(listener, tlsConfig)
    	}
    
    	serve = func() error {
    		return srv.Server.Serve(l)
    	}
    
    	return
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
Back to top