Search Options

Results per page
Sort
Preferred Languages
Advance

Results 491 - 500 of 1,332 for delegate (0.06 sec)

  1. lib/wasm/wasm_exec.js

    					"runtime.wasmExit": (sp) => {
    						sp >>>= 0;
    						const code = this.mem.getInt32(sp + 8, true);
    						this.exited = true;
    						delete this._inst;
    						delete this._values;
    						delete this._goRefCounts;
    						delete this._ids;
    						delete this._idPool;
    						this.exit(code);
    					},
    
    					// func wasmWrite(fd uintptr, p unsafe.Pointer, n int32)
    					"runtime.wasmWrite": (sp) => {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Aug 30 19:15:21 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  2. internal/bucket/bandwidth/monitor.go

    func (m *Monitor) DeleteBucket(bucket string) {
    	m.tlock.Lock()
    	for opts := range m.bucketsThrottle {
    		if opts.Name == bucket {
    			delete(m.bucketsThrottle, opts)
    		}
    	}
    	m.tlock.Unlock()
    
    	m.mlock.Lock()
    	for opts := range m.bucketsMeasurement {
    		if opts.Name == bucket {
    			delete(m.bucketsMeasurement, opts)
    		}
    	}
    	m.mlock.Unlock()
    }
    
    // DeleteBucketThrottle deletes monitoring for a bucket's target
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. api/maven-api-core/src/main/java/org/apache/maven/api/services/ModelProblemCollector.java

     * an expressive source hint for the model problem. Instead, the source hint is configured by the model builder before
     * it delegates to other components that potentially encounter problems. Then, the problem reporter can focus on
     * providing a simple error message, leaving the donkey work of creating a nice model problem to this component.
     *
     */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Sat Sep 28 09:03:24 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/service/FailureUrlService.java

            failureUrlBhv.insertOrUpdate(failureUrl, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
    
        }
    
        public void delete(final FailureUrl failureUrl) {
    
            failureUrlBhv.delete(failureUrl, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
    
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jun 24 01:20:42 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/ExtractorBuilder.java

            } finally {
                if (dfos != null && !dfos.isInMemory()) {
                    final File file = dfos.getFile();
                    if (!file.delete()) {
                        logger.warn("Failed to delete {}.", file.getAbsolutePath());
                    }
                }
            }
    
        }
    
        protected String getMimeType(final DeferredFileOutputStream out) throws IOException {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:40:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/DataServiceImpl.java

            return dataHelper.getAccessResultMap(sessionId).size();
        }
    
        /*
         * (non-Javadoc)
         *
         * @see org.codelibs.fess.crawler.service.DataService#delete(java.lang.String)
         */
        @Override
        public void delete(final String sessionId) {
            dataHelper.deleteAccessResultMap(sessionId);
        }
    
        /*
         * (non-Javadoc)
         *
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    							continue
    						}
    						// Bucket not found proceed to delete such a job.
    					}
    				} else {
    					if err := job.Replicate.Start(job.ctx, j.objLayer, *job); err != nil {
    						if !isErrBucketNotFound(err) {
    							batchLogIf(j.ctx, err)
    							j.canceler(job.ID, false)
    							continue
    						}
    						// Bucket not found proceed to delete such a job.
    					}
    				}
    			case job.KeyRotate != nil:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt

      }
      delete(file)
      return false
    }
    
    /** Delete file we expect but don't require to exist. */
    internal fun FileSystem.deleteIfExists(path: Path) {
      try {
        delete(path)
      } catch (fnfe: FileNotFoundException) {
        return
      }
    }
    
    /** Tolerant delete, try to clear as many files as possible even after a failure. */
    internal fun FileSystem.deleteContents(directory: Path) {
      var exception: IOException? = null
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 11K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/web/api/admin/searchlist/ApiAdminSearchlistAction.java

            return asJson(
                    new ApiUpdateResponse().id(doc.get(fessConfig.getIndexFieldDocId()).toString()).created(false).status(Status.OK).result());
        }
    
        // DELETE /api/admin/searchlist/doc/{doc_id}
        @Execute
        public JsonResponse<ApiResult> delete$doc(final String id) {
            try {
                final QueryBuilder query = QueryBuilders.termQuery(fessConfig.getIndexFieldDocId(), id);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Wed Jul 24 09:03:45 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  10. prepare_stmt.go

    	// 3. g1 tx exec insert, wait for unlock `conn.PrepareContext(ctx, query)` to finish tx and release.
    	stmt, err := conn.PrepareContext(ctx, query)
    	if err != nil {
    		cacheStmt.prepareErr = err
    		db.Mux.Lock()
    		delete(db.Stmts, query)
    		db.Mux.Unlock()
    		return Stmt{}, err
    	}
    
    	db.Mux.Lock()
    	cacheStmt.Stmt = stmt
    	db.Mux.Unlock()
    
    	return cacheStmt, nil
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top