Search Options

Results per page
Sort
Preferred Languages
Advance

Results 451 - 460 of 887 for closure (0.06 sec)

  1. src/main/java/jcifs/smb/SmbFileOutputStream.java

         * with it.
         *
         * @throws IOException
         *             if a network error occurs
         */
    
        @Override
        public void close () throws IOException {
            try {
                if ( this.handle.isValid() ) {
                    this.handle.close();
                }
            }
            finally {
                this.file.clearAttributeCache();
                this.tmp = null;
            }
        }
    
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Nov 13 15:14:04 UTC 2021
    - 11.9K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

          connectionUser =
            CallConnectionUser(
              call,
              client.connectionPool.delegate.connectionListener,
              chain,
            ),
        )
      }
    
      override fun close() {
        taskFaker.close()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  3. docs/debugging/inspect/main.go

    		if err != nil {
    			fatalErr(err)
    		}
    	}
    
    	// Open the input and create the output file
    	input, err := os.Open(inputFileName)
    	fatalErr(err)
    	defer input.Close()
    	output, err := os.Create(outputFileName)
    	fatalErr(err)
    
    	// Decrypt the inspect data
    	msg := fmt.Sprintf("output written to %s", outputFileName)
    
    	switch {
    	case *keyHex != "":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 31 14:49:23 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  4. istioctl/pkg/authz/authz.go

    }
    
    func getConfigDumpFromFile(filename string) (*configdump.Wrapper, error) {
    	file, err := os.Open(filename)
    	if err != nil {
    		return nil, err
    	}
    	defer func() {
    		if err := file.Close(); err != nil {
    			log.Errorf("failed to close %s: %s", filename, err)
    		}
    	}()
    	data, err := io.ReadAll(file)
    	if err != nil {
    		return nil, err
    	}
    
    	envoyConfig := &configdump.Wrapper{}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 5K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

      // ClasLoader via its AccessControlContext. It does not seem to be possible to make a
      // URLClassLoader without capturing this reference, and it probably would not be desirable for
      // security reasons anyway. Therefore, the FRQ.close() method provides a way to stop the thread
      // explicitly. This test checks that calling that method does allow an app's ClassLoader to be
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java

                }
            }
            smbAuthenticationHolder = holder;
        }
    
        @Override
        public void close() throws Exception {
            smbAuthenticationHolder = null;
            if (cifsContext != null) {
                cifsContext.close();
            }
        }
    
        /*
         * (non-Javadoc)
         *
         * @see org.codelibs.fess.crawler.client.CrawlerClient#doGet(java.lang.String)
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu May 23 01:54:36 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  7. internal/once/singleton.go

    		return true
    	default:
    		return false
    	}
    }
    
    // Set the value and unblock all Get requests.
    // This may only be called once, a second call will panic.
    func (s *Singleton[T]) Set(v *T) {
    	s.v = v
    	close(s.set)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 952 bytes
    - Viewed (0)
  8. internal/config/lambda/target/webhook.go

    		req.Header.Set("Authorization", "Bearer "+target.args.AuthToken)
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    
    	return target.httpClient.Do(req)
    }
    
    // Close the target. Will cancel all active requests.
    func (target *WebhookTarget) Close() error {
    	target.cancel()
    	return nil
    }
    
    func (target *WebhookTarget) init() error {
    	return target.lazyInit.Do(target.initWebhook)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  9. internal/http/check_port_test.go

    func TestCheckPortAvailability(t *testing.T) {
    	if runtime.GOOS != "linux" {
    		t.Skip()
    	}
    
    	l, err := net.Listen("tcp", "localhost:0") // ask kernel for a free port.
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer l.Close()
    
    	port := l.Addr().(*net.TCPAddr).Port
    
    	testCases := []struct {
    		host        string
    		port        int
    		expectedErr error
    	}{
    		{"", port, fmt.Errorf("listen tcp :%v: bind: address already in use", port)},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/suggest/normalizer/DefaultNormalizerTest.java

            runner.ensureYellow();
    
            suggester = Suggester.builder().build(runner.client(), "SuggesterTest");
        }
    
        @AfterClass
        public static void afterClass() throws Exception {
            runner.close();
            runner.clean();
        }
    
        @Test
        public void test_normalize() throws Exception {
            Normalizer normalizer = SuggestUtil.createDefaultNormalizer(runner.client(), suggester.settings());
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top