- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 220 for unpack (0.13 sec)
-
ci/official/containers/linux_arm64/builder.devtoolset/gcc9-fixups.patch
+ { while (*ep != NULL) if (!strncmp (*ep, name, len) && (*ep)[len] == '=') { @@ -332,6 +333,7 @@ unsetenv (const char *name) } else ++ep; + } UNLOCK; diff --git a/support/Makefile b/support/Makefile index a253698..2f4e2a9 100644 --- a/support/Makefile +++ b/support/Makefile @@ -167,13 +167,6 @@ CFLAGS-support_paths.c = \ -DINSTDIR_PATH=\"$(prefix)\" \
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Mon Sep 18 14:52:45 UTC 2023 - 8.9K bytes - Viewed (0) -
internal/event/target/amqp.go
} if nerr, ok := err.(*net.OpError); ok { return (nerr.Err.Error() == "use of closed network connection") } return false } target.connMutex.Lock() defer target.connMutex.Unlock() if target.conn != nil { ch, err = target.conn.Channel() if err == nil { if target.args.PublisherConfirms { confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10K bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
it throws an `InterruptedIOException`. ## Version 1.5.2 _2014-03-17_ * Fix bug where deleting a file that was absent from the `HttpResponseCache` caused an IOException. * Fix bug in HTTP/2 where our HPACK decoder wasn't emitting entries in certain eviction scenarios, leading to dropped response headers. ## Version 1.5.1 _2014-03-11_ * Fix 1.5.0 regression where connections should not have been recycled.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 6.4K bytes - Viewed (0) -
cmd/erasure-decode.go
} p.readers[i] = nil // Since ReadAt returned error, trigger another read. readTriggerCh <- true return } newBufLK.Lock() newBuf[bufIdx] = p.buf[bufIdx][:n] newBufLK.Unlock() // Since ReadAt returned success, there is no need to trigger another read. readTriggerCh <- false }(readerIndex) readerIndex++ } wg.Wait() if p.canDecode(newBuf) { p.offset += p.shardSize
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
cmd/admin-handlers_test.go
if err != nil { return nil, nil, err } // Make objLayer available to all internal services via globalObjectAPI. globalObjLayerMutex.Lock() globalObjectAPI = objLayer globalObjLayerMutex.Unlock() return objLayer, erasureDirs, nil } // cmdType - Represents different service subcomands like status, stop // and restart. type cmdType int const ( restartCmd cmdType = iota stopCmd )
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 13.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/CompactHashing.java
import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * Helper classes and static methods for implementing compact hash-based collections. * * @author Jon Noack */ @GwtIncompatible @ElementTypesAreNonnullByDefault final class CompactHashing { private CompactHashing() {} /** Indicates blank table entries. */ static final byte UNSET = 0;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 15:34:52 UTC 2024 - 7.1K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_test.cc
Multiply(context.get(), second_combined_value.get(), second_negative_one.get(), status.get())); ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get()); // Un-pack the parallel tensor to verify that the operation was // successful. The resulting structure should be: // second_device{first_device{1. * 3., 2. * 3.}, 3. * 3.}. std::array<TensorHandlePtr, 2> second_components;
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Aug 06 23:56:17 UTC 2024 - 29.4K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
// This will block all Send operations, // and finish the existing ones. // All future ones will be discarded. h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock() if h.producer != nil { h.producer.Close() h.client.Close() } // Wait for messages to be sent... h.wg.Wait() } // New initializes a new logger target which
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
had an off-by-one bug in our HPACK encoder. This bug could have caused the wrong headers to be emitted after a sequence of HTTP/2 requests! Everyone who is using OkHttp 3.4.0 or 3.4.0-RC1 should upgrade for this bug fix. ## Version 3.4.0 _2016-07-08_ * New: Support dynamic table size changes to HPACK Encoder.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
cmd/iam-object-store.go
} func (iamOS *IAMObjectStore) runlock() { iamOS.RUnlock() } func (iamOS *IAMObjectStore) lock() *iamCache { iamOS.Lock() return iamOS.iamCache } func (iamOS *IAMObjectStore) unlock() { iamOS.Unlock() } func (iamOS *IAMObjectStore) getUsersSysType() UsersSysType { return iamOS.usersSysType }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 26.6K bytes - Viewed (0)