Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 266 for listeners (0.13 sec)

  1. api/go1.11.txt

    pkg go/types, method (*Interface) EmbeddedType(int) Type
    pkg go/types, method (*Var) Embedded() bool
    pkg net, method (*ListenConfig) Listen(context.Context, string, string) (Listener, error)
    pkg net, method (*ListenConfig) ListenPacket(context.Context, string, string) (PacketConn, error)
    pkg net, type Dialer struct, Control func(string, string, syscall.RawConn) error
    pkg net, type ListenConfig struct
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 22 03:48:56 UTC 2018
    - 25K bytes
    - Viewed (0)
  2. cmd/admin-heal-ops.go

    // routine. It launches another go-routine that actually traverses
    // on-disk data, checks and heals according to the selected
    // settings. This go-routine itself, (1) monitors the traversal
    // routine for completion, and (2) listens for external stop
    // signals. When either event happens, it sets the finish status for
    // the heal-sequence.
    func (h *healSequence) healSequenceStart(objAPI ObjectLayer) {
    	// Set status as running
    	h.mutex.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. cmd/sts-handlers_test.go

    	})
    	if err != nil {
    		c.Fatalf("Error initializing client: %v", err)
    	}
    
    	// Validate that user listing does not return any entries
    	usersList, err := s.adm.ListUsers(ctx)
    	if err != nil {
    		c.Fatalf("list users should not fail: %v", err)
    	}
    	if len(usersList) != 1 {
    		c.Fatalf("expected user listing output: %v", usersList)
    	}
    	uinfo := usersList[userDN]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  4. cmd/iam.go

    	}
    
    	select {
    	case <-sys.configLoaded:
    		return sys.store.GetBucketUsers(bucket)
    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    // ListUsers - list all users.
    func (sys *IAMSys) ListUsers(ctx context.Context) (map[string]madmin.UserInfo, error) {
    	if !sys.Initialized() {
    		return nil, errServerNotInitialized
    	}
    	select {
    	case <-sys.configLoaded:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  5. tensorflow/c/c_api.cc

      delete server;
    #endif  // !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
    }
    
    void TF_RegisterLogListener(void (*listener)(const char*)) {
    #if !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
      tensorflow::logging::RegisterListener(listener);
    #endif  // !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
    }
    
    void TF_RegisterFilesystemPlugin(const char* plugin_filename,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 102.3K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    		metaDataPoolPut(buf)
    		if err != nil {
    			res["err"] = err.Error()
    			return sizeSummary{}, errSkipFile
    		}
    
    		sizeS := sizeSummary{}
    		for _, tier := range globalTierConfigMgr.ListTiers() {
    			if sizeS.tiers == nil {
    				sizeS.tiers = make(map[string]tierStats)
    			}
    			sizeS.tiers[tier.Name] = tierStats{}
    		}
    		if sizeS.tiers != nil {
    			sizeS.tiers[storageclass.STANDARD] = tierStats{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  7. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

            } else if (request.isInteractiveMode() && !commandLine.hasOption(CLIManager.LOG_FILE)) {
                //
                // If we're logging to a file then we don't want the console transfer listener as it will spew
                // download progress all over the place
                //
                return getConsoleTransferListener(verbose);
            } else {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 76.8K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/extensions/v1beta1/generated.proto

      repeated string hosts = 1;
    
      // SecretName is the name of the secret used to terminate SSL traffic on 443.
      // Field is left optional to allow SSL routing based on SNI hostname alone.
      // If the SNI host in a listener conflicts with the "Host" header field used
      // by an IngressRule, the SNI host is used for termination and value of the
      // Host header is used for routing.
      // +optional
      optional string secretName = 2;
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 45.6K bytes
    - Viewed (0)
  9. 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
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  10. api/go1.txt

    pkg net, type Interface struct, MTU int
    pkg net, type Interface struct, Name string
    pkg net, type InvalidAddrError string
    pkg net, type Listener interface { Accept, Addr, Close }
    pkg net, type Listener interface, Accept() (Conn, error)
    pkg net, type Listener interface, Addr() Addr
    pkg net, type Listener interface, Close() error
    pkg net, type MX struct
    pkg net, type MX struct, Host string
    pkg net, type MX struct, Pref uint16
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top