Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 498 for handleMsg (0.75 seconds)

  1. src/main/java/jcifs/internal/fscc/FileFsFullSizeInformation.java

     * actual free allocation units, sectors per allocation unit, and bytes per sector.
     */
    public class FileFsFullSizeInformation implements AllocInfo, FileSystemInformation, Decodable {
    
        private long alloc; // Also handles SmbQueryFSSizeInfo
        private long free;
        private int sectPerAlloc;
        private int bytesPerSect;
    
        /**
         * Default constructor for decoding file system full size information.
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.1K bytes
    - Click Count (0)
  2. compat/maven-model-builder/src/main/java/org/apache/maven/model/normalization/ModelNormalizer.java

    package org.apache.maven.model.normalization;
    
    import org.apache.maven.model.Model;
    import org.apache.maven.model.building.ModelBuildingRequest;
    import org.apache.maven.model.building.ModelProblemCollector;
    
    /**
     * Handles normalization of a model. In this context, normalization is the process of producing a canonical
     * representation for models that physically look different but are semantically equivalent.
     *
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  3. cmd/bucket-policy.go

    	"time"
    
    	jsoniter "github.com/json-iterator/go"
    	miniogopolicy "github.com/minio/minio-go/v7/pkg/policy"
    	"github.com/minio/minio-go/v7/pkg/tags"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/handlers"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/policy"
    )
    
    // PolicySys - policy subsystem.
    type PolicySys struct{}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb/SmbTransportInternalTest.java

            assertEquals(domain, domCap.getValue());
            assertEquals(rn, rnCap.getValue());
        }
    
        // Edge case: test with empty name
        @Test
        @DisplayName("getDfsReferrals handles empty name via CIFSException")
        void getDfsReferrals_emptyName() throws Exception {
            String emptyName = "";
            doThrow(new jcifs.CIFSException("invalid dfs name")).when(transport)
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/app/web/admin/design/EditForm.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.admin.design;
    
    /**
     * Form class for editing design files in the admin interface.
     * This form handles the editing of template and design files used
     * for customizing the search interface appearance and layout.
     */
    public class EditForm {
    
        /**
         * Creates a new EditForm instance.
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 1.3K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/NotifyResponse.java

     */
    package jcifs.internal;
    
    import java.util.List;
    
    import jcifs.FileNotifyInformation;
    
    /**
     * Interface for SMB change notification response messages.
     * Handles responses from directory change notification requests, providing information
     * about file system changes such as file creation, deletion, or modification events.
     *
     * @author mbechler
     */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/web/login/LoginAction.java

                RenderDataUtil.register(data, "notification", fessConfig.getNotificationLogin());
                saveToken();
            });
        }
    
        /**
         * Handles user login with the provided credentials.
         *
         * @param form the login form containing username and password
         * @return the HTML response after login attempt
         */
        @Execute
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Jan 02 06:18:24 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnup/goals/AbstractUpgradeStrategy.java

     * // ... perform domtrip operations ...
     * // Document is automatically updated
     * </pre>
     */
    public abstract class AbstractUpgradeStrategy implements UpgradeStrategy {
    
        /**
         * Template method that handles common logging and error handling.
         * Subclasses implement the actual upgrade logic in doApply().
         */
        @Override
        public final UpgradeResult apply(UpgradeContext context, Map<Path, Document> pomMap) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  9. 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].
     */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jun 14 16:09:26 GMT 2025
    - 940 bytes
    - Click Count (0)
  10. 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)
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Nov 11 17:15:17 GMT 2024
    - 4.8K bytes
    - Click Count (0)
Back to Top