Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for notifyAll (0.11 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

    @Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN", "NOTHING_TO_INLINE")
    internal inline fun Any.notify() = (this as Object).notify()
    
    @Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN", "NOTHING_TO_INLINE")
    internal inline fun Any.notifyAll() = (this as Object).notifyAll()
    
    internal fun <T> readFieldOrNull(
      instance: Any,
      fieldType: Class<T>,
      fieldName: String,
    ): T? {
      var c: Class<*> = instance.javaClass
      while (c != Any::class.java) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbSession.java

                } while (state != 0);
            } catch (SmbException se) {
                logoff(true);
                connectionState = 0;
                throw se;
            } finally {
                transport.notifyAll();
            }
    }
        }
        void logoff( boolean inError ) {
    synchronized (transport()) {
    
            if (connectionState != 2) // not-connected
                return;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 18.6K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

     * limitations under the License.
     */
    package okhttp3.internal.cache2
    
    import java.io.File
    import java.io.IOException
    import java.io.RandomAccessFile
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.notifyAll
    import okio.Buffer
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    import okio.Source
    import okio.Timeout
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbTreeImpl.java

                        finally {
                            this.connectionState.set(0);
                        }
                        throw se;
                    }
                    finally {
                        transport.notifyAll();
                    }
                }
            }
        }
    
    
        /**
         * @param transport
         * @param sess
         * @param response
         * @throws IOException
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:06:39 UTC 2023
    - 29.6K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb1/ServerMessageBlock.java

            synchronized ( this ) {
                notifyAll();
            }
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.util.transport.Response#exception(java.lang.Exception)
         */
        @Override
        public void exception ( Exception e ) {
            this.exception = e;
            synchronized ( this ) {
                notifyAll();
            }
        }
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 09:45:59 UTC 2018
    - 32.7K bytes
    - Viewed (0)
  6. src/main/java/jcifs/netbios/NameServiceClientImpl.java

            return obj;
        }
    
    
        private void updateLookupTable ( Name name ) {
            synchronized ( this.inFlightLookups ) {
                this.inFlightLookups.remove(name);
                this.inFlightLookups.notifyAll();
            }
        }
    
    
        void cacheAddress ( Name hostName, NbtAddress addr ) {
            if ( this.transportContext.getConfig().getNetbiosCachePolicy() == 0 ) {
                return;
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 14 14:26:22 UTC 2022
    - 38.2K bytes
    - Viewed (0)
  7. src/main/java/jcifs/util/transport/Transport.java

                                for ( Response response : this.response_map.values() ) {
                                    synchronized ( response ) {
                                        response.notifyAll();
                                    }
                                }
                                continue;
                            }
    
                            if ( log.isDebugEnabled() ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/netbios/NbtAddress.java

            }
    
            return obj;
        }
        private static void updateLookupTable( Name name ) {
            synchronized( LOOKUP_TABLE ) {
                LOOKUP_TABLE.remove( name );
                LOOKUP_TABLE.notifyAll();
            }
        }
    
    /** 
     * Retrieves the local host address.
     *
     * @throws UnknownHostException This is not likely as the IP returned
     *                    by <code>InetAddress</code> should be available
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 30.1K bytes
    - Viewed (0)
Back to top