Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 469 for sends (0.05 seconds)

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

  1. src/main/java/jcifs/internal/witness/WitnessClient.java

                }
            }
        }
    
        /**
         * Monitors active registrations and sends heartbeats.
         */
        private void monitorRegistrations() {
            for (WitnessRegistration registration : registrations.values()) {
                if (registration.getState() == WitnessRegistrationState.REGISTERED) {
                    // Send periodic heartbeat
                    sendHeartbeat(registration);
                }
            }
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 20.8K bytes
    - Click Count (0)
  2. internal/event/target/mysql.go

    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the mysql.
    func (target *MySQLTarget) send(eventData event.Event) error {
    	if target.args.Format == event.NamespaceFormat {
    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/util/ThreadDumpUtil.java

                    }
                });
            } catch (final Exception e) {
                logger.warn("Failed to write thread dump: file={}", file, e);
            }
        }
    
        /**
         * Processes all thread information and sends it to the provided consumer.
         *
         * @param writer the consumer that will handle each line of thread dump output
         */
        public static void processThreadDump(final Consumer<String> writer) {
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  4. internal/event/target/nats.go

    	}
    
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the Nats.
    func (target *NATSTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  5. cmd/peer-rest-client.go

    	return nil
    }
    
    // CommitBinary - sends commit binary message to remote peers.
    func (client *peerRESTClient) CommitBinary(ctx context.Context) error {
    	respBody, err := client.callWithContext(ctx, peerRESTMethodCommitBinary, nil, nil, -1)
    	if err != nil {
    		return err
    	}
    	defer xhttp.DrainBody(respBody)
    	return nil
    }
    
    // SignalService - sends signal to peer nodes.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  6. docs/iam/access-management-plugin.md

    MinIO now includes support for using an Access Management Plugin. This is to allow object storage access control to be managed externally via a webhook.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Dec 13 22:28:48 GMT 2022
    - 4.4K bytes
    - Click Count (1)
  7. src/main/java/jcifs/dcerpc/DcerpcHandle.java

        @Override
        public String toString() {
            return this.binding.toString();
        }
    
        /**
         * Sends a DCERPC fragment to the remote endpoint
         * @param buf the buffer containing the fragment data
         * @param off the offset into the buffer
         * @param length the length of data to send
         * @throws IOException if an I/O error occurs during transmission
         */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  8. docs/en/docs/advanced/security/http-basic-auth.md

    That tells the browser to show the integrated prompt for a username and password.
    
    Then, when you type that username and password, the browser sends them in the header automatically.
    
    ## Simple HTTP Basic Auth { #simple-http-basic-auth }
    
    * Import `HTTPBasic` and `HTTPBasicCredentials`.
    * Create a "`security` scheme" using `HTTPBasic`.
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:15:41 GMT 2025
    - 5K bytes
    - Click Count (0)
  9. cmd/event-notification.go

    	evnot.targetList.Remove(targetIDSet)
    }
    
    // Send - sends the event to all registered notification targets
    func (evnot *EventNotifier) Send(args eventArgs) {
    	evnot.RLock()
    	targetIDSet := evnot.bucketRulesMap[args.BucketName].Match(args.EventName, args.Object.Name)
    	evnot.RUnlock()
    
    	if len(targetIDSet) == 0 {
    		return
    	}
    
    	// If MINIO_API_SYNC_EVENTS is set, send events synchronously.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jun 21 22:22:24 GMT 2024
    - 7.7K bytes
    - Click Count (0)
  10. internal/event/targetlist_test.go

    func (target ExampleTarget) ID() TargetID {
    	return target.id
    }
    
    // Save - Sends event directly without persisting.
    func (target ExampleTarget) Save(eventData Event) error {
    	return target.send(eventData)
    }
    
    // Store - Returns a nil store.
    func (target ExampleTarget) Store() TargetStore {
    	return nil
    }
    
    func (target ExampleTarget) send(eventData Event) error {
    	b := make([]byte, 1)
    	if _, err := rand.Read(b); err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 6K bytes
    - Click Count (0)
Back to Top