Package org.voltcore.messaging

Examples of org.voltcore.messaging.LocalObjectMessage

83
84
85
86
87
88
89
90
91
92
93
                        public void run() {
                            handleMailboxMessage(message);
                        }
                    });
                } catch (RejectedExecutionException rejected) {
                    final LocalObjectMessage wrapper = (LocalObjectMessage)message;
                    AsyncCompilerWork work = (AsyncCompilerWork)(wrapper.payload);
                    generateErrorResult("Ad Hoc Planner task queue is full. Try again.", work);
                }
            }
        };
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
        retval.clientData = work.clientData;
        work.completionHandler.onCompletion(retval);
    }

    void handleMailboxMessage(final VoltMessage message) {
        final LocalObjectMessage wrapper = (LocalObjectMessage)message;
        if (wrapper.payload instanceof AdHocPlannerWork) {
            final AdHocPlannerWork w = (AdHocPlannerWork)(wrapper.payload);
            // do initial naive scan of statements for DDL, forbid mixed DDL and (DML|DQL)
            // This is not currently robust to comment, multi-line statments,
            // multiple statements on a line, etc.
View Full Code Here
379
380
381
382
383
384
385
386
387
388
389
            HeartbeatResponseMessage hrm = (HeartbeatResponseMessage)message;
            m_safetyState.updateLastSeenTxnIdFromExecutorBySiteId(
                    hrm.getExecHSId(),
                    hrm.getLastReceivedTxnId());
        } else if (message instanceof LocalObjectMessage) {
            LocalObjectMessage lom = (LocalObjectMessage)message;
            if (lom.payload instanceof Runnable) {
                ((Runnable)lom.payload).run();
            } else if (lom.payload instanceof Request) {
                Request r = (Request)lom.payload;
                long txnId = 0;
View Full Code Here
663
664
665
666
667
668
669
670
671
        }
    }

    @Override
    public void request(Request r) {
        LocalObjectMessage lom = new LocalObjectMessage(r);
        lom.m_sourceHSId = m_hsId;
        m_mailbox.deliver(lom);
    }
View Full Code Here
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
                    to.putInt(timeout);
                    to.flip();
                    cnxn.setSessionId(sessionId);
                    Request si = new Request(cnxn, sessionId, 0, OpCode.createSession, to, null);
                    try {
                        LocalObjectMessage lom = new LocalObjectMessage(si);
                        lom.m_sourceHSId = m_hsId;
                        processMessage(lom);
                    } catch (Exception e) {
                        org.voltdb.VoltDB.crashLocalVoltDB(
                                "Unexpected exception processing AgreementSite message", true, e);
                    }
                } finally {
                    sem.release();
                }
            }
        };
        LocalObjectMessage lom = new LocalObjectMessage(r);
        lom.m_sourceHSId = m_hsId;
        m_mailbox.deliverFront(lom);
        return sem;
    }
View Full Code Here
790
791
792
793
794
795
796
797
798
799
                } catch (Throwable e) {
                    org.voltdb.VoltDB.crashLocalVoltDB("Error constructing JSON", false, e);
                }
            }
        };
        LocalObjectMessage lom = new LocalObjectMessage(r);
        lom.m_sourceHSId = m_hsId;
        m_mailbox.deliver(lom);
        return cdl;
    }
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
            // This API that underlies dynamic ad hoc invocation from a stored procedure is
            // also handy here for setting up a mocked up planner work request for testing purposes.
            AdHocPlannerWork work = AdHocPlannerWork.makeStoredProcAdHocPlannerWork(100, "select * from a",
                                                                                    null, false, null,
                                                                                    handler);
            LocalObjectMessage msg = new LocalObjectMessage(work);
            msg.m_sourceHSId = 100;
            m_agent.m_mailbox.deliver(msg);
        }

        // check for one rejected request
View Full Code Here
885
886
887
888
889
890
891
892
893
894
895
            //Flush export data to the disk before the partition detection snapshot
            ee.quiesce(lastCommittedTxnId);

            // then initiate the local snapshot
        } else if (message instanceof LocalObjectMessage) {
              LocalObjectMessage lom = (LocalObjectMessage)message;
              ((Runnable)lom.payload).run();
        } else {
            hostLog.l7dlog(Level.FATAL, LogKeys.org_voltdb_dtxn_SimpleDtxnConnection_UnkownMessageClass.name(),
                           new Object[] { message.getClass().getName() }, null);
            VoltDB.crashLocalVoltDB("No additional info.", false, null);
View Full Code Here
1244
1245
1246
1247
1248
1249
1250
1251
1252
                }

                m_tracker = st;
            }
        };
        LocalObjectMessage lom = new LocalObjectMessage(r);
        lom.m_sourceHSId = m_siteId;
        m_mailbox.deliver(lom);
    }
View Full Code Here
1438
1439
1440
1441
1442
1443
1444
1445
1446
                userPartitionKey == null, userPartitionKey,
                task.procName, task.type, task.originalTxnId, task.originalUniqueId,
                VoltDB.instance().getReplicationRole() == ReplicationRole.REPLICA,
                VoltDB.instance().getCatalogContext().cluster.getUseddlschema(),
                m_adhocCompletionHandler, user);
        LocalObjectMessage work = new LocalObjectMessage( ahpw );

        m_mailbox.send(m_plannerSiteId, work);
    }
View Full Code Here
TOP

Related Classes of org.voltcore.messaging.LocalObjectMessage

  • org.voltcore.agreement.AgreementSite
  • org.voltcore.agreement.MiniSite
  • org.voltdb.ClientInterface
  • org.voltdb.compiler.AsyncCompilerAgent
  • org.voltdb.compiler.TestAsyncCompilerAgent
  • org.voltdb.ExecutionSite
    • 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.