Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 194 for Closing (0.05 seconds)

  1. src/archive/zip/writer_test.go

    	if err != nil {
    		t.Fatalf("opening %s: %v", f.Name, err)
    	}
    	b, err := io.ReadAll(rc)
    	if err != nil {
    		t.Fatalf("reading %s: %v", f.Name, err)
    	}
    	err = rc.Close()
    	if err != nil {
    		t.Fatalf("closing %s: %v", f.Name, err)
    	}
    	if !bytes.Equal(b, wt.Data) {
    		t.Errorf("File contents %q, want %q", b, wt.Data)
    	}
    }
    
    func BenchmarkCompressedZipGarbage(b *testing.B) {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  2. src/test/java/jcifs/dcerpc/DcerpcHandleTest.java

            }
    
            @Test
            @DisplayName("Should handle close operation")
            void testClose() throws IOException {
                // When: Closing handle
                handle.close();
    
                // Then: Should complete without errors
                assertDoesNotThrow(() -> handle.close());
            }
    
            @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/io/CharStreams.java

        @Override
        public String toString() {
          return "CharStreams.nullWriter()";
        }
      }
    
      /**
       * Returns a Writer that sends all output to the given {@link Appendable} target. Closing the
       * writer will close the target if it is {@link Closeable}, and flushing the writer will flush the
       * target if it is {@link java.io.Flushable}.
       *
       * @param target the object to which output will be sent
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 29 13:56:24 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  4. internal/grid/connection.go

    		defer c.connMu.Unlock()
    		if c.debugInConn != nil {
    			if debugPrint {
    				fmt.Println("debug: closing inbound connection")
    			}
    			c.debugInConn.Close()
    		}
    	case debugKillOutbound:
    		c.connMu.Lock()
    		defer c.connMu.Unlock()
    		if c.debugInConn != nil {
    			if debugPrint {
    				fmt.Println("debug: closing outgoing connection")
    			}
    			c.debugInConn.Close()
    		}
    	case debugWaitForExit:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

       * if no streams were processed.
       *
       * @param lastGoodStreamId the last stream ID processed, or zero if no streams were processed.
       * @param errorCode reason for closing the connection.
       * @param debugData only valid for HTTP/2; opaque debug data to send.
       */
      @Throws(IOException::class)
      fun goAway(
        lastGoodStreamId: Int,
        errorCode: ErrorCode,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

      try {
        close()
      } catch (e: AssertionError) {
        throw e
      } catch (rethrown: RuntimeException) {
        if (rethrown.message == "bio == null") {
          // Conscrypt in Android 10 and 11 may throw closing an SSLSocket. This is safe to ignore.
          // https://issuetracker.google.com/issues/177450597
          return
        }
        throw rethrown
      } catch (_: Exception) {
      }
    }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.3K bytes
    - Click Count (1)
  7. internal/ioutil/ioutil.go

    				}
    				nw = int64(n)
    			}
    
    			// Disable O_DIRECT on fd's on unaligned buffer
    			// perform an amortized Fdatasync(fd) on the fd at
    			// the end, this is performed by the caller before
    			// closing 'w'.
    			if err = disk.DisableDirectIO(file); err != nil {
    				return written, err
    			}
    
    			// buf is not aligned, hence use writeUnaligned()
    			// for the remainder
    			un, err = w.Write(buf[len(buf)-remain:])
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  8. internal/event/target/nats.go

    	}
    
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to NATS server.
    func (target *NATSTarget) Close() (err error) {
    	close(target.quitCh)
    	if target.stanConn != nil {
    		// closing the streaming connection does not close the provided NATS connection.
    		if target.stanConn.NatsConn() != nil {
    			target.stanConn.NatsConn().Close()
    		}
    		return target.stanConn.Close()
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  9. docs/en/docs/contributing.md

    Think of it this way: we can already write LLM prompts or run automated tools ourselves, and that would be faster than reviewing external PRs.
    
    ### Closing Automated and AI PRs
    
    If we see PRs that seem AI generated or automated in similar ways, we'll flag them and close them.
    
    The same applies to comments and descriptions, please don't copy paste the content generated by an LLM.
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Mon Mar 23 13:59:26 GMT 2026
    - 10.6K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

            if (toClose != null) {
              connection.connectionListener.connectionClosed(connection)
            }
          } else {
            check(toClose == null) // If we still have a connection we shouldn't be closing any sockets.
          }
        }
    
        val result = timeoutExit(e)
        if (e != null) {
          eventListener.callFailed(this, result!!)
        } else {
          eventListener.callEnd(this)
        }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 19.5K bytes
    - Click Count (0)
Back to Top