Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for newPath (0.06 sec)

  1. internal/store/batch.go

    func (b *Batch[I]) Close() error {
    	defer func() {
    		close(b.quitCh)
    	}()
    
    	b.Lock()
    	defer b.Unlock()
    	return b.commit()
    }
    
    // NewBatch creates a new batch
    func NewBatch[I any](config BatchConfig[I]) *Batch[I] {
    	if config.CommitTimeout == 0 {
    		config.CommitTimeout = defaultCommitTimeout
    	}
    	quitCh := make(chan struct{})
    	batch := &Batch[I]{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/XPathAPI.java

         */
        public XPath createXPath(final Consumer<XPathFactory> builder) {
            try {
                final XPathFactory factory = XPathFactory.newInstance();
                builder.accept(factory);
                return factory.newXPath();
            } catch (final Exception e) {
                throw new CrawlerSystemException("Failed to create XPath instance.", e);
            }
        }
    
        /**
         *  Use an XPath string to select a nodelist.
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  3. src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java

                digest.secureWipeKey();
    
                // Verify digest fails after wiping
                byte[] newData = new byte[128];
                Arrays.fill(newData, (byte) 0x66);
    
                assertThrows(IllegalStateException.class, () -> {
                    digest.sign(newData, 0, newData.length, request, response);
                }, "Should throw exception after key is wiped");
            }
    
            @Test
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 43.7K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/hash/Hashing.java

        @Override
        HashCode makeHash(Hasher[] hashers) {
          byte[] bytes = new byte[bits() / 8];
          int i = 0;
          for (Hasher hasher : hashers) {
            HashCode newHash = hasher.hash();
            i += newHash.writeBytesTo(bytes, i, newHash.bits() / 8);
          }
          return HashCode.fromBytesNoCopy(bytes);
        }
    
        @Override
        public int bits() {
          int bitSum = 0;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 29.8K bytes
    - Viewed (0)
  5. internal/grid/types.go

    			return newFn()
    		}},
    	}
    }
    
    // New returns a new empty Array.
    func (p *ArrayOf[T]) New() *Array[T] {
    	return &Array[T]{
    		p: p,
    	}
    }
    
    // NewWith returns a new Array with the provided value (not copied).
    func (p *ArrayOf[T]) NewWith(val []T) *Array[T] {
    	return &Array[T]{
    		p:   p,
    		val: val,
    	}
    }
    
    func (p *ArrayOf[T]) newA(sz uint32) []T {
    	t, ok := p.aPool.Get().(*[]T)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  6. internal/event/target/kafka.go

    		args:       args,
    		store:      queueStore,
    		loggerOnce: loggerOnce,
    		quitCh:     make(chan struct{}),
    	}
    	if target.store != nil {
    		if args.BatchSize > 1 {
    			target.batch = store.NewBatch[event.Event](store.BatchConfig[event.Event]{
    				Limit:         args.BatchSize,
    				Log:           loggerOnce,
    				Store:         queueStore,
    				CommitTimeout: args.BatchCommitTimeout,
    			})
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    		if m.VariableLabels == nil {
    			m.VariableLabels = make(map[string]string, 1)
    		}
    		m.VariableLabels[serverName] = globalLocalNodeName
    		res = append(res, &m)
    		return true
    	})
    	return aoMetricsGroup.NewWith(res), nil
    }
    
    // GetPeerMetrics gets the metrics to be federated across peers.
    func (s *peerRESTServer) GetPeerMetrics(_ *grid.MSS) (*grid.Array[*MetricV2], *grid.RemoteErr) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K bytes
    - Viewed (0)
  8. lib/fips140/v1.0.0-c2097c7c.zip

    divide 8 are more complex to implement, but // are likely to be more efficient if necessary. table := [(1 << 4) - 1]*Nat{ // table[i] = x ^ (i+1) // newNat calls are unrolled so they are allocated on the stack. NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), } table[0].set(x).montgomeryRepresenta(m) for i := 1; i < len(table); i++ { table[i].montgomeryMul(table[i-1], table[0], m) } out.resetFor(m) out.limbs[0]...
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Sep 25 19:53:19 UTC 2025
    - 642.7K bytes
    - Viewed (0)
  9. lib/fips140/v1.1.0-rc1.zip

    divide 8 are more complex to implement, but // are likely to be more efficient if necessary. table := [(1 << 4) - 1]*Nat{ // table[i] = x ^ (i+1) // newNat calls are unrolled so they are allocated on the stack. NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), NewNat(), } table[0].set(x).montgomeryRepresenta(m) for i := 1; i < len(table); i++ { table[i].montgomeryMul(table[i-1], table[0], m) } out.resetFor(m) out.limbs[0]...
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Dec 11 16:27:41 UTC 2025
    - 663K bytes
    - Viewed (0)
  10. api/go1.txt

    pkg math, func Y0(float64) float64
    pkg math, func Y1(float64) float64
    pkg math, func Yn(int, float64) float64
    pkg math/big, const MaxBase ideal-char
    pkg math/big, func NewInt(int64) *Int
    pkg math/big, func NewRat(int64, int64) *Rat
    pkg math/big, method (*Int) Abs(*Int) *Int
    pkg math/big, method (*Int) Add(*Int, *Int) *Int
    pkg math/big, method (*Int) And(*Int, *Int) *Int
    pkg math/big, method (*Int) AndNot(*Int, *Int) *Int
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top