Search Options

Results per page
Sort
Preferred Languages
Advance

Results 421 - 430 of 597 for serving (0.06 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

          throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this")
        }
      }
    
      val logger = Logger.getLogger("TaskFaker." + instance++)
    
      /** Though this executor service may hold many threads, they are not executed concurrently. */
      private val tasksExecutor = Executors.newCachedThreadPool(threadFactory("TaskFaker"))
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/NtStatus.java

            "The process cannot access the file because it is being used by another process.", "Access is denied.",
            "There are currently no logon servers available to service the logon request.", "The specified user already exists.",
            "The specified user does not exist.", "The specified network password is not correct.", "Logon failure: unknown user name or bad password.",
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Jun 01 10:09:29 UTC 2019
    - 11.9K bytes
    - Viewed (0)
  3. internal/s3select/sql/statement.go

    	// (otherwise -1)
    	limitValue int64
    
    	// Count of rows that have been output.
    	outputCount int64
    
    	// Table alias
    	tableAlias string
    }
    
    // ParseSelectStatement - parses a select query from the given string
    // and analyzes it.
    func ParseSelectStatement(s string) (stmt SelectStatement, err error) {
    	var selectAST Select
    	err = SQLParser.ParseString(s, &selectAST)
    	if err != nil {
    		err = errQueryParseFailure(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/ImmutableMap.java

       *
       * <p>If the mapped keys contain duplicates (according to {@link Object#equals(Object)}), the
       * values are merged using the specified merging function. If the merging function returns {@code
       * null}, then the collector removes the value that has been computed for the key thus far (though
       * future occurrences of the key would reinsert it).
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 44.6K bytes
    - Viewed (0)
  5. cmd/sts-handlers_test.go

    				suite.TearDownSuite(c)
    			},
    		)
    	}
    }
    
    type iamTestContent struct {
    	policies                map[string][]byte
    	ldapUserPolicyMappings  map[string][]string
    	ldapGroupPolicyMappings map[string][]string
    }
    
    func (s *TestSuiteIAM) TestIAMExport(c *check, caseNum int, content iamTestContent) []byte {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.25.md

        - [Support for cgroups v2 Graduates to Stable](#support-for-cgroups-v2-graduates-to-stable)
        - [Windows support improved](#windows-support-improved)
        - [Moved container registry service from k8s.gcr.io to registry.k8s.io](#moved-container-registry-service-from-k8sgcrio-to-registryk8sio)
        - [Promoted SeccompDefault to Beta](#promoted-seccompdefault-to-beta)
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Mon May 06 09:23:20 UTC 2024
    - 419.1K bytes
    - Viewed (0)
  7. internal/s3select/simdj/reader.go

    		readCloser.Close()
    		for range r.input {
    			// Read until EOF trickles through.
    			// Otherwise, we risk the decoder hanging.
    		}
    		r.readerWg.Done()
    	}
    
    	// We cannot reuse as we are sending parsed objects elsewhere.
    	simdjson.ParseNDStream(readCloser, r.input, nil)
    	r.readerWg.Add(1)
    	go r.startReader()
    	return &r
    }
    
    // NewElementReader - creates new JSON reader using readCloser.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  8. internal/event/targetlist_test.go

    	if target.closeErr {
    		return errors.New("close error")
    	}
    
    	return nil
    }
    
    func (target ExampleTarget) IsActive() (bool, error) {
    	return false, errors.New("not connected to target server/service")
    }
    
    // FlushQueueStore - No-Op. Added for interface compatibility
    func (target ExampleTarget) FlushQueueStore() error {
    	return nil
    }
    
    func TestTargetListAdd(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java

            }
        }
    
        protected FailureUrl storeFailureUrl(final CrawlerContext crawlerContext, final UrlQueue<?> urlQueue, final String errorName,
                final Throwable e) {
    
            final CrawlingConfig crawlingConfig = getCrawlingConfig(crawlerContext.getSessionId());
            final String url = urlQueue.getUrl();
    
            final FailureUrlService failureUrlService = ComponentUtil.getComponent(FailureUrlService.class);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/service/BadWordService.java

                logger.warn("Failed to write a sugget bad word.", e);
            }
        }
    
        private static String getValue(final List<String> list, final int index) {
            if (index >= list.size()) {
                return StringUtil.EMPTY;
            }
            String item = list.get(index).trim();
            if (StringUtil.isBlank(item)) {
                return StringUtil.EMPTY;
            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top