srdi.html

jxta的api库

<A NAME="RPV_REPLICATION_THRESHOLD"><!-- --></A><H3>
RPV_REPLICATION_THRESHOLD</H3>
<PRE>
public static final int <B>RPV_REPLICATION_THRESHOLD</B></PRE>
<DL>
<DL>
<DT><B>See Also:</B><DD><A HREF="../../../../constant-values.html#net.jxta.impl.cm.Srdi.RPV_REPLICATION_THRESHOLD">Constant Field Values</A></DL>
</DL>

<!-- ========= CONSTRUCTOR DETAIL ======== -->

<A NAME="constructor_detail"><!-- --></A>
<TABLE BORDER="1" WIDTH="100%" CELLPADDING="3" CELLSPACING="0" SUMMARY="">
<TR BGCOLOR="#CCCCFF" CLASS="TableHeadingColor">
<TD COLSPAN=1><FONT SIZE="+2">
<B>Constructor Detail</B></FONT></TD>
</TR>
</TABLE>

<A NAME="Srdi(net.jxta.peergroup.PeerGroup, java.lang.String, net.jxta.impl.cm.Srdi.SrdiInterface, net.jxta.impl.cm.SrdiIndex, long, long)"><!-- --></A><H3>
Srdi</H3>
<PRE>
public <B>Srdi</B>(<A HREF="../../../../net/jxta/peergroup/PeerGroup.html" title="interface in net.jxta.peergroup">PeerGroup</A>&nbsp;group,
            java.lang.String&nbsp;handlername,
            <A HREF="../../../../net/jxta/impl/cm/Srdi.SrdiInterface.html" title="interface in net.jxta.impl.cm">Srdi.SrdiInterface</A>&nbsp;srdiService,
            <A HREF="../../../../net/jxta/impl/cm/SrdiIndex.html" title="class in net.jxta.impl.cm">SrdiIndex</A>&nbsp;srdiIndex,
            long&nbsp;connectPollInterval,
            long&nbsp;pushInterval)</PRE>
<DL>
<DD>Starts the Srdi Service. wait for connectPollInterval prior to
  pushing the index if connected to a rdv, otherwise index is
  as soon as the Rendezvous connect occurs
<P>
<DT><B>Parameters:</B><DD><CODE>group</CODE> - group context to operate in<DD><CODE>handlername</CODE> - the SRDI handlername<DD><CODE>srdiService</CODE> - the service utilizing this Srdi, for purposes of
                      callback push entries on events such as rdv connect/disconnect, etc.<DD><CODE>srdiIndex</CODE> - The index instance associated with this serivce<DD><CODE>connectPollInterval</CODE> - initial timeout before the very first push of entries in milliseconds<DD><CODE>pushInterval</CODE> - the Interval at which the deltas are pushed in milliseconds</DL>

<!-- ============ METHOD DETAIL ========== -->

<A NAME="method_detail"><!-- --></A>
<TABLE BORDER="1" WIDTH="100%" CELLPADDING="3" CELLSPACING="0" SUMMARY="">
<TR BGCOLOR="#CCCCFF" CLASS="TableHeadingColor">
<TD COLSPAN=1><FONT SIZE="+2">
<B>Method Detail</B></FONT></TD>
</TR>
</TABLE>

<A NAME="stop()"><!-- --></A><H3>
stop</H3>
<PRE>
public void <B>stop</B>()</PRE>
<DL>
<DD>stop the current running thread
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>
</DL>
</DD>
</DL>
<HR>

<A NAME="replicateEntries(net.jxta.protocol.SrdiMessage)"><!-- --></A><H3>
replicateEntries</H3>
<PRE>
public void <B>replicateEntries</B>(<A HREF="../../../../net/jxta/protocol/SrdiMessage.html" title="class in net.jxta.protocol">SrdiMessage</A>&nbsp;srdiMsg)</PRE>
<DL>
<DD>Replicates a SRDI messge to other rendezvous'
 entries are replicated by breaking out entries out of the message
 and sorted out into rdv distribution bins. after which smaller messages
 are sent to other rdv's
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>
<DT><B>Parameters:</B><DD><CODE>srdiMsg</CODE> - srdi message to replicate</DL>
</DD>
</DL>
<HR>

