Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for sein (0.12 sec)

  1. cmd/bootstrap-peer-server.go

    	ns1 := s1.NEndpoints
    	ns2 := s2.NEndpoints
    	if ns1 != ns2 {
    		return fmt.Errorf("Expected number of endpoints %d, seen %d", ns1, ns2)
    	}
    
    	for i, cmdLine := range s1.CmdLines {
    		if cmdLine != s2.CmdLines[i] {
    			return fmt.Errorf("Expected command line argument %s, seen %s", cmdLine,
    				s2.CmdLines[i])
    		}
    	}
    
    	if reflect.DeepEqual(s1.MinioEnv, s2.MinioEnv) {
    		return nil
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  2. cmd/metacache.go

    		m.status = update.status
    	}
    
    	if m.status == scanStateStarted && time.Since(m.lastHandout) > metacacheMaxClientWait {
    		// Drop if client hasn't been seen for 3 minutes.
    		m.status = scanStateError
    		m.error = "client not seen"
    	}
    
    	if m.error == "" && update.error != "" {
    		m.error = update.error
    		m.status = scanStateError
    		m.ended = UTCNow()
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5K bytes
    - Viewed (0)
  3. internal/grid/muxserver.go

    		case <-m.ctx.Done():
    			return
    		case <-t.C:
    			last := time.Since(time.Unix(atomic.LoadInt64(&m.LastPing), 0))
    			if last > lastPingThreshold {
    				gridLogIf(m.ctx, fmt.Errorf("canceling remote connection %s not seen for %v", m.parent, last))
    				m.close()
    				return
    			}
    		}
    	}
    }
    
    // checkSeq will check if sequence number is correct and increment it by 1.
    func (m *muxServer) checkSeq(seq uint32) (ok bool) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
Back to top