Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 436 for readlink (0.12 sec)

  1. cmd/admin-handlers-users-race_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    //go:build !race
    // +build !race
    
    // Tests in this file are not run under the `-race` flag as they are too slow
    // and cause context deadline errors.
    
    package cmd
    
    import (
    	"context"
    	"fmt"
    	"runtime"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	minio "github.com/minio/minio-go/v7"
    	"github.com/minio/pkg/v3/sync/errgroup"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. cmd/erasure-decode.go

    	readerIndex := 0
    	var wg sync.WaitGroup
    	// if readTrigger is true, it implies next disk.ReadAt() should be tried
    	// if readTrigger is false, it implies previous disk.ReadAt() was successful and there is no need
    	// to try reading the next disk.
    	for readTrigger := range readTriggerCh {
    		newBufLK.RLock()
    		canDecode := p.canDecode(newBuf)
    		newBufLK.RUnlock()
    		if canDecode {
    			break
    		}
    		if readerIndex == len(p.readers) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  3. internal/logger/reqinfo.go

    	Val string
    }
    
    // ObjectVersion object version key/versionId
    type ObjectVersion struct {
    	ObjectName string
    	VersionID  string `json:"VersionId,omitempty"`
    }
    
    // ReqInfo stores the request info.
    // Reading/writing directly to struct requires appropriate R/W lock.
    type ReqInfo struct {
    	RemoteHost   string           // Client Host/IP
    	Host         string           // Node Host/IP
    	UserAgent    string           // User Agent
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. src/main/webapp/WEB-INF/view/admin/dict/kuromoji/admin_dict_kuromoji.jsp

                                                        <td>${f:h(data.token)}</td>
                                                        <td>${f:h(data.reading)}</td>
                                                    </tr>
                                                </c:forEach>
                                                </tbody>
                                            </table>
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Mar 27 06:24:23 UTC 2020
    - 10.1K bytes
    - Viewed (0)
  5. okcurl/src/main/kotlin/okhttp3/curl/Main.kt

        "--connect-timeout",
        help = "Maximum time allowed for connection (seconds)",
      ).int().default(DEFAULT_TIMEOUT)
    
      val readTimeout: Int by option("--read-timeout", help = "Maximum time allowed for reading data (seconds)").int().default(DEFAULT_TIMEOUT)
    
      val callTimeout: Int by option(
        "--call-timeout",
        help = "Maximum time allowed for the entire call (seconds)",
      ).int().default(DEFAULT_TIMEOUT)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  6. 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)
  7. native-image-tests/src/main/kotlin/okhttp3/RunTests.kt

     */
    fun testSelectors(inputFile: File? = null): List<DiscoverySelector> {
      val sampleTestClass = SampleTest::class.java
    
      val lines =
        inputFile?.readLines() ?: sampleTestClass.getResource("/testlist.txt").readText().lines()
    
      val flatClassnameList =
        lines
          .filter { it.isNotBlank() }
    
      return flatClassnameList
        .mapNotNull {
          try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. docs/features/caching.md

            urlIterator.remove()
          }
        }
    ```
    
    ### Troubleshooting
    
    1. Valid cacheable responses are not being cached
    
    Make sure you are reading responses fully as unless they are read fully, cancelled or stalled Responses will not be cached.
    
    ### Overriding normal cache behaviour
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java

                  return new String(buffer, 0, bufIndex);
                }
                // otherwise we got the size wrong.  This can happen if the size changes between when
                // we called sizeIfKnown and when we started reading the file (or I guess if
                // maxCharsPerByte is wrong)
                // Fallback to an incremental approach
                StringBuilder builder = new StringBuilder(bufIndex + 32);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 10 19:45:10 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  10. docs/features/calls.md

    Calls can be canceled from any thread. This will fail the call if it hasn’t yet completed! Code that is writing the request body or reading the response body will suffer an `IOException` when its call is canceled.
    
    ## Dispatch
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.9K bytes
    - Viewed (0)
Back to top