<A NAME="pushSrdi(java.lang.String, net.jxta.protocol.SrdiMessage)"><!-- --></A><H3>
pushSrdi</H3>
<PRE>
public void <B>pushSrdi</B>(java.lang.String&nbsp;peer,
                     <A HREF="../../../../net/jxta/protocol/SrdiMessage.html" title="class in net.jxta.protocol">SrdiMessage</A>&nbsp;srdi)</PRE>
<DL>
<DD>Push an SRDI message to a peer
  ttl is 1, and therefore services receiving this message could
  choose to replicate this message
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>
<DT><B>Parameters:</B><DD><CODE>peer</CODE> - peer to push message to, if peer is null it is
               the message is propagated<DD><CODE>srdi</CODE> - SRDI message to send</DL>
</DD>
</DL>
<HR>

<A NAME="forwardQuery(java.lang.Object, net.jxta.protocol.ResolverQueryMsg)"><!-- --></A><H3>
forwardQuery</H3>
<PRE>
public void <B>forwardQuery</B>(java.lang.Object&nbsp;peer,
                         <A HREF="../../../../net/jxta/protocol/ResolverQueryMsg.html" title="class in net.jxta.protocol">ResolverQueryMsg</A>&nbsp;query)</PRE>
<DL>
<DD>Forwards a Query to a specific peer
  hopCount is incremented to indicate this query is forwarded
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>
<DT><B>Parameters:</B><DD><CODE>peer</CODE> - peerid to forward query to<DD><CODE>query</CODE> - The query</DL>
</DD>
</DL>
<HR>

<A NAME="forwardQuery(java.util.Vector, net.jxta.protocol.ResolverQueryMsg)"><!-- --></A><H3>
forwardQuery</H3>
<PRE>
public void <B>forwardQuery</B>(java.util.Vector&nbsp;peers,
                         <A HREF="../../../../net/jxta/protocol/ResolverQueryMsg.html" title="class in net.jxta.protocol">ResolverQueryMsg</A>&nbsp;query)</PRE>
<DL>
<DD>Forwards a Query to a list of peers
  hopCount is incremented to indicate this query is forwarded
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>
<DT><B>Parameters:</B><DD><CODE>peers</CODE> - The peerids to forward query to<DD><CODE>query</CODE> - The query</DL>
</DD>
</DL>
<HR>

<A NAME="forwardQuery(java.util.Vector, net.jxta.protocol.ResolverQueryMsg, int)"><!-- --></A><H3>
forwardQuery</H3>
<PRE>
public void <B>forwardQuery</B>(java.util.Vector&nbsp;peers,
                         <A HREF="../../../../net/jxta/protocol/ResolverQueryMsg.html" title="class in net.jxta.protocol">ResolverQueryMsg</A>&nbsp;query,
                         int&nbsp;threshold)</PRE>
<DL>
<DD>Forwards a Query to a list of peers
 if the list of peers exceeds threshold, and random threshold is picked
 from <code>peers</code>
 hopCount is incremented to indicate this query is forwarded
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>
<DT><B>Parameters:</B><DD><CODE>peers</CODE> - The peerids to forward query to<DD><CODE>query</CODE> - The query</DL>
</DD>
</DL>
<HR>

<A NAME="randomResult(java.util.Vector, int)"><!-- --></A><H3>
randomResult</H3>
<PRE>
protected java.util.Vector <B>randomResult</B>(java.util.Vector&nbsp;result,
                                        int&nbsp;threshold)</PRE>
<DL>
<DD>returns a random vector(threshold) from a given vector
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>
</DL>
</DD>
</DL>
<HR>

<A NAME="getReplicaPeer(java.lang.String)"><!-- --></A><H3>
getReplicaPeer</H3>
<PRE>
public <A HREF="../../../../net/jxta/peer/PeerID.html" title="class in net.jxta.peer">PeerID</A> <B>getReplicaPeer</B>(java.lang.String&nbsp;expression)</PRE>
<DL>
<DD>Given an expression return a peer from the list peers in the peerview
  this function is used to to give a replication point, and entry point
  to query on a pipe
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>
<DT><B>Parameters:</B><DD><CODE>expression</CODE> - expression to derive the mapping from
<DT><B>Returns:</B><DD>The replicaPeer value</DL>
</DD>
</DL>
<HR>

