Lines Matching refs:SyncOperation
50 // A Map of SyncOperations operationKey -> SyncOperation that is designed for
51 // quick lookup of an enqueued SyncOperation.
52 private final HashMap<String, SyncOperation> mOperationsMap = Maps.newHashMap();
74 SyncOperation syncOperation = new SyncOperation(
79 syncOperation.expedited = op.expedited;
80 syncOperation.pendingOperation = op;
81 add(syncOperation, op);
85 public boolean add(SyncOperation operation) {
89 private boolean add(SyncOperation operation,
97 final SyncOperation existingOperation = mOperationsMap.get(operationKey);
135 ArrayList<SyncOperation> opsToRemove = new ArrayList<SyncOperation>();
136 for (SyncOperation op : mOperationsMap.values()) {
142 for (SyncOperation op : opsToRemove) {
151 public void remove(SyncOperation operation) {
152 SyncOperation operationToRemove = mOperationsMap.remove(operation.key);
165 for (SyncOperation op : mOperationsMap.values()) {
177 for (SyncOperation op : mOperationsMap.values()) {
186 Iterator<Map.Entry<String, SyncOperation>> entries = mOperationsMap.entrySet().iterator();
188 Map.Entry<String, SyncOperation> entry = entries.next();
189 SyncOperation syncOperation = entry.getValue();
190 if (account != null && !syncOperation.account.equals(account)) {
193 if (authority != null && !syncOperation.authority.equals(authority)) {
196 if (userId != syncOperation.userId) {
200 if (!mSyncStorageEngine.deleteFromPending(syncOperation.pendingOperation)) {
201 final String errorMessage = "unable to find pending row for " + syncOperation;
207 public Collection<SyncOperation> getOperations() {
214 for (SyncOperation operation : mOperationsMap.values()) {
