Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 144 for Pipe (0.02 sec)

  1. docs/bucket/replication/test_del_marker_proxying.sh

    # Run the test to make sure proxying of DEL marker doesn't happen
    loop_count=0
    while true; do
    	if [ $loop_count -eq 1000 ]; then
    		break
    	fi
    	echo "Hello World" | ./mc pipe sitea/bucket/obj$loop_count
    	./mc rm sitea/bucket/obj$loop_count
    	RESULT=$({ ./mc stat --no-list sitea/bucket/obj$loop_count; } 2>&1)
    	if [[ ${RESULT} != *"Object does not exist"* ]]; then
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/smb1/trans/TransTransactNamedPipeResponseTest.java

            assertEquals(0, result);
        }
    
        @Test
        void testReadDataWireFormatSuccess() throws SMBProtocolDecodingException {
            // Test successful data read
            byte[] testData = "Test data for named pipe".getBytes();
            byte[] buffer = new byte[100];
            System.arraycopy(testData, 0, buffer, 10, testData.length);
    
            int result = response.readDataWireFormat(buffer, 10, testData.length);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  3. src/main/java/jcifs/dcerpc/DcerpcBinding.java

            if (key.equals("endpoint")) {
                this.endpoint = val.toString();
                final String lep = this.endpoint.toLowerCase(Locale.ENGLISH);
                if (lep.startsWith("\\pipe\\")) {
                    final String iface = INTERFACES.get(lep.substring(6));
                    if (iface != null) {
                        int c, p;
                        c = iface.indexOf(':');
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 5K bytes
    - Viewed (0)
  4. buildscripts/verify-healing.sh

    			chmod +x /tmp/mc
    	fi
    }
    
    function upload_objects() {
    	/tmp/mc mb myminio/testbucket/
    	for ((i = 0; i < 20; i++)); do
    		echo "my content" | /tmp/mc pipe myminio/testbucket/file-$i
    	done
    }
    
    function perform_test() {
    	start_port=$2
    
    	start_minio_3_node $start_port
    
    	echo "Testing Distributed Erasure setup healing of drives"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/SmbEnumerationUtil.java

                    ctx);
        }
    
        static FileEntry[] doDfsRootEnum(final CIFSContext ctx, final SmbResourceLocator loc, final Address address) throws IOException {
            try (DcerpcHandle handle = getHandle(ctx, loc, address, "\\PIPE\\netdfs")) {
                final MsrpcDfsRootEnum rpc = new MsrpcDfsRootEnum(loc.getServer());
                handle.sendrecv(rpc);
                if (rpc.retval != 0) {
                    throw new SmbException(rpc.retval, true);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/smb1/SmbShareInfo.java

     */
    public class SmbShareInfo implements FileEntry {
    
        /**
         * The network name of the share.
         */
        protected String netName;
        /**
         * The type of the share (e.g., disk, printer, named pipe).
         */
        protected int type;
        /**
         * A descriptive comment or remark about the share.
         */
        protected String remark;
    
        /**
         * Default constructor for SMB share information.
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/dcerpc/DcerpcBinding.java

            if (key.equals("endpoint")) {
                endpoint = val.toString();
                final String lep = endpoint.toLowerCase();
                if (lep.startsWith("\\pipe\\")) {
                    final String iface = (String) INTERFACES.get(lep.substring(6));
                    if (iface != null) {
                        int c, p;
                        c = iface.indexOf(':');
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/NetServerEnum2.java

            this.domain = domain;
            this.serverTypes = serverTypes;
            command = SMB_COM_TRANSACTION;
            subCommand = NET_SERVER_ENUM2; // not really true be used by upper logic
            name = "\\PIPE\\LANMAN";
    
            maxParameterCount = 8;
            maxDataCount = 16384;
            maxSetupCount = (byte) 0x00;
            setupCount = 0;
            timeout = 5000;
        }
    
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbFileInputStream.java

        /**
         * This stream class is unbuffered. Therefore this method will always
         * return 0 for streams connected to regular files. However, a
         * stream created from a Named Pipe this method will query the server using a
         * "peek named pipe" operation and return the number of available bytes
         * on the server.
         */
        @Override
        public int available() throws IOException {
            return 0;
        }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  10. src/main/java/jcifs/dcerpc/DcerpcHandle.java

         * or
         * proto:[key1=val1,key2=val2]
         *
         * If a key is absent it is assumed to be 'endpoint'. Thus the
         * following are equivalent:
         * proto:\\ts0.win.net[endpoint=\pipe\srvsvc]
         * proto:ts0.win.net[\pipe\srvsvc]
         *
         * If the server is absent it is set to "127.0.0.1"
         */
        /**
         * Parses a DCERPC binding string into a DcerpcBinding object
         * @param str the binding string to parse
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 15.9K bytes
    - Viewed (0)
Back to top