Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 1,168 for lose (0.03 sec)

  1. cmd/bitrot-streaming.go

    }
    
    func (b *streamingBitrotWriter) Close() error {
    	// Close the underlying writer.
    	// This will also flush the ring buffer if used.
    	err := b.iow.Close()
    
    	// Wait for all data to be written before returning else it causes race conditions.
    	// Race condition is because of io.PipeWriter implementation. i.e consider the following
    	// sequent of operations:
    	// 1) pipe.Write()
    	// 2) pipe.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. internal/logger/logrotate.go

    		return err
    	}
    	defer gw.Close()
    
    	var wc io.WriteCloser
    	wc = gzip.NewWriter(gw)
    	if _, err = io.Copy(wc, r); err != nil {
    		return err
    	}
    
    	if err = wc.Close(); err != nil {
    		return err
    	}
    
    	// Persist to disk any caches.
    	if err = gw.Sync(); err != nil {
    		return err
    	}
    
    	// close everything before we delete.
    	if err = gw.Close(); err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

            acceptConnections()
          } catch (e: Throwable) {
            logger.log(Level.WARNING, "$this failed unexpectedly", e)
          }
    
          // Release all sockets and all threads, even if any close fails.
          serverSocket?.closeQuietly()
    
          val openClientSocket = openClientSockets.iterator()
          while (openClientSocket.hasNext()) {
            openClientSocket.next().closeQuietly()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

            @Throws(IOException::class)
            override fun close() {
              if (!cacheRequestClosed &&
                !discard(ExchangeCodec.DISCARD_STREAM_TIMEOUT_MILLIS, MILLISECONDS)
              ) {
                cacheRequestClosed = true
                cacheRequest.abort()
              }
              source.close()
            }
          }
    
        val contentType = response.header("Content-Type")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Mar 22 07:09:21 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/MultipartReaderTest.kt

          )
    
        val part = parts.nextPart()!!
        parts.close()
    
        assertFailsWith<IllegalStateException> {
          part.body.request(10)
        }.also { expected ->
          assertThat(expected).hasMessage("closed")
        }
      }
    
      @Test fun `cannot call nextPart after calling close`() {
        val parts =
          MultipartReader(
            boundary = "simple boundary",
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/MultiReader.java

        return 0;
      }
    
      @Override
      public boolean ready() throws IOException {
        return (current != null) && current.ready();
      }
    
      @Override
      public void close() throws IOException {
        if (current != null) {
          try {
            current.close();
          } finally {
            current = null;
          }
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  7. .github/workflows/invalid_question.yml

    name: "Close invalid questions issues"
    on:
      schedule:
      - cron: "*/10 * * * *"
    
    permissions:
      contents: read
    
    jobs:
      stale:
        permissions:
          issues: write  # for actions/stale to close stale issues
          pull-requests: write  # for actions/stale to close stale PRs
        runs-on: ubuntu-latest
        env:
          ACTIONS_STEP_DEBUG: true
        steps:
        - name: Close Stale Issues
          uses: actions/stale@v8
          with:
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Apr 11 02:27:05 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  8. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  9. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/ResponseBodyTest.kt

              val source = Buffer().writeUtf8("hello")
              return object : ForwardingSource(source) {
                override fun close() {
                  closed = true
                  super.close()
                }
              }.buffer()
            }
          }
        body.source().close()
        assertThat(closed).isTrue()
      }
    
      @Test
      fun throwingUnderlyingSourceClosesQuietly() {
        val body: ResponseBody =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top