<A NAME="forwardSrdiMessage(net.jxta.peer.PeerID, net.jxta.peer.PeerID, java.lang.String, java.lang.String, java.lang.String, long)"><!-- --></A><H3>
forwardSrdiMessage</H3>
<PRE>
public void <B>forwardSrdiMessage</B>(<A HREF="../../../../net/jxta/peer/PeerID.html" title="class in net.jxta.peer">PeerID</A>&nbsp;peerid,
                               <A HREF="../../../../net/jxta/peer/PeerID.html" title="class in net.jxta.peer">PeerID</A>&nbsp;srcPid,
                               java.lang.String&nbsp;primaryKey,
                               java.lang.String&nbsp;secondarykey,
                               java.lang.String&nbsp;value,
                               long&nbsp;expiration)</PRE>
<DL>
<DD>forward srdi message to another peer
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>
<DT><B>Parameters:</B><DD><CODE>peerid</CODE> - PeerID to forward query to<DD><CODE>srcPid</CODE> - The source originator<DD><CODE>primaryKey</CODE> - primary key<DD><CODE>secondarykey</CODE> - secondary key<DD><CODE>value</CODE> - value of the entry<DD><CODE>expiration</CODE> - expiration in ms</DL>
</DD>
</DL>
<HR>

<A NAME="rendezvousEvent(net.jxta.rendezvous.RendezvousEvent)"><!-- --></A><H3>
rendezvousEvent</H3>
<PRE>
public void <B>rendezvousEvent</B>(<A HREF="../../../../net/jxta/rendezvous/RendezvousEvent.html" title="class in net.jxta.rendezvous">RendezvousEvent</A>&nbsp;event)</PRE>
<DL>
<DD>rendezvousEvent the rendezvous event
<P>
<DD><DL>
<DT><B>Specified by:</B><DD><CODE><A HREF="../../../../net/jxta/rendezvous/RendezvousListener.html#rendezvousEvent(net.jxta.rendezvous.RendezvousEvent)">rendezvousEvent</A></CODE> in interface <CODE><A HREF="../../../../net/jxta/rendezvous/RendezvousListener.html" title="interface in net.jxta.rendezvous">RendezvousListener</A></CODE></DL>
</DD>
<DD><DL>
<DT><B>Parameters:</B><DD><CODE>event</CODE> - RendezvousEvent event</DL>
</DD>
</DL>
<HR>

<A NAME="run()"><!-- --></A><H3>
run</H3>
<PRE>
public void <B>run</B>()</PRE>
<DL>
<DD>Main processing method for the SRDI Worker thread
  Send all entries, wait for pushInterval, then send deltas
<P>
<DD><DL>
<DT><B>Specified by:</B><DD><CODE>run</CODE> in interface <CODE>java.lang.Runnable</CODE></DL>
</DD>
<DD><DL>
</DL>
</DD>
</DL>
<HR>

<A NAME="createPeerID(java.lang.String)"><!-- --></A><H3>
createPeerID</H3>
<PRE>
protected static <A HREF="../../../../net/jxta/peer/PeerID.html" title="class in net.jxta.peer">PeerID</A> <B>createPeerID</B>(java.lang.String&nbsp;id)</PRE>
<DL>
<DD><DL>
</DL>
</DD>
<DD><DL>
</DL>
</DD>
</DL>
<HR>

<A NAME="getGlobalPeerView()"><!-- --></A><H3>
getGlobalPeerView</H3>
<PRE>
public java.util.Vector <B>getGlobalPeerView</B>()</PRE>
<DL>
<DD>get the global peerview as the rendezvous service only returns
 the peerview without the local RDV peer.  We need this
 consistent view for the SRDI index if not each RDVr will have a
 different peerview, off setting the index even when the peerview
 is stable
<P>
<DD><DL>
</DL>
</DD>
<DD><DL>

<DT><B>Returns:</B><DD>the sorted list</DL>
</DD>
</DL>
<!-- ========= END OF CLASS DATA ========= -->
<HR>


