Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 565 for closes (0.03 seconds)

  1. src/archive/zip/zip_test.go

    			Method: Store, // Deflate is too slow when it is compiled with -race flag
    		})
    		if err != nil {
    			t.Fatalf("creating file %d: %v", i, err)
    		}
    	}
    	if err := w.Close(); err != nil {
    		t.Fatalf("Writer.Close: %v", err)
    	}
    	s := buf.String()
    	zr, err := NewReader(strings.NewReader(s), int64(len(s)))
    	if err != nil {
    		t.Fatalf("NewReader: %v", err)
    	}
    	if got := len(zr.File); got != nFiles {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu May 23 01:00:11 GMT 2024
    - 19.6K bytes
    - Click Count (0)
  2. internal/store/batch.go

    	default:
    	}
    	if _, err := b.store.PutMultiple(b.items); err != nil {
    		return err
    	}
    	b.items = make([]I, 0, b.limit)
    	return nil
    }
    
    // Close commits the pending items and quits the goroutines
    func (b *Batch[I]) Close() error {
    	defer func() {
    		close(b.quitCh)
    	}()
    
    	b.Lock()
    	defer b.Unlock()
    	return b.commit()
    }
    
    // NewBatch creates a new batch
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 2.9K bytes
    - Click Count (0)
  3. build-logic/documentation/src/main/groovy/gradlebuild/docs/model/SimpleClassMetaDataRepository.java

                try {
                    ObjectOutputStream objOutputStream = new ObjectOutputStream(new BufferedOutputStream(outputStream));
                    objOutputStream.writeObject(classes);
                    objOutputStream.close();
                } finally {
                    outputStream.close();
                }
            } catch (IOException e) {
                throw new GradleException(String.format("Could not write meta-data to %s.", repoFile), e);
            }
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed May 21 06:20:45 GMT 2025
    - 4K bytes
    - Click Count (0)
  4. internal/event/target/redis.go

    		}
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - releases the resources used by the pool.
    func (target *RedisTarget) Close() error {
    	close(target.quitCh)
    	if target.pool != nil {
    		return target.pool.Close()
    	}
    	return nil
    }
    
    func (target *RedisTarget) init() error {
    	return target.initOnce.Do(target.initRedis)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  5. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsWriter.java

         */
        void write(File output, Map<String, Object> options, Settings settings) throws IOException;
    
        /**
         * Writes the supplied settings to the specified character writer. The writer will be automatically closed before
         * the method returns.
         *
         * @param output The writer to serialize the settings to, must not be {@code null}.
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3K bytes
    - Click Count (0)
  6. src/bufio/net_test.go

    		t.Fatal(err)
    	}
    
    	defer wg.Wait()
    	defer clientConn.Close()
    
    	const data = "data"
    	r := bufio.NewReader(strings.NewReader(data))
    	n, err := io.Copy(clientConn, r)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if n != int64(len(data)) {
    		t.Errorf("io.Copy returned %d, want %d", n, len(data))
    	}
    
    	clientConn.Close()
    	tot := <-ch
    
    	if tot != len(data) {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 19:37:07 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  7. internal/s3select/simdj/reader_amd64_test.go

    					t.Fatal(err)
    				}
    				switch typ {
    				case simdjson.TypeNone:
    					close(dst)
    					break parser
    				case simdjson.TypeRoot:
    					typ, obj, err := next.Root(nil)
    					if err != nil {
    						t.Fatal(err)
    					}
    					if typ != simdjson.TypeObject {
    						if typ == simdjson.TypeNone {
    							close(dst)
    							break parser
    						}
    						t.Fatal("Unexpected type:", typ.String())
    					}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  8. internal/deadlineconn/deadlineconn.go

    	c.infWrites.Store(t.IsZero())
    	c.writeSetAt = time.Time{}
    	return c.Conn.SetWriteDeadline(t)
    }
    
    // Close wraps conn.Close and stops sending deadline updates.
    func (c *DeadlineConn) Close() error {
    	c.abortReads.Store(true)
    	c.abortWrites.Store(true)
    	return c.Conn.Close()
    }
    
    // WithReadDeadline sets a new read side net.Conn deadline.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Dec 02 13:21:17 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  9. internal/config/identity/ldap/ldap.go

    // username.
    func (l *Config) LookupUserDN(username string) (*xldap.DNSearchResult, []string, error) {
    	conn, err := l.LDAP.Connect()
    	if err != nil {
    		return nil, nil, err
    	}
    	defer conn.Close()
    
    	// Bind to the lookup user account
    	if err = l.LDAP.LookupBind(conn); err != nil {
    		return nil, nil, err
    	}
    
    	// Lookup user DN
    	lookupRes, err := l.LDAP.LookupUsername(conn, username)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 01:04:53 GMT 2024
    - 12.4K bytes
    - Click Count (1)
  10. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/PluginDescriptor.java

            List<ComponentDescriptor<?>> clones = null;
            if (mojos != null) {
                clones = new ArrayList<>(mojos.size());
                for (MojoDescriptor mojo : mojos) {
                    MojoDescriptor clone = mojo.clone();
                    clone.setPluginDescriptor(pluginDescriptor);
                    clones.add(clone);
                }
            }
            return clones;
        }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 16.2K bytes
    - Click Count (0)
Back to Top