Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 321 - 330 of 843 for closer (0.03 seconds)

  1. internal/ioutil/read_file.go

    // as an error to be reported.
    func ReadFileWithFileInfo(name string) ([]byte, fs.FileInfo, error) {
    	f, err := OsOpenFile(name, readMode, 0o666)
    	if err != nil {
    		return nil, nil, err
    	}
    	defer f.Close()
    
    	st, err := f.Stat()
    	if err != nil {
    		return nil, nil, err
    	}
    
    	dst := make([]byte, st.Size())
    	_, err = io.ReadFull(f, dst)
    	return dst, st, err
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Dec 09 18:17:51 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/HeadersTest.kt

        }
      }
    
      @Test fun headersEquals() {
        val headers1 =
          Headers
            .Builder()
            .add("Connection", "close")
            .add("Transfer-Encoding", "chunked")
            .build()
        val headers2 =
          Headers
            .Builder()
            .add("Connection", "close")
            .add("Transfer-Encoding", "chunked")
            .build()
        assertThat(headers2).isEqualTo(headers1)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt

        val delegate = delegate
        if (delegate != null) {
          this.delegate = null
          delegate.onClosed(webSocket, code, reason)
        } else {
          events.add(Closed(code, reason))
        }
      }
    
      override fun onFailure(
        webSocket: WebSocket,
        t: Throwable,
        response: Response?,
      ) {
        Platform.get().log("[WS $name] onFailure", Platform.INFO, t)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/GeneralRange.java

      }
    
      @Override
      public String toString() {
        return comparator
            + ":"
            + (lowerBoundType == CLOSED ? '[' : '(')
            + (hasLowerBound ? lowerEndpoint : "-\u221e")
            + ','
            + (hasUpperBound ? upperEndpoint : "\u221e")
            + (upperBoundType == CLOSED ? ']' : ')');
      }
    
      @Nullable T getLowerEndpoint() {
        return lowerEndpoint;
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  5. internal/config/identity/ldap/ldap.go

    // username.
    func (l *Config) LookupUserDN(username string) (*xldap.DNSearchResult, []string, error) {
    	conn, err := l.LDAP.Connect()
    	if err != nil {
    		return nil, nil, err
    	}
    	defer conn.Close()
    
    	// Bind to the lookup user account
    	if err = l.LDAP.LookupBind(conn); err != nil {
    		return nil, nil, err
    	}
    
    	// Lookup user DN
    	lookupRes, err := l.LDAP.LookupUsername(conn, username)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 01:04:53 GMT 2024
    - 12.4K bytes
    - Click Count (1)
  6. guava-tests/benchmark/com/google/common/io/BaseEncodingBenchmark.java

          StringWriter target = new StringWriter(2 * n);
          OutputStream encodingStream = encoding.encoding.encodingStream(target);
          encodingStream.write(encodingInputs[i & INPUTS_MASK]);
          encodingStream.close();
          tmp += target.getBuffer().length();
        }
        return tmp;
      }
    
      @Benchmark
      public int decodingStream(int reps) throws IOException {
        int tmp = 0;
        byte[] target = new byte[n];
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 3.2K bytes
    - Click Count (0)
  7. internal/s3select/simdj/reader_amd64_test.go

    					t.Fatal(err)
    				}
    				switch typ {
    				case simdjson.TypeNone:
    					close(dst)
    					break parser
    				case simdjson.TypeRoot:
    					typ, obj, err := next.Root(nil)
    					if err != nil {
    						t.Fatal(err)
    					}
    					if typ != simdjson.TypeObject {
    						if typ == simdjson.TypeNone {
    							close(dst)
    							break parser
    						}
    						t.Fatal("Unexpected type:", typ.String())
    					}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  8. cmd/metacache-entries.go

    }
    
    // mergeEntryChannels will merge entries from in and return them sorted on out.
    // To signify no more results are on an input channel, close it.
    // The output channel will be closed when all inputs are emptied.
    // If file names are equal, compareMeta is called to select which one to choose.
    // The entry not chosen will be discarded.
    // If the context is canceled the function will return the error,
    // otherwise the function will return nil.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  9. internal/store/batch_test.go

    		Limit:         limit,
    		Store:         store,
    		CommitTimeout: 5 * time.Minute,
    		Log: func(ctx context.Context, err error, id string, errKind ...any) {
    			t.Log(err)
    		},
    	})
    	defer batch.Close()
    
    	for i := 0; i < int(limit); i++ {
    		if err := batch.Add(testItem); err != nil {
    			t.Fatalf("failed to add %v; %v", i, err)
    		}
    	}
    
    	batchLen := batch.Len()
    	if batchLen != int(limit) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/io/MultiReaderTest.java

                  throw new IllegalStateException("More than one source open");
                }
                return new FilterReader(source.openStream()) {
                  @Override
                  public void close() throws IOException {
                    super.close();
                    counter[0]--;
                  }
                };
              }
            };
        Reader joinedReader = CharSource.concat(reader, reader, reader).openStream();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3.7K bytes
    - Click Count (0)
Back to Top