Search Options

Results per page
Sort
Preferred Languages
Advance

Results 491 - 500 of 2,090 for contexts (0.11 sec)

  1. src/main/java/jcifs/NetbiosAddress.java

    public interface NetbiosAddress extends Address {
    
        /**
         * Determines if the address is a group address. This is also
         * known as a workgroup name or group name.
         * 
         * @param tc
         *            context to use
         * @return whether the given address is a group address
         *
         * @throws UnknownHostException
         *             if the host cannot be resolved to find out.
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 6K bytes
    - Viewed (0)
  2. cmd/local-locker_test.go

    package cmd
    
    import (
    	"context"
    	"encoding/hex"
    	"fmt"
    	"math/rand"
    	"testing"
    	"time"
    
    	"github.com/google/uuid"
    	"github.com/minio/minio/internal/dsync"
    )
    
    func TestLocalLockerExpire(t *testing.T) {
    	wResources := make([]string, 1000)
    	rResources := make([]string, 1000)
    	quorum := 0
    	l := newLocker()
    	ctx := context.Background()
    	for i := range wResources {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  3. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableList.java

          checkNotNull(builder);
          contents.addAll(builder.contents);
          return this;
        }
    
        @Override
        public ImmutableList<E> build() {
          return copyOf(contents);
        }
    
        ImmutableList<E> buildSorted(Comparator<? super E> comparator) {
          Collections.sort(contents, comparator);
          return copyOf(contents);
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 22:14:46 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Diag.java

            super(messageBuilderFactory, secDispatcher);
        }
    
        @Override
        protected int doExecute(DefaultEncryptInvoker.LocalContext context) {
            dumpResponse(context, "", secDispatcher.validateConfiguration());
            return OK;
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  7. docs/extensions/fan-out/README.md

    Fan-Out uploads are automatically enabled if `x-minio-fanout-list` form-field is provided with the PostUpload API, to keep things simple higher level APIs are provided in our SDKs for example in `minio-go` SDK:
    
    ```
    PutObjectFanOut(ctx context.Context, bucket string, fanOutContent io.Reader, fanOutReq minio.PutObjectFanOutRequest) ([]minio.PutObjectFanOutResponse, error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 25 05:51:07 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  8. cmd/sftp-server.go

    	switch tag {
    	case xsftp.AcceptNetworkError:
    		sftpLogOnceIf(context.Background(), err, "accept-limit-sftp")
    	case xsftp.AcceptChannelError:
    		sftpLogOnceIf(context.Background(), err, "accept-channel-sftp")
    	case xsftp.SSHKeyExchangeError:
    		sftpLogOnceIf(context.Background(), err, "key-exchange-sftp")
    	default:
    		sftpLogOnceIf(context.Background(), err, "unknown-error-sftp")
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 20:00:29 UTC 2024
    - 16K bytes
    - Viewed (0)
  9. internal/rest/client.go

    	return
    }
    
    // ErrClientClosed returned when *Client is closed.
    var ErrClientClosed = errors.New("rest client is closed")
    
    // CallWithHTTPMethod - make a REST call with context, using a custom HTTP method.
    func (c *Client) CallWithHTTPMethod(ctx context.Context, httpMethod, rpcMethod string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) {
    	switch atomic.LoadInt32(&c.connected) {
    	case closed:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  10. scripts/deploy_docs_status.py

                description="No Docs Changes",
                context="deploy-docs",
                target_url=run_url,
            )
            logging.info("No docs changes found")
            return
        if not settings.deploy_url:
            current_commit.create_status(
                state="pending",
                description="Deploying Docs",
                context="deploy-docs",
                target_url=run_url,
            )
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Aug 09 15:52:41 UTC 2024
    - 3.1K bytes
    - Viewed (0)
Back to top