Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 561 for resp (0.02 sec)

  1. src/main/java/jcifs/smb1/smb1/SmbSession.java

                tree.treeConnect( null, null );
            } else {
                Trans2FindFirst2 req = new Trans2FindFirst2( "\\", "*", SmbFile.ATTR_DIRECTORY );
                Trans2FindFirst2Response resp = new Trans2FindFirst2Response();
                tree.send( req, resp );
            }
        }
    
        /* 0 - not connected
         * 1 - connecting
         * 2 - connected
         * 3 - disconnecting
         */
        int connectionState;
        int uid;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 18.6K bytes
    - Viewed (0)
  2. istioctl/pkg/proxyconfig/proxyconfig.go

    					}
    				}
    			}
    
    			var resp string
    			var errs *multierror.Error
    			for _, podName := range podNames {
    				if len(destLoggerLevels) == 0 {
    					resp, err = setupEnvoyLogConfig(kubeClient, "", podName, podNamespace)
    				} else {
    					if ll, ok := destLoggerLevels[defaultLoggerName]; ok {
    						// update levels of all loggers first
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbCopyUtil.java

                throw sae;
            }
        }
    
    
        /**
         * @param dest
         * @param b
         * @param bsize
         * @param w
         * @param dh
         * @param sh
         * @param req
         * @param resp
         * @throws SmbException
         */
        static void copyFile ( SmbFile src, SmbFile dest, byte[][] b, int bsize, WriterThread w, SmbTreeHandleImpl sh, SmbTreeHandleImpl dh )
                throws SmbException {
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:52:42 UTC 2020
    - 17.1K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbFileInputStream.java

                            request.setRemainingBytes(len - r);
    
                            try {
                                Smb2ReadResponse resp = th.send(request, RequestParam.NO_RETRY);
                                n = resp.getDataLength();
                            }
                            catch ( SmbException e ) {
                                if ( e.getNtStatus() == 0xC0000011 ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 08:55:14 UTC 2020
    - 13.2K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    // The resp channel is closed before the call returns.
    // Only a canceled context will return an error.
    func (p *xlStorageDiskIDCheck) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadMultiple, req.Bucket, req.Prefix)
    	if err != nil {
    		xioutil.SafeClose(resp)
    		return err
    	}
    	defer done(0, &err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  6. istioctl/pkg/proxyconfig/proxyconfig_test.go

    		tf := cmdtesting.NewTestFactory()
    		_, _, codec := cmdtesting.NewExternalScheme()
    		tf.UnstructuredClient = &fake.RESTClient{
    			NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer,
    			Resp: &http.Response{
    				StatusCode: http.StatusOK,
    				Header:     cmdtesting.DefaultHeader(),
    				Body: cmdtesting.ObjBody(codec,
    					cmdtesting.NewInternalType("", "", "foo")),
    			},
    		}
    		return tf
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Apr 10 21:51:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  7. cmd/metacache-server-pool.go

    		// Create or ping with handout...
    		rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix))
    		var c *metacache
    		if rpc == nil {
    			resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o)
    			c = &resp
    		} else {
    			rctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			c, err = rpc.GetMetacacheListing(rctx, *o)
    			cancel()
    		}
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  8. cmd/storage-interface.go

    	ReadParts(ctx context.Context, bucket string, partMetaPaths ...string) ([]*ObjectPartInfo, error)
    	ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) error
    	CleanAbandonedData(ctx context.Context, volume string, path string) error
    
    	// Write all data, syncs the data to disk.
    	// Should be used for smaller payloads.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. src/main/java/jcifs/util/transport/Transport.java

                        Iterator<Entry<Long, Response>> iterator = this.response_map.entrySet().iterator();
                        while ( iterator.hasNext() ) {
                            Response resp = iterator.next().getValue();
                            resp.exception(ex);
                            iterator.remove();
                            notified = true;
    
                        }
                        if ( notified ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  10. internal/grid/muxserver.go

    	"fmt"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    type muxServer struct {
    	ID                 uint64
    	LastPing           int64
    	SendSeq, RecvSeq   uint32
    	Resp               chan []byte
    	BaseFlags          Flags
    	ctx                context.Context
    	cancel             context.CancelFunc
    	inbound            chan []byte
    	parent             *Connection
    	sendMu             sync.Mutex
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top