Skip to content

Commit cde86ef

Browse files
committed
WIP
1 parent b147c3a commit cde86ef

3 files changed

Lines changed: 25 additions & 2 deletions

File tree

modules/core/src/main/java/org/apache/ignite/internal/CoreMessagesProvider.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -211,14 +211,15 @@
211211
import org.apache.ignite.internal.processors.metastorage.persistence.DistributedMetaStorageUpdateAckMessage;
212212
import org.apache.ignite.internal.processors.metastorage.persistence.DistributedMetaStorageUpdateMessage;
213213
import org.apache.ignite.internal.processors.plugin.PluginsData;
214-
import org.apache.ignite.internal.processors.query.schema.message.InlineSizesData;
215214
import org.apache.ignite.internal.processors.query.QueryField;
216215
import org.apache.ignite.internal.processors.query.h2.twostep.messages.GridQueryCancelRequest;
217216
import org.apache.ignite.internal.processors.query.h2.twostep.messages.GridQueryFailResponse;
218217
import org.apache.ignite.internal.processors.query.h2.twostep.messages.GridQueryNextPageRequest;
219218
import org.apache.ignite.internal.processors.query.h2.twostep.messages.GridQueryNextPageResponse;
220219
import org.apache.ignite.internal.processors.query.messages.GridQueryKillRequest;
221220
import org.apache.ignite.internal.processors.query.messages.GridQueryKillResponse;
221+
import org.apache.ignite.internal.processors.query.schema.message.ActiveProposals;
222+
import org.apache.ignite.internal.processors.query.schema.message.InlineSizesData;
222223
import org.apache.ignite.internal.processors.query.schema.message.SchemaFinishDiscoveryMessage;
223224
import org.apache.ignite.internal.processors.query.schema.message.SchemaOperationStatusMessage;
224225
import org.apache.ignite.internal.processors.query.schema.message.SchemaProposeDiscoveryMessage;
@@ -582,6 +583,7 @@ public CoreMessagesProvider(Marshaller dfltMarsh, Marshaller schemaAwareMarsh, C
582583
withNoSchema(CacheContinuousQueryBatchAck.class);
583584
withSchema(CacheContinuousQueryEntry.class);
584585
withNoSchema(InlineSizesData.class);
586+
withSchema(ActiveProposals.class);
585587

586588
// [11200 - 11300]: Compute, distributed process messages.
587589
msgIdx = 11200;

modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/InitialUsersData.java

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,20 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one or more
3+
* contributor license agreements. See the NOTICE file distributed with
4+
* this work for additional information regarding copyright ownership.
5+
* The ASF licenses this file to You under the Apache License, Version 2.0
6+
* (the "License"); you may not use this file except in compliance with
7+
* the License. You may obtain a copy of the License at
8+
*
9+
* http://www.apache.org/licenses/LICENSE-2.0
10+
*
11+
* Unless required by applicable law or agreed to in writing, software
12+
* distributed under the License is distributed on an "AS IS" BASIS,
13+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
* See the License for the specific language governing permissions and
15+
* limitations under the License.
16+
*/
17+
118
package org.apache.ignite.internal.processors.authentication;
219

320
import java.util.ArrayList;

modules/core/src/main/java/org/apache/ignite/internal/processors/authentication/User.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
package org.apache.ignite.internal.processors.authentication;
1919

20+
import java.io.Serializable;
2021
import java.util.Objects;
2122
import org.apache.ignite.internal.Order;
2223
import org.apache.ignite.internal.util.tostring.GridToStringExclude;
@@ -28,7 +29,10 @@
2829

2930
/**
3031
*/
31-
public class User implements Message {
32+
public class User implements Serializable, Message {
33+
/** */
34+
private static final long serialVersionUID = 0L;
35+
3236
/** Default user name. */
3337
public static final String DFAULT_USER_NAME = "ignite";
3438

0 commit comments

Comments
 (0)