Examples of CreateObjectCommand

Examples of org.apache.cloudstack.storage.command.CreateObjectCommand

160
161
162
163
164
165
166
167
168
169
170
    @Override
    public void createAsync(DataObject vol,
            AsyncCompletionCallback<CreateCmdResult> callback) {
        EndPoint ep = selector.select(vol);
        CreateObjectCommand createCmd = new CreateObjectCommand(vol.getUri());
       
        CreateVolumeContext<CreateCmdResult> context = new CreateVolumeContext<CreateCmdResult>(callback, vol);
        AsyncCallbackDispatcher<DefaultPrimaryDataStoreDriverImpl, Answer> caller = AsyncCallbackDispatcher.create(this);
        caller.setContext(context)
            .setCallback(caller.getTarget().createAsyncCallback(null, null));
View Full Code Here

Examples of org.apache.cloudstack.storage.command.CreateObjectCommand

180
181
182
183
184
185
186
187
188
189
190
        try {
            DecodedDataObject obj = Decoder.decode(uri);
            if (obj.getPath() == null) {
                //create an obj
                EndPoint newEp = selector.select(object);
                CreateObjectCommand createCmd = new CreateObjectCommand(uri);
                CreateObjectAnswer answer = (CreateObjectAnswer)ep.sendMessage(createCmd);
                if (answer.getResult()) {
                    dataObjMgr.update(object, answer.getPath(), answer.getSize());
                } else {
                    s_logger.debug("failed to create object" + answer.getDetails());
View Full Code Here

Examples of org.apache.cloudstack.storage.command.CreateObjectCommand

80
81
82
83
84
85
86
87
88
89
90
            if (ep == null) {
                result.setResult("can't find storage client for:" + data.getId() + "," + data.getType());
                callback.complete(result);
                return;
            }
            CreateObjectCommand createCmd = new CreateObjectCommand(data.getUri());
            CreateObjectAnswer answer = (CreateObjectAnswer)ep.sendMessage(createCmd);
            if (answer.getResult()) {
                //update imagestorevo
              
                result = new CreateCmdResult(answer.getPath(), answer.getSize());
View Full Code Here

Examples of org.apache.cloudstack.storage.command.CreateObjectCommand

191
192
193
194
195
196
197
198
199
200
201
        if (ep == null) {
            String errMsg = "No remote endpoint to send command, check if host or ssvm is down?";
            s_logger.error(errMsg);
            throw new CloudRuntimeException(errMsg);
        }
        CreateObjectCommand createCmd = new CreateObjectCommand(null);

        CreateVolumeContext<CreateCmdResult> context = new CreateVolumeContext<CreateCmdResult>(callback, vol);
        AsyncCallbackDispatcher<SamplePrimaryDataStoreDriverImpl, Answer> caller = AsyncCallbackDispatcher.create(this);
        caller.setContext(context).setCallback(caller.getTarget().createAsyncCallback(null, null));
View Full Code Here

Examples of org.apache.isis.core.runtime.persistence.objectstore.transaction.CreateObjectCommand

104
105
106
107
108
109
110
111
112
113
114
    private PersistenceCommand command2;
    private PersistenceCommand command3;


    private CreateObjectCommand createCreateCommand(final ObjectAdapter object, final String name) {
        return new CreateObjectCommand() {

            @Override
            public void execute(final PersistenceCommandContext context) throws ObjectPersistenceException {
            }
View Full Code Here

Examples of org.apache.isis.core.runtime.persistence.objectstore.transaction.CreateObjectCommand

81
82
83
84
85
86
87
88
89
90
91
    private PersistenceCommand command;
    private PersistenceCommand command2;
    private PersistenceCommand command3;

    private CreateObjectCommand createCreateCommand(final ObjectAdapter object, final String name) {
        return new CreateObjectCommand() {

            @Override
            public void execute(final PersistenceCommandContext context) throws ObjectPersistenceException {
            }
View Full Code Here

Examples of org.apache.isis.core.runtime.persistence.objectstore.transaction.CreateObjectCommand

176
177
178
179
180
181
182
183
184
185
186
        }
    }

    @Override
    public CreateObjectCommand createCreateObjectCommand(final ObjectAdapter object) {
        return new CreateObjectCommand() {
            @Override
            public void execute(final PersistenceCommandContext context) {
                final DatabaseConnector connection = ((SqlExecutionContext) context).getConnection();
                LOG.debug("  create object " + object);
                final ObjectMapping mapping = objectMappingLookup.getMapping(object, connection);
View Full Code Here

Examples of org.apache.isis.core.runtime.persistence.objectstore.transaction.CreateObjectCommand

99
100
101
102
103
104
105
106
107
108
109
    @Ignore // DKH: refactor to use contract tests (see in-memory object store for basis)
    @Test
    public void createCreateObjectCommand_andExecute_persistsNewInstance() throws Exception {
        // given
        final CreateObjectCommand command = objectStore.createCreateObjectCommand(adapter1);
        // when
        command.execute(transaction);
        // then
        assertFalse(objectStore.hasInstances(specification));
    }
View Full Code Here

Examples of org.apache.isis.core.runtime.persistence.objectstore.transaction.CreateObjectCommand

78
79
80
81
82
83
84
85
86
87
88
    private PersistenceCommand command;
    private PersistenceCommand command2;
    private PersistenceCommand command3;

    private CreateObjectCommand createCreateCommand(final ObjectAdapter object, final String name) {
        return new CreateObjectCommand() {

            @Override
            public void execute(final PersistenceCommandContext context) throws ObjectPersistenceException {
            }
View Full Code Here

Examples of org.apache.isis.runtimes.dflt.runtime.persistence.objectstore.transaction.CreateObjectCommand

91
92
93
94
95
96
97
98
99
        objectStore.createSaveObjectCommand(mockAdapter);
    }

    @Test
    public void ValidatesCreateObjectCommand() throws Exception {
        final CreateObjectCommand command = objectStore.createCreateObjectCommand(adapter);
        command.execute(transaction);
        assertFalse(objectStore.hasInstances(spec));
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.