Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 458 for handleMsg (0.04 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/storage/ItemForm.java

    import org.lastaflute.web.ruts.multipart.MultipartFormFile;
    
    import jakarta.validation.constraints.Size;
    
    /**
     * Form class for storage item operations in the admin interface.
     * This form handles file upload and management operations for storage items.
     */
    public class ItemForm {
    
        /** The path of the storage item */
        public String path;
    
        /**
         * Default constructor.
         */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  2. cmd/utils.go

    		RequestID:    reqID,
    		RemoteHost:   handlers.GetSourceIP(r),
    		Host:         getHostName(r),
    		UserAgent:    r.UserAgent(),
    		API:          api,
    		BucketName:   bucket,
    		ObjectName:   object,
    		VersionID:    strings.TrimSpace(r.Form.Get(xhttp.VersionID)),
    	}
    
    	return logger.SetReqInfo(r.Context(), reqInfo)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 33K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/builder/RequestDataBuilder.java

     *     .method("GET")
     *     .url("https://example.com")
     *     .weight(1.0f)
     *     .build();
     * </pre>
     *
     * <p>The builder is implemented using an inner class {@link RequestDataContext} that handles
     * the actual construction of the RequestData object.</p>
     *
     */
    public final class RequestDataBuilder {
        private RequestDataBuilder() {
        }
    
        /**
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  4. internal/deadlineconn/deadlineconn_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package deadlineconn
    
    import (
    	"bufio"
    	"fmt"
    	"io"
    	"net"
    	"sync"
    	"testing"
    	"time"
    )
    
    // Test deadlineconn handles read timeout properly by reading two messages beyond deadline.
    func TestBuffConnReadTimeout(t *testing.T) {
    	l, err := net.Listen("tcp", "localhost:0")
    	if err != nil {
    		t.Fatalf("unable to create listener. %v", err)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Nov 11 17:15:17 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  5. compat/maven-model-builder/src/main/java/org/apache/maven/model/plugin/LifecycleBindingsInjector.java

     */
    package org.apache.maven.model.plugin;
    
    import org.apache.maven.model.Model;
    import org.apache.maven.model.building.ModelBuildingRequest;
    import org.apache.maven.model.building.ModelProblemCollector;
    
    /**
     * Handles injection of plugin executions induced by the lifecycle bindings for a packaging.
     *
     * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead
     */
    @Deprecated(since = "4.0.0")
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Feb 25 08:27:34 UTC 2025
    - 2K bytes
    - Viewed (0)
  6. compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/ProfileInjector.java

    import org.apache.maven.model.Model;
    import org.apache.maven.model.Profile;
    import org.apache.maven.model.building.ModelBuildingRequest;
    import org.apache.maven.model.building.ModelProblemCollector;
    
    /**
     * Handles profile injection into the model.
     *
     * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead
     */
    @Deprecated(since = "4.0.0")
    public interface ProfileInjector {
    
        /**
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Feb 25 08:27:34 UTC 2025
    - 2K bytes
    - Viewed (0)
  7. cmd/sftp-server-driver.go

    		globalTrace.Publish(sftpTrace(s, startTime, source, user, err, sz))
    	}
    }
    
    // NewSFTPDriver initializes sftp.Handlers implementation of following interfaces
    //
    // - sftp.Fileread
    // - sftp.Filewrite
    // - sftp.Filelist
    // - sftp.Filecmd
    func NewSFTPDriver(perms *ssh.Permissions, remoteIP string) sftp.Handlers {
    	handler := &sftpDriver{
    		endpoint:    fmt.Sprintf("127.0.0.1:%s", globalMinioPort),
    		permissions: perms,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 10 16:35:49 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  8. impl/maven-core/src/test/java/org/apache/maven/artifact/handler/ArtifactHandlerTest.java

        @Inject
        PlexusContainer container;
    
        @Test
        @SuppressWarnings("checkstyle:UnusedLocalVariable")
        void testAptConsistency() throws Exception {
            File apt = getTestFile("src/site/apt/artifact-handlers.apt");
    
            List<String> lines = Files.readAllLines(apt.toPath());
    
            for (String line : lines) {
                if (line.startsWith("||")) {
                    String[] cols = line.split("\\|\\|");
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jul 23 17:27:08 UTC 2025
    - 4K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/artifact/handler/DefaultArtifactHandler.java

        private boolean includesDependencies;
    
        private String language;
    
        @Deprecated
        private boolean addedToClasspath;
    
        /**
         * Default ctor for Plexus compatibility, as many plugins have artifact handlers declared in legacy Plexus XML.
         * Do not use directly!
         *
         * @deprecated This ctor is present only for Plexus XML defined component compatibility, do not use it.
         */
        @Deprecated
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/SocketHandler.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package mockwebserver3
    
    import okio.Socket
    
    /**
     * Handles a call's request and response streams directly. Use this instead of [MockResponseBody] to
     * begin sending response data before all request data has been received.
     *
     * See [okhttp3.RequestBody.isDuplex].
     */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Jun 14 16:09:26 UTC 2025
    - 940 bytes
    - Viewed (0)
Back to top