Package org.apache.cassandra.net

Examples of org.apache.cassandra.net.EndPoint

947
948
949
950
951
952
953
954
955
956
957
{
    private static Logger logger_ = Logger.getLogger( JoinVerbHandler.class);

    public void doVerb(Message message)
    {
        EndPoint from = message.getFrom();
        logger_.debug("Received a JoinMessage from " + from);

        byte[] bytes = (byte[])message.getMessageBody()[0];
        DataInputStream dis = new DataInputStream( new ByteArrayInputStream(bytes) );
View Full Code Here
974
975
976
977
978
979
980
981
982
983
984
{
    private static Logger logger_ = Logger.getLogger( GossipDigestSynVerbHandler.class);

    public void doVerb(Message message)
    {
        EndPoint from = message.getFrom();
        logger_.trace("Received a GossipDigestSynMessage from " + from);

        byte[] bytes = (byte[])message.getMessageBody()[0];
        DataInputStream dis = new DataInputStream( new ByteArrayInputStream(bytes) );
View Full Code Here
1031
1032
1033
1034
1035
1036
1037
1038
1039
1040
1041
         * of the local EndPointState and the version found in the GossipDigest.
        */
        List<GossipDigest> diffDigests = new ArrayList<GossipDigest>();
        for ( GossipDigest gDigest : gDigestList )
        {
            EndPoint ep = gDigest.getEndPoint();
            EndPointState epState = Gossiper.instance().getEndPointStateForEndPoint(ep);
            int version = (epState != null) ? Gossiper.instance().getMaxEndPointStateVersion( epState ) : 0;
            int diffVersion = Math.abs(version - gDigest.getMaxVersion() );
            diffDigests.add( new GossipDigest(ep, gDigest.getGeneration(), diffVersion) );
        }
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
        }

        private boolean sendMessage(String endpointAddress, String key) throws Exception
        {
          boolean success = false; // TODO : fix the hack we need to make sure the data is written on the other end.
          if(FailureDetector.instance().isAlive(new EndPoint(endpointAddress, DatabaseDescriptor.getControlPort())))
          {
            success = true;
          }
          else
          {
            return success;
          }
          Table table = Table.open(DatabaseDescriptor.getTables().get(0));
          Row row = null;
          row = table.get(key);
          RowMutation rm = new RowMutation(DatabaseDescriptor.getTables().get(0), row);
      RowMutationMessage rmMsg = new RowMutationMessage(rm);
      Message message = RowMutationMessage.makeRowMutationMessage( rmMsg );
      EndPoint endPoint = new EndPoint(endpointAddress, DatabaseDescriptor.getStoragePort());
      MessagingService.getMessagingInstance().sendOneWay(message, endPoint);
      return success;
        }
View Full Code Here
1058
1059
1060
1061
1062
1063
1064
1065
1066
1067
1068
1069
1070
1071
1072
1073
1074
1075
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
1090
1091
{
    private static Logger logger_ = Logger.getLogger(GossipDigestAckVerbHandler.class);

    public void doVerb(Message message)
    {
        EndPoint from = message.getFrom();
        logger_.trace("Received a GossipDigestAckMessage from " + from);

        byte[] bytes = (byte[])message.getMessageBody()[0];
        DataInputStream dis = new DataInputStream( new ByteArrayInputStream(bytes) );

        try
        {
            GossipDigestAckMessage gDigestAckMessage = GossipDigestAckMessage.serializer().deserialize(dis);
            List<GossipDigest> gDigestList = gDigestAckMessage.getGossipDigestList();
            Map<EndPoint, EndPointState> epStateMap = gDigestAckMessage.getEndPointStateMap();

            if ( epStateMap.size() > 0 )
            {
                /* Notify the Failure Detector */
                Gossiper.instance().notifyFailureDetector(epStateMap);
                Gossiper.instance().applyStateLocally(epStateMap);
            }

            /* Get the state required to send to this gossipee - construct GossipDigestAck2Message */
            Map<EndPoint, EndPointState> deltaEpStateMap = new HashMap<EndPoint, EndPointState>();
            for( GossipDigest gDigest : gDigestList )
            {
                EndPoint addr = gDigest.getEndPoint();
                EndPointState localEpStatePtr = Gossiper.instance().getStateForVersionBiggerThan(addr, gDigest.getMaxVersion());
                if ( localEpStatePtr != null )
                    deltaEpStateMap.put(addr, localEpStatePtr);
            }

View Full Code Here
1105
1106
1107
1108
1109
1110
1111
1112
1113
1114
1115
{
    private static Logger logger_ = Logger.getLogger(GossipDigestAck2VerbHandler.class);

    public void doVerb(Message message)
    {
        EndPoint from = message.getFrom();
        logger_.trace("Received a GossipDigestAck2Message from " + from);

        byte[] bytes = (byte[])message.getMessageBody()[0];
        DataInputStream dis = new DataInputStream( new ByteArrayInputStream(bytes) );
        try
View Full Code Here
738
739
740
741
742
743
744
745
746
747
748
                  System.err.println(jsap.getHelp());                 
                  System.err.println("**********Errors*************");
          }
              if ( jsap.messagePrinted() ) return null;   
          String hostName = FBUtilities.getHostName();
          from_ = new EndPoint(hostName,10001);
          MessagingService.getMessagingInstance().listen(from_, false);
    }
    catch ( Exception ex)
    {
      logger_.debug(LogUtil.throwableToString(ex));
View Full Code Here
755
756
757
758
759
760
761
762
763
764
765
    requestsPerSecond_ = config.getInt("tps");
    int numThreads = requestsPerSecond_/1000 + 1;
    if(config.getString("Server") != null)
    {
      server_ = config.getString("Server");
      to_ = new EndPoint(config.getString("Server"), 7000);
    }
    runner_ = new DebuggableThreadPoolExecutor( numThreads,
        numThreads,
              Integer.MAX_VALUE,
              TimeUnit.SECONDS,
View Full Code Here
63
64
65
66
67
68
69
70
71
72
    public static Message makeRowMutationMessage(RowMutationMessage rowMutationMessage, String verbHandlerName) throws IOException
    {
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        DataOutputStream dos = new DataOutputStream( bos );
        RowMutationMessage.serializer().serialize(rowMutationMessage, dos);
        EndPoint local = StorageService.getLocalStorageEndPoint();
        EndPoint from = ( local != null ) ? local : new EndPoint(FBUtilities.getHostName(), 7000);
        Message message = new Message(from, StorageService.mutationStage_, verbHandlerName, new Object[]{bos.toByteArray()});        
        return message;
    }
View Full Code Here
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
    }

    public static void main(String[] args) throws Throwable
    {
        StorageService ss = StorageService.instance();
        ss.updateTokenMetadata(BigInteger.valueOf(3), new EndPoint("A", 7000));
        ss.updateTokenMetadata(BigInteger.valueOf(6), new EndPoint("B", 7000));
        ss.updateTokenMetadata(BigInteger.valueOf(9), new EndPoint("C", 7000));
        ss.updateTokenMetadata(BigInteger.valueOf(12), new EndPoint("D", 7000));
        ss.updateTokenMetadata(BigInteger.valueOf(15), new EndPoint("E", 7000));
        ss.updateTokenMetadata(BigInteger.valueOf(18), new EndPoint("F", 7000));
        ss.updateTokenMetadata(BigInteger.valueOf(21), new EndPoint("G", 7000));
        ss.updateTokenMetadata(BigInteger.valueOf(24), new EndPoint("H", 7000));
       
        Runnable runnable = new LeaveJoinProtocolImpl( new EndPoint[]{new EndPoint("C", 7000), new EndPoint("D", 7000)}, new BigInteger[]{BigInteger.valueOf(22), BigInteger.valueOf(23)} );
        runnable.run();
    }
View Full Code Here
TOP

Related Classes of org.apache.cassandra.net.EndPoint

  • org.apache.cassandra.bulkloader.CassandraBulkLoader$Reduce
  • org.apache.cassandra.client.RingCache
  • org.apache.cassandra.client.TestRingCache
  • org.apache.cassandra.db.BootstrapTest
  • org.apache.cassandra.db.HintedHandOffManager
  • org.apache.cassandra.db.HintedHandOffManager$HintedHandOff
  • org.apache.cassandra.db.RowMutation
  • org.apache.cassandra.db.RowMutationMessage
  • org.apache.cassandra.db.RowMutationVerbHandler
  • org.apache.cassandra.db.Table$BootstrapCompletionHandler
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.