Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1081 - 1090 of 2,060 for must (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top