Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 1,581 for Notify (0.11 seconds)

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

  1. src/main/java/jcifs/smb/NtStatus.java

         */
    
        /** The operation completed successfully */
        int NT_STATUS_SUCCESS = 0x00000000;
        /** The request is pending */
        int NT_STATUS_PENDING = 0x00000103;
        /** A notify change request is being completed and information is being returned */
        int NT_STATUS_NOTIFY_ENUM_DIR = 0x0000010C;
        /** The data was too large to fit into the specified buffer */
        int NT_STATUS_BUFFER_OVERFLOW = 0x80000005;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 14.9K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

                  if (errorExceptionToDeliver == null &&
                    unacknowledgedBytesRead >= connection.okHttpSettings.initialWindowSize / 2
                  ) {
                    // Flow control: notify the peer that we're ready for more data! Only send a
                    // WINDOW_UPDATE if the stream isn't in error.
                    connection.writeWindowUpdateLater(id, unacknowledgedBytesRead)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 07 18:57:05 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  3. cmd/iam.go

    			}
    		}
    	}
    
    	err := sys.store.DeletePolicy(ctx, policyName, !notifyPeers)
    	if err != nil {
    		return err
    	}
    
    	if !notifyPeers || sys.HasWatcher() {
    		return nil
    	}
    
    	// Notify all other MinIO peers to delete policy
    	for _, nerr := range globalNotificationSys.DeletePolicy(ctx, policyName) {
    		if nerr.Err != nil {
    			logger.GetReqInfo(ctx).SetTags("peerAddress", nerr.Host.String())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb/DosErrorTest.java

            @SuppressWarnings("unchecked")
            BiConsumer<Integer, Integer> consumer = mock(BiConsumer.class);
    
            // Act: for each input, if a mapping exists, notify the consumer
            for (int dos : inputs) {
                int nt = findNtStatusOrMinusOne(dos);
                if (nt != -1) {
                    consumer.accept(dos, nt);
                }
            }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  5. cmd/object-handlers.go

    		w.Header().Set(xhttp.AmzServerSideEncryptionCustomerKeyMD5, r.Header.Get(xhttp.AmzServerSideEncryptionCustomerKeyMD5))
    	}
    
    	s3Select.Evaluate(w)
    
    	// Notify object accessed via a GET request.
    	sendEvent(eventArgs{
    		EventName:    event.ObjectAccessedGet,
    		BucketName:   bucket,
    		Object:       objInfo,
    		ReqParams:    extractReqParams(r),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  6. PULL_REQUESTS_ETIQUETTE.md

    4. **Before Submitting**:
       - Run `make verify` to check formatting, linting, and tests.
       - Reference related issues (e.g., “Closes #1234”).
       - Notify team members via GitHub `@mentions` if urgent or complex.
    
    ## Reviewing PRs
    
    Reviewers ensure MinIO’s commit history remains a clear, reliable record. Responsibilities include:
    
    1. **Commit Quality**:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun May 25 16:32:03 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  7. cmd/batch-handlers.go

    		return errors.New(resp.Status)
    	}
    
    	return nil
    }
    
    // Notify notifies notification endpoint if configured regarding job failure or success.
    func (r BatchJobReplicateV1) Notify(ctx context.Context, ri *batchJobInfo) error {
    	return notifyEndpoint(ctx, ri, r.Flags.Notify.Endpoint, r.Flags.Notify.Token)
    }
    
    // ReplicateFromSource - this is not implemented yet where source is 'remote' and target is local.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  8. internal/config/lambda/parse.go

    	"github.com/minio/minio/internal/config/lambda/target"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	logSubsys = "notify"
    )
    
    func logOnceIf(ctx context.Context, err error, id string, errKind ...any) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

              if (multipleReadyTasks || !coordinatorWaiting && readyQueues.isNotEmpty()) {
                startAnotherThread()
              }
    
              return readyTask
            }
    
            // Notify the coordinator of a task that's coming up soon.
            coordinatorWaiting -> {
              if (minDelayNanos < coordinatorWakeUpAt - now) {
                backend.coordinatorNotify(this@TaskRunner)
              }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Aug 30 11:30:11 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  10. CODE_OF_CONDUCT.md

    
    ## Enforcement
    
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Fri Feb 05 18:43:16 GMT 2021
    - 5.2K bytes
    - Click Count (0)
Back to Top