(DeleteUpdateCommand cmd)
| 872 | } |
| 873 | return -1; |
| 874 | } |
| 875 | |
| 876 | public void delete(DeleteUpdateCommand cmd) { |
| 877 | BytesRef br = cmd.getIndexedId(); |
| 878 | |
| 879 | synchronized (this) { |
| 880 | if ((cmd.getFlags() & UpdateCommand.BUFFERING) != 0) { |
| 881 | ensureBufferTlog(); |
| 882 | bufferTlog.writeDelete(cmd); |
| 883 | return; |
| 884 | } |
| 885 | |
| 886 | long pos = -1; |
| 887 | if (!updateFromOldTlogs(cmd)) { |
| 888 | ensureLog(); |
| 889 | pos = tlog.writeDelete(cmd); |
| 890 | } |
| 891 | |
| 892 | LogPtr ptr = new LogPtr(pos, cmd.version); |
| 893 | map.put(br, ptr); |
| 894 | oldDeletes.put(br, ptr); |
| 895 | |
| 896 | if (trace) { |
| 897 | log.trace( |
| 898 | "TLOG: added delete for id {} to {} {} map={}", |
| 899 | cmd.id, |
| 900 | tlog, |
| 901 | ptr, |
| 902 | System.identityHashCode(map)); |
| 903 | } |
| 904 | } |
| 905 | } |
| 906 |
no test coverage detected