Search Options

Results per page
Sort
Preferred Languages
Advance

Results 441 - 450 of 1,713 for Context (0.04 sec)

  1. cmd/bucket-replication-stats.go

    	}
    }
    
    func (r *ReplicationStats) collectWorkerMetrics(ctx context.Context) {
    	if r == nil {
    		return
    	}
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-r.wTimer.C:
    			r.wlock.Lock()
    			r.workers.update()
    			r.wlock.Unlock()
    		}
    	}
    }
    
    func (r *ReplicationStats) collectQueueMetrics(ctx context.Context) {
    	if r == nil {
    		return
    	}
    
    	for {
    		select {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  2. callbacks/row.go

    			db.Statement.Settings.Delete("rows")
    			db.Statement.Dest, db.Error = db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    		} else {
    			db.Statement.Dest = db.Statement.ConnPool.QueryRowContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    		}
    
    		db.RowsAffected = -1
    	}
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed Feb 08 05:40:41 UTC 2023
    - 581 bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

        }
      }
    
      @SuppressLint("NewApi")
      override fun afterEach(context: ExtensionContext) {
        val failure = context.executionException.orElseGet { null }
    
        if (uncaughtException != null) {
          throw failure + AssertionError("uncaught exception thrown during test", uncaughtException)
        }
    
        if (context.isFlaky()) {
          logEvents()
        }
    
        LogManager.getLogManager().reset()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  4. cmd/data-scanner_test.go

    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestApplyNewerNoncurrentVersionsLimit(t *testing.T) {
    	// Prepare object layer
    	objAPI, disks, err := prepareErasure(t.Context(), 8)
    	if err != nil {
    		t.Fatalf("Failed to initialize object layer: %v", err)
    	}
    	defer removeRoots(disks)
    	setObjectLayer(objAPI)
    
    	// Prepare bucket metadata
    	globalBucketMetadataSys = NewBucketMetadataSys()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  5. tests/prepared_stmt_test.go

    import (
    	"context"
    	"errors"
    	"sync"
    	"testing"
    	"time"
    
    	"gorm.io/gorm"
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestPreparedStmt(t *testing.T) {
    	tx := DB.Session(&gorm.Session{PrepareStmt: true})
    
    	if _, ok := tx.ConnPool.(*gorm.PreparedStmtDB); !ok {
    		t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode")
    	}
    
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 8K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java

         *
         * @param delegate the underlying SMB transport to wrap
         * @param context the CIFS context for configuration
         */
        public RdmaTransport(SmbTransportInternal delegate, CIFSContext context) {
            this.delegate = delegate;
            this.rdmaProvider = RdmaProviderFactory.getProvider(context.getConfig());
            this.bufferManager = new RdmaBufferManager(rdmaProvider);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb2/lease/DirectoryLeaseManagerTest.java

        @BeforeEach
        public void setUp() {
            mocks = MockitoAnnotations.openMocks(this);
            when(context.getConfig()).thenReturn(config);
            when(config.isDirectoryNotificationsEnabled()).thenReturn(false); // Disable for unit tests
    
            directoryLeaseManager = new DirectoryLeaseManager(context, baseLeaseManager);
        }
    
        @AfterEach
        public void tearDown() throws Exception {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  8. cmd/erasure-common.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"math/rand"
    	"sync"
    	"time"
    )
    
    func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) {
    	disks := er.getDisks()
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  9. docs/sts/custom-token-identity.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package main
    
    import (
    	"context"
    	"flag"
    	"fmt"
    	"log"
    	"net/url"
    	"time"
    
    	"github.com/minio/minio-go/v7"
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    var (
    	// LDAP integrated Minio endpoint
    	stsEndpoint string
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 27 00:58:09 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  10. src/main/java/jcifs/dcerpc/DcerpcBind.java

            buf.enc_ndr_short(this.max_recv);
            buf.enc_ndr_long(0); /* assoc. group */
            buf.enc_ndr_small(1); /* num context items */
            buf.enc_ndr_small(0); /* reserved */
            buf.enc_ndr_short(0); /* reserved2 */
            buf.enc_ndr_short(0); /* context id */
            buf.enc_ndr_small(1); /* number of items */
            buf.enc_ndr_small(0); /* reserved */
            this.binding.getUuid().encode(buf);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.6K bytes
    - Viewed (0)
Back to top