Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 664 for balk (0.03 sec)

  1. internal/s3select/jstream/scanner.go

    		}
    	}
    
    	s.pos++
    	return s.buf[s.ipos]
    }
    
    // back undoes a previous call to next(), moving backward one byte in the internal buffer.
    // as we only guarantee a lookback buffer size of one, any subsequent calls to back()
    // before calling next() may panic
    func (s *scanner) back() {
    	if s.ipos <= 0 {
    		panic("back buffer exhausted")
    	}
    	s.ipos--
    	s.pos--
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/suggest/index/writer/SuggestIndexWriter.java

    import org.codelibs.fess.suggest.settings.SuggestSettings;
    import org.codelibs.fess.suggest.util.SuggestUtil;
    import org.opensearch.action.bulk.BulkItemResponse;
    import org.opensearch.action.bulk.BulkRequestBuilder;
    import org.opensearch.action.bulk.BulkResponse;
    import org.opensearch.action.get.GetResponse;
    import org.opensearch.action.index.IndexAction;
    import org.opensearch.action.index.IndexRequest;
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  3. internal/bpool/bpool.go

    	if cap(b) != bp.wcap {
    		// someone tried to put back buffer which is not part of this buffer pool
    		// we simply don't put this back into pool, a modified buffer provided
    		// by this package is no more usable, callers make sure to not modify
    		// the capacity of the buffer.
    		return
    	}
    
    	select {
    	case bp.c <- b[:bp.w]:
    		// buffer went back into pool
    	default:
    		// buffer didn't go back into pool, just discard
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. compat/maven-compat/src/test/java/org/apache/maven/project/artifact/MavenMetadataSourceTest.java

            assertEquals( Artifact.SCOPE_COMPILE, artifact.getScope(), "dependency artifact has wrong scope." );
    
            //check for back-propagation of default scope.
            assertEquals( Artifact.SCOPE_COMPILE, dep.getScope(), "default scope NOT back-propagated to dependency." );
            */
        }
    
        @Test
        @Disabled
        void testShouldUseInjectedTestScopeFromDependencyManagement() throws Exception {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. src/main/webapp/WEB-INF/view/common/admin/crud/buttons.jsp

    		<em class="fa fa-plus">
    		<la:message key="labels.crud_button_create" />
    	</button>
    	</c:if>
    </c:if>
    <c:if test="${crudMode == 2}">
    	<button type="submit" class="btn btn-default" name="edit" value="back">
    		<em class="fa fa-arrow-circle-left">
    		<la:message key="labels.crud_button_back" />
    	</button>
    	<c:if test="${editable}">
    	<button type="submit" class="btn btn-success" name="update"
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Feb 10 12:37:20 UTC 2020
    - 2.7K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/netns_linux.go

    		defer threadNS.Close()
    
    		// switch to target namespace
    		if err = NetnsSet(fdable); err != nil {
    			return err
    		}
    		defer func() {
    			err := threadNS.Set() // switch back
    			if err == nil {
    				// Unlock the current thread only when we successfully switched back
    				// to the original namespace; otherwise leave the thread locked which
    				// will force the runtime to scrap the current thread, that is maybe
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 31 10:05:36 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  7. src/archive/tar/writer.go

    			for _, s := range spd {
    				hdr.Size += s.Length
    			}
    			copy(blk.V7().Size(), zeroBlock[:]) // Reset field
    			f.formatNumeric(blk.V7().Size(), hdr.Size)
    			f.formatNumeric(blk.GNU().RealSize(), realSize)
    		}
    	*/
    	blk.setFormat(FormatGNU)
    	if err := tw.writeRawHeader(blk, hdr.Size, hdr.Typeflag); err != nil {
    		return err
    	}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/ThemeHelper.java

                if (logger.isDebugEnabled()) {
                    logger.debug("{} does not exists.", dir);
                }
                return;
            }
            try (Stream<Path> walk = Files.walk(dir, FileVisitOption.FOLLOW_LINKS)) {
                walk.sorted(Comparator.reverseOrder()).forEach(f -> {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Deleting {}", f);
                    }
                    try {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

            return client.prepareDelete(index, id);
        }
    
        @Override
        public ActionFuture<BulkResponse> bulk(final BulkRequest request) {
            return client.bulk(request);
        }
    
        @Override
        public void bulk(final BulkRequest request, final ActionListener<BulkResponse> listener) {
            client.bulk(request, listener);
        }
    
        @Override
        public BulkRequestBuilder prepareBulk() {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/api/admin/documents/ApiAdminDocumentsAction.java

        // ===================================================================================
        // Search Execute
        //
    
        // POST /api/admin/documents/bulk
        @Execute
        public JsonResponse<ApiResult> post$bulk(final BulkBody body) {
            validateApi(body, messages -> {});
            if (body.documents == null) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Jul 25 01:48:41 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top