Search Options

Results per page
Sort
Preferred Languages
Advance

Results 461 - 470 of 576 for delegates (0.06 sec)

  1. src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java

            }
            return asJson(new ApiResult.ApiUpdateResponse().id(entity.getId()).created(false).status(ApiResult.Status.OK).result());
        }
    
        /**
         * Deletes a scheduler setting by ID.
         *
         * @param id the ID of the scheduler setting to delete
         * @return JSON response indicating success or failure
         */
        // DELETE /api/admin/scheduler/setting/{id}
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 10K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/io/FileUtil.java

                ChannelUtil.write(fos.getChannel(), ByteBuffer.wrap(bytes));
            } catch (final IOException e) {
                throw new IORuntimeException(e);
            }
        }
    
        /**
         * Deletes the specified file in a background thread.
         *
         * @param file
         *            The file to delete.
         */
        public static void deleteInBackground(final File file) {
            if (file != null) {
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  3. cmd/bucket-replication-stats.go

    	if r == nil {
    		return
    	}
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-r.qTimer.C:
    			r.qCache.update()
    		}
    	}
    }
    
    // Delete deletes in-memory replication statistics for a bucket.
    func (r *ReplicationStats) Delete(bucket string) {
    	if r == nil {
    		return
    	}
    
    	r.Lock()
    	defer r.Unlock()
    	delete(r.Cache, bucket)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

                maxPurgeSize = fessConfig.getPageThumbnailPurgeMaxFetchSizeAsInteger();
                searchEngineClient = ComponentUtil.getSearchEngineClient();
            }
    
            /**
             * Deletes files marked for deletion after checking if they exist in the search index.
             */
            protected void deleteFiles() {
                final Map<String, Path> deleteFileMap = new HashMap<>();
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 26.9K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/api/admin/fileconfig/ApiAdminFileconfigAction.java

            });
            return asJson(new ApiUpdateResponse().id(fileConfig.getId()).created(false).status(Status.OK).result());
        }
    
        // DELETE /api/admin/fileconfig/setting/{id}
        /**
         * Deletes a specific file configuration setting.
         *
         * @param id the file configuration setting ID to delete
         * @return JSON response with deletion status
         */
        @Execute
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  6. cmd/metacache-bucket.go

    	for k, v := range b.cachesRoot {
    		tmp := make([]string, len(v))
    		copy(tmp, v)
    		dst2[k] = tmp
    	}
    
    	return dst, dst2
    }
    
    // deleteAll will delete all on disk data for ALL caches.
    // Deletes are performed concurrently.
    func (b *bucketMetacache) deleteAll() {
    	ctx := context.Background()
    
    	objAPI := newObjectLayerFn()
    	if objAPI == nil {
    		return
    	}
    
    	ez, ok := objAPI.(deleteAllStorager)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java

        public synchronized void update(final CharMappingItem item) {
            try (MappingUpdater updater = new MappingUpdater(item)) {
                reload(updater);
            }
        }
    
        /**
         * Deletes a character mapping item from the dictionary file.
         *
         * @param item the character mapping item to delete
         */
        @Override
        public synchronized void delete(final CharMappingItem item) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  8. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

         */
        @Override
        public int getCount(final String sessionId) {
            return getCount(builder -> builder.setQuery(QueryBuilders.termQuery(SESSION_ID, sessionId)));
        }
    
        /**
         * Deletes all access results for a specific session.
         *
         * @param sessionId The session ID.
         */
        @Override
        public void delete(final String sessionId) {
            deleteBySessionId(sessionId);
        }
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/web/api/admin/dict/stopwords/ApiAdminDictStopwordsAction.java

            return asJson(
                    new ApiResult.ApiUpdateResponse().id(String.valueOf(entity.getId())).created(false).status(ApiResult.Status.OK).result());
        }
    
        /**
         * Deletes a stopwords dictionary item by ID.
         *
         * @param dictId the dictionary ID
         * @param id the ID of the stopwords item to delete
         * @return JSON response indicating the deletion status
         */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

        stream: Http2Stream? = null,
      ): Sink {
        var result: Sink = this
    
        if (policy.throttlePeriodNanos > 0L) {
          result =
            ThrottledSink(
              socket = socket,
              delegate = result,
              bytesPerPeriod = policy.throttleBytesPerPeriod,
              periodDelayNanos = policy.throttlePeriodNanos,
            )
        }
    
        if (socketEffect != null) {
          val halfwayByteCount =
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 40.3K bytes
    - Viewed (0)
Back to top