Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for readLine (0.1 sec)

  1. cmd/admin-handlers.go

    		healthInfo.Error = string(encodedErrorResponse)
    		adminLogIf(ctx, enc.Encode(healthInfo))
    	}
    
    	deadline := 10 * time.Second // Default deadline is 10secs for health diagnostics.
    	if dstr := query.Get("deadline"); dstr != "" {
    		var err error
    		deadline, err = time.ParseDuration(dstr)
    		if err != nil {
    			errResp(err)
    			return
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. cmd/storage-datatypes_gen.go

    			err = msgp.WrapError(err, "Data")
    			return
    		}
    		if z.Data == nil {
    			z.Data = make([]byte, 0)
    		}
    	}
    	z.NumVersions, err = dc.ReadInt()
    	if err != nil {
    		err = msgp.WrapError(err, "NumVersions")
    		return
    	}
    	z.SuccessorModTime, err = dc.ReadTime()
    	if err != nil {
    		err = msgp.WrapError(err, "SuccessorModTime")
    		return
    	}
    	z.Fresh, err = dc.ReadBool()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/CallTest.kt

        // Call 1: set a deadline on the response body.
        val request1 = Request.Builder().url(server.url("/")).build()
        val response1 = client.newCall(request1).execute()
        val body1 = response1.body.source()
        assertThat(body1.readUtf8()).isEqualTo("abc")
        body1.timeout().deadline(5, TimeUnit.SECONDS)
    
        // Call 2: check for the absence of a deadline on the request body.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  4. CHANGELOG/CHANGELOG-1.4.md

    * Add a check for file size if the reading content returns empty ([#33976](https://github.com/kubernetes/kubernetes/pull/33976), [@jingxu97](https://github.com/jingxu97))
    * Add a retry when reading a file content from a container ([#35560](https://github.com/kubernetes/kubernetes/pull/35560), [@jingxu97](https://github.com/jingxu97))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 133.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbFile.java

     *
     * @return <code>true</code> if the file is read-only
     */
    
        public boolean canRead() throws SmbException {
            if( getType() == TYPE_NAMED_PIPE ) { // try opening the pipe for reading?
                return true;
            }
            return exists(); // try opening and catch sharing violation?
        }
    
    /**
     * Tests to see if the file this <code>SmbFile</code> represents
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Mar 13 12:00:57 UTC 2023
    - 107.9K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.5.md

    * On GCI, cleanup kubelet startup ([#35319](https://github.com/kubernetes/kubernetes/pull/35319), [@vishh](https://github.com/vishh))
    * Add a retry when reading a file content from a container ([#35560](https://github.com/kubernetes/kubernetes/pull/35560), [@jingxu97](https://github.com/jingxu97))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 136.4K bytes
    - Viewed (0)
  7. cmd/site-replication.go

    			c.Lock()
    			defer c.Unlock()
    			c.state = srState{}
    			c.enabled = false
    		}
    		return err
    	}
    
    	// attempt to read just the version key in the state file to ensure we
    	// are reading a compatible version.
    	var ver struct {
    		Version int `json:"version"`
    	}
    	err = json.Unmarshal(buf, &ver)
    	if err != nil {
    		return err
    	}
    	if ver.Version != srStateFormatVersion1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
Back to top