Search Options

Results per page
Sort
Preferred Languages
Advance

Results 421 - 430 of 887 for closure (0.05 sec)

  1. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

          logger.log(Level.WARNING, "MockWebServer shutdown failed", e)
        }
      }
    
      override fun toString(): String = delegate.toString()
    
      @Throws(IOException::class)
      override fun close() = delegate.close()
    
      companion object {
        private val logger = Logger.getLogger(MockWebServer::class.java.name)
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/NetServerEnumIterator.java

                this.next = null;
            }
            return n;
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.CloseableIterator#close()
         */
        @Override
        public void close () throws CIFSException {
            if ( this.next != null ) {
                doClose();
            }
        }
    
    
        /**
         * 
         */
        private void doClose () {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 6K bytes
    - Viewed (0)
  3. impl/maven-core/src/main/java/org/apache/maven/internal/aether/LegacyRepositorySystemSessionExtender.java

                        p.setNtlmDomain(authCtx.get(AuthenticationContext.NTLM_DOMAIN));
                        p.setNtlmHost(authCtx.get(AuthenticationContext.NTLM_WORKSTATION));
                        authCtx.close();
                    }
                    return p;
                }
            }
            return null;
        }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. internal/config/dns/operator_dns.go

    // No Op for Operator because operator deals on with bucket entries
    func (c *OperatorDNS) DeleteRecord(record SrvRecord) error {
    	return ErrNotImplemented
    }
    
    // Close closes the internal http client
    func (c *OperatorDNS) Close() error {
    	return nil
    }
    
    // List - Retrieves list of DNS entries for the domain.
    // This is a No Op for Operator because, there is no intent to enforce global
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  5. internal/event/targetlist_test.go

    	return nil
    }
    
    // SendFromStore - interface compatible method does no-op.
    func (target *ExampleTarget) SendFromStore(_ store.Key) error {
    	return nil
    }
    
    func (target ExampleTarget) Close() error {
    	if target.closeErr {
    		return errors.New("close error")
    	}
    
    	return nil
    }
    
    func (target ExampleTarget) IsActive() (bool, error) {
    	return false, errors.New("not connected to target server/service")
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  6. cni/pkg/log/uds.go

    	}()
    
    	go func() {
    		<-stop
    		if err := l.loggingServer.Close(); err != nil {
    			log.Errorf("CNI log server terminated with error: %v", err)
    		} else {
    			log.Debug("CNI log server terminated")
    		}
    	}()
    
    	return nil
    }
    
    func (l *UDSLogger) handleLog(w http.ResponseWriter, req *http.Request) {
    	if req.Body == nil {
    		return
    	}
    	defer req.Body.Close()
    	data, err := io.ReadAll(req.Body)
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/io/IoTestCase.java

            byte[] buf = new byte[4096];
            for (int read = in.read(buf); read != -1; read = in.read(buf)) {
              out.write(buf, 0, read);
            }
          } finally {
            out.close();
          }
        } finally {
          in.close();
        }
      }
    
      @CanIgnoreReturnValue
      private boolean delete(File file) {
        if (file.isDirectory()) {
          File[] files = file.listFiles();
          if (files != null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 31 12:36:13 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. docs/auditlog/auditlog-echo.go

    )
    
    var port int
    
    func init() {
    	flag.IntVar(&port, "port", 8080, "Port to listen on")
    }
    
    func mainHandler(w http.ResponseWriter, r *http.Request) {
    	body, err := io.ReadAll(r.Body)
    	defer r.Body.Close()
    	if err != nil {
    		log.Printf("Error reading request body: %v", err)
    		w.WriteHeader(http.StatusBadRequest)
    		return
    	}
    
    	log.Printf(">>> %s %s\n", r.Method, r.URL.Path)
    	var out bytes.Buffer
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 21:31:13 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  9. android-test-app/src/main/kotlin/okhttp/android/testapp/MainActivity.kt

              println("failed: $e")
            }
    
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              println("response: ${response.code}")
              response.close()
            }
          },
        )
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. src/archive/tar/example_test.go

    			Size: int64(len(file.Body)),
    		}
    		if err := tw.WriteHeader(hdr); err != nil {
    			log.Fatal(err)
    		}
    		if _, err := tw.Write([]byte(file.Body)); err != nil {
    			log.Fatal(err)
    		}
    	}
    	if err := tw.Close(); err != nil {
    		log.Fatal(err)
    	}
    
    	// Open and iterate through the files in the archive.
    	tr := tar.NewReader(&buf)
    	for {
    		hdr, err := tr.Next()
    		if err == io.EOF {
    			break // End of archive
    		}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 16 16:54:08 UTC 2017
    - 1.4K bytes
    - Viewed (0)
Back to top