Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 288 for synchronized (0.07 sec)

  1. src/main/java/jcifs/smb/SmbPipeOutputStream.java

        @Override
        public boolean isOpen () {
            return this.handle.isOpen();
        }
    
    
        @Override
        protected synchronized SmbTreeHandleImpl ensureTreeConnected () throws CIFSException {
            return this.handle.ensureTreeConnected();
        }
    
    
        @Override
        protected synchronized SmbFileHandleImpl ensureOpen () throws CIFSException {
            return this.handle.ensureOpen();
        }
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.9K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/DfsImpl.java

         *
         * @see jcifs.DfsResolver#isTrustedDomain(jcifs.CIFSContext, java.lang.String)
         */
        @Override
        public boolean isTrustedDomain ( CIFSContext tf, String domain ) throws SmbAuthException {
            synchronized ( this.domainsLock ) {
                Map<String, Map<String, CacheEntry<DfsReferralDataInternal>>> domains = getTrustedDomains(tf);
                if ( domains == null )
                    return false;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:07:29 UTC 2023
    - 29.1K bytes
    - Viewed (0)
  3. samples/slack/src/main/java/okhttp3/slack/RtmSession.java

        webSocket = slackApi.rtm(rtmStartResponse.url, this);
      }
    
      // TODO(jwilson): can I read the response body? Do I have to?
      //                the body from slack is a 0-byte-buffer
      @Override public synchronized void onOpen(WebSocket webSocket, Response response) {
        System.out.println("onOpen: " + response);
      }
    
      // TOOD(jwilson): decode incoming messages and dispatch them somewhere.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Nov 19 20:16:58 UTC 2016
    - 2.4K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb1/smb1/NtlmAuthenticator.java

            sae = null;
        }
    
    /**
    Set the default <tt>NtlmAuthenticator</tt>. Once the default authenticator is set it cannot be changed. Calling this metho again will have no effect.
     */
    
        public synchronized static void setDefault( NtlmAuthenticator a ) {
            if( auth != null ) {
                return;
            }
            auth = a;
        }
    
        protected final String getRequestingURL() {
            return url;
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 2.8K bytes
    - Viewed (0)
  5. src/test/java/jcifs/tests/ConcurrencyTest.java

    
            public void waitForStart () throws InterruptedException {
                synchronized ( this.startedLock ) {
                    while ( !this.started ) {
                        this.startedLock.wait();
                    }
                }
            }
    
    
            public void shutdown () {
                this.shutdown = true;
                synchronized ( this.shutdownLock ) {
                    this.shutdownLock.notify();
                }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:40:50 UTC 2021
    - 17.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/smb1/SmbTree.java

                return matches(tree.share, tree.service);
            }
            return false;
        }
        void send( ServerMessageBlock request,
                                ServerMessageBlock response ) throws SmbException {
    synchronized (session.transport()) {
            if( response != null ) {
                response.received = false;
            }
            treeConnect( request, response );
            if( request == null || (response != null && response.received )) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 8K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/BufferCacheImpl.java

            this.bufferSize = maxSize;
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.BufferCache#getBuffer()
         */
        @Override
        public byte[] getBuffer () {
            synchronized ( this.cache ) {
                byte[] buf;
    
                if ( this.freeBuffers > 0 ) {
                    for ( int i = 0; i < this.cache.length; i++ ) {
                        if ( this.cache[ i ] != null ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jan 24 11:40:34 UTC 2021
    - 2.9K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/AsyncDns.kt

                  ) {
                    synchronized(allAddresses) {
                      allAddresses.addAll(addresses)
                    }
                    latch.countDown()
                  }
    
                  override fun onFailure(
                    hostname: String,
                    e: IOException,
                  ) {
                    synchronized(allExceptions) {
                      allExceptions.add(e)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbPipeInputStream.java

            super(handle.getPipe(), th, null);
            this.handle = handle;
        }
    
    
        protected synchronized SmbTreeHandleImpl ensureTreeConnected () throws CIFSException {
            return this.handle.ensureTreeConnected();
        }
    
    
        @Override
        protected synchronized SmbFileHandleImpl ensureOpen () throws CIFSException {
            return this.handle.ensureOpen();
        }
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 07:12:23 UTC 2018
    - 3.5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

            int max = NbtAddress.NBNS.length;
    
            if (max == 0)
                max = 1; /* No WINs, try only bcast addr */
    
            synchronized( response ) {
                while (max-- > 0) {
                    try {
                        synchronized( LOCK ) {
                            request.nameTrnId = getNextNameTrnId();
                            nid = new Integer( request.nameTrnId );
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 17.4K bytes
    - Viewed (0)
Back to top