Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 1,481 for messages (0.08 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/peer-rest-server.go

    		}
    		if err != nil {
    			return np, grid.NewRemoteErr(err)
    		}
    	default:
    		return np, grid.NewRemoteErr(errUnsupportedSignal)
    	}
    	return np, nil
    }
    
    // ListenHandler sends http trace messages back to peer rest client
    func (s *peerRESTServer) ListenHandler(ctx context.Context, v *grid.URLValues, out chan<- *grid.Bytes) *grid.RemoteErr {
    	values := v.Values()
    	defer v.Recycle()
    	var prefix string
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/api/chat/ChatApiManager.java

            }
    
            final String message = request.getParameter("message");
            final String sessionId = request.getParameter("sessionId");
    
            if (logger.isDebugEnabled()) {
                logger.debug("Processing stream request. sessionId={}, messageLength={}", sessionId, message != null ? message.length() : 0);
            }
    
            if (StringUtil.isBlank(message)) {
                if (logger.isDebugEnabled()) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 06:06:55 GMT 2026
    - 25.8K bytes
    - Click Count (0)
  3. src/cmd/asm/internal/asm/parse.go

    func (p *Parser) line(scratch [][]lex.Token) (word, cond string, operands [][]lex.Token, ok bool) {
    next:
    	// Skip newlines.
    	var tok lex.ScanToken
    	for {
    		tok = p.nextToken()
    		// We save the line number here so error messages from this instruction
    		// are labeled with this line. Otherwise we complain after we've absorbed
    		// the terminating newline and the line numbers are off by one in errors.
    		p.lineNum = p.lex.Line()
    		switch tok {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Feb 17 19:57:47 GMT 2026
    - 37.3K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/exec/Crawler.java

        @Resource
        protected CrawlingInfoService crawlingInfoService;
    
        /**
         * Adds an error message to the error queue for later processing.
         * This method is thread-safe and can be called from multiple crawler threads.
         *
         * @param msg the error message to add; ignored if null or blank
         */
        public static void addError(final String msg) {
            if (StringUtil.isNotBlank(msg)) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 32.4K bytes
    - Click Count (0)
  5. cmd/metrics-v2.go

    			metrics = append(metrics, MetricV2{
    				Description: MetricDescription{
    					Namespace: minioNamespace,
    					Subsystem: auditSubsystem,
    					Name:      "target_queue_length",
    					Help:      "Number of unsent messages in queue for target",
    					Type:      gaugeMetric,
    				},
    				VariableLabels: map[string]string{"target_id": id},
    				Value:          float64(st.QueueLength),
    			})
    			metrics = append(metrics, MetricV2{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  6. tensorflow/c/c_api.h

    // it will be stopped and joined.
    TF_CAPI_EXPORT extern void TF_DeleteServer(TF_Server* server);
    
    // Register a listener method that processes printed messages.
    //
    // If any listeners are registered, the print operator will call all listeners
    // with the printed messages and immediately return without writing to the
    // logs.
    TF_CAPI_EXPORT extern void TF_RegisterLogListener(
        void (*listener)(const char*));
    
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Oct 26 21:08:15 GMT 2023
    - 82.3K bytes
    - Click Count (0)
  7. docs/changelogs/changelog_3x.md

        `OkHttpClient.newWebSocket()`, send messages with `send()`, and receive messages with the
        `WebSocketListener`.
    
        The `okhttp-ws` submodule is no longer available and `okhttp-ws` artifacts from previous
        releases of OkHttp are not compatible with OkHttp 3.5. When upgrading to the new package
        please note that the `WebSocket` and `WebSocketCall` classes have been merged. Sending messages
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  8. CHANGELOG/CHANGELOG-1.23.md

    - JSON log output is configurable and now supports writing info messages to stdout and error messages to stderr. Info messages can be buffered in memory. The default is to write both to stdout without buffering, as before. ([#104873](https://github.com/kubernetes/kubernetes/pull/104873), [@pohly](https://github.com/pohly))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Tue Feb 28 21:06:52 GMT 2023
    - 424.5K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb1/smb1/SmbTransport.java

    import jcifs.smb1.util.transport.TransportException;
    
    /**
     * Legacy SMB transport implementation for SMB1 protocol communication.
     * Handles the low-level transport layer for SMB1 protocol messages.
     */
    public class SmbTransport extends Transport implements SmbConstants {
    
        static final byte[] BUF = new byte[0xFFFF];
        static final SmbComNegotiate NEGOTIATE_REQUEST = new SmbComNegotiate();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 31.8K bytes
    - Click Count (0)
  10. src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java

        }
    
        /**
         * Gets the next message in the compound chain.
         *
         * @return the next message or null if this is the last message
         */
        protected ServerMessageBlock2 getNext() {
            return this.next;
        }
    
        /**
         * Sets the next message in the compound chain.
         *
         * @param n the next message
         */
        protected void setNext(final ServerMessageBlock2 n) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 24K bytes
    - Click Count (0)
Back to Top