Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 536 for fprintf (0.24 sec)

  1. internal/s3select/simdj/errors.go

    	return err.statusCode
    }
    
    func (err *s3Error) Error() string {
    	return err.message
    }
    
    func errJSONParsingError(err error) *s3Error {
    	return &s3Error{
    		code:       "JSONParsingError",
    		message:    fmt.Sprintf("Encountered an error parsing the JSON file: %v. Check the file and try again.", err),
    		statusCode: 400,
    		cause:      err,
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  2. ci/official/utilities/cleanup_summary.sh

    Try the links below:
    EOF
      # Find any "Streaming build results to" lines,
      # de-duplicate,
      # and print the last word from each
      awk '/Streaming build results to/ {print $NF}' "$TFCI_OUTPUT_DIR/script.log" | uniq
    }
    
    # Print out any ResultStore URLs for Bazel invocations' results.
    # Each failed target there will have its own representation, making failures
    # easier to find and read.
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Wed Aug 07 23:01:25 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  3. scripts/docs.py

                if non_translatable_path.exists():
                    error_paths.append(non_translatable_path)
        if error_paths:
            print("Non-translated pages found, remove them:")
            for error_path in error_paths:
                print(error_path)
            raise typer.Abort()
        print("No non-translated pages found ✅")
    
    
    @app.command()
    def verify_docs():
        verify_readme()
        verify_config()
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Tue Oct 08 11:01:17 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  4. docs/debugging/hash-set/main.go

    		}
    		for set, files := range distrib {
    			fmt.Println("Set:", set+1, "Objects:", len(files))
    			if !verbose {
    				continue
    			}
    			for _, s := range files {
    				fmt.Printf("\t%s\n", s)
    			}
    		}
    		os.Exit(0)
    	}
    
    	if object == "" {
    		log.Fatalln("object name is mandatory")
    	}
    
    	if shards != 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  5. docs/debugging/xattr/main.go

    		for _, attr := range names {
    			value, err := getxattr(path, attr)
    			if err != nil {
    				data = append(data, []string{attr, errors.Unwrap(err).Error()})
    			} else {
    				data = append(data, []string{attr, fmt.Sprintf("%d", value)})
    			}
    		}
    		table.AppendBulk(data) // Add Bulk Data
    		table.Render()
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Dec 29 23:52:41 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  6. docs_src/custom_request_and_route/tutorial003.py

                duration = time.time() - before
                response.headers["X-Response-Time"] = str(duration)
                print(f"route duration: {duration}")
                print(f"route response: {response}")
                print(f"route response headers: {response.headers}")
                return response
    
            return custom_route_handler
    
    
    app = FastAPI()
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Thu Mar 26 19:09:53 UTC 2020
    - 1K bytes
    - Viewed (0)
  7. internal/grid/muxclient.go

    		return true
    	}
    
    	// Only check ping when not closed.
    	if got := time.Since(time.Unix(0, atomic.LoadInt64(&m.LastPong))); got > m.clientPingInterval*2 {
    		m.respMu.Unlock()
    		if debugPrint {
    			fmt.Printf("Mux %d: last pong %v ago, disconnecting\n", m.MuxID, got)
    		}
    		m.addErrorNonBlockingClose(respHandler, ErrDisconnected)
    		return false
    	}
    
    	// Send new ping
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  8. cmd/metacache-bucket_test.go

    	const elements = 50000
    	const paths = 100
    	if elements%paths != 0 {
    		b.Fatal("elements must be divisible by the number of paths")
    	}
    	var pathNames [paths]string
    	for i := range pathNames[:] {
    		pathNames[i] = fmt.Sprintf("prefix/%d", i)
    	}
    	for i := 0; i < elements; i++ {
    		bm.findCache(listPathOptions{
    			ID:           mustGetUUID(),
    			Bucket:       "",
    			BaseDir:      pathNames[i%paths],
    			Prefix:       "",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Mar 25 23:29:45 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  9. src/bytes/compare_test.go

    		if Compare(b1, b2[offset:]) != 0 {
    			b.Fatal("b1 != b2")
    		}
    	}
    	b.SetBytes(int64(len(b1)))
    }
    
    func BenchmarkCompareBytesBigUnaligned(b *testing.B) {
    	for i := 1; i < 8; i++ {
    		b.Run(fmt.Sprintf("offset=%d", i), func(b *testing.B) {
    			benchmarkCompareBytesBigUnaligned(b, i)
    		})
    	}
    }
    
    func benchmarkCompareBytesBigBothUnaligned(b *testing.B, offset int) {
    	b.StopTimer()
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Jul 13 23:11:42 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  10. cmd/background-newdisks-heal-ops.go

    			return nil
    		}
    		if !errors.Is(err, errUnformattedDisk) {
    			return err
    		}
    	}
    
    	// Prevent parallel erasure set healing
    	locker := z.NewNSLock(minioMetaBucket, fmt.Sprintf("new-drive-healing/%d/%d", poolIdx, setIdx))
    	lkctx, err := locker.GetLock(ctx, newDiskHealingTimeout)
    	if err != nil {
    		return fmt.Errorf("Healing of drive '%v' on %s pool, belonging to %s erasure set already in progress: %w",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
Back to top