- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for setIndex (0.11 sec)
-
src/main/java/jcifs/dcerpc/DcerpcMessage.java
} encode_in(buf); this.length = buf.getIndex() - start; if ( this.ptype == 0 ) { buf.setIndex(alloc_hint_index); this.alloc_hint = this.length - alloc_hint_index; buf.enc_ndr_long(this.alloc_hint); } buf.setIndex(start); encode_header(buf); buf.setIndex(start + this.length); } @Override
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcMessage.java
} encode_in(buf); length = buf.getIndex() - start; if (ptype == 0) { buf.setIndex(alloc_hint_index); alloc_hint = length - alloc_hint_index; buf.enc_ndr_long(alloc_hint); } buf.setIndex(start); encode_header(buf); buf.setIndex(start + length); } public void decode(NdrBuffer buf) throws NdrException {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 4.2K bytes - Viewed (0) -
cmd/mrf_gen.go
} case "Versions": z.Versions, err = dc.ReadBytes(z.Versions) if err != nil { err = msgp.WrapError(err, "Versions") return } case "SetIndex": z.SetIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "SetIndex") return } case "PoolIndex": z.PoolIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "PoolIndex") return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.8K bytes - Viewed (0) -
cmd/erasure-sets.go
} } } func (s *erasureSets) GetLockers(setIndex int) func() ([]dsync.NetLocker, string) { return func() ([]dsync.NetLocker, string) { lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex])) copy(lockers, s.erasureLockers[setIndex]) return lockers, s.erasureLockOwner } } func (s *erasureSets) GetEndpointStrings(setIndex int) func() []string { return func() []string {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops_gen.go
return } case "PoolIndex": z.PoolIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "PoolIndex") return } case "SetIndex": z.SetIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "SetIndex") return } case "DiskIndex": z.DiskIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "DiskIndex") return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 20 15:42:49 UTC 2024 - 24.6K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
// If the tracker has been deleted an error is returned. func (h *healingTracker) update(ctx context.Context) error { h.mu.Lock() if h.ID == "" || h.PoolIndex < 0 || h.SetIndex < 0 || h.DiskIndex < 0 { h.ID, _ = h.disk.GetDiskID() h.PoolIndex, h.SetIndex, h.DiskIndex = h.disk.GetDiskLoc() } h.mu.Unlock() return h.save(ctx) } // save will unconditionally save the tracker and will be created if not existing.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcHandle.java
} doReceiveFragment(stub, isDirect); buf.reset(); buf.setIndex(8); buf.setLength(buf.dec_ndr_short()); if (securityProvider != null) securityProvider.unwrap(buf); buf.setIndex(0); msg.decode_header(buf); off = 24;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 8.8K bytes - Viewed (0) -
cmd/global-heal.go
indexed := make(map[string][]madmin.Disk) for _, disk := range si.Disks { setIdx := fmt.Sprintf("%d-%d", disk.PoolIndex, disk.SetIndex) indexed[setIdx] = append(indexed[setIdx], disk) } for id, disks := range indexed { ss := madmin.SetStatus{ ID: id, SetIndex: disks[0].SetIndex, PoolIndex: disks[0].PoolIndex, } for _, disk := range disks { ss.Disks = append(ss.Disks, disk)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/score/ScoreBooster.java
} final String index = fessConfig.getIndexDocumentUpdateIndex(); for (final String id : ids) { bulkRequestBuilder.add(client.prepareUpdate().setIndex(index).setId(id) .setScript(new Script(ScriptType.INLINE, scriptLang, scriptCode, params))); } if (bulkRequestBuilder.numberOfActions() > requestCacheSize) { flush(); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java
return response.getResult() == Result.CREATED ? 1 : 0; } protected IndexRequestBuilder createInsertRequest(final EsAbstractEntity esEntity) { final IndexRequestBuilder builder = client.prepareIndex().setIndex(asEsIndex()).setSource(toSource(esEntity)); final String id = esEntity.asDocMeta().id(); if (id != null) { builder.setId(id); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 26.4K bytes - Viewed (0)