- Sort Score
- Result 10 results
- Languages All
Results 1081 - 1090 of 2,060 for must (0.03 sec)
-
internal/grid/muxserver.go
return pongMsg{Err: &err} default: atomic.StoreInt64(&m.LastPing, time.Now().Unix()) return pongMsg{} } } // disconnect will disconnect the mux. // m.recvMu must be locked when calling this function. func (m *muxServer) disconnect(msg string, locked bool) { if debugPrint { fmt.Println("Mux", m.ID, "disconnecting. Reason:", msg) } if msg != "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
tensorflow/c/eager/immediate_execution_context.h
// Distributed runtime related functions. //===--------------------------------------------------------------------===// #if !defined(IS_MOBILE_PLATFORM) // Set up a multi-client distributed execution environment. Must be called on // all tasks in the cluster. // This call internally coordinates with other tasks to initialize the eager // context and TF server for multi-client execution.
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 12.3K bytes - Viewed (0) -
android/guava/src/com/google/common/primitives/Floats.java
if (min <= max) { return Math.min(Math.max(value, min), max); } throw new IllegalArgumentException( lenientFormat("min (%s) must be less than or equal to max (%s)", min, max)); } /** * Returns the values from each provided array combined into a single array. For example, {@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 15:52:18 UTC 2024 - 25.8K bytes - Viewed (0) -
guava/src/com/google/common/primitives/Floats.java
if (min <= max) { return Math.min(Math.max(value, min), max); } throw new IllegalArgumentException( lenientFormat("min (%s) must be less than or equal to max (%s)", min, max)); } /** * Returns the values from each provided array combined into a single array. For example, {@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 15:52:18 UTC 2024 - 25.8K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
* can always page it to disk "for free". However, on systems where killing processes * happens all the time in normal conditions (i.e., android) the OS must make a tradeoff * between paging memory and killing other processes - so allocating a gigantic buffer and * then sequentially accessing it could result in other processes dying. This is solvable
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 29.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
ioe.addSuppressed(ioe2); log.error("disconnect failed", ioe2); } throw ioe; } } // must be synchronized with peekKey @Override protected void doRecv ( Response response ) throws IOException { CommonServerMessageBlock resp = (CommonServerMessageBlock) response;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Wed Jan 18 23:47:00 UTC 2023 - 67K bytes - Viewed (0) -
src/packaging/deb/init.d/fess
exit 1 fi } case "$1" in start) checkJava if [ -n "$MAX_LOCKED_MEMORY" -a -z "$FESS_HEAP_SIZE" ]; then log_failure_msg "MAX_LOCKED_MEMORY is set - FESS_HEAP_SIZE must also be set" exit 1 fi log_daemon_msg "Starting $DESC" pid=`pidofproc -p $PID_FILE fess` if [ -n "$pid" ] ; then log_begin_msg "Already running." log_end_msg 0 exit 0 fi
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Jan 15 06:32:15 UTC 2023 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
/** * Creates a new web socket and immediately returns it. Creating a web socket initiates an * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must either close or cancel the returned web socket when it is no longer * in use. */ fun newWebSocket( request: Request, listener: WebSocketListener, ): WebSocket }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/EnumHashBiMapTest.java
EnumHashBiMap<Currency, String> bimap = EnumHashBiMap.create(map); assertEquals("dollar", bimap.get(Currency.DOLLAR)); assertEquals(Currency.DOLLAR, bimap.inverse().get("dollar")); /* Map must have at least one entry if not an EnumHashBiMap. */ assertThrows( IllegalArgumentException.class, () -> EnumHashBiMap.create(Collections.<Currency, String>emptyMap()));
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:05:46 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/bucket-lifecycle_test.go
expectedStatus: restoreObjStatus{}, expectedErr: errRestoreHDRMalformed, }, { // invalid; completed restore object request must have expiry set on it. restoreHdr: `ongoing-request="false"`, expectedStatus: restoreObjStatus{}, expectedErr: errRestoreHDRMalformed, }, } for i, tc := range testCases {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 31 09:57:57 UTC 2022 - 7K bytes - Viewed (0)