Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 471 - 480 of 1,209 for close (0.23 seconds)

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

  1. android/guava/src/com/google/common/util/concurrent/Monitor.java

      //
      // 1. What about leaving/unlocking? Are you going to do
      //    guard.enter() paired with monitor.leave()? That might get
      //    confusing. It's nice for the finally block to look as close as
      //    possible to the thing right before the try. You could have
      //    guard.leave(), but that's a little odd as well because the
      //    guard doesn't have anything to do with leaving. You can't
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 43.5K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

      So they began solemnly dancing round and round Alice, every now
    and then treading on her toes when they passed too close, and
    waving their forepaws to mark the time, while the Mock Turtle
    sang this, very slowly and sadly:--
    
    
    `"Will you walk a little faster?" said a whiting to a snail.
    "There's a porpoise close behind us, and he's treading on my
     tail.
    See how eagerly the lobsters and the turtles all advance!
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Oct 29 21:35:03 GMT 2012
    - 145.2K bytes
    - Click Count (0)
  3. cmd/local-locker.go

    		if len(v) == 0 {
    			delete(l.lockMap, k)
    			continue
    		}
    		lockCopy[k] = append(make([]lockRequesterInfo, 0, len(v)), v...)
    	}
    	return lockCopy
    }
    
    func (l *localLocker) Close() error {
    	return nil
    }
    
    // IsOnline - local locker is always online.
    func (l *localLocker) IsOnline() bool {
    	return true
    }
    
    // IsLocal - local locker returns true.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  4. src/main/java/jcifs/dcerpc/DcerpcHandle.java

         */
        protected abstract int doSendReceiveFragment(byte[] out, int off, int length, byte[] inB) throws IOException;
    
        @Override
        public void close() throws IOException {
            this.state = 0;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  5. src/archive/tar/tar_test.go

    	}
    	if err := tw.WriteHeader(hdr); err != nil {
    		t.Fatalf("tw.WriteHeader: %v", err)
    	}
    	if _, err := tw.Write(data); err != nil {
    		t.Fatalf("tw.Write: %v", err)
    	}
    	if err := tw.Close(); err != nil {
    		t.Fatalf("tw.Close: %v", err)
    	}
    
    	// Read it back.
    	tr := NewReader(&b)
    	rHdr, err := tr.Next()
    	if err != nil {
    		t.Fatalf("tr.Next: %v", err)
    	}
    	if !reflect.DeepEqual(rHdr, hdr) {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Jul 25 00:25:45 GMT 2024
    - 23.9K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/dcerpc/msrpc/lsarpc.java

            }
        }
    
        /**
         * LSA close handle message.
         */
        public static class LsarClose extends DcerpcMessage {
    
            @Override
            public int getOpnum() {
                return 0x00;
            }
    
            /** Return value from the RPC call. */
            public int retval;
            /** Policy handle to be closed. */
            public rpc.policy_handle handle;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 42.5K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        response.body.string()
        val cached = cacheGet(cache, request)
        if (shouldWriteToCache) {
          assertThat(cached).isNotNull()
          cached!!.body.close()
        } else {
          assertThat(cached).isNull()
        }
        server.close() // tearDown() isn't sufficient; this test starts multiple servers
      }
    
      private fun assertSubsequentResponseCached(
        initialResponseCode: Int,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 121K bytes
    - Click Count (0)
  8. src/cmd/asm/internal/lex/input.go

    	}
    	delete(in.macros, name)
    }
    
    func (in *Input) Push(r TokenReader) {
    	if len(in.tr) > 100 {
    		in.Error("input recursion")
    	}
    	in.Stack.Push(r)
    }
    
    func (in *Input) Close() {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Nov 12 03:59:40 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb/MultiChannelManager.java

            }
        }
    
        /**
         * Cleanup and shutdown the multi-channel manager.
         */
        public void shutdown() {
            log.info("Shutting down MultiChannelManager");
    
            // Close all channels
            for (String sessionId : new ArrayList<>(sessionChannels.keySet())) {
                removeChannels(sessionId);
            }
    
            // Shutdown thread pools
            healthCheckExecutor.shutdown();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  10. api/go1.24.txt

    pkg net/url, method (*URL) AppendBinary([]uint8) ([]uint8, error) #62384
    pkg os, func OpenInRoot(string, string) (*File, error) #67002
    pkg os, func OpenRoot(string) (*Root, error) #67002
    pkg os, method (*Root) Close() error #67002
    pkg os, method (*Root) Create(string) (*File, error) #67002
    pkg os, method (*Root) FS() fs.FS #67002
    pkg os, method (*Root) Lstat(string) (fs.FileInfo, error) #67002
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Dec 17 21:28:29 GMT 2024
    - 14.2K bytes
    - Click Count (0)
Back to Top