SeaweedFS is a distributed storage system for object storage (S3), file systems, and Iceberg tables, designed to handle billions of files with O(1) disk access and effortless horizontal scaling.
This report presents the forensic synthetic code analysis of seaweedfs/seaweedfs, a Go project with 33,484 GitHub stars. SynthScan v2.0 examined 883,173 lines of code across 3250 source files, recording 1296 pattern matches distributed across 21 syntactic categories. The overall adjusted score of 2.4 places this repository in the Likely human-written band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 1296 distinct pattern matches across 21 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | install.sh | 1 | #!/bin/bash | COMMENT |
| LOW | S3_LIFECYCLE_REDESIGN.md | 381 | COMMENT | |
| LOW | S3_LIFECYCLE_REDESIGN.md | 581 | // One probe per task entry: which per-filer log shards exist, what's the earliest | COMMENT |
| LOW | S3_LIFECYCLE_REDESIGN.md | 601 | // reseeding via lazy-seeding when F reappears. Safe to delete cursor[F]. | COMMENT |
| LOW | S3_LIFECYCLE_REDESIGN.md | 621 | // 2. Surface `lifecycle_lost_log_total{filer_id}` and | COMMENT |
| LOW | S3_LIFECYCLE_REDESIGN.md | 1521 | // RetryTarget carries the routing/identification fields needed to (a) write a | COMMENT |
| LOW | terraform/test/local/run_local_cluster.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | terraform/modules/core/variables.tf | 1 | # ============================================================================= | COMMENT |
| LOW | seaweedfs-rdma-sidecar/rdma-engine/src/ipc.rs | 121 | /// Response with engine capabilities | COMMENT |
| LOW | seaweedfs-rdma-sidecar/rdma-engine/src/lib.rs | 1 | //! High-Performance RDMA Engine for SeaweedFS | COMMENT |
| LOW | seaweedfs-rdma-sidecar/rdma-engine/src/main.rs | 1 | //! RDMA Engine Server | COMMENT |
| LOW | seaweedfs-rdma-sidecar/pkg/rdma/client.go | 421 | // MOCK DATA IMPLEMENTATION - FOR DEVELOPMENT/TESTING ONLY | COMMENT |
| LOW | weed/operation/upload_content.go | 121 | COMMENT | |
| LOW | weed/s3api/s3api_bucket_config.go | 981 | func (s3a *S3ApiServer) GetBucketMetadata(bucket string) (*BucketMetadata, error) { | COMMENT |
| LOW | weed/s3api/chunked_reader_v4.go | 301 | // | COMMENT |
| LOW | weed/s3api/chunked_reader_v4.go | 381 | // Check if we have credentials for signature verification | COMMENT |
| LOW | weed/s3api/auth_credentials.go | 1121 | // isEnabled reports whether S3 auth should be enforced for this server. | COMMENT |
| LOW | weed/s3api/auth_credentials.go | 1541 | return identity, s3err.ErrNone, reqAuthType | COMMENT |
| LOW | weed/s3api/auth_credentials.go | 2141 | // This does NOT flip isAuthEnabled on its own. The advanced IAM machinery is | COMMENT |
| LOW | weed/s3api/s3api_versioning_heal_log_test.go | 21 | // public functions don't panic and that the format strings work. | COMMENT |
| LOW | weed/s3api/s3api_versioning_heal_log_test.go | 101 | COMMENT | |
| LOW | weed/s3api/s3api_object_handlers_put.go | 361 | lockKey string | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 1001 | return r.URL.Query() | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 1221 | entry.Extended = make(map[string][]byte) | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 1421 | // clear. The pointer clear emits a meta-log event the lifecycle | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 1561 | COMMENT | |
| LOW | weed/s3api/s3api_internal_lifecycle.go | 341 | } | COMMENT |
| LOW | weed/s3api/sts_params_test.go | 141 | // The Router does not match "/" for STS because Action is not in query. | COMMENT |
| LOW | weed/s3api/s3api_server_routing_test.go | 141 | COMMENT | |
| LOW | weed/s3api/s3api_tables.go | 641 | // and in the X-Amz-Credential query parameter for presigned requests. | COMMENT |
| LOW | weed/s3api/s3_validation_utils.go | 41 | COMMENT | |
| LOW | weed/s3api/s3_sse_kms.go | 81 | // Ensure we clear the plaintext data key from memory when done | COMMENT |
| LOW | weed/s3api/s3_action_resolver.go | 21 | // - bucket: Bucket name from the request path | COMMENT |
| LOW | weed/s3api/s3_iam_middleware.go | 481 | return false | COMMENT |
| LOW | weed/s3api/auth_signature_v4.go | 1 | /* | COMMENT |
| LOW | weed/s3api/s3api_object_versioning.go | 41 | COMMENT | |
| LOW | weed/s3api/s3api_object_versioning.go | 1161 | // so the .versions/ directory should be empty — try to tear it | COMMENT |
| LOW | weed/s3api/s3api_object_versioning.go | 1201 | // expected to run the post-deletion .versions/ teardown so the now-empty | COMMENT |
| LOW | weed/s3api/s3api_object_versioning.go | 1401 | } | COMMENT |
| LOW | weed/s3api/s3api_object_versioning.go | 1581 | return nil | COMMENT |
| LOW | weed/s3api/s3api_object_versioning.go | 1601 | // latest-pointer fields to still match the stale id observed by the | COMMENT |
| LOW | weed/s3api/s3api_object_versioning.go | 1941 | COMMENT | |
| LOW | weed/s3api/s3api_object_versioning.go | 1961 | // reads take the clean ErrNotFound path instead of re-entering this | COMMENT |
| LOW | weed/s3api/s3api_object_versioning.go | 2121 | // rescanning .versions/ when the cached latest-version pointer is missing on the | COMMENT |
| LOW | weed/s3api/s3api_bucket_policy_engine.go | 101 | // EvaluatePolicy evaluates whether an action is allowed by bucket policy | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_copy.go | 941 | endOffset = int64(entry.Attributes.FileSize) - 1 | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_copy.go | 1641 | } | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_copy.go | 2881 | // this stored only KeyID/context/bucketKey, leaving EncryptedDataKey | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_copy.go | 3001 | // bytes raw without decryption — yielding deterministic byte | COMMENT |
| LOW | weed/s3api/s3api_governance_permissions_test.go | 181 | // | COMMENT |
| LOW | weed/s3api/s3api_governance_permissions_test.go | 201 | // Test specifically for users with IAM bypass permission | COMMENT |
| LOW | weed/s3api/s3api_governance_permissions_test.go | 401 | } | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_copy_alloc_test.go | 21 | // | COMMENT |
| LOW | weed/s3api/bucket_size_metrics_test.go | 1 | package s3api | COMMENT |
| LOW | weed/s3api/auto_signature_v4_test.go | 1201 | COMMENT | |
| LOW | weed/s3api/s3api_server.go | 101 | objectWriteLockClient *cluster.LockClient | COMMENT |
| LOW | weed/s3api/s3api_server.go | 241 | // | COMMENT |
| LOW | weed/s3api/s3api_server.go | 361 | // Set the integration in the traditional IAM for compatibility. | COMMENT |
| LOW | weed/s3api/s3api_server.go | 781 | // Apply CORS middleware to bucket routers for automatic CORS header handling | COMMENT |
| LOW | weed/s3api/auth_signature_v2.go | 1 | /* | COMMENT |
| 423 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | seaweedfs-rdma-sidecar/WEED-MOUNT-CODE-PATH.md | 117 | // Step 1: Lookup volume location from master | COMMENT |
| LOW⚡ | seaweedfs-rdma-sidecar/WEED-MOUNT-CODE-PATH.md | 120 | // Step 2: Find best server (local preferred) | COMMENT |
| LOW⚡ | seaweedfs-rdma-sidecar/WEED-MOUNT-CODE-PATH.md | 123 | // Step 3: Make HTTP request to target server's RDMA sidecar | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 341 | // Step 1: Sign a request targeting the client-facing URL using real AWS SDK signer | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 349 | // Step 2: Create a separate request as the proxy would deliver it | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 359 | // Step 3: Verify | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 501 | // Step 1: Sign a request using the real AWS SDK v2 signer. | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 510 | // Step 2: Build the request as the proxy would deliver it to SeaweedFS. | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 530 | // Step 3: Verify extractHostHeader returns the expected value. | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 537 | // Step 4: Verify the full signature matches. | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 551 | // Step 3: Calculate MD5 hash and add SSE metadata to chunks | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 650 | // Step 4: Create metadata entry | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 810 | // Step 4: Save metadata to filer via gRPC | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_copy.go | 2266 | // Step 1: Decrypt source data | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_copy.go | 2363 | // Step 2: Re-encrypt with destination encryption (if any) | COMMENT |
| LOW | weed/s3api/s3_sse_s3_integration_test.go | 47 | // Step 1: Encrypt (simulates what happens during PUT) | COMMENT |
| LOW | weed/s3api/s3_sse_s3_integration_test.go | 72 | // Step 2: Simulate storage (inline file - no chunks) | COMMENT |
| LOW | weed/s3api/s3_sse_s3_integration_test.go | 83 | // Step 3: Decrypt (simulates what happens during GET) | COMMENT |
| LOW⚡ | weed/s3api/s3api_object_retention.go | 551 | // Step 1: Check if governance bypass was requested via header | COMMENT |
| LOW⚡ | weed/s3api/s3api_object_retention.go | 558 | // Step 2: Validate user has permission to bypass governance retention | COMMENT |
| LOW⚡ | weed/s3api/s3_list_parts_action_test.go | 200 | // Step 1: Initiate multipart upload (POST with uploads query) | COMMENT |
| LOW⚡ | weed/s3api/s3_list_parts_action_test.go | 210 | // Step 2: List existing parts (GET with uploadId query) - THIS WAS THE MISSING MAPPING | COMMENT |
| LOW⚡ | weed/s3api/s3_list_parts_action_test.go | 220 | // Step 3: Upload a part (PUT with uploadId and partNumber) | COMMENT |
| LOW | weed/s3api/s3_list_parts_action_test.go | 231 | // Step 4: Complete multipart upload (POST with uploadId) | COMMENT |
| LOW | weed/util/chunk_cache/chunk_cache.go | 226 | // Step 1: Read and validate header (volume ID + cookie) | COMMENT |
| LOW | weed/util/chunk_cache/chunk_cache.go | 252 | // Step 2: Read actual data from the offset position (after header) | COMMENT |
| LOW | weed/shell/command_remote_cache.go | 109 | // Step 1: Collect all remote files | COMMENT |
| LOW | weed/shell/command_remote_cache.go | 123 | // Step 2: Collect all local files (only if we need to delete local extra files) | COMMENT |
| LOW | weed/shell/command_remote_cache.go | 141 | // Step 3: Determine actions needed | COMMENT |
| LOW | weed/shell/command_remote_cache.go | 221 | // Step 4: Execute actions | COMMENT |
| LOW⚡ | weed/shell/command_s3_user_provision.go | 114 | // Step 0: Check if user already exists | COMMENT |
| LOW⚡ | weed/shell/command_s3_user_provision.go | 123 | // Step 1: Create policy | COMMENT |
| LOW | weed/shell/command_s3_user_provision.go | 157 | // Step 2: Create new user with credentials | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 113 | // Step 1: Collect all local files that are part of the remote mount | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 129 | // Step 2: Check which files exist on remote storage | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 143 | // Step 3: Determine files to copy and files to delete | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 174 | // Step 4: Copy files to remote storage | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 225 | // Step 5: Delete extraneous files from remote storage | COMMENT |
| LOW | weed/admin/topology/storage_slot_test.go | 555 | // Step 1: Add pending task (should reserve capacity via StorageSlotChange) | COMMENT |
| LOW | weed/admin/topology/storage_slot_test.go | 579 | // Step 2: Assign task (capacity already reserved by pending task) | COMMENT |
| LOW⚡ | weed/admin/topology/storage_slot_test.go | 592 | // Step 3: Complete task (should release reserved capacity) | COMMENT |
| LOW⚡ | weed/admin/topology/storage_slot_test.go | 601 | // Step 4: Apply actual storage change (simulates master topology update) | COMMENT |
| LOW | weed/storage/volume_replica/replica_sync.go | 115 | // Step 1: Find the largest replica (highest file count) that's not excluded. | COMMENT |
| LOW | weed/storage/volume_replica/replica_sync.go | 136 | // Step 2: Read index database from the best replica | COMMENT |
| LOW | weed/storage/volume_replica/replica_sync.go | 147 | // Step 3: For each other replica (including excluded), find entries missing from best and copy them | COMMENT |
| LOW | weed/iam/integration/iam_integration_test.go | 64 | // Step 1: Attempt role assumption | COMMENT |
| LOW | weed/iam/integration/iam_integration_test.go | 84 | // Step 2: Test policy enforcement with assumed credentials | COMMENT |
| LOW | weed/iam/integration/iam_integration_test.go | 138 | // Step 1: Attempt role assumption with LDAP credentials | COMMENT |
| LOW | weed/iam/integration/iam_integration_test.go | 158 | // Step 2: Test policy enforcement | COMMENT |
| LOW⚡ | weed/iam/policy/policy_engine.go | 1218 | // Step 1: Substitute policy variables (e.g., ${aws:username}, ${saml:username}) | COMMENT |
| LOW⚡ | weed/iam/policy/policy_engine.go | 1221 | // Step 2: Handle special patterns | COMMENT |
| LOW⚡ | weed/iam/policy/policy_engine.go | 1226 | // Step 3: Case-insensitive exact match | COMMENT |
| LOW⚡ | weed/iam/policy/policy_engine.go | 1231 | // Step 4: Handle AWS-style wildcards (case-insensitive) | COMMENT |
| LOW | weed/mount/meta_cache/meta_cache_deadlock_test.go | 104 | // Step 1: the "flush handler" takes the fh exclusive lock | COMMENT |
| LOW | weed/mount/meta_cache/meta_cache_deadlock_test.go | 116 | // Step 2: a subscriber event arrives; the apply loop will run | COMMENT |
| LOW | weed/mount/meta_cache/meta_cache_deadlock_test.go | 131 | // Step 3: still holding the fh lock, the flush handler applies its local | COMMENT |
| LOW | weed/mq/topic/local_partition.go | 136 | // Step 2: Enter the main loop - read from in-memory buffer, occasionally checking disk | COMMENT |
| LOW | weed/mq/kafka/protocol/offset_fetch_pattern_test.go | 45 | // Step 1: Fetch batch of messages starting from nextOffset | COMMENT |
| LOW⚡ | weed/mq/kafka/protocol/offset_fetch_pattern_test.go | 64 | // Step 2: Commit the last offset in this batch | COMMENT |
| LOW⚡ | weed/mq/kafka/protocol/offset_fetch_pattern_test.go | 70 | // Step 3: Verify offset is correctly stored | COMMENT |
| 170 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | weed/s3api/auth_security_test.go | 341 | // Step 1: Sign a request targeting the client-facing URL using real AWS SDK signer | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 349 | // Step 2: Create a separate request as the proxy would deliver it | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 359 | // Step 3: Verify | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 501 | // Step 1: Sign a request using the real AWS SDK v2 signer. | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 510 | // Step 2: Build the request as the proxy would deliver it to SeaweedFS. | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 530 | // Step 3: Verify extractHostHeader returns the expected value. | COMMENT |
| LOW⚡ | weed/s3api/auth_security_test.go | 537 | // Step 4: Verify the full signature matches. | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 551 | // Step 3: Calculate MD5 hash and add SSE metadata to chunks | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 650 | // Step 4: Create metadata entry | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_put.go | 810 | // Step 4: Save metadata to filer via gRPC | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_copy.go | 2266 | // Step 1: Decrypt source data | COMMENT |
| LOW | weed/s3api/s3api_object_handlers_copy.go | 2363 | // Step 2: Re-encrypt with destination encryption (if any) | COMMENT |
| LOW | weed/s3api/s3_sse_s3_integration_test.go | 47 | // Step 1: Encrypt (simulates what happens during PUT) | COMMENT |
| LOW | weed/s3api/s3_sse_s3_integration_test.go | 72 | // Step 2: Simulate storage (inline file - no chunks) | COMMENT |
| LOW | weed/s3api/s3_sse_s3_integration_test.go | 83 | // Step 3: Decrypt (simulates what happens during GET) | COMMENT |
| LOW⚡ | weed/s3api/s3api_object_retention.go | 551 | // Step 1: Check if governance bypass was requested via header | COMMENT |
| LOW⚡ | weed/s3api/s3api_object_retention.go | 558 | // Step 2: Validate user has permission to bypass governance retention | COMMENT |
| LOW⚡ | weed/s3api/s3_list_parts_action_test.go | 200 | // Step 1: Initiate multipart upload (POST with uploads query) | COMMENT |
| LOW⚡ | weed/s3api/s3_list_parts_action_test.go | 210 | // Step 2: List existing parts (GET with uploadId query) - THIS WAS THE MISSING MAPPING | COMMENT |
| LOW⚡ | weed/s3api/s3_list_parts_action_test.go | 220 | // Step 3: Upload a part (PUT with uploadId and partNumber) | COMMENT |
| LOW | weed/s3api/s3_list_parts_action_test.go | 231 | // Step 4: Complete multipart upload (POST with uploadId) | COMMENT |
| LOW | weed/util/chunk_cache/chunk_cache.go | 226 | // Step 1: Read and validate header (volume ID + cookie) | COMMENT |
| LOW | weed/util/chunk_cache/chunk_cache.go | 252 | // Step 2: Read actual data from the offset position (after header) | COMMENT |
| LOW | weed/shell/command_remote_cache.go | 109 | // Step 1: Collect all remote files | COMMENT |
| LOW | weed/shell/command_remote_cache.go | 123 | // Step 2: Collect all local files (only if we need to delete local extra files) | COMMENT |
| LOW | weed/shell/command_remote_cache.go | 141 | // Step 3: Determine actions needed | COMMENT |
| LOW | weed/shell/command_remote_cache.go | 179 | // For caching, we need to check if the local file exists and needs caching | COMMENT |
| LOW | weed/shell/command_remote_cache.go | 221 | // Step 4: Execute actions | COMMENT |
| LOW⚡ | weed/shell/command_s3_user_provision.go | 114 | // Step 0: Check if user already exists | COMMENT |
| LOW⚡ | weed/shell/command_s3_user_provision.go | 123 | // Step 1: Create policy | COMMENT |
| LOW | weed/shell/command_s3_user_provision.go | 157 | // Step 2: Create new user with credentials | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 113 | // Step 1: Collect all local files that are part of the remote mount | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 129 | // Step 2: Check which files exist on remote storage | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 143 | // Step 3: Determine files to copy and files to delete | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 174 | // Step 4: Copy files to remote storage | COMMENT |
| LOW | weed/shell/command_remote_copy_local.go | 225 | // Step 5: Delete extraneous files from remote storage | COMMENT |
| LOW | weed/admin/topology/storage_slot_test.go | 555 | // Step 1: Add pending task (should reserve capacity via StorageSlotChange) | COMMENT |
| LOW | weed/admin/topology/storage_slot_test.go | 579 | // Step 2: Assign task (capacity already reserved by pending task) | COMMENT |
| LOW⚡ | weed/admin/topology/storage_slot_test.go | 592 | // Step 3: Complete task (should release reserved capacity) | COMMENT |
| LOW⚡ | weed/admin/topology/storage_slot_test.go | 601 | // Step 4: Apply actual storage change (simulates master topology update) | COMMENT |
| LOW | weed/storage/volume_replica/replica_sync.go | 115 | // Step 1: Find the largest replica (highest file count) that's not excluded. | COMMENT |
| LOW | weed/storage/volume_replica/replica_sync.go | 136 | // Step 2: Read index database from the best replica | COMMENT |
| LOW | weed/storage/volume_replica/replica_sync.go | 147 | // Step 3: For each other replica (including excluded), find entries missing from best and copy them | COMMENT |
| LOW | weed/iam/integration/iam_integration_test.go | 64 | // Step 1: Attempt role assumption | COMMENT |
| LOW | weed/iam/integration/iam_integration_test.go | 84 | // Step 2: Test policy enforcement with assumed credentials | COMMENT |
| LOW | weed/iam/integration/iam_integration_test.go | 138 | // Step 1: Attempt role assumption with LDAP credentials | COMMENT |
| LOW | weed/iam/integration/iam_integration_test.go | 158 | // Step 2: Test policy enforcement | COMMENT |
| LOW⚡ | weed/iam/policy/policy_engine.go | 1218 | // Step 1: Substitute policy variables (e.g., ${aws:username}, ${saml:username}) | COMMENT |
| LOW⚡ | weed/iam/policy/policy_engine.go | 1221 | // Step 2: Handle special patterns | COMMENT |
| LOW⚡ | weed/iam/policy/policy_engine.go | 1226 | // Step 3: Case-insensitive exact match | COMMENT |
| LOW⚡ | weed/iam/policy/policy_engine.go | 1231 | // Step 4: Handle AWS-style wildcards (case-insensitive) | COMMENT |
| LOW | weed/mount/meta_cache/meta_cache_deadlock_test.go | 104 | // Step 1: the "flush handler" takes the fh exclusive lock | COMMENT |
| LOW | weed/mount/meta_cache/meta_cache_deadlock_test.go | 116 | // Step 2: a subscriber event arrives; the apply loop will run | COMMENT |
| LOW | weed/mount/meta_cache/meta_cache_deadlock_test.go | 131 | // Step 3: still holding the fh lock, the flush handler applies its local | COMMENT |
| LOW | weed/mq/topic/local_partition.go | 136 | // Step 2: Enter the main loop - read from in-memory buffer, occasionally checking disk | COMMENT |
| LOW | weed/mq/kafka/protocol/offset_fetch_pattern_test.go | 45 | // Step 1: Fetch batch of messages starting from nextOffset | COMMENT |
| LOW⚡ | weed/mq/kafka/protocol/offset_fetch_pattern_test.go | 64 | // Step 2: Commit the last offset in this batch | COMMENT |
| LOW⚡ | weed/mq/kafka/protocol/offset_fetch_pattern_test.go | 70 | // Step 3: Verify offset is correctly stored | COMMENT |
| LOW⚡ | weed/mq/kafka/protocol/offset_fetch_pattern_test.go | 76 | // Step 4: Next fetch should start from lastConsumedOffset + 1 | COMMENT |
| LOW | weed/mq/kafka/protocol/fetch.go | 1011 | // We need to check if this looks like a real RecordValue or just random bytes | COMMENT |
| 165 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | terraform/test/local-secure/main.tf | 1 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | terraform/test/local-secure/main.tf | 6 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | terraform/test/local/main.tf | 1 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | terraform/test/local/main.tf | 8 | # ============================================================================= | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 1 | # ============================================================================= | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 6 | # ============================================================================= | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 78 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 80 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 123 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 125 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 170 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 172 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 221 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 223 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 264 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 266 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 314 | # =========================================================================== | COMMENT |
| MEDIUM | terraform/modules/core/main.tf | 316 | # =========================================================================== | COMMENT |
| MEDIUM⚡ | terraform/modules/core/variables.tf | 1 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | terraform/modules/core/variables.tf | 13 | # ============================================================================= | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 51 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 54 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 106 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 108 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 145 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 147 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 191 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 193 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 236 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 239 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 267 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 270 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 283 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/variables.tf | 285 | # ---------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/tests/render.tftest.hcl | 8 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/tests/render.tftest.hcl | 32 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/tests/render.tftest.hcl | 54 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/tests/render.tftest.hcl | 72 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/tests/render.tftest.hcl | 100 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/tests/render.tftest.hcl | 132 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/core/tests/render.tftest.hcl | 155 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | terraform/modules/security/variables.tf | 1 | # ============================================================================= | COMMENT |
| MEDIUM | terraform/modules/security/variables.tf | 9 | # ============================================================================= | COMMENT |
| MEDIUM | terraform/modules/aws/security.tf | 1 | # ============================================================================= | COMMENT |
| MEDIUM | terraform/modules/aws/security.tf | 10 | # ============================================================================= | COMMENT |
| MEDIUM | terraform/modules/aws/variables.tf | 1 | # ============================================================================= | COMMENT |
| MEDIUM | terraform/modules/aws/variables.tf | 8 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | seaweedfs-rdma-sidecar/rdma-engine/src/lib.rs | 10 | //! ┌─────────────────────┐ IPC ┌─────────────────────┐ | COMMENT |
| MEDIUM⚡ | seaweedfs-rdma-sidecar/rdma-engine/src/lib.rs | 11 | //! │ Go Control Plane │◄─────────►│ Rust Data Plane │ | COMMENT |
| MEDIUM⚡ | seaweedfs-rdma-sidecar/rdma-engine/src/lib.rs | 17 | //! └─────────────────────┘ └─────────────────────┘ | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 39 | // ── shortName ──────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 56 | // ── relevantNodes ──────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 70 | // ── computeOwnerTarget ─────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 110 | // ── buildDistributionCounts ────────────────────────────────────────────────── | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 156 | // ── selectActiveNodes ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 181 | // ── planOwnerMoves ─────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 223 | // ── planDistribution: primary ───────────────────────────────────────────────── | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 287 | // ── planDistribution: round-robin ───────────────────────────────────────────── | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 361 | // ── planDistribution: replica ───────────────────────────────────────────────── | COMMENT |
| MEDIUM | weed/shell/command_fs_distribute_chunks_test.go | 410 | // ── printRedistributionPlan ────────────────────────────────────────────────── | COMMENT |
| 11 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | terraform/test/local-secure/main.tf | 2 | # Local mTLS test harness: generate the CA + component certs + JWT keys with the | COMMENT |
| MEDIUM | terraform/test/local-secure/main.tf | 39 | # non-secure harness. | COMMENT |
| MEDIUM⚡ | terraform/test/local/main.tf | 2 | # Local test harness: render a small SeaweedFS cluster with the core module | COMMENT |
| MEDIUM | terraform/test/local/main.tf | 33 | # High port range so the harness does not collide with a SeaweedFS cluster | COMMENT |
| MEDIUM⚡ | terraform/modules/core/variables.tf | 7 | # infra wrappers (consume cloud_init/systemd_unit) and the local test harness | COMMENT |
| MEDIUM | cmd/weed-sql/sqlcmd.go | 185 | // Split file content into individual queries (robust approach). | COMMENT |
| MEDIUM | seaweedfs-rdma-sidecar/test-fixes-standalone.go | 86 | // NEW (robust): | COMMENT |
| MEDIUM | weed/s3api/s3api_sts.go | 298 | // Use typed errors for robust error checking | COMMENT |
| MEDIUM | weed/s3api/s3_iam_middleware.go | 118 | // Determine token type by issuer claim (more robust than checking role claim) | COMMENT |
| MEDIUM | weed/s3api/s3_metadata_util.go | 55 | // Use url.ParseQuery for robust parsing and automatic URL decoding | COMMENT |
| MEDIUM | weed/kms/gcp/gcp_kms.go | 300 | // This is a simplified implementation - in production, you might want a more robust serialization | COMMENT |
| MEDIUM | weed/util/sqlutil/splitter.go | 8 | // This robust implementation handles SQL comments, quoted strings, and escaped characters. | COMMENT |
| MEDIUM | weed/shell/command_remote_cache.go | 37 | # comprehensive sync and cache: update metadata, cache content, and remove deleted files | COMMENT |
| MEDIUM | weed/shell/command_ec_decode.go | 228 | // Keep this robust against wording tweaks while still being specific. | COMMENT |
| MEDIUM | weed/server/postgres/protocol.go | 41 | // Use typed errors for robust error mapping | COMMENT |
| MEDIUM | weed/storage/disk_location_ec.go | 391 | // checkDatFileExists checks if a .dat file with actual data exists with robust | COMMENT |
| MEDIUM | weed/iam/providers/errors.go | 6 | // These enable robust error checking with errors.Is() throughout the stack | COMMENT |
| MEDIUM | weed/iam/oidc/oidc_provider.go | 681 | // Use JWT library's typed errors for robust error checking | COMMENT |
| MEDIUM | weed/iam/utils/arn_utils_test.go | 13 | // format to ensure robust handling of both legacy and modern AWS ARN formats. | COMMENT |
| MEDIUM | weed/iam/sts/sts_service.go | 897 | // Map provider errors to STS errors using errors.Is() for robust error checking | COMMENT |
| MEDIUM | weed/iam/sts/session_claims.go | 94 | // This enables seamless integration with existing code expecting SessionInfo | COMMENT |
| MEDIUM | weed/iam/sts/constants.go | 90 | // Typed errors for robust error checking with errors.Is() | COMMENT |
| MEDIUM | weed/filer/filer_deletion.go | 480 | // TODO: Consider these improvements for more robust error handling: | COMMENT |
| MEDIUM | weed/query/engine/hybrid_message_scanner.go | 239 | // Uses SeaweedFS MQ's GenMergedReadFunc for seamless integration | COMMENT |
| MEDIUM | test/benchmark/fuse_db/bin/lib.sh | 2 | # IMPORTANT: this harness manages ONLY its own processes via pidfiles and its own | COMMENT |
| MEDIUM | test/s3/remote_cache/command_edge_cases_test.go | 102 | // This is a simplified check; a more robust test would check if the file is *actually* gone from local cache | COMMENT |
| MEDIUM | test/s3/remote_cache/command_edge_cases_test.go | 105 | // The instruction implies just adding the test, not necessarily making it fully robust for all pattern scenarios. | COMMENT |
| MEDIUM | test/s3/iam/s3_iam_distributed_test.go | 114 | // Test concurrent operations across distributed instances with robust retry mechanisms | COMMENT |
| MEDIUM | test/samba/smb_tests.sh | 5 | # harness (run_inside_container.sh). | COMMENT |
| MEDIUM | test/kafka/kafka-client-loadtest/docker-compose.yml | 65 | # Enable comprehensive Kafka client DEBUG logging to trace offset management | COMMENT |
| MEDIUM | test/kafka/kafka-client-loadtest/config/loadtest.yaml | 4 | test_mode: "comprehensive" # producer, consumer, comprehensive | CODE |
| MEDIUM | …st/kafka/kafka-client-loadtest/scripts/run-loadtest.sh | 81 | # Run comprehensive test for 5 minutes | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | docker/test.py | 91 | except Exception as e: | CODE |
| MEDIUM | docker/test.py | 92 | print(f"Error listing files: {e}") | CODE |
| MEDIUM | test/s3/compatibility/fix_s3_tests_bucket_conflicts.py | 35 | print(f"Error: File {file_path} not found") | CODE |
| LOW⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 151 | except Exception: | CODE |
| LOW⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 161 | except Exception: | CODE |
| LOW⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 171 | except Exception: | CODE |
| LOW⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 183 | except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testing | CODE |
| LOW⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 192 | except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testing | CODE |
| LOW⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 201 | except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testing | CODE |
| LOW⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 216 | except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testing | CODE |
| LOW⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 225 | except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testing | CODE |
| LOW⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 234 | except Exception as e: # noqa: BLE001 - Intentionally broad for compatibility testing | CODE |
| LOW | test/s3/parquet/test_cross_filesystem_compatibility.py | 94 | except Exception: | CODE |
| LOW | test/s3/parquet/test_cross_filesystem_compatibility.py | 132 | except Exception: | CODE |
| LOW | test/s3/parquet/test_cross_filesystem_compatibility.py | 302 | except Exception as e: # noqa: BLE001 - Top-level exception handler for test orchestration | CODE |
| LOW | test/s3/parquet/test_cross_filesystem_compatibility.py | 339 | except Exception as e: # noqa: BLE001 - Top-level exception handler for test orchestration | CODE |
| LOW | test/s3/parquet/test_cross_filesystem_compatibility.py | 352 | except Exception: | CODE |
| LOW | test/s3/parquet/s3_parquet_test.py | 118 | except Exception: | CODE |
| LOW | test/s3/parquet/s3_parquet_test.py | 132 | except Exception: | CODE |
| LOW | test/s3/parquet/s3_parquet_test.py | 144 | except Exception as e: | CODE |
| LOW | test/s3/parquet/s3_parquet_test.py | 159 | except Exception as e: | CODE |
| LOW | test/s3/parquet/s3_parquet_test.py | 199 | except Exception as e: | CODE |
| LOW | test/s3/parquet/s3_parquet_test.py | 225 | except Exception as e: | CODE |
| LOW⚡ | test/s3/parquet/s3_parquet_test.py | 253 | except Exception as e: | CODE |
| LOW⚡ | test/s3/parquet/s3_parquet_test.py | 266 | except Exception as e: | CODE |
| LOW | test/s3/parquet/s3_parquet_test.py | 278 | except Exception as e: | CODE |
| LOW | test/s3/parquet/s3_parquet_test.py | 319 | except Exception as e: | CODE |
| LOW | test/s3/parquet/s3_parquet_test.py | 342 | except Exception as e: | CODE |
| MEDIUM | test/s3/parquet/s3_parquet_test.py | 410 | print(f"Error details logged to: {ERROR_LOG_FILE}") | CODE |
| LOW | test/s3/parquet/debug_write_dataset.py | 55 | except Exception as e: | CODE |
| LOW⚡ | test/s3/parquet/debug_write_dataset.py | 69 | except Exception as e: | CODE |
| LOW⚡ | test/s3/parquet/debug_write_dataset.py | 79 | except Exception as e: | CODE |
| LOW⚡ | test/s3/parquet/debug_write_dataset.py | 82 | except Exception as e: | CODE |
| MEDIUM | test/s3/parquet/debug_write_dataset.py | 38 | def list_recursive(path, indent=0): | CODE |
| LOW | test/s3/parquet/test_implicit_directory_fix.py | 132 | except Exception as e: | CODE |
| LOW | test/s3/parquet/test_implicit_directory_fix.py | 155 | except Exception as e: | CODE |
| LOW⚡ | test/s3/parquet/test_implicit_directory_fix.py | 174 | except Exception as e: | CODE |
| LOW⚡ | test/s3/parquet/test_implicit_directory_fix.py | 195 | except Exception as e: | CODE |
| LOW⚡ | test/s3/parquet/test_implicit_directory_fix.py | 226 | except Exception as e: | CODE |
| LOW | test/s3/parquet/test_implicit_directory_fix.py | 245 | except Exception as e: | CODE |
| LOW | test/s3/parquet/test_pyarrow_native_s3.py | 111 | except Exception: | CODE |
| LOW | test/s3/parquet/test_pyarrow_native_s3.py | 148 | except Exception: | CODE |
| LOW | test/s3/parquet/test_pyarrow_native_s3.py | 170 | except Exception as e: | CODE |
| LOW | test/s3/parquet/test_pyarrow_native_s3.py | 179 | except Exception: | CODE |
| LOW⚡ | test/s3/parquet/test_pyarrow_native_s3.py | 266 | except Exception as exc: | CODE |
| LOW | test/s3/parquet/test_pyarrow_native_s3.py | 302 | except Exception: | CODE |
| LOW | test/s3/parquet/test_sse_s3_compatibility.py | 98 | except Exception: | CODE |
| LOW | test/s3/parquet/test_sse_s3_compatibility.py | 134 | except Exception: | CODE |
| LOW | test/s3/parquet/test_sse_s3_compatibility.py | 165 | except Exception as e: | CODE |
| LOW | test/s3/spark/issue_8234_repro_test.go | 47 | except Exception as err: | CODE |
| LOW | test/s3tables/catalog/test_rest_catalog_auth.py | 141 | except Exception as e: | CODE |
| LOW | test/s3tables/catalog/test_rest_catalog_auth.py | 182 | except Exception as e: | CODE |
| LOW | test/s3tables/catalog/test_rest_catalog_auth.py | 212 | except Exception as e: | CODE |
| LOW | test/s3tables/catalog/test_rest_catalog.py | 146 | except Exception as e: | CODE |
| LOW | test/s3tables/catalog/test_rest_catalog.py | 172 | except Exception as e: | CODE |
| LOW | test/s3tables/catalog/test_rest_catalog.py | 209 | except Exception as e: | CODE |
| LOW | test/s3tables/catalog/test_rest_catalog.py | 240 | except Exception as e: | CODE |
| LOW | test/s3tables/catalog_spark/spark_operations_test.go | 210 | except Exception as e: | STRING |
| LOW | test/s3tables/sts_integration/sts_integration_test.go | 327 | except Exception: | CODE |
| LOW | test/s3tables/sts_integration/sts_integration_test.go | 432 | except Exception as e: | CODE |
| 18 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | seaweedfs-rdma-sidecar/test-rdma-integration.sh | 92 | # Check if it has the expected fields | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/performance-benchmark.sh | 107 | # Display result with color coding | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/performance-benchmark.sh | 167 | # Check if connection pooling is working | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/performance-benchmark.sh | 186 | # Check if sidecar is ready | COMMENT |
| LOW | …fs-rdma-sidecar/scripts/test-complete-optimizations.sh | 181 | # Check if socket was created | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/mount-helper.sh | 65 | # Check if RDMA is actually enabled | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/mount-helper.sh | 118 | # Check if already mounted | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/mount-health-check.sh | 7 | # Check if mount point exists and is mounted | COMMENT |
| LOW | …eedfs-rdma-sidecar/scripts/test-zero-copy-mechanism.sh | 66 | # Check if file is in page cache (approximation) | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/run-integration-tests.sh | 159 | # Read file | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/run-integration-tests.sh | 202 | # Check if response contains expected fields | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/demo-mount-rdma.sh | 151 | # Check if mount is successful | COMMENT |
| LOW | seaweedfs-rdma-sidecar/scripts/demo-mount-rdma.sh | 239 | # Check if mount is still active | COMMENT |
| LOW | docker/admin_integration/check_volumes.sh | 7 | # Check if master is running | COMMENT |
| LOW | docker/admin_integration/demo_vacuum_testing.sh | 7 | # Check if SeaweedFS is running | COMMENT |
| LOW | test/kms/setup_openbao.sh | 25 | # Check if we can connect | COMMENT |
| LOW | test/s3/iam/setup_keycloak.sh | 145 | # Check if it exists now (might have been created by another process) | COMMENT |
| LOW | test/s3/iam/setup_keycloak.sh | 215 | # Check if role already assigned | COMMENT |
| LOW | test/s3/iam/setup_keycloak.sh | 236 | # Check if a realm roles mapper already exists for this client | COMMENT |
| LOW | test/s3/iam/setup_keycloak.sh | 277 | # Check if an audience mapper already exists for this client | COMMENT |
| LOW | test/s3/iam/setup_all_tests.sh | 57 | # Check if LDAP container is already running | COMMENT |
| LOW | test/s3/iam/setup_all_tests.sh | 176 | # Check if Keycloak is responding | COMMENT |
| LOW | test/s3/parquet/test_pyarrow_native_s3.py | 133 | # Check if bucket exists | COMMENT |
| LOW | test/s3/parquet/test_pyarrow_native_s3.py | 156 | # Check if bucket exists by trying to list it | COMMENT |
| LOW | test/java/spark/run-tests.sh | 8 | # Check if SeaweedFS is running | COMMENT |
| LOW | test/java/spark/quick-start.sh | 8 | # Check if SeaweedFS is running | COMMENT |
| LOW⚡ | test/java/spark/quick-start.sh | 92 | # Check if Docker is available | COMMENT |
| LOW⚡ | test/java/spark/quick-start.sh | 98 | # Check if Maven is available | COMMENT |
| LOW⚡ | test/java/spark/quick-start.sh | 104 | # Check if SeaweedFS is running, if not start it | COMMENT |
| LOW | test/postgres/validate-setup.sh | 27 | # Check if running from correct directory | COMMENT |
| LOW | test/postgres/validate-setup.sh | 65 | # Check if services are running | COMMENT |
| LOW | test/kafka/test-schema-bypass.sh | 11 | # Check if Kafka gateway is running | COMMENT |
| LOW | test/kafka/loadtest/run_million_record_test.sh | 25 | # Check if SeaweedFS infrastructure is running | COMMENT |
| LOW | test/kafka/scripts/test_schema_registry.sh | 10 | # Check if we have a real schema registry URL | COMMENT |
| LOW | test/kafka/scripts/test_schema_registry.sh | 46 | # Check if services are running | COMMENT |
| LOW | …fka/kafka-client-loadtest/scripts/wait-for-services.sh | 39 | # Check if a service is reachable | COMMENT |
| LOW | …fka/kafka-client-loadtest/scripts/wait-for-services.sh | 71 | # Check if we have at least one volume server | COMMENT |
| LOW | …fka/kafka-client-loadtest/scripts/wait-for-services.sh | 96 | # Check if Schema Registry container is running first | COMMENT |
| LOW | …fka/kafka-client-loadtest/scripts/wait-for-services.sh | 185 | # Check if it's still starting up (healthcheck start_period) | COMMENT |
| LOW | …st/kafka/kafka-client-loadtest/scripts/run-loadtest.sh | 181 | # Check if Docker and Docker Compose are available | COMMENT |
| LOW | …afka/kafka-client-loadtest/scripts/register-schemas.sh | 95 | # Check if it's a consumer lag timeout (error_code 50002) | COMMENT |
| LOW | .github/workflows/s3-keycloak-tests.yml | 62 | # Set WEED_BINARY to use the installed version | COMMENT |
| LOW | .github/workflows/deploy_telemetry.yml | 137 | # Check if service exists and deploy accordingly | COMMENT |
| LOW | .github/workflows/s3-policy-tests.yml | 113 | # Set WEED_BINARY to use the installed version | COMMENT |
| LOW | .github/workflows/s3-policy-tests.yml | 422 | # Set WEED_BINARY to use the installed version (though test uses 'weed' command) | COMMENT |
| LOW | .github/workflows/s3-proxy-signature-tests.yml | 66 | # Check if containers are running | COMMENT |
| LOW | .github/workflows/s3-iam-tests.yml | 115 | # Set WEED_BINARY to use the installed version | COMMENT |
| LOW | .github/workflows/s3tests.yml | 895 | # Check if server process is still alive before waiting | COMMENT |
| LOW | .github/workflows/s3tests.yml | 911 | # Check if server process is still alive | COMMENT |
| LOW | .github/workflows/kafka-tests.yml | 253 | # Check if broker is properly registered by querying cluster nodes | COMMENT |
| LOW | .github/workflows/kafka-tests.yml | 270 | # Check if broker failed to start and show logs | COMMENT |
| LOW | .github/workflows/kafka-tests.yml | 432 | # Check if broker is properly registered by querying cluster nodes | COMMENT |
| LOW | .github/workflows/kafka-tests.yml | 449 | # Check if broker failed to start and show logs | COMMENT |
| LOW | .github/workflows/kafka-tests.yml | 593 | # Check if broker is properly registered by querying cluster nodes | COMMENT |
| LOW | .github/workflows/kafka-tests.yml | 610 | # Check if broker failed to start and show logs | COMMENT |
| LOW | .github/workflows/kafka-tests.yml | 751 | # Check if broker is properly registered by querying cluster nodes | COMMENT |
| LOW | .github/workflows/kafka-tests.yml | 768 | # Check if broker failed to start and show logs | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 249 | if not read.schema.equals(original.schema): | CODE |
| HIGH⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 257 | if not read_sorted.equals(original_sorted): | CODE |
| HIGH⚡ | test/s3/parquet/test_cross_filesystem_compatibility.py | 263 | if not col_original.equals(col_read): | CODE |
| HIGH⚡ | test/s3/parquet/test_pyarrow_native_s3.py | 208 | if not table_read.schema.equals(table.schema): | CODE |
| HIGH⚡ | test/s3/parquet/test_pyarrow_native_s3.py | 215 | if not table_read_sorted.equals(table_sorted): | CODE |
| HIGH⚡ | test/s3/parquet/test_pyarrow_native_s3.py | 221 | if not col_original.equals(col_read): | CODE |
| HIGH | test/s3/parquet/test_pyarrow_native_s3.py | 235 | if not table_dataset_sorted.equals(table_sorted): | CODE |
| HIGH | test/s3/parquet/test_pyarrow_native_s3.py | 240 | if not col_original.equals(col_read): | CODE |
| HIGH⚡ | test/s3/parquet/test_pyarrow_native_s3.py | 254 | if not table_pads_sorted.equals(table_sorted): | CODE |
| HIGH⚡ | test/s3/parquet/test_pyarrow_native_s3.py | 259 | if not col_original.equals(col_read): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | weed/static/javascript/jquery-3.6.0.min.js | 2 | !function(e,t){"use strict";"object"==typeof module&&"object"==typeof module.exports?module.exports=e.document?t(e,!0):f | CODE |
| CRITICAL | …a/spark/src/test/java/seaweed/spark/SparkTestBase.java | 108 | org.apache.hadoop.fs.FileSystem fs = org.apache.hadoop.fs.FileSystem.get( | CODE |
| CRITICAL | …java/seaweed/spark/ParquetOperationComparisonTest.java | 308 | try (ParquetWriter<Group> writer = org.apache.parquet.hadoop.example.ExampleParquetWriter.builder(path) | CODE |
| CRITICAL | …java/seaweed/spark/ParquetOperationComparisonTest.java | 347 | try (ParquetWriter<Group> writer = org.apache.parquet.hadoop.example.ExampleParquetWriter.builder(path) | CODE |
| CRITICAL | …est/java/seaweed/spark/SparkReadDirectParquetTest.java | 157 | try (ParquetWriter<Group> writer = org.apache.parquet.hadoop.example.ExampleParquetWriter.builder(path) | CODE |
| CRITICAL | …k/src/test/java/seaweed/spark/SimpleOneColumnTest.java | 27 | org.apache.hadoop.fs.FileSystem fs = org.apache.hadoop.fs.FileSystem.get( | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | terraform/modules/core/variables.tf | 4 | # This module is a PURE RENDERER. It creates zero cloud resources. It takes a | COMMENT |
| MEDIUM | seaweedfs-rdma-sidecar/scripts/demo-mount-rdma.sh | 169 | # Create a larger test file | COMMENT |
| MEDIUM | weed/command/mini.go | 1105 | sb.WriteString("# This file is loaded on startup if it exists\n\n") | CODE |
| MEDIUM | test/kms/setup_openbao.sh | 60 | # Create the encryption key | COMMENT |
| MEDIUM | test/s3/parquet/debug_write_dataset.py | 9 | # Create a simple test table | COMMENT |
| MEDIUM | test/s3/parquet/test_implicit_directory_fix.py | 83 | # Create a dataset using PyArrow (creates implicit directory) | COMMENT |
| MEDIUM⚡ | test/s3/parquet/test_implicit_directory_fix.py | 185 | # Create an explicit directory marker | COMMENT |
| MEDIUM⚡ | test/s3/parquet/test_implicit_directory_fix.py | 216 | # Create an empty file with text/plain mime type | COMMENT |
| MEDIUM | test/s3tables/catalog/test_rest_catalog_auth.py | 83 | # Define a simple schema | COMMENT |
| MEDIUM | test/s3tables/catalog/test_rest_catalog.py | 83 | # Define a simple schema | COMMENT |
| MEDIUM | …afka/kafka-client-loadtest/scripts/register-schemas.sh | 66 | # Create the schema registration payload | COMMENT |
| MEDIUM | …afka/kafka-client-loadtest/scripts/register-schemas.sh | 181 | # Define the Avro schema for load test messages | COMMENT |
| MEDIUM | …afka/kafka-client-loadtest/scripts/register-schemas.sh | 197 | # Define the JSON schema for load test messages | COMMENT |
| MEDIUM | …afka/kafka-client-loadtest/scripts/register-schemas.sh | 217 | # Define the Protobuf schema for load test messages | COMMENT |
| MEDIUM | …afka/kafka-client-loadtest/scripts/register-schemas.sh | 232 | # Define the key schema (simple string) | COMMENT |
| MEDIUM | test/foundationdb/test_fdb_s3.sh | 114 | # Create a directory | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | weed/s3api/auth_credentials.go | 128 | EmailAddress: "admin@example.com", | CODE |
| LOW | weed/s3api/auth_sts_identity_test.go | 334 | "email": "user@example.com", | CODE |
| LOW | weed/s3api/auth_sts_identity_test.go | 353 | assert.Equal(t, "user@example.com", sessionInfo.RequestContext["email"]) | CODE |
| LOW | weed/s3api/auth_sts_identity_test.go | 363 | assert.Equal(t, "user@example.com", identity.Claims["email"], "email should be in Claims") | CODE |
| LOW | weed/kms/config.go | 471 | req := &DescribeKeyRequest{KeyID: "health-check-dummy-key"} | CODE |
| LOW | weed/admin/config/schema.go | 59 | Placeholder string `json:"placeholder"` | CODE |
| LOW | weed/iam/oidc/oidc_provider_test.go | 128 | "email": "user@example.com", | CODE |
| LOW | weed/iam/oidc/oidc_provider_test.go | 140 | assert.Equal(t, "user@example.com", email) | CODE |
| LOW | weed/iam/oidc/oidc_provider_test.go | 353 | "email": "user@example.com", | CODE |
| LOW | weed/iam/oidc/oidc_provider_test.go | 362 | assert.Equal(t, "user@example.com", identity.Email) | CODE |
| LOW | weed/iam/oidc/oidc_provider_test.go | 376 | "email": "user@example.com", | CODE |
| LOW | weed/iam/oidc/oidc_provider_test.go | 454 | "email": "user@example.com", | CODE |
| LOW | weed/iam/oidc/oidc_provider_test.go | 486 | assert.Equal(t, "user@example.com", identity.Email) | CODE |
| LOW | weed/iam/oidc/oidc_provider_test.go | 538 | assert.Equal(t, "user@example.com", identity.Email) | CODE |
| LOW | weed/iam/oidc/oidc_provider_test.go | 646 | "email": "user@example.com", | CODE |
| LOW | weed/mq/kafka/schema/reconstruction_test.go | 64 | "name": "John Doe", | CODE |
| LOW | weed/mq/kafka/schema/reconstruction_test.go | 111 | if finalDecodedMsg.RecordValue.Fields["name"].GetStringValue() != "John Doe" { | CODE |
| LOW | weed/mq/kafka/schema/reconstruction_test.go | 112 | t.Errorf("Expected name='John Doe', got %v", finalDecodedMsg.RecordValue.Fields["name"].GetStringValue()) | CODE |
| LOW | weed/mq/kafka/schema/reconstruction_test.go | 314 | "name": "John Doe", | CODE |
| LOW | weed/mq/kafka/schema/manager_test.go | 64 | "name": "John Doe", | CODE |
| LOW | weed/mq/kafka/schema/manager_test.go | 106 | if nameValue == nil || nameValue.GetStringValue() != "John Doe" { | CODE |
| LOW | weed/mq/kafka/schema/manager_test.go | 107 | t.Errorf("Expected name='John Doe', got %v", nameValue) | CODE |
| LOW | weed/mq/kafka/schema/decode_encode_test.go | 50 | "name": "John Doe", | CODE |
| LOW | weed/mq/kafka/schema/decode_encode_test.go | 212 | "street": "123 Main St", | CODE |
| LOW | weed/mq/kafka/schema/json_schema_decoder_test.go | 106 | "name": "John Doe", | CODE |
| LOW⚡ | weed/mq/kafka/schema/json_schema_decoder_test.go | 132 | "name": "John Doe" | CODE |
| LOW⚡ | weed/mq/kafka/schema/json_schema_decoder_test.go | 140 | "name": "John Doe", | CODE |
| LOW⚡ | weed/mq/kafka/schema/json_schema_decoder_test.go | 149 | "name": "John Doe", | CODE |
| LOW | weed/mq/kafka/schema/json_schema_decoder_test.go | 519 | jsonData := []byte(`{"id": 123, "name": "John Doe"}`) | CODE |
| LOW | weed/mq/kafka/schema/json_schema_decoder_test.go | 538 | jsonData := []byte(`{"id": 123, "name": "John Doe"}`) | CODE |
| LOW | weed/mq/kafka/schema/integration_test.go | 454 | "email": map[string]interface{}{"string": "user@example.com"}, | CODE |
| LOW | weed/mq/kafka/schema/avro_decoder_test.go | 87 | "name": "John Doe", | CODE |
| LOW | weed/mq/kafka/schema/avro_decoder_test.go | 110 | if result["name"] != "John Doe" { | CODE |
| LOW | weed/mq/kafka/schema/avro_decoder_test.go | 111 | t.Errorf("Expected name='John Doe', got %v", result["name"]) | CODE |
| LOW | weed/mq/kafka/schema/avro_decoder_test.go | 519 | "name": "John Doe", | CODE |
| LOW | weed/query/engine/test_sample_data_test.go | 125 | "data": {Kind: &schema_pb.Value_StringValue{StringValue: `{"field": "email", "new_value": "user@example.com"} | CODE |
| LOW | test/s3/iam/s3_iam_framework.go | 335 | return []byte("dummy-key"), nil | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | weed/admin/static/js/s3tables.js | 378 | async function loadIcebergNamespaceTables(node, bucketArn, catalogName) { | CODE |
| LOW | weed/admin/static/js/admin.js | 966 | function updateDeleteSelectedButton() { | CODE |
| LOW | weed/admin/static/js/admin.js | 1418 | function setupFileManagerEventHandlers() { | CODE |
| LOW | weed/admin/view/app/service_accounts_templ.go | 275 | templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 26, "</select> <small class=\"form-text text-mute | CODE |
| LOW | weed/admin/view/app/file_browser_templ.go | 804 | templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 89, "\"><!-- File List Preview --><div id=\"fileL | CODE |
| LOW | weed/admin/view/app/object_store_users_templ.go | 243 | templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 24, "</div><div class=\"mb-3\"><label for=\"email | CODE |
| LOW | weed/admin/view/app/plugin_templ.go | 107 | templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 6, "</p></div><div class=\"btn-group\"><button ty | CODE |
| LOW | weed/admin/view/app/topic_details_templ.go | 1001 | templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 117, "</div></div></div></div></div></div></div>< | CODE |
| LOW | weed/admin/view/app/policies_templ.go | 196 | templ_7745c5c3_Err = templruntime.WriteString(templ_7745c5c3_Buffer, 15, "</tbody></table></div></div></div></div></di | CODE |
| LOW | test/s3/compatibility/fix_s3_tests_bucket_conflicts.py | 185 | def _sw_get_new_bucket_resource(name=None): | CODE |
| LOW⚡ | test/s3/parquet/s3_parquet_test.py | 259 | def read_with_parquet_dataset(path: str, fs: s3fs.S3FileSystem) -> Tuple[bool, str, int]: | CODE |
| LOW | test/s3/parquet/test_implicit_directory_fix.py | 69 | def test_implicit_directory_head_behavior(fs, s3_client): | CODE |
| LOW | test/s3/parquet/test_implicit_directory_fix.py | 159 | def test_pyarrow_dataset_read(fs): | CODE |
| LOW⚡ | test/s3/parquet/test_implicit_directory_fix.py | 179 | def test_explicit_directory_marker(fs, s3_client): | CODE |
| LOW⚡ | test/s3/parquet/test_implicit_directory_fix.py | 210 | def test_empty_file_not_directory(fs, s3_client): | CODE |
| LOW | test/s3tables/catalog/test_rest_catalog_auth.py | 41 | def test_namespace_operations(catalog, prefix): | CODE |
| LOW | test/s3tables/catalog/test_rest_catalog.py | 41 | def test_namespace_operations(catalog, prefix): | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | install.sh | 6 | # Usage: | COMMENT |
| LOW | weed/filer/filer.go | 515 | // Example usage: | COMMENT |
| LOW | weed/wdclient/vidmap_client.go | 132 | // Example usage: | COMMENT |
| LOW | weed/worker/tasks/base/volume_utils.go | 14 | // Example usage: | COMMENT |
| LOW | docker/compose/test-git-on-mount.sh | 14 | # Usage: | COMMENT |
| LOW | test/s3/proxy_signature/test.sh | 5 | # Usage: | COMMENT |
| LOW | test/s3tables/catalog/docker-compose.test.yaml | 6 | # Usage: | COMMENT |
| LOW | test/samba/run.sh | 17 | # Usage: | COMMENT |
| LOW | test/pjdfstest/run.sh | 13 | # Usage: | COMMENT |
| LOW | k8s/charts/seaweedfs/openshift-values.yaml | 19 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | weed/server/volume_grpc_tier_upload.go | 50 | // check whether the existing backend storage is the same as requested | COMMENT |
| HIGH | .github/pull_request_template.md | 17 | # Checks for AI generated PRs | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | terraform/examples/aws-ha-distributed/main.tf | 7 | # This is a scaffold: it provisions instances, protected EBS data disks, and the | COMMENT |
| MEDIUM | test/s3/parquet/test_cross_filesystem_compatibility.py | 302 | except Exception as e: # noqa: BLE001 - Top-level exception handler for test orchestration | CODE |
| MEDIUM | test/s3/parquet/test_cross_filesystem_compatibility.py | 339 | except Exception as e: # noqa: BLE001 - Top-level exception handler for test orchestration | CODE |
| MEDIUM | test/volume_server/DEV_PLAN.md | 413 | ### Phase 0: Harness and scaffolding | COMMENT |
| MEDIUM | test/postgres/SETUP_OVERVIEW.md | 11 | ├── docker-compose.yml # Multi-service orchestration | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | test/s3/parquet/test_cross_filesystem_compatibility.py | 49 | CODE | |
| LOW | test/s3/parquet/test_cross_filesystem_compatibility.py | 50 | CODE | |
| LOW | test/s3/parquet/debug_write_dataset.py | 36 | CODE | |
| LOW | test/s3/parquet/test_implicit_directory_fix.py | 13 | CODE | |
| LOW | test/s3/parquet/test_implicit_directory_fix.py | 21 | CODE | |
| LOW | test/s3/parquet/example_pyarrow_native.py | 33 | CODE | |
| LOW | test/s3tables/unity_catalog/delta_rs_writer.py | 25 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | test/s3/parquet/debug_write_dataset.py | 38 | CODE | |
| LOW | test/s3/parquet/test_pyarrow_native_s3.py | 184 | CODE | |
| LOW | test/s3/parquet/test_pyarrow_native_s3.py | 271 | CODE | |
| LOW | postgres-examples/test_client.py | 103 | CODE | |
| LOW | postgres-examples/test_client.py | 145 | CODE | |
| LOW | postgres-examples/test_client.py | 242 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | test/s3/parquet/s3_parquet_test.py | 168 | Helper to discover all parquet files for a given path. Args: path: S3 path (file or directory) | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | k8s/charts/seaweedfs/values.yaml | 365 | # If these don't meet your needs, you can use "custom" here along with extraVolumes and extraVolumeMounts | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | weed/filer/filechunk_group_test.go | 250 | // TODO: Add test cases. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | test/s3/parquet/test_implicit_directory_fix.py | 31 | logger = logging.getLogger(__name__) | CODE |