INTERNAL: make piped insert operations process synchronously

[oliviarla]

🔗 Related Issue

• https://github.com/naver/arcus-java-client/pull/795 를 대체할 수 있는 PR입니다.
• PR 생성 이유는 https://github.com/naver/arcus-java-client/pull/795#issuecomment-2720428907 참고 바랍니다.

⌨️ What I did

• ArcusClient 클래스

  • syncCollectionPipedInsert() / syncCollectionPipedUpdate() 메서드

    • Operation 객체가 2개 이상 생성되는 경우, Operation 객체에 next Operation 변수를 담아 두도록 합니다.

    • callback.complete() 처리 방법

      • 현재 Operation에 담긴 모든 요청이 성공할 경우, next Operation을 큐와 Future에 추가합니다.

      • 현재 Operation에 담긴 요청이 실패할 경우, 다음 케이스로 나뉩니다. (cancel/error 발생 시 지금은 failedResult를 조회할 수 없으나, 본 PR 반영된 후 조회 기능을 추가하는 PR을 올리겠습니다.)

        • cancel로 인해 일부 item 결과를 기다리지 않음 -> Future#failedResult에 결과가 오지 않은 가장 첫 아이템에 undefined 상태로 추가하고, 다음 op의 첫번째 아이템에 stopped 상태 추가 (이를 통해 undefined ~ stopped - 1 인덱스들은 수행 여부를 응용에서 다시 체크할 수 있음)
        • error로 인해 일부 item이 실행되지 않음 -> Future#failedResult에 실행되지 않은 최초의 item에 stopped 상태 추가
        • item이 모두 수행되었지만 not found 등 실패 존재 -> Future#failedResult에 실패한 상태들 추가하고, 다음 op 있으면 stopped 상태 추가

      • cancel로 인해 연산 응답을 더 이상 기다리지 않는 상태이더라도, 나중에 응답을 처리할 때 성공 응답이 오면 failedResult에서 데이터를 제거하고, 실패 응답이 오면 failedResult에 있던 undefined 상태를 실패 원인으로 교체한다.

• SingleKeyPipeOperationImpl 클래스

  • pipedCancel() 메서드: cancel 요청이 들어왔을 때 현재 Operation cancel에 실패하면, next Operation cancel을 시도한 후 결과를 반환합니다.

• PipedCollectionFuture 클래스

  • removeEachResult() 메서드: cancel된 후 성공 응답을 받았을 때 failedResult에서 데이터를 제거하도록 합니다.
  • 그외 메서드들을 수정했습니다.

[oliviarla]

@jhpark816 리뷰 반영하였습니다.

[jhpark816]

@uhm0311 리뷰 바랍니다.

[oliviarla]

현재 다음과 같이 동시성 문제 해결해둔 상태입니다.

• receivedStatus가 IO/Worker 스레드에서 중복 호출되는 문제

  • CANCEL/최종 실패 정보가 들어가고 어떤 정보가 먼저 들어가도, complete 콜백 메서드에서 처리는 문제 없다. 즉, 요청이 CANCEL 되었어도 FAIL_END 상태가 Future#OperationStatus 에 저장되는 것에 문제 없다고 판단한다.

• addEachResult(gotStatus 콜백) 메서드가 cancel된 후에도 IO 스레드에 의해 호출되어 기존 값(UNDEFINED) 덮어쓰는 문제

  • handleLine에서 호출되는 gotStatus 콜백 메서드가 cancel 상태면 불리지 않도록 수정하였다.

하지만 여전히 문제가 될 부분이 남아있는데요, 다음과 같이 cancel 변수에 대한 동시성 제어가 되어있지 않기 때문입니다. 따라서 iscancelled와 cancel 메서드 간에 동시 접근을 하지 못하도록 synchronized 메서드로 만드는 것에 대해 고민 중입니다.

[jhpark816]

@oliviarla ~op의 cancelled 플래그가 true이면 그 op의 상태를 WRITING 상태로 변경하지 못하므로, 위의 고민 사항은 문제되지 않을 것입니다. 검토 바랍니다.~

[oliviarla]

@jhpark816 @uhm0311 PR 첫 코멘트를 현재 형태에 맞게 수정했습니다. 복잡하게 failedResult에 아이템들을 추가하는 로직은 본 PR과 무관하게 추후 논의할 예정입니다. 리뷰 부탁드립니다.

[oliviarla]

https://github.com/jam2in/arcus-works/issues/716 완료 후 다시 진행하겠습니다.

[jhpark816]

@oliviarla 리뷰 코멘트 달았으니, 확인 바랍니다.