Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 42 for Biscardi (0.18 sec)

  1. cmd/admin-handlers-users_test.go

    	r, err := client.GetObject(ctx, bucket, object, minio.GetObjectOptions{})
    	if err != nil {
    		c.Fatalf("user was unable to download the object: %v", err)
    	}
    	defer r.Close()
    
    	_, err = io.Copy(io.Discard, r)
    	if err != nil {
    		c.Fatalf("user was unable to download the object: %v", err)
    	}
    }
    
    func (c *check) mustHeadObject(ctx context.Context, client *minio.Client, bucket, object string, tagCount int) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 16:36:16 GMT 2024
    - 45.7K bytes
    - Viewed (0)
  2. statement.go

    				writer.WriteByte('(')
    				stmt.AddVar(writer, v...)
    				writer.WriteByte(')')
    			} else {
    				writer.WriteString("(NULL)")
    			}
    		case *DB:
    			subdb := v.Session(&Session{Logger: logger.Discard, DryRun: true}).getInstance()
    			if v.Statement.SQL.Len() > 0 {
    				var (
    					vars = subdb.Statement.Vars
    					sql  = v.Statement.SQL.String()
    				)
    
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Fri Jan 12 08:42:21 GMT 2024
    - 19.8K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    			// unconsumedTimer fires.
    			select {
    			// Check after a second
    			case <-time.After(time.Second):
    				h.mutex.Unlock()
    				continue
    
    			case <-h.ctx.Done():
    				h.mutex.Unlock()
    				// discard result and return.
    				return errHealStopSignalled
    
    			// Timeout if no results consumed for too long.
    			case <-unconsumedTimer.C:
    				h.mutex.Unlock()
    				return errHealIdleTimeout
    			}
    		}
    		break
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  4. src/bytes/buffer.go

    func (b *Buffer) Cap() int { return cap(b.buf) }
    
    // Available returns how many bytes are unused in the buffer.
    func (b *Buffer) Available() int { return cap(b.buf) - len(b.buf) }
    
    // Truncate discards all but the first n unread bytes from the buffer
    // but continues to use the same allocated storage.
    // It panics if n is negative or greater than the length of the buffer.
    func (b *Buffer) Truncate(n int) {
    	if n == 0 {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 17:10:31 GMT 2023
    - 15.7K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

          TYPE_GOAWAY -> readGoAway(handler, length, flags, streamId)
          TYPE_WINDOW_UPDATE -> readWindowUpdate(handler, length, flags, streamId)
          else -> source.skip(length.toLong()) // Implementations MUST discard frames of unknown types.
        }
    
        return true
      }
    
      @Throws(IOException::class)
      private fun readHeaders(
        handler: Handler,
        length: Int,
        flags: Int,
        streamId: Int,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  6. api/go1.19.txt

    pkg io/ioutil, func ReadFile //deprecated #42026
    pkg io/ioutil, func TempDir //deprecated #42026
    pkg io/ioutil, func TempFile //deprecated #42026
    pkg io/ioutil, func WriteFile //deprecated #42026
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Fri Dec 02 16:29:41 GMT 2022
    - 17.9K bytes
    - Viewed (1)
  7. api/go1.5.txt

    pkg archive/zip, method (*Writer) SetOffset(int64)
    pkg bufio, method (*Reader) Discard(int) (int, error)
    pkg bufio, method (ReadWriter) Discard(int) (int, error)
    pkg bytes, func LastIndexByte([]uint8, uint8) int
    pkg bytes, method (*Buffer) Cap() int
    pkg bytes, method (*Reader) Size() int64
    pkg crypto, const SHA512_224 = 14
    pkg crypto, const SHA512_224 Hash
    pkg crypto, const SHA512_256 = 15
    pkg crypto, const SHA512_256 Hash
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Thu Jul 30 21:14:09 GMT 2015
    - 46.6K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    				}
    				if hdr.OpCode.IsControl() {
    					if err := controlHandler(hdr, &wsReader); err != nil {
    						return nil, err
    					}
    					continue
    				}
    				if hdr.OpCode&want == 0 {
    					if err := wsReader.Discard(); err != nil {
    						return nil, err
    					}
    					continue
    				}
    				if int64(cap(dst)) < hdr.Length+1 {
    					dst = make([]byte, 0, hdr.Length+hdr.Length>>3)
    				}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  9. cmd/server-main.go

    			UseIdleTimeout(globalServerCtxt.IdleTimeout).
    			UseReadHeaderTimeout(globalServerCtxt.ReadHeaderTimeout).
    			UseBaseContext(GlobalContext).
    			UseCustomLogger(log.New(io.Discard, "", 0)). // Turn-off random logging by Go stdlib
    			UseTCPOptions(globalTCPOptions)
    
    		httpServer.TCPOptions.Trace = bootstrapTraceMsg
    		go func() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  10. src/cmd/asm/internal/asm/parse.go

    		p.symDefRef(w, word, operands)
    	}
    	return p.errorCount == 0
    }
    
    // nextToken returns the next non-build-comment token from the lexer.
    // It reports misplaced //go:build comments but otherwise discards them.
    func (p *Parser) nextToken() lex.ScanToken {
    	for {
    		tok := p.lex.Next()
    		if tok == lex.BuildComment {
    			if p.sawCode {
    				p.errorf("misplaced //go:build comment")
    			}
    			continue
    		}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Feb 21 14:34:57 GMT 2024
    - 36.9K bytes
    - Viewed (0)
Back to top