<!-- ======= START OF BOTTOM NAVBAR ====== -->
<A NAME="navbar_bottom"><!-- --></A>
<A HREF="#skip-navbar_bottom" title="Skip navigation links"></A>
<TABLE BORDER="0" WIDTH="100%" CELLPADDING="1" CELLSPACING="0" SUMMARY="">
<TR>
<TD COLSPAN=3 BGCOLOR="#EEEEFF" CLASS="NavBarCell1">
<A NAME="navbar_bottom_firstrow"><!-- --></A>
<TABLE BORDER="0" CELLPADDING="0" CELLSPACING="3" SUMMARY="">
  <TR ALIGN="center" VALIGN="top">
  <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1">    <A HREF="../../../../overview-summary.html"><FONT CLASS="NavBarFont1"><B>Overview</B></FONT></A>&nbsp;</TD>
  <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1">    <A HREF="package-summary.html"><FONT CLASS="NavBarFont1"><B>Package</B></FONT></A>&nbsp;</TD>
  <TD BGCOLOR="#FFFFFF" CLASS="NavBarCell1Rev"> &nbsp;<FONT CLASS="NavBarFont1Rev"><B>Class</B></FONT>&nbsp;</TD>
  <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1">    <A HREF="class-use/Srdi.html"><FONT CLASS="NavBarFont1"><B>Use</B></FONT></A>&nbsp;</TD>
  <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1">    <A HREF="package-tree.html"><FONT CLASS="NavBarFont1"><B>Tree</B></FONT></A>&nbsp;</TD>
  <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1">    <A HREF="../../../../deprecated-list.html"><FONT CLASS="NavBarFont1"><B>Deprecated</B></FONT></A>&nbsp;</TD>
  <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1">    <A HREF="../../../../index-all.html"><FONT CLASS="NavBarFont1"><B>Index</B></FONT></A>&nbsp;</TD>
  <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1">    <A HREF="../../../../help-doc.html"><FONT CLASS="NavBarFont1"><B>Help</B></FONT></A>&nbsp;</TD>
  </TR>
</TABLE>
</TD>
<TD ALIGN="right" VALIGN="top" ROWSPAN=3><EM>
JXTA J2SE</EM>
</TD>
</TR>

<TR>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
&nbsp;<A HREF="../../../../net/jxta/impl/cm/Indexer.SearchCallback.html" title="class in net.jxta.impl.cm"><B>PREV CLASS</B></A>&nbsp;
&nbsp;<A HREF="../../../../net/jxta/impl/cm/SrdiCache.html" title="class in net.jxta.impl.cm"><B>NEXT CLASS</B></A></FONT></TD>
<TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2">
  <A HREF="../../../../index.html" target="_top"><B>FRAMES</B></A>  &nbsp;
&nbsp;<A HREF="Srdi.html" target="_top"><B>NO FRAMES</B></A>  &nbsp;
&nbsp;<SCRIPT type="text/javascript">
  <!--
  if(window==top) {
    document.writeln('<A HREF="../../../../allclasses-noframe.html"><B>All Classes</B></A>');
  }
  //-->
</SCRIPT>
<NOSCRIPT>
  <A HREF="../../../../allclasses-noframe.html"><B>All Classes</B></A>
</NOSCRIPT>

</FONT></TD>
</TR>
<TR>
<TD VALIGN="top" CLASS="NavBarCell3"><FONT SIZE="-2">
  SUMMARY:&nbsp;<A HREF="#nested_class_summary">NESTED</A>&nbsp;|&nbsp;<A HREF="#field_summary">FIELD</A>&nbsp;|&nbsp;<A HREF="#constructor_summary">CONSTR</A>&nbsp;|&nbsp;<A HREF="#method_summary">METHOD</A></FONT></TD>
<TD VALIGN="top" CLASS="NavBarCell3"><FONT SIZE="-2">
DETAIL:&nbsp;<A HREF="#field_detail">FIELD</A>&nbsp;|&nbsp;<A HREF="#constructor_detail">CONSTR</A>&nbsp;|&nbsp;<A HREF="#method_detail">METHOD</A></FONT></TD>
</TR>
</TABLE>
<A NAME="skip-navbar_bottom"></A>
<!-- ======== END OF BOTTOM NAVBAR ======= -->

<HR>

</BODY>
</HTML>