Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for addEntry (0.04 sec)

  1. internal/event/target/elasticsearch.go

    	stop()
    	entryExists(context.Context, string, string) (bool, error)
    	removeEntry(context.Context, string, string) error
    	updateEntry(context.Context, string, string, event.Event) error
    	addEntry(context.Context, string, event.Event) error
    }
    
    // ElasticsearchArgs - Elasticsearch target arguments.
    type ElasticsearchArgs struct {
    	Enable     bool            `json:"enable"`
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15K bytes
    - Viewed (0)
  2. cmd/tier-sweeper.go

    //
    //	if gerr == nil {
    //	   os.SetTransitionState(goi)
    //	}
    //
    // // After the overwriting object operation is complete.
    //
    //	if jentry, ok := os.ShouldRemoveRemoteObject(); ok {
    //	    err := globalTierJournal.AddEntry(jentry)
    //	    logger.LogIf(ctx, err)
    //	}
    type objSweeper struct {
    	Object              string
    	Bucket              string
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. impl/maven-core/src/test/remote-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar

    equals(Object); public int hashCode(); public String toString(); public java.util.Collection values(); public java.util.Set entrySet(); public java.util.Set keySet(); protected void sizeChanged(); private static int keyHash(Object); private void addEntry(Object, Object); private void removeEntry(FastMap$EntryImpl); private void initialize(int); private void readObject(java.io.ObjectInputStream) throws java.io.IOException, ClassNotFoundExcepti; private void writeObject(java.io.ObjectOutputStream)...
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 164.6K bytes
    - Viewed (0)
  4. src/test/java/jcifs/netbios/NameQueryResponseTest.java

            addrEntryField.setAccessible(true);
            addrEntryField.set(nameQueryResponse, null);
    
            // The toString method appends to super.toString(). We'll check the appended part.
            String expectedEnd = ",addrEntry=]";
            String actual = nameQueryResponse.toString();
            assertTrue(actual.endsWith(expectedEnd), "toString should end with ',addrEntry=]' when addrEntry is null");
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  5. src/main/java/jcifs/netbios/NameQueryResponse.java

            if (address != 0) {
                this.addrEntry[this.addrIndex] = new NbtAddress(this.recordName, address, groupName, nodeType);
            } else {
                this.addrEntry[this.addrIndex] = null;
            }
    
            return 6;
        }
    
        @Override
        public String toString() {
            return ("NameQueryResponse[" + super.toString() + ",addrEntry=" + (this.addrEntry != null ? Arrays.toString(this.addrEntry) : "")
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/netbios/NameQueryResponse.java

            if (address != 0) {
                addrEntry[addrIndex] = new NbtAddress(recordName, address, groupName, nodeType);
            } else {
                addrEntry[addrIndex] = null;
            }
    
            return 6;
        }
    
        @Override
        public String toString() {
            return ("NameQueryResponse[" + super.toString() + ",addrEntry=" + addrEntry + "]");
        }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 2K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                    }
    
                    if (response.received && response.resultCode == 0) {
                        final int last = response.addrEntry.length - 1;
                        response.addrEntry[last].hostName.srcHashCode = addr.hashCode();
                        return response.addrEntry[last];
                    }
                } while (--n > 0 && request.isBroadcast);
    
                throw new UnknownHostException(name.name);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/netbios/NameServiceClientImpl.java

                    }
    
                    if (response.received && response.resultCode == 0) {
                        final int last = response.addrEntry.length - 1;
                        response.addrEntry[last].hostName.srcHashCode = addr.hashCode();
                        return response.addrEntry[last];
                    }
                } while (--n > 0 && request.isBroadcast);
    
                throw new UnknownHostException(name.name);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 38.5K bytes
    - Viewed (0)
  9. src/test/java/jcifs/netbios/NameServicePacketTest.java

            assertEquals(NameServicePacket.IN, packet.recordClass);
            assertEquals(100, packet.ttl);
            assertEquals(6, packet.rDataLength);
            assertNotNull(packet.addrEntry);
            assertEquals(1, packet.addrEntry.length);
        }
    
        @Test
        void testReadResourceRecordWireFormat_differentRecordName() {
            byte[] src = new byte[20];
            // No pointer, so mockRecordName will be read
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  10. src/main/java/jcifs/netbios/NameServicePacket.java

                    + (src[srcIndex + 3] & 0xFF);
        }
    
        static int readNameTrnId(final byte[] src, final int srcIndex) {
            return readInt2(src, srcIndex);
        }
    
        int addrIndex;
        NbtAddress[] addrEntry;
    
        int nameTrnId;
    
        int opCode, resultCode, questionCount, answerCount, authorityCount, additionalCount;
        boolean received, isResponse, isAuthAnswer, isTruncated, isRecurDesired, isRecurAvailable, isBroadcast;
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 11.1K bytes
    - Viewed (0)
Back to top