Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 1,339 for contextos (0.09 sec)

  1. src/test/java/jcifs/tests/NtlmTest.java

    import org.junit.Test;
    
    import jcifs.CIFSContext;
    import jcifs.context.SingletonContext;
    import jcifs.ntlmssp.NtlmFlags;
    import jcifs.ntlmssp.Type1Message;
    import jcifs.ntlmssp.Type2Message;
    import jcifs.ntlmssp.Type3Message;
    
    
    /**
     * @author mbechler
     *
     */
    @SuppressWarnings ( "javadoc" )
    public class NtlmTest {
    
        private CIFSContext context;
    
    
        @Before
        public void setUp () {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Dec 16 10:38:43 UTC 2018
    - 4.8K bytes
    - Viewed (0)
  2. cmd/erasure_test.go

    		buffer := make([]byte, len(data), 2*len(data))
    		copy(buffer, data)
    
    		erasure, err := NewErasure(context.Background(), test.dataBlocks, test.parityBlocks, blockSizeV2)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create erasure: %v", i, err)
    		}
    		encoded, err := erasure.EncodeData(context.Background(), buffer)
    		if err != nil {
    			t.Fatalf("Test %d: failed to encode data: %v", i, err)
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  3. callbacks/delete.go

    			if !ok {
    				result, err := db.Statement.ConnPool.ExecContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    				if db.AddError(err) == nil {
    					db.RowsAffected, _ = result.RowsAffected()
    				}
    
    				return
    			}
    
    			if rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...); db.AddError(err) == nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Feb 25 02:48:23 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  4. cmd/consolelogger.go

    // the console logging pub sub system
    func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys {
    	return &HTTPConsoleLoggerSys{
    		pubsub:  pubsub.New[log.Info, madmin.LogMask](8),
    		console: console.New(w),
    		logBuf:  ring.New(defaultLogBufferCount),
    	}
    }
    
    // IsOnline always true in case of console logger
    func (sys *HTTPConsoleLoggerSys) IsOnline(_ context.Context) bool {
    	return true
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. internal/config/lambda/parse.go

    	"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 ...interface{}) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cluster-health.go

    		"Count of all drives in the cluster")
    )
    
    // loadClusterHealthDriveMetrics - `MetricsLoaderFn` for cluster storage drive metrics
    // such as online, offline and total drives.
    func loadClusterHealthDriveMetrics(ctx context.Context, m MetricValues,
    	c *metricsCache,
    ) error {
    	clusterDriveMetrics, _ := c.clusterDriveMetrics.Get()
    
    	m.Set(healthDrivesOfflineCount, float64(clusterDriveMetrics.offlineDrives))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    	healingMetricBucket healingMetric = iota
    	healingMetricObject
    	healingMetricCheckAbandonedParts
    )
    
    func (er erasureObjects) listAndHeal(ctx context.Context, bucket, prefix string, scanMode madmin.HealScanMode, healEntry func(string, metaCacheEntry, madmin.HealScanMode) error) error {
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	disks, _ := er.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  8. internal/config/identity/plugin/config.go

    		o.args.RoleARN: o.args.RolePolicy,
    	}
    }
    
    // checkConnectivity returns true if we are able to connect to the plugin
    // service.
    func (o *AuthNPlugin) checkConnectivity(ctx context.Context) bool {
    	ctx, cancel := context.WithTimeout(ctx, healthCheckTimeout)
    	defer cancel()
    	u := url.URL(*o.args.URL)
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodHead, u.String(), nil)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/informers_test.go

    	"istio.io/istio/pkg/monitoring/monitortest"
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestExistingPodAddedWhenNsLabeled(t *testing.T) {
    	setupLogging()
    	NodeName = "testnode"
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  10. cmd/peer-rest-server.go

    	go func() {
    		err := globalTierConfigMgr.Reload(context.Background(), newObjectLayerFn())
    		if err != nil {
    			peersLogIf(context.Background(), fmt.Errorf("Failed to reload remote tier config %s", err))
    		}
    	}()
    
    	return
    }
    
    // ConsoleLogHandler sends console logs of this node back to peer rest client
    func (s *peerRESTServer) ConsoleLogHandler(ctx context.Context, params *grid.MSS, out chan<- *grid.Bytes) *grid.RemoteErr {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top