update proposal

Signed-off-by: Tom <[email protected]>

Author: Flying-Tom

config/kmesh_marcos_def.h

@@ -14,15 +14,15 @@
  * and sidecar containers. The bpf_sk_original_addr auxiliary function is
  * used to obtain the original destination address.
  */
-#define MDA_NAT_ACCEL 1
+#define MDA_NAT_ACCEL 0
 
 /* supports acceleration function filtering based on GID and UID.
  * That is, the GID or UID corresponding to the process to be accelerated
  * is configured in the configuration file. The bpf_get_sockops_uid_gid
  * auxiliary function is used to obtain the GID and UID of the current
  * process.
  */
-#define MDA_GID_UID_FILTER 1
+#define MDA_GID_UID_FILTER 0
 
 /*
  * openEuler-23.03 is an innovative version of openEuler, in the early time, we
@@ -67,4 +67,4 @@
  * the libbpf version in the current environment, and the code in the project
  * is enabled accordingly.
  * */
-#define LIBBPF_HIGHER_0_6_0_VERSION 0
+#define LIBBPF_HIGHER_0_6_0_VERSION 1

docs/proposal/dual_engine_dns.md

@@ -176,19 +176,23 @@ func (p *Processor) handleServicesAndWorkloads(services []*workloadapi.Service,
           p.DnsResolverChan <- workloads
         }
         go func() {
-          maxRetries := 30
+         maxRetries := 50
+          var address [][]byte
           for range maxRetries {
             workload := p.WorkloadCache.GetWorkloadByUid(uid)
-            address := workload.GetAddresses()
-            if address != nil {
-              if err := p.handleWorkload(workload); err != nil {
-                log.Errorf("handle workload %s failed, err: %v", workload.ResourceName(), err)
-              }
+            if address = workload.GetAddresses(); address != nil {
               break
             } else {
-              log.Warnf("workload: %s/%s addresses is still nil, retrying...", workload.Namespace, workload.Name)
+              time.Sleep(WorkloadDnsRefreshRate)
             }
-            time.Sleep(1 * time.Second)
+          }
+          if address != nil {
+            log.Infof("workload: %s/%s addresses resolved: %v", workload.Namespace, workload.Name, address)
+            if err := p.handleWorkload(workload); err != nil {
+              log.Errorf("handle workload %s failed, err: %v", workload.ResourceName(), err)
+            }
+          } else {
+            log.Warnf("workload: %s/%s addresses is still nil after %d retries, skipping", workload.Namespace, workload.Name, maxRetries)
           }
         }()
         // wait for the service entry to be resolved
@@ -201,6 +205,12 @@ func (p *Processor) handleServicesAndWorkloads(services []*workloadapi.Service,
 }
 ```
 
+Overall, the DNS logic under the Dual-engine mode is roughly illustrated in the block diagram below.
+
+![](./pics/dual-engine-dns.png)
+
+As mentioned earlier, this implementation largely mirrors the DNS logic in AdsController, resulting in significant structural redundancy. Therefore, after the Step-1 we need to further abstract the current DNS logic. As shown in the diagram, both WorkerController and DnsResolver are already cohesive and self-contained; however, the interface layer highlighted in orange differs across modes. Subsequent refactoring will attempt to treat Cluster or Workload as first-class entities—load objects that Controller and DnsController (Resolver) interact with directly—thereby achieving looser coupling.
+
 #### Test Plan
 
 <!--

docs/proposal/pics/dual-engine-dns.png

@@ -1,4 +1,4 @@
-prefix=
+prefix=/kmesh/
 
 Name: api-v2-c
 Description: api-v2-c

mk/api-v2-c.pc

@@ -1,4 +1,4 @@
-prefix=
+prefix=/kmesh/
 Name: bpf
 Description: bpf
 Version: