Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 1,018 for closer (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/deadlineconn/deadlineconn_test.go

    func TestBuffConnReadTimeout(t *testing.T) {
    	l, err := net.Listen("tcp", "localhost:0")
    	if err != nil {
    		t.Fatalf("unable to create listener. %v", err)
    	}
    	defer l.Close()
    	serverAddr := l.Addr().String()
    
    	tcpListener, ok := l.(*net.TCPListener)
    	if !ok {
    		t.Fatalf("failed to assert to net.TCPListener")
    	}
    
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Nov 11 17:15:17 GMT 2024
    - 4.8K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/fess/script/groovy/GroovyEngineTest.java

            engine.close();
        }
    
        // ===== Close Lifecycle Tests =====
    
        /**
         * Test that close() can be called multiple times without error
         */
        @Test
        public void test_close_idempotent() {
            final GroovyEngine engine = new GroovyEngine();
            engine.evaluate("return 1", new HashMap<>());
            engine.close();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Mar 15 06:03:38 GMT 2026
    - 29.1K bytes
    - Click Count (0)
  3. cmd/metacache-walk.go

    	}
    	defer done(0, &err)
    
    	return p.storage.WalkDir(ctx, opts, wr)
    }
    
    // WalkDir will traverse a directory and return all entries found.
    // On success a meta cache stream will be returned, that should be closed when done.
    func (client *storageRESTClient) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error {
    	// Ensure remote has the same disk ID.
    	opts.DiskID = *client.diskID.Load()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon May 26 07:06:43 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  4. internal/s3select/json/preader_test.go

    				if err != nil {
    					break
    				}
    			}
    			r.Close()
    			if err != io.EOF {
    				t.Fatalf("Reading failed with %s, %s", err, file.Name())
    			}
    		})
    
    		t.Run(file.Name()+"-close", func(t *testing.T) {
    			f, err := os.Open(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				t.Fatal(err)
    			}
    			r := NewPReader(f, &ReaderArgs{})
    			r.Close()
    			var record sql.Record
    			for {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  5. internal/s3select/json/reader_test.go

    				if err != nil {
    					break
    				}
    			}
    			r.Close()
    			if err != io.EOF {
    				t.Fatalf("Reading failed with %s, %s", err, file.Name())
    			}
    		})
    
    		t.Run(file.Name()+"-close", func(t *testing.T) {
    			f, err := os.Open(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				t.Fatal(err)
    			}
    			r := NewReader(f, &ReaderArgs{})
    			r.Close()
    			var record sql.Record
    			for {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

        url =
          serverIpv4
            .url("/")
            .newBuilder()
            .host("localhost")
            .build()
      }
    
      @AfterEach
      internal fun tearDown() {
        serverIpv4.close()
        serverIpv6.close()
      }
    
      @Test
      fun callIpv6FirstEvenWhenIpv4IpIsListedFirst() {
        dnsResults =
          listOf(
            localhostIpv4,
            localhostIpv6,
          )
        serverIpv4.enqueue(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/collect/TreeMultisetTest.java

        assertEquals(Integer.MAX_VALUE, ms.headMultiset("b", CLOSED).size());
        assertEquals(Integer.MAX_VALUE, ms.headMultiset("a", CLOSED).size());
    
        assertEquals(3, ms.tailMultiset("c", CLOSED).size());
        assertEquals(Integer.MAX_VALUE, ms.tailMultiset("b", CLOSED).size());
        assertEquals(Integer.MAX_VALUE, ms.tailMultiset("a", CLOSED).size());
      }
    
      @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 13.1K bytes
    - Click Count (0)
  8. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt

        events.add(Event(id, type, data))
        drainCancelQueue(eventSource)
      }
    
      override fun onClosed(eventSource: EventSource) {
        get().log("[ES] onClosed", Platform.INFO, null)
        events.add(Closed)
        drainCancelQueue(eventSource)
      }
    
      override fun onFailure(
        eventSource: EventSource,
        t: Throwable?,
        response: Response?,
      ) {
        get().log("[ES] onFailure", Platform.INFO, t)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Aug 30 11:32:52 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb1/dcerpc/msrpc/MsrpcSamrCloseHandle.java

    import jcifs.smb1.dcerpc.rpc;
    
    /**
     * MS-RPC SAMR close handle operation.
     *
     * This class implements the SAMR CloseHandle operation for releasing
     * Security Account Manager (SAM) handles.
     */
    public class MsrpcSamrCloseHandle extends samr.SamrCloseHandle {
    
        /**
         * Creates a new request to close a SAM handle.
         *
         * @param policyHandle the policy handle to close
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  10. src/main/java/jcifs/internal/smb1/com/SmbComClose.java

    import jcifs.internal.Request;
    import jcifs.internal.smb1.SMB1SigningDigest;
    import jcifs.internal.smb1.ServerMessageBlock;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB1 Close file request message.
     *
     * This command is used to close a file that was previously opened
     * with an Open command.
     */
    public class SmbComClose extends ServerMessageBlock implements Request<SmbComBlankResponse> {
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.4K bytes
    - Click Count (0)
Back to Top